[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_104":86,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":58,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",10,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","deba10f2-ac00-11f1-8495-1607ee4eb77e","name","fileType","http","content","/**\n * Handled lead qualifier, Pipedrive write endpoint.\n *\n * POST /lead Vapi function-tool webhook. Creates (or reuses) an organization\n * and a person, writes a lead with the four custom deal fields,\n * and attaches a note. Replies in the Vapi results envelope.\n * GET /health Liveness plus the resolved custom-field mapping.\n *\n * Credentials come from env vars: PIPEDRIVE_API_TOKEN, PIPEDRIVE_COMPANY_DOMAIN.\n */\n\nimport { Hono } from \"npm:hono\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst TOKEN = Deno.env.get(\"PIPEDRIVE_API_TOKEN\") ?? \"\";\nconst COMPANY_DOMAIN = Deno.env.get(\"PIPEDRIVE_COMPANY_DOMAIN\") ?? \"\";\nconst BASE = `https://${COMPANY_DOMAIN}.pipedrive.com`;\n\n// ---------------------------------------------------------------------------\n// Field mapping\n// ---------------------------------------------------------------------------\n\ntype FieldDef = { key: string; options: Record };\ntype FieldMap = { source: \"live\" | \"fallback\"; fields: Record };\ntype FieldName = \"Service Market\" | \"Facility Type\" | \"Square Footage\" | \"Service Type\";\n\n/**\n * Baked-in copy of the sandbox schema. Only used when GET /dealFields fails,\n * because a sandbox rebuild silently renumbers every option id.\n */\nconst FALLBACK: Record = {\n \"Service Market\": {\n key: \"14bcf70e8454b86eb8a48503a9835870da18cdb4\",\n options: {\n \"Bentonville/Fayetteville, AR\": 43,\n \"Little Rock, AR\": 44,\n \"Fort Smith, AR\": 45,\n \"Kansas City, KC/MO\": 46,\n \"Wichita, KS\": 47,\n \"Charlotte, NC\": 48,\n \"Florida\": 49,\n \"Connecticut\": 50,\n \"New Jersey\": 51,\n \"Massachusetts\": 52,\n \"Other\": 53,\n },\n },\n \"Facility Type\": {\n key: \"3fc0dd94b9e28b36f593fb99861595298210163a\",\n options: {\n \"Office\": 54,\n \"Construction / General Contractor\": 55,\n \"Medical / Healthcare\": 56,\n \"Property Management\": 57,\n \"Retail\": 58,\n \"Fitness\": 59,\n \"Education\": 60,\n \"Manufacturing\": 61,\n \"Government\": 62,\n \"Restaurants\": 63,\n \"Auto Dealership\": 64,\n \"Religious\": 65,\n \"Industrial\": 66,\n \"Data Site / Critical Environment\": 67,\n \"Other\": 68,\n },\n },\n \"Square Footage\": {\n key: \"0023a9fb03d8f33b3d46b2d293a3624e28f02057\",\n options: { \"Under 5k\": 39, \"5k - 15k\": 40, \"15k - 50k\": 41, \"+50K\": 42 },\n },\n \"Service Type\": {\n key: \"91dc1f687a97a930861256ca1ef274c28d6e308e\",\n options: {\n \"Janitorial\": 69,\n \"Construction Cleaning\": 70,\n \"Carpet Cleaning / Water Extraction\": 71,\n \"Hard Floor\": 72,\n \"Window Cleaning\": 73,\n \"Pressure Washing\": 74,\n \"Other\": 75,\n },\n },\n};\n\nconst FIELD_NAMES = Object.keys(FALLBACK) as FieldName[];\n\n/**\n * Synonyms keyed by option LABEL, never by id, so they survive a renumbering.\n * These are only consulted after an exact and a prefix match both miss.\n */\nconst ALIASES: Record> = {\n \"Service Market\": {\n \"Bentonville/Fayetteville, AR\": [\"bentonville\", \"fayetteville\", \"nwa\", \"northwest arkansas\", \"rogers\", \"springdale\"],\n \"Little Rock, AR\": [\"little rock\", \"north little rock\", \"central arkansas\"],\n \"Fort Smith, AR\": [\"fort smith\", \"ft smith\"],\n \"Kansas City, KC/MO\": [\"kansas city\", \"kc\", \"kcmo\", \"overland park\"],\n \"Wichita, KS\": [\"wichita\"],\n \"Charlotte, NC\": [\"charlotte\", \"north carolina\"],\n \"Florida\": [\"fl\", \"orlando\", \"tampa\", \"miami\", \"jacksonville\"],\n \"Connecticut\": [\"ct\", \"hartford\", \"new haven\"],\n \"New Jersey\": [\"nj\", \"newark\", \"jersey\"],\n \"Massachusetts\": [\"ma\", \"mass\", \"boston\", \"worcester\"],\n },\n \"Facility Type\": {\n \"Office\": [\"office\", \"offices\", \"corporate\", \"corporate office\", \"professional office\"],\n \"Construction / General Contractor\": [\"construction\", \"general contractor\", \"gc\", \"contractor\", \"job site\", \"jobsite\", \"build\"],\n \"Medical / Healthcare\": [\"medical\", \"healthcare\", \"health care\", \"clinic\", \"hospital\", \"dental\", \"dentist\", \"doctor\", \"surgery center\", \"urgent care\"],\n \"Property Management\": [\"property management\", \"property manager\", \"apartment\", \"apartments\", \"multifamily\", \"hoa\", \"residential complex\"],\n \"Retail\": [\"retail\", \"store\", \"shop\", \"storefront\", \"mall\"],\n \"Fitness\": [\"fitness\", \"gym\", \"health club\", \"studio\", \"yoga\"],\n \"Education\": [\"education\", \"school\", \"university\", \"college\", \"campus\", \"daycare\", \"childcare\"],\n \"Manufacturing\": [\"manufacturing\", \"factory\", \"plant\", \"production facility\"],\n \"Government\": [\"government\", \"municipal\", \"city hall\", \"county\", \"federal\", \"public sector\"],\n \"Restaurants\": [\"restaurant\", \"restaurants\", \"food service\", \"cafe\", \"coffee shop\", \"bar\", \"kitchen\", \"brewery\"],\n \"Auto Dealership\": [\"auto dealership\", \"dealership\", \"car dealer\", \"auto dealer\", \"service bay\"],\n \"Religious\": [\"religious\", \"church\", \"synagogue\", \"mosque\", \"temple\", \"worship\", \"faith\"],\n \"Industrial\": [\"industrial\", \"warehouse\", \"distribution\", \"distribution center\", \"logistics\", \"fulfillment\"],\n \"Data Site / Critical Environment\": [\"data site\", \"data center\", \"datacenter\", \"critical environment\", \"server room\", \"clean room\"],\n },\n \"Square Footage\": {\n \"Under 5k\": [\"under 5k\", \"under 5000\", \"less than 5000\", \"under five thousand\", \"small\", \"under 5 000\", \"below 5000\"],\n \"5k - 15k\": [\"5k 15k\", \"5000 15000\", \"5000 to 15000\", \"five to fifteen thousand\", \"5 to 15k\", \"around 10000\"],\n \"15k - 50k\": [\"15k 50k\", \"15000 50000\", \"15000 to 50000\", \"fifteen to fifty thousand\", \"15 to 50k\", \"around 25000\"],\n \"+50K\": [\"over 50k\", \"more than 50k\", \"above 50k\", \"plus 50k\", \"over 50000\", \"more than 50000\", \"50000 plus\", \"50 000 plus\", \"large\"],\n },\n \"Service Type\": {\n \"Janitorial\": [\"janitorial\", \"cleaning\", \"office cleaning\", \"custodial\", \"housekeeping\", \"nightly cleaning\", \"day porter\", \"general cleaning\"],\n \"Construction Cleaning\": [\"construction cleaning\", \"post construction\", \"post construction cleanup\", \"final clean\", \"rough clean\", \"punch clean\"],\n \"Carpet Cleaning / Water Extraction\": [\"carpet\", \"carpet cleaning\", \"water extraction\", \"flood\", \"water damage\", \"shampoo\", \"steam clean\"],\n \"Hard Floor\": [\"hard floor\", \"floor care\", \"floors\", \"vct\", \"strip and wax\", \"buffing\", \"burnishing\", \"tile\", \"polishing\"],\n \"Window Cleaning\": [\"window\", \"windows\", \"window cleaning\", \"window washing\", \"glass\"],\n \"Pressure Washing\": [\"pressure washing\", \"power washing\", \"pressure wash\", \"power wash\", \"exterior washing\"],\n },\n};\n\nlet fieldMapPromise: Promise | null = null;\n\n/** Resolved once per isolate. A failure is not cached, so the next call retries. */\nfunction getFieldMap(): Promise {\n fieldMapPromise ??= loadFieldMap().catch((err) => {\n fieldMapPromise = null;\n console.error(\"[fields] load failed, using fallback:\", err?.message ?? err);\n return { source: \"fallback\" as const, fields: FALLBACK };\n });\n return fieldMapPromise;\n}\n\nasync function loadFieldMap(): Promise {\n const res = await pd(\"GET\", \"/api/v1/dealFields?limit=500\");\n const byName = new Map();\n for (const f of res?.data ?? []) byName.set(String(f.name ?? \"\").toLowerCase(), f);\n\n const fields = {} as Record;\n for (const name of FIELD_NAMES) {\n const live = byName.get(name.toLowerCase());\n if (!live?.key || !Array.isArray(live.options) || live.options.length === 0) {\n console.warn(`[fields] \"${name}\" not found live, using fallback`);\n fields[name] = FALLBACK[name];\n continue;\n }\n const options: Record = {};\n for (const o of live.options) {\n if (o?.label != null && o?.id != null) options[String(o.label)] = Number(o.id);\n }\n fields[name] = { key: String(live.key), options };\n }\n console.log(\"[fields] resolved live from dealFields\");\n return { source: \"live\", fields };\n}\n\n// ---------------------------------------------------------------------------\n// Forgiving label matching\n// ---------------------------------------------------------------------------\n\n/** Lowercase, strip punctuation and accents, collapse whitespace. */\nfunction norm(s: unknown): string {\n return String(s ?? \"\")\n .normalize(\"NFKD\")\n .replace(/[̀-ͯ]/g, \"\")\n .toLowerCase()\n .replace(/[^a-z0-9]+/g, \" \")\n // Range connectors, so \"15k to 50k\" normalizes onto the \"15k - 50k\" label.\n .replace(/\\b(?:to|thru|through)\\b/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n}\n\n/** Whole-token containment, so a two-letter input can't match inside a word. */\nfunction containsPhrase(hay: string, needle: string): boolean {\n if (!needle || !hay) return false;\n const escaped = needle.replace(/[.*+?^${}()|[\\]\\\\]/g, \"\\\\$&\");\n return new RegExp(`(^| )${escaped}( |$)`).test(hay);\n}\n\nconst STOPWORDS = new Set([\"a\", \"an\", \"the\", \"and\", \"or\", \"of\", \"in\", \"at\", \"for\", \"to\", \"our\", \"my\", \"its\", \"is\"]);\n\nfunction tokens(s: string): string[] {\n return norm(s).split(\" \").filter((t) => t && !STOPWORDS.has(t));\n}\n\ntype Resolution = { label: string; id: number; matched: true } | { label: null; id: null; matched: false };\n\n/**\n * Maps a spoken label onto an option id. Exact label, exact alias, prefix,\n * whole-token containment (longest needle wins, so \"medical office building\"\n * lands on Medical rather than Office), then token overlap. Returns unmatched\n * rather than guessing wildly; the caller decides what to do with that.\n */\nfunction resolveOption(fieldName: FieldName, raw: string, map: FieldMap): Resolution {\n const def = map.fields[fieldName];\n const input = norm(raw);\n if (!input) return { label: null, id: null, matched: false };\n\n const entries = Object.entries(def.options);\n const aliasTable = ALIASES[fieldName] ?? {};\n const aliasesFor = (label: string) => (aliasTable[label] ?? []).map(norm).filter(Boolean);\n const hit = (label: string): Resolution => ({ label, id: def.options[label], matched: true });\n\n // 1. exact label\n for (const [label] of entries) if (norm(label) === input) return hit(label);\n\n // 2. exact alias\n for (const [label] of entries) if (aliasesFor(label).includes(input)) return hit(label);\n\n // 3. prefix, either direction\n for (const [label] of entries) {\n const n = norm(label);\n if (n.startsWith(input + \" \") || input.startsWith(n + \" \")) return hit(label);\n }\n\n // 4. whole-token containment over labels and aliases, longest needle wins\n let bestPhrase: { label: string; len: number } | null = null;\n for (const [label] of entries) {\n if (norm(label) === \"other\") continue;\n for (const needle of [norm(label), ...aliasesFor(label)]) {\n if (!containsPhrase(input, needle) && !containsPhrase(needle, input)) continue;\n const len = needle.length;\n if (!bestPhrase || len > bestPhrase.len) bestPhrase = { label, len };\n }\n }\n if (bestPhrase) return hit(bestPhrase.label);\n\n // 5. token overlap, best scoring label wins if it clears the bar\n const inTok = new Set(tokens(input));\n if (inTok.size) {\n let best: { label: string; score: number } | null = null;\n for (const [label] of entries) {\n if (norm(label) === \"other\") continue;\n const labTok = tokens(label);\n const aliasTok = (aliasTable[label] ?? []).flatMap(tokens);\n const all = new Set([...labTok, ...aliasTok]);\n let overlap = 0;\n for (const t of all) if (inTok.has(t)) overlap++;\n if (overlap === 0) continue;\n const score = overlap / Math.min(inTok.size, Math.max(all.size, 1));\n if (!best || score > best.score) best = { label, score };\n }\n if (best && best.score >= 0.5) return hit(best.label);\n }\n\n return { label: null, id: null, matched: false };\n}\n\n// ---------------------------------------------------------------------------\n// Pipedrive client\n// ---------------------------------------------------------------------------\n\nclass PipedriveError extends Error {\n status: number;\n constructor(message: string, status: number) {\n super(message);\n this.name = \"PipedriveError\";\n this.status = status;\n }\n}\n\nasync function pd(method: string, path: string, body?: unknown): Promise {\n const res = await fetch(`${BASE}${path}`, {\n method,\n headers: {\n \"x-api-token\": TOKEN,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n body: body === undefined ? undefined : JSON.stringify(body),\n });\n const text = await res.text();\n let json: any = null;\n try {\n json = text ? JSON.parse(text) : null;\n } catch {\n // fall through, a non-JSON body is reported below\n }\n if (!res.ok || json?.success === false) {\n const detail = json?.error ?? json?.message ?? text.slice(0, 300);\n // Logged, never returned to the agent.\n console.error(`[pipedrive] ${method} ${path} -> ${res.status}: ${detail}`);\n throw new PipedriveError(`${method} ${path} failed (${res.status})`, res.status);\n }\n return json;\n}\n\nasync function findOrCreateOrganization(name: string, rid: string): Promise {\n const search = await pd(\n \"GET\",\n `/api/v2/organizations/search?term=${encodeURIComponent(name)}&fields=name&exact_match=true`,\n );\n const existing = search?.data?.items?.[0]?.item?.id;\n if (existing) {\n console.log(`[${rid}] org reused id=${existing}`);\n return Number(existing);\n }\n const created = await pd(\"POST\", \"/api/v2/organizations\", { name });\n const id = Number(created?.data?.id);\n console.log(`[${rid}] org created id=${id}`);\n return id;\n}\n\nasync function findOrCreatePerson(\n args: { name: string; email: string; phone?: string; orgId: number },\n rid: string,\n): Promise {\n // `email` is what actually matches an email term; the extra fields are harmless.\n const search = await pd(\n \"GET\",\n `/api/v2/persons/search?term=${encodeURIComponent(args.email)}&fields=${\n encodeURIComponent(\"email,custom_fields,name\")\n }`,\n );\n const existing = search?.data?.items?.[0]?.item?.id;\n if (existing) {\n console.log(`[${rid}] person reused id=${existing}`);\n return Number(existing);\n }\n const body: Record = {\n name: args.name,\n org_id: args.orgId,\n emails: [{ value: args.email, primary: true, label: \"work\" }],\n };\n if (args.phone) body.phones = [{ value: args.phone, primary: true, label: \"work\" }];\n const created = await pd(\"POST\", \"/api/v2/persons\", body);\n const id = Number(created?.data?.id);\n console.log(`[${rid}] person created id=${id}`);\n return id;\n}\n\n// ---------------------------------------------------------------------------\n// Request handling\n// ---------------------------------------------------------------------------\n\ntype LeadArgs = {\n company_name?: string;\n contact_name?: string;\n email?: string;\n phone?: string;\n service_market?: string;\n facility_type?: string;\n service_type?: string;\n square_footage?: string;\n note?: string;\n};\n\nconst REQUIRED: Array<[keyof LeadArgs, string]> = [\n [\"company_name\", \"company name\"],\n [\"contact_name\", \"contact name\"],\n [\"email\", \"email address\"],\n [\"phone\", \"phone number\"],\n [\"service_market\", \"service market\"],\n [\"facility_type\", \"facility type\"],\n [\"service_type\", \"service type\"],\n];\n\nconst EMAIL_RE = /^[^\\s@]+@[^\\s@]+\\.[a-z]{2,}$/i;\n\nfunction str(v: unknown): string {\n return typeof v === \"string\" ? v.trim() : v == null ? \"\" : String(v).trim();\n}\n\nfunction escapeHtml(s: string): string {\n return s.replace(/&/g, \"&\").replace(//g, \">\");\n}\n\n/** Pulls the tool-call id and arguments out of the Vapi webhook envelope. */\nfunction parseEnvelope(body: any): { toolCallId: string | null; args: LeadArgs } {\n const call = body?.message?.toolCalls?.[0] ?? body?.message?.toolCallList?.[0] ?? body?.toolCalls?.[0];\n let raw = call?.function?.arguments ?? call?.arguments;\n if (typeof raw === \"string\") {\n try {\n raw = JSON.parse(raw);\n } catch {\n raw = null;\n }\n }\n // Bare-body form, for curl and local testing.\n if (!raw && body && typeof body === \"object\" && !body.message) raw = body;\n return { toolCallId: call?.id ?? body?.toolCallId ?? null, args: (raw ?? {}) as LeadArgs };\n}\n\nfunction envelope(toolCallId: string | null, payload: unknown): Response {\n return Response.json({\n results: [{ toolCallId: toolCallId ?? \"unknown\", result: JSON.stringify(payload) }],\n });\n}\n\nconst IDEMPOTENCY_WINDOW_MS = 5 * 60 * 1000;\nconst CLAIM_TTL_MS = 30 * 1000;\n\nasync function idemKey(email: string, company: string, callId: string): Promise {\n // Keyed on the Vapi call id when we have one. Keying on (email, company) let a caller\n // who corrected their email after the write produce a second lead, and those two are\n // the fields most often corrected late.\n const basis = callId ? `call:${norm(callId)}` : `${norm(email)}|${norm(company)}`;\n const data = new TextEncoder().encode(basis);\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n const hex = [...new Uint8Array(digest)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n return `lead:idem:${hex.slice(0, 32)}`;\n}\n\ntype IdemRecord =\n | { status: \"done\"; leadId: string; company: string; at: number }\n | { status: \"pending\"; at: number };\n\nconst app = new Hono();\n\napp.onError((err) => Promise.reject(err));\n\napp.get(\"/\", (c) => c.redirect(\"/health\"));\n\napp.get(\"/health\", async (c) => {\n const map = await getFieldMap();\n const fields: Record = {};\n for (const name of FIELD_NAMES) {\n fields[name] = { key: map.fields[name].key, options: map.fields[name].options };\n }\n return c.json({\n ok: true,\n service: \"handled-lead\",\n pipedrive_domain: COMPANY_DOMAIN || null,\n token_present: TOKEN.length > 0,\n field_source: map.source,\n fields,\n time: new Date().toISOString(),\n });\n});\n\napp.post(\"/lead\", async (c) => {\n const rid = crypto.randomUUID().slice(0, 8);\n let body: any;\n try {\n body = await c.req.json();\n } catch {\n console.error(`[${rid}] unparseable request body`);\n return c.json({ error: \"bad_request\", message: \"Request body was not JSON.\" }, 400);\n }\n\n const { toolCallId, args } = parseEnvelope(body);\n console.log(`[${rid}] toolCallId=${toolCallId} args=${JSON.stringify(args)}`);\n\n if (!TOKEN || !COMPANY_DOMAIN) {\n console.error(`[${rid}] missing PIPEDRIVE_API_TOKEN or PIPEDRIVE_COMPANY_DOMAIN`);\n return c.json({ error: \"misconfigured\", message: \"Pipedrive credentials are not configured.\" }, 500);\n }\n\n // ---- validation (business failures, HTTP 200) --------------------------\n const missing = REQUIRED.filter(([k]) => !str(args[k])).map(([, label]) => label);\n if (missing.length) {\n console.warn(`[${rid}] missing required: ${missing.join(\", \")}`);\n return envelope(toolCallId, {\n error: \"missing_fields\",\n message: `The lead is missing the ${missing.join(\", the \")}.`,\n missing,\n next_step: \"Nothing was saved. Ask the caller for what is missing before doing anything else.\",\n });\n }\n\n const company = str(args.company_name);\n const contact = str(args.contact_name);\n const email = str(args.email);\n const phone = str(args.phone);\n\n if (!EMAIL_RE.test(email)) {\n console.warn(`[${rid}] invalid email: ${email}`);\n return envelope(toolCallId, {\n error: \"invalid_email\",\n message: \"That email address does not look complete.\",\n next_step: \"Nothing was saved. Read the email address back and get it right before doing anything else.\",\n });\n }\n\n // ---- idempotency -------------------------------------------------------\n const key = await idemKey(email, company, str(args.vapi_call_id));\n const now = Date.now();\n let prior: IdemRecord | undefined;\n try {\n prior = (await blob.getJSON(key)) as IdemRecord | undefined;\n } catch (err) {\n console.warn(`[${rid}] idempotency read failed: ${(err as Error)?.message}`);\n }\n\n if (prior?.status === \"done\" && now - prior.at < IDEMPOTENCY_WINDOW_MS) {\n console.log(`[${rid}] idempotent replay, returning lead ${prior.leadId}`);\n return envelope(toolCallId, {\n success: true,\n lead_id: prior.leadId,\n company: prior.company,\n duplicate: true,\n next_step: \"The lead is saved. Confirm it is in and wrap up.\",\n });\n }\n\n // A retry that lands while the first write is still running waits briefly\n // for it rather than creating a second lead.\n if (prior?.status === \"pending\" && now - prior.at < CLAIM_TTL_MS) {\n for (let i = 0; i < 4; i++) {\n await new Promise((r) => setTimeout(r, 1000));\n const again = (await blob.getJSON(key).catch(() => undefined)) as IdemRecord | undefined;\n if (again?.status === \"done\") {\n console.log(`[${rid}] concurrent write completed, returning lead ${again.leadId}`);\n return envelope(toolCallId, {\n success: true,\n lead_id: again.leadId,\n company: again.company,\n duplicate: true,\n next_step: \"The lead is saved. Confirm it is in and wrap up.\",\n });\n }\n }\n console.warn(`[${rid}] pending claim never completed, proceeding`);\n }\n\n await blob.setJSON(key, { status: \"pending\", at: now } satisfies IdemRecord).catch((err) =>\n console.warn(`[${rid}] idempotency claim failed: ${err?.message}`)\n );\n\n // ---- resolve the dropdowns --------------------------------------------\n const map = await getFieldMap();\n const custom: Record = {};\n const unresolved: string[] = [];\n\n const spoken: Array<[FieldName, string]> = [\n [\"Service Market\", str(args.service_market)],\n [\"Facility Type\", str(args.facility_type)],\n [\"Service Type\", str(args.service_type)],\n ];\n\n for (const [fieldName, value] of spoken) {\n const def = map.fields[fieldName];\n const r = resolveOption(fieldName, value, map);\n if (r.matched) {\n custom[def.key] = r.id;\n console.log(`[${rid}] ${fieldName}: \"${value}\" -> ${r.label} (${r.id})`);\n continue;\n }\n // Losing a categorization is recoverable, losing the lead is not.\n const otherLabel = Object.keys(def.options).find((l) => norm(l) === \"other\");\n if (otherLabel) {\n custom[def.key] = def.options[otherLabel];\n console.warn(`[${rid}] ${fieldName}: \"${value}\" unresolved -> Other (${def.options[otherLabel]})`);\n } else {\n console.warn(`[${rid}] ${fieldName}: \"${value}\" unresolved, no Other option, omitted`);\n }\n unresolved.push(`${fieldName}: ${value}`);\n }\n\n // Square footage is optional and has no Other option: unresolved means omit\n // the field and carry the spoken value into the note.\n const sqft = str(args.square_footage);\n if (sqft) {\n const def = map.fields[\"Square Footage\"];\n const r = resolveOption(\"Square Footage\", sqft, map);\n if (r.matched) {\n custom[def.key] = r.id;\n console.log(`[${rid}] Square Footage: \"${sqft}\" -> ${r.label} (${r.id})`);\n } else {\n console.warn(`[${rid}] Square Footage: \"${sqft}\" unresolved, omitted`);\n unresolved.push(`Square Footage: ${sqft}`);\n }\n }\n\n // ---- write -------------------------------------------------------------\n try {\n const orgId = await findOrCreateOrganization(company, rid);\n const personId = await findOrCreatePerson({ name: contact, email, phone, orgId }, rid);\n\n // Custom field hashes go at the TOP LEVEL of a v1 lead body, and the value\n // is the integer option id, not the label.\n const leadBody: Record = {\n title: company,\n person_id: personId,\n organization_id: orgId,\n ...custom,\n };\n const leadRes = await pd(\"POST\", \"/api/v1/leads\", leadBody);\n const leadId = String(leadRes?.data?.id ?? \"\");\n console.log(`[${rid}] lead created id=${leadId}`);\n\n const noteParts: string[] = [];\n const spokenNote = str(args.note);\n if (spokenNote) noteParts.push(escapeHtml(spokenNote));\n if (unresolved.length) {\n noteParts.push(\n `Unmatched answers from the call:
${unresolved.map((u) => escapeHtml(u)).join(\"
\")}`,\n );\n }\n if (noteParts.length && leadId) {\n await pd(\"POST\", \"/api/v1/notes\", { content: noteParts.join(\"

\"), lead_id: leadId });\n console.log(`[${rid}] note attached to lead ${leadId}`);\n }\n\n await blob\n .setJSON(key, { status: \"done\", leadId, company, at: Date.now() } satisfies IdemRecord)\n .catch((err) => console.warn(`[${rid}] idempotency write failed: ${err?.message}`));\n\n return envelope(toolCallId, {\n success: true,\n lead_id: leadId,\n company,\n next_step: \"The lead is saved. Confirm it is in and wrap up.\",\n });\n } catch (err) {\n console.error(`[${rid}] write failed:`, err);\n await blob.delete(key).catch(() => {});\n // Business-shaped failure: HTTP 200, speakable message, never the raw body.\n return envelope(toolCallId, {\n error: \"save_failed\",\n message: \"The lead did not save on this attempt.\",\n next_step: \"The lead was not saved. Let the caller know the team will follow up, then wrap up normally.\",\n });\n }\n});\n\napp.all(\"*\", (c) => c.json({ error: \"not_found\", message: \"Unknown route.\" }, 404));\n\nexport default app.fetch;\n","/**\n * Handled lead qualifier, Pipedrive write endpoint.\n *\n * POST /lead Vapi function-tool webhook. Creates (or reuses) an organization\n * and a person, writes a lead with the four custom deal fields,\n * and attaches a note. Replies in the Vapi results envelope.\n * GET /health Liveness plus the resolved custom-field mapping.\n *\n * Credentials come from env vars: PIPEDRIVE_API_TOKEN, PIPEDRIVE_COMPANY_DOMAIN.\n */\n\nimport { Hono } from \"npm:hono\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst TOKEN = Deno.env.get(\"PIPEDRIVE_API_TOKEN\") ?? \"\";\nconst COMPANY_DOMAIN = Deno.env.get(\"PIPEDRIVE_COMPANY_DOMAIN\") ?? \"\";\nconst BASE = `https://${COMPANY_DOMAIN}.pipedrive.com`;\n\n// ---------------------------------------------------------------------------\n// Field mapping\n// ---------------------------------------------------------------------------\n\ntype FieldDef = { key: string; options: Record };\ntype FieldMap = { source: \"live\" | \"fallback\"; fields: Record };\ntype FieldName = \"Service Market\" | \"Facility Type\" | \"Square Footage\" | \"Service Type\";\n\n/**\n * Baked-in copy of the sandbox schema. Only used when GET /dealFields fails,\n * because a sandbox rebuild silently renumbers every option id.\n */\nconst FALLBACK: Record = {\n \"Service Market\": {\n key: \"14bcf70e8454b86eb8a48503a9835870da18cdb4\",\n options: {\n \"Bentonville/Fayetteville, AR\": 43,\n \"Little Rock, AR\": 44,\n \"Fort Smith, AR\": 45,\n \"Kansas City, KC/MO\": 46,\n \"Wichita, KS\": 47,\n \"Charlotte, NC\": 48,\n \"Florida\": 49,\n \"Connecticut\": 50,\n \"New Jersey\": 51,\n \"Massachusetts\": 52,\n \"Other\": 53,\n },\n },\n \"Facility Type\": {\n key: \"3fc0dd94b9e28b36f593fb99861595298210163a\",\n options: {\n \"Office\": 54,\n \"Construction / General Contractor\": 55,\n \"Medical / Healthcare\": 56,\n \"Property Management\": 57,\n \"Retail\": 58,\n \"Fitness\": 59,\n \"Education\": 60,\n \"Manufacturing\": 61,\n \"Government\": 62,\n \"Restaurants\": 63,\n \"Auto Dealership\": 64,\n \"Religious\": 65,\n \"Industrial\": 66,\n \"Data Site / Critical Environment\": 67,\n \"Other\": 68,\n },\n },\n \"Square Footage\": {\n key: \"0023a9fb03d8f33b3d46b2d293a3624e28f02057\",\n options: { \"Under 5k\": 39, \"5k - 15k\": 40, \"15k - 50k\": 41, \"+50K\": 42 },\n },\n \"Service Type\": {\n key: \"91dc1f687a97a930861256ca1ef274c28d6e308e\",\n options: {\n \"Janitorial\": 69,\n \"Construction Cleaning\": 70,\n \"Carpet Cleaning / Water Extraction\": 71,\n \"Hard Floor\": 72,\n \"Window Cleaning\": 73,\n \"Pressure Washing\": 74,\n \"Other\": 75,\n },\n },\n};\n\nconst FIELD_NAMES = Object.keys(FALLBACK) as FieldName[];\n\n/**\n * Synonyms keyed by option LABEL, never by id, so they survive a renumbering.\n * These are only consulted after an exact and a prefix match both miss.\n */\nconst ALIASES: Record> = {\n \"Service Market\": {\n \"Bentonville/Fayetteville, AR\": [\"bentonville\", \"fayetteville\", \"nwa\", \"northwest arkansas\", \"rogers\", \"springdale\"],\n \"Little Rock, AR\": [\"little rock\", \"north little rock\", \"central arkansas\"],\n \"Fort Smith, AR\": [\"fort smith\", \"ft smith\"],\n \"Kansas City, KC/MO\": [\"kansas city\", \"kc\", \"kcmo\", \"overland park\"],\n \"Wichita, KS\": [\"wichita\"],\n \"Charlotte, NC\": [\"charlotte\", \"north carolina\"],\n \"Florida\": [\"fl\", \"orlando\", \"tampa\", \"miami\", \"jacksonville\"],\n \"Connecticut\": [\"ct\", \"hartford\", \"new haven\"],\n \"New Jersey\": [\"nj\", \"newark\", \"jersey\"],\n \"Massachusetts\": [\"ma\", \"mass\", \"boston\", \"worcester\"],\n },\n \"Facility Type\": {\n \"Office\": [\"office\", \"offices\", \"corporate\", \"corporate office\", \"professional office\"],\n \"Construction / General Contractor\": [\"construction\", \"general contractor\", \"gc\", \"contractor\", \"job site\", \"jobsite\", \"build\"],\n \"Medical / Healthcare\": [\"medical\", \"healthcare\", \"health care\", \"clinic\", \"hospital\", \"dental\", \"dentist\", \"doctor\", \"surgery center\", \"urgent care\"],\n \"Property Management\": [\"property management\", \"property manager\", \"apartment\", \"apartments\", \"multifamily\", \"hoa\", \"residential complex\"],\n \"Retail\": [\"retail\", \"store\", \"shop\", \"storefront\", \"mall\"],\n \"Fitness\": [\"fitness\", \"gym\", \"health club\", \"studio\", \"yoga\"],\n \"Education\": [\"education\", \"school\", \"university\", \"college\", \"campus\", \"daycare\", \"childcare\"],\n \"Manufacturing\": [\"manufacturing\", \"factory\", \"plant\", \"production facility\"],\n \"Government\": [\"government\", \"municipal\", \"city hall\", \"county\", \"federal\", \"public sector\"],\n \"Restaurants\": [\"restaurant\", \"restaurants\", \"food service\", \"cafe\", \"coffee shop\", \"bar\", \"kitchen\", \"brewery\"],\n \"Auto Dealership\": [\"auto dealership\", \"dealership\", \"car dealer\", \"auto dealer\", \"service bay\"],\n \"Religious\": [\"religious\", \"church\", \"synagogue\", \"mosque\", \"temple\", \"worship\", \"faith\"],\n \"Industrial\": [\"industrial\", \"warehouse\", \"distribution\", \"distribution center\", \"logistics\", \"fulfillment\"],\n \"Data Site / Critical Environment\": [\"data site\", \"data center\", \"datacenter\", \"critical environment\", \"server room\", \"clean room\"],\n },\n \"Square Footage\": {\n \"Under 5k\": [\"under 5k\", \"under 5000\", \"less than 5000\", \"under five thousand\", \"small\", \"under 5 000\", \"below 5000\"],\n \"5k - 15k\": [\"5k 15k\", \"5000 15000\", \"5000 to 15000\", \"five to fifteen thousand\", \"5 to 15k\", \"around 10000\"],\n \"15k - 50k\": [\"15k 50k\", \"15000 50000\", \"15000 to 50000\", \"fifteen to fifty thousand\", \"15 to 50k\", \"around 25000\"],\n \"+50K\": [\"over 50k\", \"more than 50k\", \"above 50k\", \"plus 50k\", \"over 50000\", \"more than 50000\", \"50000 plus\", \"50 000 plus\", \"large\"],\n },\n \"Service Type\": {\n \"Janitorial\": [\"janitorial\", \"cleaning\", \"office cleaning\", \"custodial\", \"housekeeping\", \"nightly cleaning\", \"day porter\", \"general cleaning\"],\n \"Construction Cleaning\": [\"construction cleaning\", \"post construction\", \"post construction cleanup\", \"final clean\", \"rough clean\", \"punch clean\"],\n \"Carpet Cleaning / Water Extraction\": [\"carpet\", \"carpet cleaning\", \"water extraction\", \"flood\", \"water damage\", \"shampoo\", \"steam clean\"],\n \"Hard Floor\": [\"hard floor\", \"floor care\", \"floors\", \"vct\", \"strip and wax\", \"buffing\", \"burnishing\", \"tile\", \"polishing\"],\n \"Window Cleaning\": [\"window\", \"windows\", \"window cleaning\", \"window washing\", \"glass\"],\n \"Pressure Washing\": [\"pressure washing\", \"power washing\", \"pressure wash\", \"power wash\", \"exterior washing\"],\n },\n};\n\nlet fieldMapPromise: Promise | null = null;\n\n/** Resolved once per isolate. A failure is not cached, so the next call retries. */\nfunction getFieldMap(): Promise {\n fieldMapPromise ??= loadFieldMap().catch((err) => {\n fieldMapPromise = null;\n console.error(\"[fields] load failed, using fallback:\", err?.message ?? err);\n return { source: \"fallback\" as const, fields: FALLBACK };\n });\n return fieldMapPromise;\n}\n\nasync function loadFieldMap(): Promise {\n const res = await pd(\"GET\", \"/api/v1/dealFields?limit=500\");\n const byName = new Map();\n for (const f of res?.data ?? []) byName.set(String(f.name ?? \"\").toLowerCase(), f);\n\n const fields = {} as Record;\n for (const name of FIELD_NAMES) {\n const live = byName.get(name.toLowerCase());\n if (!live?.key || !Array.isArray(live.options) || live.options.length === 0) {\n console.warn(`[fields] \"${name}\" not found live, using fallback`);\n fields[name] = FALLBACK[name];\n continue;\n }\n const options: Record = {};\n for (const o of live.options) {\n if (o?.label != null && o?.id != null) options[String(o.label)] = Number(o.id);\n }\n fields[name] = { key: String(live.key), options };\n }\n console.log(\"[fields] resolved live from dealFields\");\n return { source: \"live\", fields };\n}\n\n// ---------------------------------------------------------------------------\n// Forgiving label matching\n// ---------------------------------------------------------------------------\n\n/** Lowercase, strip punctuation and accents, collapse whitespace. */\nfunction norm(s: unknown): string {\n return String(s ?? \"\")\n .normalize(\"NFKD\")\n .replace(/[̀-ͯ]/g, \"\")\n .toLowerCase()\n .replace(/[^a-z0-9]+/g, \" \")\n // Range connectors, so \"15k to 50k\" normalizes onto the \"15k - 50k\" label.\n .replace(/\\b(?:to|thru|through)\\b/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n}\n\n/** Whole-token containment, so a two-letter input can't match inside a word. */\nfunction containsPhrase(hay: string, needle: string): boolean {\n if (!needle || !hay) return false;\n const escaped = needle.replace(/[.*+?^${}()|[\\]\\\\]/g, \"\\\\$&\");\n return new RegExp(`(^| )${escaped}( |$)`).test(hay);\n}\n\nconst STOPWORDS = new Set([\"a\", \"an\", \"the\", \"and\", \"or\", \"of\", \"in\", \"at\", \"for\", \"to\", \"our\", \"my\", \"its\", \"is\"]);\n\nfunction tokens(s: string): string[] {\n return norm(s).split(\" \").filter((t) => t && !STOPWORDS.has(t));\n}\n\ntype Resolution = { label: string; id: number; matched: true } | { label: null; id: null; matched: false };\n\n/**\n * Maps a spoken label onto an option id. Exact label, exact alias, prefix,\n * whole-token containment (longest needle wins, so \"medical office building\"\n * lands on Medical rather than Office), then token overlap. Returns unmatched\n * rather than guessing wildly; the caller decides what to do with that.\n */\nfunction resolveOption(fieldName: FieldName, raw: string, map: FieldMap): Resolution {\n const def = map.fields[fieldName];\n const input = norm(raw);\n if (!input) return { label: null, id: null, matched: false };\n\n const entries = Object.entries(def.options);\n const aliasTable = ALIASES[fieldName] ?? {};\n const aliasesFor = (label: string) => (aliasTable[label] ?? []).map(norm).filter(Boolean);\n const hit = (label: string): Resolution => ({ label, id: def.options[label], matched: true });\n\n // 1. exact label\n for (const [label] of entries) if (norm(label) === input) return hit(label);\n\n // 2. exact alias\n for (const [label] of entries) if (aliasesFor(label).includes(input)) return hit(label);\n\n // 3. prefix, either direction\n for (const [label] of entries) {\n const n = norm(label);\n if (n.startsWith(input + \" \") || input.startsWith(n + \" \")) return hit(label);\n }\n\n // 4. whole-token containment over labels and aliases, longest needle wins\n let bestPhrase: { label: string; len: number } | null = null;\n for (const [label] of entries) {\n if (norm(label) === \"other\") continue;\n for (const needle of [norm(label), ...aliasesFor(label)]) {\n if (!containsPhrase(input, needle) && !containsPhrase(needle, input)) continue;\n const len = needle.length;\n if (!bestPhrase || len > bestPhrase.len) bestPhrase = { label, len };\n }\n }\n if (bestPhrase) return hit(bestPhrase.label);\n\n // 5. token overlap, best scoring label wins if it clears the bar\n const inTok = new Set(tokens(input));\n if (inTok.size) {\n let best: { label: string; score: number } | null = null;\n for (const [label] of entries) {\n if (norm(label) === \"other\") continue;\n const labTok = tokens(label);\n const aliasTok = (aliasTable[label] ?? []).flatMap(tokens);\n const all = new Set([...labTok, ...aliasTok]);\n let overlap = 0;\n for (const t of all) if (inTok.has(t)) overlap++;\n if (overlap === 0) continue;\n const score = overlap / Math.min(inTok.size, Math.max(all.size, 1));\n if (!best || score > best.score) best = { label, score };\n }\n if (best && best.score >= 0.5) return hit(best.label);\n }\n\n return { label: null, id: null, matched: false };\n}\n\n// ---------------------------------------------------------------------------\n// Pipedrive client\n// ---------------------------------------------------------------------------\n\nclass PipedriveError extends Error {\n status: number;\n constructor(message: string, status: number) {\n super(message);\n this.name = \"PipedriveError\";\n this.status = status;\n }\n}\n\nasync function pd(method: string, path: string, body?: unknown): Promise {\n const res = await fetch(`${BASE}${path}`, {\n method,\n headers: {\n \"x-api-token\": TOKEN,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n body: body === undefined ? undefined : JSON.stringify(body),\n });\n const text = await res.text();\n let json: any = null;\n try {\n json = text ? JSON.parse(text) : null;\n } catch {\n // fall through, a non-JSON body is reported below\n }\n if (!res.ok || json?.success === false) {\n const detail = json?.error ?? json?.message ?? text.slice(0, 300);\n // Logged, never returned to the agent.\n console.error(`[pipedrive] ${method} ${path} -> ${res.status}: ${detail}`);\n throw new PipedriveError(`${method} ${path} failed (${res.status})`, res.status);\n }\n return json;\n}\n\nasync function findOrCreateOrganization(name: string, rid: string): Promise {\n const search = await pd(\n \"GET\",\n `/api/v2/organizations/search?term=${encodeURIComponent(name)}&fields=name&exact_match=true`,\n );\n const existing = search?.data?.items?.[0]?.item?.id;\n if (existing) {\n console.log(`[${rid}] org reused id=${existing}`);\n return Number(existing);\n }\n const created = await pd(\"POST\", \"/api/v2/organizations\", { name });\n const id = Number(created?.data?.id);\n console.log(`[${rid}] org created id=${id}`);\n return id;\n}\n\nasync function findOrCreatePerson(\n args: { name: string; email: string; phone?: string; orgId: number },\n rid: string,\n): Promise {\n // `email` is what actually matches an email term; the extra fields are harmless.\n const search = await pd(\n \"GET\",\n `/api/v2/persons/search?term=${encodeURIComponent(args.email)}&fields=${\n encodeURIComponent(\"email,custom_fields,name\")\n }`,\n );\n const existing = search?.data?.items?.[0]?.item?.id;\n if (existing) {\n console.log(`[${rid}] person reused id=${existing}`);\n return Number(existing);\n }\n const body: Record = {\n name: args.name,\n org_id: args.orgId,\n emails: [{ value: args.email, primary: true, label: \"work\" }],\n };\n if (args.phone) body.phones = [{ value: args.phone, primary: true, label: \"work\" }];\n const created = await pd(\"POST\", \"/api/v2/persons\", body);\n const id = Number(created?.data?.id);\n console.log(`[${rid}] person created id=${id}`);\n return id;\n}\n\n// ---------------------------------------------------------------------------\n// Request handling\n// ---------------------------------------------------------------------------\n\ntype LeadArgs = {\n company_name?: string;\n contact_name?: string;\n email?: string;\n phone?: string;\n service_market?: string;\n facility_type?: string;\n service_type?: string;\n square_footage?: string;\n note?: string;\n};\n\nconst REQUIRED: Array<[keyof LeadArgs, string]> = [\n [\"company_name\", \"company name\"],\n [\"contact_name\", \"contact name\"],\n [\"email\", \"email address\"],\n [\"phone\", \"phone number\"],\n [\"service_market\", \"service market\"],\n [\"facility_type\", \"facility type\"],\n [\"service_type\", \"service type\"],\n];\n\nconst EMAIL_RE = /^[^\\s@]+@[^\\s@]+\\.[a-z]{2,}$/i;\n\nfunction str(v: unknown): string {\n return typeof v === \"string\" ? v.trim() : v == null ? \"\" : String(v).trim();\n}\n\nfunction escapeHtml(s: string): string {\n return s.replace(/&/g, \"&\").replace(//g, \">\");\n}\n\n/** Pulls the tool-call id and arguments out of the Vapi webhook envelope. */\nfunction parseEnvelope(body: any): { toolCallId: string | null; args: LeadArgs } {\n const call = body?.message?.toolCalls?.[0] ?? body?.message?.toolCallList?.[0] ?? body?.toolCalls?.[0];\n let raw = call?.function?.arguments ?? call?.arguments;\n if (typeof raw === \"string\") {\n try {\n raw = JSON.parse(raw);\n } catch {\n raw = null;\n }\n }\n // Bare-body form, for curl and local testing.\n if (!raw && body && typeof body === \"object\" && !body.message) raw = body;\n return { toolCallId: call?.id ?? body?.toolCallId ?? null, args: (raw ?? {}) as LeadArgs };\n}\n\nfunction envelope(toolCallId: string | null, payload: unknown): Response {\n return Response.json({\n results: [{ toolCallId: toolCallId ?? \"unknown\", result: JSON.stringify(payload) }],\n });\n}\n\nconst IDEMPOTENCY_WINDOW_MS = 5 * 60 * 1000;\nconst CLAIM_TTL_MS = 30 * 1000;\n\nasync function idemKey(email: string, company: string, callId: string): Promise {\n // Keyed on the Vapi call id when we have one. Keying on (email, company) let a caller\n // who corrected their email after the write produce a second lead, and those two are\n // the fields most often corrected late.\n const basis = callId ? `call:${norm(callId)}` : `${norm(email)}|${norm(company)}`;\n const data = new TextEncoder().encode(basis);\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n const hex = [...new Uint8Array(digest)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n return `lead:idem:${hex.slice(0, 32)}`;\n}\n\ntype IdemRecord =\n | { status: \"done\"; leadId: string; company: string; at: number }\n | { status: \"pending\"; at: number };\n\nconst app = new Hono();\n\napp.onError((err) => Promise.reject(err));\n\napp.get(\"/\", (c) => c.redirect(\"/health\"));\n\napp.get(\"/health\", async (c) => {\n const map = await getFieldMap();\n const fields: Record = {};\n for (const name of FIELD_NAMES) {\n fields[name] = { key: map.fields[name].key, options: map.fields[name].options };\n }\n return c.json({\n ok: true,\n service: \"handled-lead\",\n pipedrive_domain: COMPANY_DOMAIN || null,\n token_present: TOKEN.length > 0,\n field_source: map.source,\n fields,\n time: new Date().toISOString(),\n });\n});\n\napp.post(\"/lead\", async (c) => {\n const rid = crypto.randomUUID().slice(0, 8);\n let body: any;\n try {\n body = await c.req.json();\n } catch {\n console.error(`[${rid}] unparseable request body`);\n return c.json({ error: \"bad_request\", message: \"Request body was not JSON.\" }, 400);\n }\n\n const { toolCallId, args } = parseEnvelope(body);\n console.log(`[${rid}] toolCallId=${toolCallId} args=${JSON.stringify(args)}`);\n\n if (!TOKEN || !COMPANY_DOMAIN) {\n console.error(`[${rid}] missing PIPEDRIVE_API_TOKEN or PIPEDRIVE_COMPANY_DOMAIN`);\n return c.json({ error: \"misconfigured\", message: \"Pipedrive credentials are not configured.\" }, 500);\n }\n\n // ---- validation (business failures, HTTP 200) --------------------------\n const missing = REQUIRED.filter(([k]) => !str(args[k])).map(([, label]) => label);\n if (missing.length) {\n console.warn(`[${rid}] missing required: ${missing.join(\", \")}`);\n return envelope(toolCallId, {\n error: \"missing_fields\",\n message: `The lead is missing the ${missing.join(\", the \")}.`,\n missing,\n next_step: \"Nothing was saved. Ask the caller for what is missing before doing anything else.\",\n });\n }\n\n const company = str(args.company_name);\n const contact = str(args.contact_name);\n const email = str(args.email);\n const phone = str(args.phone);\n\n if (!EMAIL_RE.test(email)) {\n console.warn(`[${rid}] invalid email: ${email}`);\n return envelope(toolCallId, {\n error: \"invalid_email\",\n message: \"That email address does not look complete.\",\n next_step: \"Nothing was saved. Read the email address back and get it right before doing anything else.\",\n });\n }\n\n // ---- idempotency -------------------------------------------------------\n const key = await idemKey(email, company, str(args.vapi_call_id));\n const now = Date.now();\n let prior: IdemRecord | undefined;\n try {\n prior = (await blob.getJSON(key)) as IdemRecord | undefined;\n } catch (err) {\n console.warn(`[${rid}] idempotency read failed: ${(err as Error)?.message}`);\n }\n\n if (prior?.status === \"done\" && now - prior.at < IDEMPOTENCY_WINDOW_MS) {\n console.log(`[${rid}] idempotent replay, returning lead ${prior.leadId}`);\n return envelope(toolCallId, {\n success: true,\n lead_id: prior.leadId,\n company: prior.company,\n duplicate: true,\n next_step: \"The lead is saved. Confirm it is in and wrap up.\",\n });\n }\n\n // A retry that lands while the first write is still running waits briefly\n // for it rather than creating a second lead.\n if (prior?.status === \"pending\" && now - prior.at < CLAIM_TTL_MS) {\n for (let i = 0; i < 4; i++) {\n await new Promise((r) => setTimeout(r, 1000));\n const again = (await blob.getJSON(key).catch(() => undefined)) as IdemRecord | undefined;\n if (again?.status === \"done\") {\n console.log(`[${rid}] concurrent write completed, returning lead ${again.leadId}`);\n return envelope(toolCallId, {\n success: true,\n lead_id: again.leadId,\n company: again.company,\n duplicate: true,\n next_step: \"The lead is saved. Confirm it is in and wrap up.\",\n });\n }\n }\n console.warn(`[${rid}] pending claim never completed, proceeding`);\n }\n\n await blob.setJSON(key, { status: \"pending\", at: now } satisfies IdemRecord).catch((err) =>\n console.warn(`[${rid}] idempotency claim failed: ${err?.message}`)\n );\n\n // ---- resolve the dropdowns --------------------------------------------\n const map = await getFieldMap();\n const custom: Record = {};\n const unresolved: string[] = [];\n\n const spoken: Array<[FieldName, string]> = [\n [\"Service Market\", str(args.service_market)],\n [\"Facility Type\", str(args.facility_type)],\n [\"Service Type\", str(args.service_type)],\n ];\n\n for (const [fieldName, value] of spoken) {\n const def = map.fields[fieldName];\n const r = resolveOption(fieldName, value, map);\n if (r.matched) {\n custom[def.key] = r.id;\n console.log(`[${rid}] ${fieldName}: \"${value}\" -> ${r.label} (${r.id})`);\n continue;\n }\n // Losing a categorization is recoverable, losing the lead is not.\n const otherLabel = Object.keys(def.options).find((l) => norm(l) === \"other\");\n if (otherLabel) {\n custom[def.key] = def.options[otherLabel];\n console.warn(`[${rid}] ${fieldName}: \"${value}\" unresolved -> Other (${def.options[otherLabel]})`);\n } else {\n console.warn(`[${rid}] ${fieldName}: \"${value}\" unresolved, no Other option, omitted`);\n }\n unresolved.push(`${fieldName}: ${value}`);\n }\n\n // Square footage is optional and has no Other option: unresolved means omit\n // the field and carry the spoken value into the note.\n const sqft = str(args.square_footage);\n if (sqft) {\n const def = map.fields[\"Square Footage\"];\n const r = resolveOption(\"Square Footage\", sqft, map);\n if (r.matched) {\n custom[def.key] = r.id;\n console.log(`[${rid}] Square Footage: \"${sqft}\" -> ${r.label} (${r.id})`);\n } else {\n console.warn(`[${rid}] Square Footage: \"${sqft}\" unresolved, omitted`);\n unresolved.push(`Square Footage: ${sqft}`);\n }\n }\n\n // ---- write -------------------------------------------------------------\n try {\n const orgId = await findOrCreateOrganization(company, rid);\n const personId = await findOrCreatePerson({ name: contact, email, phone, orgId }, rid);\n\n // Custom field hashes go at the TOP LEVEL of a v1 lead body, and the value\n // is the integer option id, not the label.\n const leadBody: Record = {\n title: company,\n person_id: personId,\n organization_id: orgId,\n ...custom,\n };\n const leadRes = await pd(\"POST\", \"/api/v1/leads\", leadBody);\n const leadId = String(leadRes?.data?.id ?? \"\");\n console.log(`[${rid}] lead created id=${leadId}`);\n\n const noteParts: string[] = [];\n const spokenNote = str(args.note);\n if (spokenNote) noteParts.push(escapeHtml(spokenNote));\n if (unresolved.length) {\n noteParts.push(\n `Unmatched answers from the call:
${unresolved.map((u) => escapeHtml(u)).join(\"
\")}`,\n );\n }\n if (noteParts.length && leadId) {\n await pd(\"POST\", \"/api/v1/notes\", { content: noteParts.join(\"

\"), lead_id: leadId });\n console.log(`[${rid}] note attached to lead ${leadId}`);\n }\n\n await blob\n .setJSON(key, { status: \"done\", leadId, company, at: Date.now() } satisfies IdemRecord)\n .catch((err) => console.warn(`[${rid}] idempotency write failed: ${err?.message}`));\n\n return envelope(toolCallId, {\n success: true,\n lead_id: leadId,\n company,\n next_step: \"The lead is saved. Confirm it is in and wrap up.\",\n });\n } catch (err) {\n console.error(`[${rid}] write failed:`, err);\n await blob.delete(key).catch(() => {});\n // Business-shaped failure: HTTP 200, speakable message, never the raw body.\n return envelope(toolCallId, {\n error: \"save_failed\",\n message: \"The lead did not save on this attempt.\",\n next_step: \"The lead was not saved and no one will see it. Do not promise a follow up. Give the caller the main line so they can reach the office directly, then close.\",\n });\n }\n});\n\napp.all(\"*\", (c) => c.json({ error: \"not_found\", message: \"Unknown route.\" }, 404));\n\nexport default app.fetch;\n","createdAt",["D",1788927843926],"branchVersion","branchId","6967bbdd-b286-484e-8706-cfdecad5b22a","id","92ec675c-f85a-43ba-9573-5b35feeeb03f","handled-lead",["D",1788925516105],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Vapi tool endpoint writing qualified leads into Pipedrive","imageUrl","019ca0d6-7e9d-7708-aea8-6df17bfdceea","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019ca0d6-7e9d-7708-aea8-700f071be19f","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_103":99},"org",{"_96":95,"_97":-5,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",52,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","veltson","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNBR2hoWFBtaWhlZUdZZlg1TnNKZ2Uwc1YyQyJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":151,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":152,"_80":153,"_82":154,"_84":25},"tree",[146],"files",[146],"counts",{"_134":62,"_135":136,"_137":62,"_138":139,"_140":141},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"735c6217-2377-4acb-b624-291967d60424","parentId","latest",["D",1788927843926],9,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":144,"_145":62},"connections",{"_142":62,"_143":62},"count","unfilledCount",3,"emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":147,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_148":149,"_27":150},["D",1788927843926],"children",[],[28],["D",1788925516105],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_123":188,"_189":190,"_191":192,"_193":25,"_194":25,"_195":25,"_196":58,"_197":-5,"_198":-7,"_199":-7,"_200":62,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":86,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v10