[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_101":102,"_103":104},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","veltson","name","handled-lead","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_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":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/veltson/handled-lead/code/main.ts","extension","id","d8e2e312-89c9-40b7-8b93-3ccd9797e734","fileId","deba10f2-ac00-11f1-8495-1607ee4eb77e","parentId","branchId","6967bbdd-b286-484e-8706-cfdecad5b22a","branchVersion",51,"latest",true,"createdAt",["D",1789515791628],"version",41,"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 its custom deal fields, and\n * attaches a note carrying everything without a field of its own.\n * 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\" | \"Timeline\" | \"Urgency\" | \"Voice Agent Disposition\";\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 \"Timeline\": {\n key: \"082013c8e57292129ddc2243b3f3d9e37cc94ac0\",\n options: { \"Immediately, within 2 weeks\": 0, \"Within 30 days\": 0, \"60 to 90 days\": 0, \"Longer than 90 days\": 0, \"Just researching\": 0 },\n },\n \"Urgency\": {\n key: \"bb095b39b9baf920de6ecba2a7ca02598a41ec84\",\n options: { \"Hot\": 0, \"Standard\": 0, \"Low\": 0 },\n },\n \"Voice Agent Disposition\": {\n key: \"c5f5f939374a1f57b95157bd787703f2c3245e9f\",\n options: { \"Qualified lead\": 0, \"Duplicate, logged to existing Deal\": 0, \"Service issue\": 0, \"Applicant\": 0, \"Partner\": 0, \"Acquisition inquiry\": 0, \"Spam\": 0, \"Residential decline\": 0, \"Out of area\": 0, \"Abandoned\": 0, \"Transferred to human\": 0 },\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 \"Timeline\": {\n \"Immediately, within 2 weeks\": [\n \"right away\", \"as soon as possible\", \"asap\", \"immediately\", \"yesterday\",\n \"this week\", \"next week\", \"urgent\", \"two weeks\", \"2 weeks\",\n ],\n \"Within 30 days\": [\"this month\", \"within a month\", \"thirty days\", \"30 days\", \"by the end of the month\", \"next month\"],\n \"60 to 90 days\": [\"couple of months\", \"two or three months\", \"next quarter\", \"sixty days\", \"60 days\", \"ninety days\", \"90 days\"],\n \"Longer than 90 days\": [\"later this year\", \"next year\", \"not for a while\", \"six months\", \"down the road\"],\n \"Just researching\": [\"no timeline\", \"just researching\", \"just looking\", \"no rush\", \"exploring\"],\n },\n // The agent passes the town and state as the caller said them; the mapping happens here.\n // Brief 6.4: a town that is not itself an option resolves to its STATE, with the town\n // carried into the note. Cities are listed before their state so the more specific match\n // wins, and every operating state appears by name and by abbreviation.\n \"Service Market\": {\n \"Bentonville/Fayetteville, AR\": [\"bentonville\", \"fayetteville\", \"nwa\", \"northwest arkansas\", \"rogers\", \"springdale\", \"bella vista\", \"siloam springs\"],\n \"Little Rock, AR\": [\"little rock\", \"north little rock\", \"central arkansas\", \"conway\", \"benton\", \"jacksonville ar\"],\n \"Fort Smith, AR\": [\"fort smith\", \"ft smith\", \"van buren\", \"greenwood\"],\n \"Kansas City, KC/MO\": [\"kansas city\", \"kc\", \"kcmo\", \"overland park\", \"olathe\", \"lenexa\", \"independence\"],\n \"Wichita, KS\": [\"wichita\", \"kansas\", \"ks\", \"derby\", \"andover\"],\n \"Charlotte, NC\": [\"charlotte\", \"north carolina\", \"nc\", \"concord\", \"gastonia\", \"huntersville\"],\n \"Florida\": [\"fl\", \"florida\", \"orlando\", \"tampa\", \"miami\", \"jacksonville\", \"fort lauderdale\", \"ft lauderdale\", \"st petersburg\", \"sarasota\"],\n \"Connecticut\": [\"ct\", \"connecticut\", \"hartford\", \"new haven\", \"stamford\", \"bridgeport\", \"waterbury\", \"norwalk\", \"danbury\", \"greenwich\"],\n \"New Jersey\": [\"nj\", \"new jersey\", \"jersey\", \"newark\", \"jersey city\", \"paterson\", \"elizabeth\", \"edison\", \"trenton\"],\n \"Massachusetts\": [\"ma\", \"mass\", \"massachusetts\", \"boston\", \"worcester\", \"springfield ma\", \"cambridge\", \"lowell\", \"quincy\"],\n },\n \"Facility Type\": {\n \"Office\": [\"office\", \"offices\", \"corporate\", \"corporate office\", \"professional office\",\n \"office building\", \"business office\", \"office suite\", \"office park\", \"law firm\", \"accounting firm\"],\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\", \"storefront\", \"mall\", \"shopping center\", \"strip mall\",\n \"boutique\", \"salon\", \"pharmacy\", \"grocery\", \"shop\"],\n \"Fitness\": [\"fitness\", \"gym\", \"health club\", \"studio\", \"yoga\"],\n \"Education\": [\"education\", \"school\", \"schools\", \"university\", \"college\", \"campus\",\n \"daycare\", \"childcare\", \"academy\", \"charter school\", \"preschool\", \"classroom\", \"classrooms\"],\n \"Manufacturing\": [\"manufacturing\", \"factory\", \"plant\", \"production facility\",\n \"food processing\", \"processing facility\", \"food plant\", \"packaging\", \"assembly\", \"mill\"],\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 \"auto shop\", \"auto repair\", \"auto service\", \"body shop\", \"repair shop\", \"car lot\",\n \"service department\", \"showroom\", \"tire shop\", \"collision center\"],\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 */\n/**\n * Picks the best label for a spoken phrase out of a label -> aliases table.\n * Exact label, exact alias, prefix in either direction, whole-token containment\n * with the longest needle winning (so \"medical office building\" lands on Medical\n * rather than Office), then token overlap that has to clear half. Returns null\n * rather than guessing wildly; the caller decides what to do with that.\n */\nfunction bestLabel(raw: string, table: Record): string | null {\n const input = norm(raw);\n if (!input) return null;\n const labels = Object.keys(table);\n const aliasesFor = (label: string) => (table[label] ?? []).map(norm).filter(Boolean);\n\n for (const label of labels) if (norm(label) === input) return label;\n for (const label of labels) if (aliasesFor(label).includes(input)) return label;\n for (const label of labels) {\n const n = norm(label);\n if (n.startsWith(input + \" \") || input.startsWith(n + \" \")) return label;\n }\n\n // The earliest match wins, with the longer needle breaking a tie. English puts the\n // qualifier before the head noun, and a caller leads with the thing they mean, so\n // \"dental office\" is a dental practice and \"a school with offices, a gym and a\n // cafeteria\" is a school. Ranking by needle length instead reads a descriptive\n // sentence as whichever incidental feature happened to have the longest label.\n let bestPhrase: { label: string; len: number; at: number } | null = null;\n for (const label of labels) {\n if (norm(label) === \"other\") continue;\n for (const needle of [norm(label), ...aliasesFor(label)]) {\n const inInput = containsPhrase(input, needle);\n if (!inInput && !containsPhrase(needle, input)) continue;\n const at = inInput ? input.indexOf(needle) : 0;\n if (\n !bestPhrase ||\n at < bestPhrase.at ||\n (at === bestPhrase.at && needle.length > bestPhrase.len)\n ) {\n bestPhrase = { label, len: needle.length, at };\n }\n }\n }\n if (bestPhrase) return bestPhrase.label;\n\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 labels) {\n if (norm(label) === \"other\") continue;\n const all = new Set([...tokens(label), ...(table[label] ?? []).flatMap(tokens)]);\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 best.label;\n }\n return null;\n}\n\n/** Maps a spoken label onto a Pipedrive option id using the shared resolver. */\nfunction resolveOption(fieldName: FieldName, raw: string, map: FieldMap): Resolution {\n const def = map.fields[fieldName];\n const table: Record = {};\n for (const label of Object.keys(def.options)) table[label] = ALIASES[fieldName]?.[label] ?? [];\n const label = bestLabel(raw, table);\n return label ? { label, id: def.options[label], matched: true } : { 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\nconst PIPELINE_ID = 2; // Janitorial - New Client Board\nconst STAGE_ID = 7; // New Voice Lead\nconst VOICE_CALL_ID_KEY = \"05745c9e083399a6a4f08183be3f6af61504211c\";\nconst RECORDING_URL_KEY = \"49575212f5213e1aa3bf7b62ac84f17fc9a9e7ee\";\nconst TRANSCRIPT_URL_KEY = \"1970a1a4c78b1d3dd23241d4c3edb3f3efc0ad3b\";\nconst WALKTHROUGH_KEY = \"29bd9c6cc3b9e3afd4d4fe27fb06e6bfa380aac3\";\n\n/**\n * Brief 11.3. Only one of the nine caller types opens a sales Deal, and four of them\n * create no CRM object at all. A Deal on any row marked NO is called a defect rather than\n * a judgement call, and they audit for it.\n */\ntype WritePlan = { contact: boolean; deal: boolean; tag?: string };\nfunction planFor(disposition: string): WritePlan {\n const d = norm(disposition);\n if (d === norm(\"Applicant\") || d === norm(\"Spam\") ||\n d === norm(\"Residential decline\") || d === norm(\"Abandoned\")) {\n return { contact: false, deal: false };\n }\n if (d === norm(\"Callback requested\") || d === norm(\"Service issue\") || d === norm(\"Duplicate, logged to existing Deal\")) {\n return { contact: true, deal: false };\n }\n if (d === norm(\"Partner\")) return { contact: true, deal: false, tag: \"PARTNER\" };\n if (d === norm(\"Acquisition inquiry\")) return { contact: true, deal: false, tag: \"ACQUISITION\" };\n return { contact: true, deal: true }; // Qualified lead, Out of area, anything unknown\n}\n\nasync function orgFindOrCreate(name: string, rid: string): Promise {\n if (!name) return null;\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 personSearch(term: string, field: \"phone\" | \"email\", rid: string) {\n if (!term) return null;\n const res = await pd(\n \"GET\",\n `/api/v2/persons/search?term=${encodeURIComponent(term)}&fields=${field}`,\n );\n const hit = res?.data?.items?.[0]?.item;\n if (hit) console.log(`[${rid}] person matched on ${field} id=${hit.id}`);\n return hit ?? null;\n}\n\n/**\n * Brief 11.2, in the order the brief insists on. Phone and email both live on the Person,\n * so a dedupe that starts at the Organization misses every time. An update fills gaps and\n * never overwrites a populated field with a blank.\n */\nasync function resolveContact(\n args: { company: string; contact: string; email: string; phone: string },\n rid: string,\n): Promise<{ personId: number | null; orgId: number | null; isRepeat: boolean }> {\n const found = (await personSearch(args.phone, \"phone\", rid)) ??\n (await personSearch(args.email, \"email\", rid));\n\n let orgId: number | null = null;\n if (found) {\n // Read the org already linked rather than creating a second one.\n orgId = Number(found.organization?.id ?? found.org_id?.value ?? found.org_id ?? 0) || null;\n if (!orgId) orgId = await orgFindOrCreate(args.company, rid);\n } else {\n orgId = await orgFindOrCreate(args.company, rid);\n }\n\n if (found) {\n const patch: Record = {};\n if (!found.name && args.contact) patch.name = args.contact;\n if (orgId && !found.organization?.id && !found.org_id) patch.org_id = orgId;\n if (args.email && !(found.emails ?? []).some((e: any) => e?.value)) {\n patch.emails = [{ value: args.email, primary: true, label: \"work\" }];\n }\n if (args.phone && !(found.phones ?? []).some((p: any) => p?.value)) {\n patch.phones = [{ value: args.phone, primary: true, label: \"work\" }];\n }\n if (Object.keys(patch).length) {\n await pd(\"PATCH\", `/api/v2/persons/${found.id}`, patch);\n console.log(`[${rid}] person ${found.id} gaps filled: ${Object.keys(patch).join(\", \")}`);\n }\n return { personId: Number(found.id), orgId, isRepeat: true };\n }\n\n const body: Record = { name: args.contact || args.email || \"Unnamed caller\" };\n if (orgId) body.org_id = orgId;\n if (args.email) body.emails = [{ value: args.email, primary: true, label: \"work\" }];\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 { personId: id, orgId, isRepeat: false };\n}\n\ntype DealState = \"open\" | \"lost\" | \"won\" | \"none\";\n\n/** Brief 11.4. The same prospect calling twice must never produce a second Deal. */\nasync function latestDealFor(personId: number, rid: string): Promise<{ id: number; state: DealState }> {\n const res = await pd(\"GET\", `/api/v2/deals?person_id=${personId}&limit=100&sort_by=update_time&sort_direction=desc`);\n const deals = res?.data ?? [];\n if (!deals.length) return { id: 0, state: \"none\" };\n const open = deals.find((d: any) => d.status === \"open\");\n if (open) {\n console.log(`[${rid}] repeat caller, open deal ${open.id}`);\n return { id: Number(open.id), state: \"open\" };\n }\n const recent = deals[0];\n const state: DealState = recent.status === \"won\" ? \"won\" : recent.status === \"lost\" ? \"lost\" : \"open\";\n console.log(`[${rid}] repeat caller, most recent deal ${recent.id} is ${state}`);\n return { id: Number(recent.id), state };\n}\n\nasync function activityLog(\n args: { personId: number | null; dealId: number; subject: string; note: string },\n rid: string,\n) {\n const body: Record = {\n subject: args.subject,\n type: \"call\",\n done: true,\n note: args.note,\n };\n if (args.personId) body.person_id = args.personId;\n if (args.dealId) body.deal_id = args.dealId;\n await pd(\"POST\", \"/api/v1/activities\", body).catch((e) =>\n console.warn(`[${rid}] activity failed: ${e?.message}`)\n );\n console.log(`[${rid}] activity logged against person=${args.personId ?? \"-\"} deal=${args.dealId || \"-\"}`);\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 // Fixed choices the agent matches silently. Timeline, urgency and disposition\n // resolve onto their own Pipedrive fields; the rest are carried into the note.\n timeline?: string;\n urgency_flag?: string;\n disposition?: string;\n role?: string;\n decision_role?: string;\n site_count?: string;\n frequency?: string;\n current_situation?: string;\n special_requirements?: string;\n lead_source?: string;\n // Free text.\n site_address?: string;\n contract_end_date?: string;\n walkthrough_window?: string;\n callback_window?: string;\n budget_mention?: string;\n // Supplied by the platform as a static tool parameter, with the call envelope\n // as a fallback. Never something the model fills in.\n vapi_call_id?: string;\n // Written by the end-of-call webhook, not by the agent: neither URL exists while the\n // call is still running.\n recording_url?: string;\n transcript_url?: string;\n};\n\n// What a write has to carry depends on what kind of call it was. A qualified lead\n// needs the full set. A crew partner, an acquisition inquiry or a customer with a\n// service problem is a real record with no email and no facility type, and holding\n// those to the lead standard sends the agent back to ask a vendor for an email.\nconst LEAD_REQUIRED: Array<[keyof LeadArgs, string]> = [\n [\"company_name\", \"company name\"],\n [\"contact_name\", \"contact name\"],\n [\"service_market\", \"service market\"],\n [\"facility_type\", \"facility type\"],\n [\"service_type\", \"service type\"],\n];\n\n// The spec asks for a phone number OR an email, not both, so neither is required on its\n// own and a lead with one of them is complete. Demanding both cost a real lead on a demo\n// call, where the caller had given a working number and the agent kept pushing for email.\nconst REACHABLE_BY: Array<[keyof LeadArgs, string]> = [\n [\"phone\", \"phone number\"],\n [\"email\", \"email address\"],\n];\n\n// A company and a number are what make a non-lead record actionable. The contact name is\n// wanted and usually there, but demanding it would add a turn to a complaint call the\n// brief wants finished in a minute, and the person write already falls back without one.\nconst CONTACT_REQUIRED: Array<[keyof LeadArgs, string]> = [\n [\"company_name\", \"company name\"],\n [\"phone\", \"phone number\"],\n];\n\n// A vendor pitch gives you a company and hangs up. The record is still worth having.\nconst MINIMAL_REQUIRED: Array<[keyof LeadArgs, string]> = [[\"company_name\", \"company name\"]];\n\n/** An unrecognised or absent disposition falls back to the lead standard, never below it. */\nfunction requiredFor(disposition: string): Array<[keyof LeadArgs, string]> {\n const d = norm(disposition);\n if (d === norm(\"Spam\")) return MINIMAL_REQUIRED;\n if (\n d === norm(\"Callback requested\") || d === norm(\"Service issue\") || d === norm(\"Partner\") || d === norm(\"Acquisition inquiry\") ||\n d === norm(\"Duplicate, logged to existing Deal\") || d === norm(\"Transferred to human\") ||\n d === norm(\"Out of area\") || d === norm(\"Abandoned\") || d === norm(\"Residential decline\")\n ) return CONTACT_REQUIRED;\n return LEAD_REQUIRED;\n}\n\n/**\n * Maps a spoken square footage onto a CRM bracket.\n *\n * The agent used to do this arithmetic and carry the four bracket labels in its prompt,\n * which cost a paragraph of rules and produced the one defect it was written to stop: the\n * bracket, or an adjective standing in for it, reaching the caller's ear instead of their\n * own figure. Taking the labels out of the model's vocabulary entirely means it cannot\n * speak one. It passes on what it heard and the mapping happens here.\n *\n * Handles \"3000\", \"3,000\", \"about 3,500 sq ft\", \"25k\", \"3000-4000\" (takes the larger, a\n * caller hedging between two numbers is telling you it is at least the bigger one) and\n * the spoken forms of round numbers. Returns null when there is no number in there, which\n * leaves the field blank rather than guessing.\n */\nconst WORD_NUMBERS: Record = {\n one: 1, two: 2, three: 3, four: 4, five: 5, six: 6, seven: 7, eight: 8, nine: 9, ten: 10,\n eleven: 11, twelve: 12, fifteen: 15, twenty: 20, twentyfive: 25, thirty: 30, forty: 40,\n fifty: 50, sixty: 60, seventy: 70, eighty: 80, ninety: 90, hundred: 100,\n};\n\nexport function squareFeetParse(raw: string): number | null {\n // Commas come out BEFORE normalising, or \"150,000\" normalises to \"150 000\" and reads\n // as one hundred and fifty.\n const t = norm(String(raw ?? \"\").replace(/,/g, \"\"));\n if (!t) return null;\n\n const found: number[] = [];\n\n // \"25k\", \"50 k\"\n for (const m of t.matchAll(/(\\d+(?:\\.\\d+)?)\\s*k\\b/g)) found.push(parseFloat(m[1]) * 1000);\n // \"fifty k\", \"twenty five k\"\n for (const m of t.matchAll(/\\b([a-z]+)\\s*k\\b/g)) {\n const n = WORD_NUMBERS[m[1]];\n if (n) found.push(n * 1000);\n }\n // bare digits, anything shorter than three is not an area\n for (const m of t.matchAll(/\\b(\\d{3,7})\\b/g)) found.push(parseInt(m[1], 10));\n // \"twenty thousand\", \"three thousand\"\n for (const m of t.matchAll(/\\b([a-z]+)\\s+thousand\\b/g)) {\n const n = WORD_NUMBERS[m[1]];\n if (n) found.push(n * 1000);\n }\n // bare \"a thousand\"\n if (!found.length && /\\bthousand\\b/.test(t)) found.push(1000);\n\n if (!found.length) return null;\n // A caller who says \"three thousand, maybe four\" has at least four.\n let sqft = Math.max(...found);\n // \"over fifty k\" lands exactly on a boundary and has to read as past it, and the same\n // in reverse for \"under five thousand\".\n if (/\\b(over|above|more than|north of|plus|upwards of)\\b/.test(t)) sqft += 1;\n else if (/\\b(under|below|less than|no more than|up to)\\b/.test(t)) sqft -= 1;\n return sqft;\n}\n\nexport function bracketFor(raw: string): string | null {\n const sqft = squareFeetParse(raw);\n if (sqft === null) return null;\n if (sqft < 5000) return \"Under 5k\";\n if (sqft < 15000) return \"5k - 15k\";\n if (sqft <= 50000) return \"15k - 50k\";\n return \"+50K\";\n}\n\n/**\n * Lead grading, brief section 7.3.\n *\n * Every condition the brief states in prose is a value the agent already captures as an\n * enum, so the grade is a pure function of three fields rather than a judgement. It was\n * the model's call until the same scenario came back Hot on one sim run and Standard on\n * the next, which is what a judgement gets you on a field the brief marks required.\n *\n * Three places the brief is genuinely ambiguous, resolved here and worth revisiting with\n * Handled rather than silently owning:\n * - \"Within 30 days\" satisfies Hot's \"under 30 days\" AND Standard's \"30 to 90 days\".\n * Counted as Hot, on the reading that the label is a ceiling.\n * - \"Longer than 90 days\" matches no grade at all. Counted as Low.\n * - A contract ending is not literally \"an active vendor problem\", but section 7.2 calls\n * a renewal window a live opportunity, so it counts toward Hot.\n */\n/**\n * Grading inputs arrive as whatever the caller actually said. The rubric needs\n * canonical labels, so the mapping lives here rather than in a schema enum the\n * model has to pick from mid-call. Same resolver the CRM dropdowns use.\n */\nconst GRADE_VOCAB: Record<\"decision_role\" | \"current_situation\" | \"timeline\", Record> = {\n decision_role: {\n \"Decision maker\": [\n \"i decide\", \"i make the decision\", \"my call\", \"my decision\", \"i sign\", \"i sign off\",\n \"i am the owner\", \"owner\", \"i own the building\", \"i handle that\", \"up to me\",\n \"i approve\", \"final say\", \"i am the decision maker\", \"facilities director\",\n ],\n \"Influencer\": [\n \"i recommend\", \"i make a recommendation\", \"i put it forward\", \"i pass it up\",\n \"i advise\", \"i have input\", \"i weigh in\", \"part of the decision\",\n ],\n \"Gathering information\": [\n \"just looking\", \"just gathering\", \"collecting quotes\", \"doing research\",\n \"seeing what is out there\", \"getting numbers\", \"price shopping\", \"just curious\",\n ],\n \"Committee\": [\n \"the board decides\", \"a committee\", \"we vote\", \"board approval\", \"goes to the board\",\n \"ownership group\", \"partners decide\",\n ],\n },\n current_situation: {\n \"Have a vendor and unhappy\": [\n \"unhappy\", \"not happy\", \"they keep missing\", \"quality has dropped\", \"fed up\",\n \"current vendor is bad\", \"they are terrible\", \"sick of them\", \"not doing the job\",\n \"keeps slipping\", \"complaints\", \"we want to replace them\", \"looking to switch\",\n \"no one shows up\", \"nobody shows up\", \"they do not show\", \"they never show\",\n \"missing visits\", \"miss visits\", \"skipping nights\", \"missing nights\",\n \"missed nights\", \"missed again\", \"second chance\", \"half the time\",\n \"missing entire nights\", \"rushing jobs\", \"rushing through\", \"cutting corners\",\n \"given notice\", \"gave notice\", \"giving notice\", \"terminated them\", \"let them go\",\n \"skips nights\", \"skip nights\", \"skipped nights\", \"crew skips\", \"does not answer\",\n \"doesn t answer\", \"never answers\", \"no answer\", \"unresponsive\", \"ignoring us\",\n \"dealing with it for\", \"been putting up with\", \"had enough\",\n \"cannot reach them\", \"goes to voicemail\", \"voicemail\", \"no response\",\n \"spotty\", \"inconsistent\", \"hit or miss\", \"letting things slide\",\n ],\n \"Have a vendor contract ending\": [\n \"contract is up\", \"contract ends\", \"contract expiring\", \"renewal\", \"up for renewal\",\n \"coming up for bid\", \"rebidding\", \"out to bid\", \"term is ending\",\n ],\n \"New facility opening\": [\n \"new building\", \"new location\", \"opening a new\", \"just leased\", \"moving in\",\n \"we are expanding\", \"second location\", \"new site\",\n ],\n \"No current vendor\": [\n \"nobody right now\", \"no vendor\", \"we do not have anyone\", \"first time\",\n \"never had a service\", \"no one currently\", \"handling it ourselves\",\n ],\n \"In-house staff\": [\n \"our own staff\", \"in house\", \"we have a janitor\", \"our people do it\",\n \"employees clean\", \"we do it internally\",\n ],\n },\n timeline: {\n \"Immediately, within 2 weeks\": [\n \"right away\", \"as soon as possible\", \"asap\", \"immediately\", \"yesterday\",\n \"this week\", \"next week\", \"urgent\", \"two weeks\",\n ],\n \"Within 30 days\": [\"this month\", \"within a month\", \"thirty days\", \"by the end of the month\", \"next month\"],\n \"60 to 90 days\": [\"couple of months\", \"two or three months\", \"next quarter\", \"sixty days\", \"ninety days\"],\n \"Longer than 90 days\": [\"later this year\", \"next year\", \"not for a while\", \"six months\", \"down the road\"],\n \"Just researching\": [\"no timeline\", \"just researching\", \"just looking\", \"no rush\", \"exploring\"],\n },\n};\n\n/** Canonical grading value for a spoken answer, or \"\" when nothing matches. */\nfunction gradeValue(field: keyof typeof GRADE_VOCAB, raw: unknown): string {\n const spoken = str(raw);\n if (!spoken) return \"\";\n return bestLabel(spoken, GRADE_VOCAB[field]) ?? spoken;\n}\n\nconst HOT_TIMELINES = new Set([\"immediately within 2 weeks\", \"within 30 days\"].map(norm));\nconst HOT_SITUATIONS = new Set(\n [\"have a vendor and unhappy\", \"new facility opening\", \"have a vendor contract ending\"].map(norm),\n);\nconst LOW_TIMELINES = new Set([\"just researching\", \"longer than 90 days\"].map(norm));\nconst LOW_DECISION_ROLES = new Set([\"gathering information\", \"influencer\"].map(norm));\n\nfunction gradeLead(args: LeadArgs): \"Hot\" | \"Standard\" | \"Low\" | null {\n const timeline = norm(gradeValue(\"timeline\", args.timeline));\n const decision = norm(gradeValue(\"decision_role\", args.decision_role));\n const situation = norm(gradeValue(\"current_situation\", args.current_situation));\n\n // Nothing to grade on. Fall back to whatever the model said.\n if (!timeline && !decision && !situation) return null;\n\n if (HOT_TIMELINES.has(timeline) && decision === norm(\"Decision maker\") && HOT_SITUATIONS.has(situation)) {\n return \"Hot\";\n }\n if (LOW_TIMELINES.has(timeline) || LOW_DECISION_ROLES.has(decision)) return \"Low\";\n return \"Standard\";\n}\n\n/**\n * A field the model fills is not evidence, it is a claim, so anything that could only\n * have come from the prompt or a placeholder is rejected rather than written. Three\n * sources seen in practice: an unrendered Liquid or Mustache template, a stand-in word\n * the model reached for instead of omitting the field, and a number lifted out of the\n * prompt itself. `gpt-4.1` wrote Handled's own published line into a caller's phone, and\n * wrote the endpointing sentinel from the caller-number block into it as well.\n */\nconst PROMPT_OWNED_NUMBERS = [\"5013291515\", \"266696687\", \"8706410922\"];\nconst PLACEHOLDER_WORDS = /^(?:unknown|not provided|not specified|n\\/?a|none|tbd|pending|placeholder|caller|customer|no answer|not given|unsure)$/i;\n\nfunction fabricationReason(field: string, raw: unknown): string | null {\n const value = str(raw);\n if (!value) return null;\n if (/\\{\\{|\\}\\}|\\{%/.test(value)) return `${field} came through as an unrendered template`;\n if (PLACEHOLDER_WORDS.test(value.trim())) return `${field} is a placeholder rather than an answer`;\n const digits = value.replace(/\\D/g, \"\");\n if (digits.length >= 10 && PROMPT_OWNED_NUMBERS.some((n) => digits.endsWith(n))) {\n return `${field} is a number that belongs to Handled, not to the caller`;\n }\n return null;\n}\n\n/** Fields where a fabricated value would reach a person or a callback. */\nconst NEVER_FABRICATED: Array<[string, string]> = [\n [\"company_name\", \"company name\"], [\"contact_name\", \"contact name\"],\n [\"phone\", \"phone number\"], [\"email\", \"email\"],\n [\"service_market\", \"town or metro\"], [\"site_address\", \"site address\"],\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 const args = (raw ?? {}) as LeadArgs;\n // The call id is on the envelope, never in the model's arguments. Taking it from\n // there keeps the Voice Call ID field populated and keeps idempotency keyed on the\n // call rather than on (email, company), which a late email correction can change.\n const envelopeCallId = body?.message?.call?.id ?? body?.call?.id;\n if (!args.vapi_call_id && typeof envelopeCallId === \"string\") args.vapi_call_id = envelopeCallId;\n return { toolCallId: call?.id ?? body?.toolCallId ?? null, args };\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\n// Returns the grade for a set of fields without writing anything. The rubric is the one\n// piece of this endpoint with enough branching to be worth testing on its own, and doing\n// it through the real code path means the test cannot drift from what production runs.\napp.post(\"/grade\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const { args } = parseEnvelope(body);\n return c.json({\n grade: gradeLead(args),\n inputs: {\n timeline: str(args.timeline) || null,\n decision_role: str(args.decision_role) || null,\n current_situation: str(args.current_situation) || null,\n },\n });\n});\n\n// Same purpose as /grade: the two pieces of derivation the agent no longer does are the\n// two with enough branching to deserve their own tests, and testing them through the real\n// code path means a test cannot drift from what production runs.\napp.post(\"/bracket\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const raw = typeof body?.square_footage === \"string\" ? body.square_footage : \"\";\n return c.json({ input: raw, square_feet: squareFeetParse(raw), bracket: bracketFor(raw) });\n});\n\n// Same purpose as /grade and /bracket: the market mapping is now derived rather than\n// chosen by the agent, so it gets its own test surface and writes nothing.\napp.post(\"/market\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const raw = typeof body?.service_market === \"string\" ? body.service_market : \"\";\n const map = await getFieldMap();\n const r = resolveOption(\"Service Market\", raw, map);\n return c.json({ input: raw, label: r.matched ? r.label : null });\n});\n\n/**\n * Resolves any CRM dropdown field from spoken phrasing, so the suite can prove a\n * freed schema field still lands on the right option without writing to the CRM.\n */\napp.post(\"/resolve\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const field = typeof body?.field === \"string\" ? body.field : \"\";\n const raw = typeof body?.value === \"string\" ? body.value : \"\";\n if (field in GRADE_VOCAB) {\n const label = bestLabel(raw, GRADE_VOCAB[field as keyof typeof GRADE_VOCAB]);\n return c.json({ field, input: raw, label, id: null });\n }\n if (!FIELD_NAMES.includes(field as FieldName)) {\n return c.json({ error: \"unknown field\", known: [...FIELD_NAMES, ...Object.keys(GRADE_VOCAB)] }, 400);\n }\n const map = await getFieldMap();\n const r = resolveOption(field as FieldName, raw, map);\n return c.json({ field, input: raw, label: r.matched ? r.label : null, id: r.matched ? r.id : null });\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 // A follow-up save carries only the new detail, because the record it is adding to\n // already holds the rest. Holding it to the full standard rejects correct behaviour.\n // The relaxation is gated on a completed write for this call id, never on the flag\n // alone: a model cannot set follow_up on a first save to skip the requirements,\n // because with no prior record the full standard still applies.\n let followUpToPrior = false;\n if (str(args.follow_up).toLowerCase() === \"yes\") {\n const priorKey = await idemKey(str(args.email), str(args.company_name), str(args.vapi_call_id));\n const priorRecord = (await blob.getJSON(priorKey).catch(() => undefined)) as IdemRecord | undefined;\n followUpToPrior = priorRecord?.status === \"done\";\n if (!followUpToPrior) console.warn(`[${rid}] follow_up set with no completed prior write; full requirements apply`);\n }\n const required = followUpToPrior ? MINIMAL_REQUIRED : requiredFor(str(args.disposition));\n const missing = required.filter(([k]) => !str(args[k])).map(([, label]) => label);\n // A lead also has to be reachable somehow. Either channel satisfies it.\n if (!followUpToPrior && required === LEAD_REQUIRED && !REACHABLE_BY.some(([k]) => str(args[k]))) {\n missing.push(REACHABLE_BY.map(([, label]) => label).join(\" or the \"));\n }\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 fabricated = NEVER_FABRICATED\n .map(([key, label]) => {\n const reason = fabricationReason(label, (args as Record)[key]);\n return reason ? { key, label, reason } : null;\n })\n .filter((x): x is { key: string; label: string; reason: string } => x !== null);\n if (fabricated.length) {\n console.warn(`[${rid}] refused fabricated: ${fabricated.map((f) => f.reason).join(\"; \")}`);\n return envelope(toolCallId, {\n error: \"unusable_values\",\n message: `Cannot save: ${fabricated.map((f) => f.reason).join(\"; \")}.`,\n fields: fabricated.map((f) => f.key),\n next_step:\n \"Nothing was saved. Ask the caller for these details in their own words and save again. Never fill a field with a placeholder, and never use a number you read anywhere other than from the caller.\",\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 // Only a write that is carrying an email has to have a valid one.\n if (email && !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 record 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 record 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 // The grade is computed, not taken. Only a lead carries one: Hot or Low means nothing on\n // a vendor pitch, and the brief only defines the three grades for qualified prospects.\n const isLead = !str(args.disposition) || norm(args.disposition) === norm(\"Qualified lead\");\n const computed = isLead ? gradeLead(args) : null;\n const urgency = isLead ? (computed ?? str(args.urgency_flag)) : \"\";\n if (isLead && computed && norm(computed) !== norm(str(args.urgency_flag))) {\n console.log(`[${rid}] urgency: model said \"${str(args.urgency_flag)}\", rubric says \"${computed}\"`);\n }\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 [\"Timeline\", str(args.timeline)],\n [\"Urgency\", urgency],\n [\"Voice Agent Disposition\", str(args.disposition)],\n ];\n\n for (const [fieldName, value] of spoken) {\n // A field the caller never gave is blank, not \"Other\". Calls that are not leads carry\n // almost none of these, and falling through to Other wrote a vendor pitch into the CRM\n // as an Other market doing Other work in an Other facility.\n if (!value) continue;\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 arrives as whatever the caller actually said, so the figure is parsed\n // here rather than bracketed by the agent. Falling back to the label matcher covers a\n // caller who genuinely speaks in ranges (\"somewhere over fifty k\"). No match means the\n // field stays blank and their words go in the note, which beats a guessed bracket.\n const sqft = str(args.square_footage);\n if (sqft) {\n const def = map.fields[\"Square Footage\"];\n const label = bracketFor(sqft) ?? (resolveOption(\"Square Footage\", sqft, map).label ?? null);\n const id = label ? def.options[label] : undefined;\n if (label && id !== undefined) {\n custom[def.key] = id;\n console.log(`[${rid}] Square Footage: \"${sqft}\" -> ${label} (${id})`);\n } else {\n console.warn(`[${rid}] Square Footage: \"${sqft}\" unresolved, omitted`);\n unresolved.push(`Square Footage: ${sqft}`);\n }\n }\n\n // ---- write, brief 11.2 order with the 11.3 gate and the 11.4 branch ------\n try {\n const plan = planFor(str(args.disposition));\n\n // Four caller types create no CRM object at all. The disposition is the record.\n if (!plan.contact) {\n console.log(`[${rid}] disposition \"${str(args.disposition)}\" creates no CRM object`);\n await blob\n .setJSON(key, { status: \"done\", leadId: \"\", company, at: Date.now() } satisfies IdemRecord)\n .catch(() => {});\n return envelope(toolCallId, {\n success: true,\n lead_id: \"\",\n company,\n next_step: \"Logged for reporting. Nothing else to do, wrap up.\",\n });\n }\n\n const { personId, orgId, isRepeat } = await resolveContact({ company, contact, email, phone }, rid);\n\n // Everything the structured fields did not catch, carried into the note.\n const noteParts: string[] = [];\n const spokenNote = str(args.note);\n if (spokenNote) noteParts.push(escapeHtml(spokenNote));\n const CARRIED: Array<[string, string]> = [\n [\"Role\", \"role\"], [\"Decision role\", \"decision_role\"], [\"Site address\", \"site_address\"],\n [\"Sites\", \"site_count\"], [\"Frequency\", \"frequency\"], [\"Current situation\", \"current_situation\"],\n [\"Contract ends\", \"contract_end_date\"], [\"Special requirements\", \"special_requirements\"],\n [\"Walkthrough window\", \"walkthrough_window\"], [\"Callback window\", \"callback_window\"],\n [\"Lead source\", \"lead_source\"], [\"Budget mentioned\", \"budget_mention\"],\n [\"Square footage as given\", \"square_footage\"],\n ];\n const carried = CARRIED\n .map(([label, k]) => [label, str((args as Record)[k])] as const)\n .filter(([, v]) => v);\n if (carried.length) {\n noteParts.push(`From the call:
${carried.map(([l, v]) => `${escapeHtml(l)}: ${escapeHtml(v)}`).join(\"
\")}`);\n }\n if (unresolved.length) {\n noteParts.push(`Unmatched answers:
${unresolved.map((u) => escapeHtml(u)).join(\"
\")}`);\n }\n if (plan.tag) noteParts.push(`Tagged ${escapeHtml(plan.tag)}, held outside the sales pipeline.`);\n const noteBody = noteParts.join(\"

\");\n\n const traceFields: Record = {};\n if (str(args.vapi_call_id)) traceFields[VOICE_CALL_ID_KEY] = str(args.vapi_call_id);\n if (str(args.recording_url)) traceFields[RECORDING_URL_KEY] = str(args.recording_url);\n if (str(args.transcript_url)) traceFields[TRANSCRIPT_URL_KEY] = str(args.transcript_url);\n if (str(args.walkthrough_window)) traceFields[WALKTHROUGH_KEY] = str(args.walkthrough_window);\n\n // 11.3 says only a qualified prospect opens a Deal. Everyone else who gets a contact\n // record gets an Activity against it and nothing on the board.\n if (!plan.deal) {\n await activityLog({ personId, dealId: 0, subject: `Voice call, ${str(args.disposition) || \"inbound\"}`, note: noteBody }, rid);\n await blob.setJSON(key, { status: \"done\", leadId: \"\", company, at: Date.now() } satisfies IdemRecord).catch(() => {});\n return envelope(toolCallId, {\n success: true,\n lead_id: \"\",\n company,\n next_step: \"Logged against the contact for the team. Wrap up.\",\n });\n }\n\n // 11.4. A repeat caller never produces a second Deal. The brief's edge case is a NEW\n // contact at a company that already has one open: two facility managers in the same\n // building are one opportunity, so fall back to the organization before creating.\n let prior = personId ? await latestDealFor(personId, rid) : { id: 0, state: \"none\" as DealState };\n if (prior.state === \"none\" && orgId) {\n const byOrg = await pd(\"GET\", `/api/v2/deals?org_id=${orgId}&status=open&limit=1`).catch(() => null);\n const orgDeal = byOrg?.data?.[0];\n if (orgDeal) {\n console.log(`[${rid}] new contact at an org with open deal ${orgDeal.id}`);\n prior = { id: Number(orgDeal.id), state: \"open\" };\n }\n }\n\n if (prior.state === \"open\" || prior.state === \"lost\") {\n if (prior.state === \"lost\") {\n await pd(\"PUT\", `/api/v1/deals/${prior.id}`, { status: \"open\" });\n console.log(`[${rid}] reopened closed-lost deal ${prior.id} as a re-engagement`);\n }\n // An update fills what this call improved, it never blanks what is already there.\n const refresh: Record = { ...custom, ...traceFields };\n if (Object.keys(refresh).length) await pd(\"PUT\", `/api/v1/deals/${prior.id}`, refresh);\n await activityLog({\n personId,\n dealId: prior.id,\n subject: prior.state === \"lost\" ? \"Voice call, re-engagement\" : \"Voice call, repeat caller\",\n note: noteBody,\n }, rid);\n await blob.setJSON(key, { status: \"done\", leadId: String(prior.id), company, at: Date.now() } satisfies IdemRecord).catch(() => {});\n return envelope(toolCallId, {\n success: true,\n lead_id: String(prior.id),\n company,\n duplicate: true,\n next_step: \"This caller already had one open with the team, so it went on that rather than a second one. Confirm it is in and wrap up.\",\n });\n }\n\n if (prior.state === \"won\") {\n // An existing customer is not a prospect. Never open a sales Deal against a won\n // account without a human deciding to.\n await activityLog({ personId, dealId: prior.id, subject: \"Voice call, existing customer\", note: noteBody }, rid);\n await blob.setJSON(key, { status: \"done\", leadId: String(prior.id), company, at: Date.now() } satisfies IdemRecord).catch(() => {});\n return envelope(toolCallId, {\n success: true,\n lead_id: String(prior.id),\n company,\n duplicate: true,\n next_step: \"This is an existing customer, so it went to their account rather than a new deal. Confirm it is in and wrap up.\",\n });\n }\n\n const dealBody: Record = {\n title: company,\n pipeline_id: PIPELINE_ID,\n stage_id: STAGE_ID,\n ...custom,\n ...traceFields,\n };\n if (personId) dealBody.person_id = personId;\n if (orgId) dealBody.org_id = orgId;\n const dealRes = await pd(\"POST\", \"/api/v1/deals\", dealBody);\n const dealId = String(dealRes?.data?.id ?? \"\");\n console.log(`[${rid}] deal created id=${dealId} on pipeline ${PIPELINE_ID}${isRepeat ? \" (known person, no prior deal)\" : \"\"}`);\n\n await activityLog({ personId, dealId: Number(dealId) || 0, subject: \"Voice call, new lead\", note: noteBody }, rid);\n\n await blob\n .setJSON(key, { status: \"done\", leadId: dealId, 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: dealId,\n company,\n next_step: \"The record 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\n/**\n * Vapi end-of-call-report webhook. Two jobs, both from the brief.\n *\n * 11.5 wants the recording and the transcript on the record, and neither URL exists until\n * the call is over, so they cannot be written by the agent mid-call. This finds the Deal\n * the call created, by the Voice Call ID it stamped, and fills them in.\n */\napp.post(\"/end-of-call\", async (c) => {\n const rid = crypto.randomUUID().slice(0, 8);\n const body = await c.req.json().catch(() => ({}));\n const msg = body?.message ?? {};\n if (msg.type && msg.type !== \"end-of-call-report\") return c.json({ ok: true, skipped: msg.type });\n\n const callId = str(msg?.call?.id);\n const recording = str(msg?.artifact?.recordingUrl ?? msg?.recordingUrl);\n const transcript = str(msg?.artifact?.transcriptUrl ?? msg?.transcriptUrl);\n if (!callId) return c.json({ ok: false, error: \"no call id\" });\n\n const found = await pd(\n \"GET\",\n `/api/v1/deals/search?term=${encodeURIComponent(callId)}&fields=custom_fields&exact_match=true`,\n ).catch(() => null);\n const dealId = found?.data?.items?.[0]?.item?.id;\n if (!dealId) {\n console.log(`[${rid}] end-of-call ${callId}: no deal carries this call id`);\n return c.json({ ok: true, matched: false });\n }\n\n const patch: Record = {};\n if (recording) patch[RECORDING_URL_KEY] = recording;\n if (transcript) patch[TRANSCRIPT_URL_KEY] = transcript;\n if (Object.keys(patch).length) {\n await pd(\"PUT\", `/api/v1/deals/${dealId}`, patch);\n console.log(`[${rid}] end-of-call ${callId}: deal ${dealId} traced`);\n }\n return c.json({ ok: true, matched: true, deal_id: dealId, wrote: Object.keys(patch).length });\n});\n\napp.all(\"*\", (c) => c.json({ error: \"not_found\", message: \"Unknown route.\" }, 404));\n\nexport default app.fetch;\n","deleted",false,"label",[14],"92ec675c-f85a-43ba-9573-5b35feeeb03f",["D",1788925516105],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Vapi tool endpoint writing qualified leads into Pipedrive","imageUrl","userId","019ca0d6-7e9d-7708-aea8-6df17bfdceea","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ca0d6-7e9d-7708-aea8-700f071be19f","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_100":96},"org",{"_9":10,"_94":-5,"_95":96,"_55":56,"_97":98,"_99":42},"branch",{"_35":30,"_11":85,"_22":28,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":12,"_93":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNBR2hoWFBtaWhlZUdZZlg1TnNKZ2Uwc1YyQyJ9","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_134":135,"_136":137,"_138":139,"_140":42,"_141":42,"_142":42,"_143":32,"_144":-5,"_145":-7,"_146":-7,"_147":62,"_148":42,"_149":42,"_150":-5,"_151":42,"_152":42,"_153":42,"_154":-5},"ENV",{"_105":106,"_107":108,"_109":85,"_110":111,"_112":113,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]