[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_166":167,"_168":169},"routes/_app.x.$handle.$name",{"_95":94,"_32":44,"_103":85,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":26,"_118":119,"_120":24,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":24,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":26},"version",22,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":26,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":26},"previous","deleted",true,"deletedHere",false,"path","scratch-grades.ts","latestPath","fileId","b8a82620-ae39-11f1-a7b3-1607ee4eb77e","name","fileType","script","content","const TOKEN = Deno.env.get(\"PIPEDRIVE_API_TOKEN\")!;\nconst DOMAIN = Deno.env.get(\"PIPEDRIVE_COMPANY_DOMAIN\")!;\nconst URGENCY = \"bb095b39b9baf920de6ecba2a7ca02598a41ec84\";\nconst TIMELINE = \"082013c8e57292129ddc2243b3f3d9e37cc94ac0\";\nconst LABEL: Record = { 81: \"Hot\", 82: \"Standard\", 83: \"Low\" };\n\nconst res = await fetch(`https://${DOMAIN}.pipedrive.com/api/v1/leads?limit=100`, {\n headers: { \"x-api-token\": TOKEN, accept: \"application/json\" },\n});\nconst json = await res.json();\nfor (const l of (json?.data ?? [])) {\n const t = String(l.title ?? \"\");\n if (!t.startsWith(\"Grade \")) continue;\n console.log(`${t} urgency=${LABEL[l[URGENCY]] ?? l[URGENCY] ?? \"(blank)\"} timelineOpt=${l[TIMELINE] ?? \"-\"}`);\n}\n","createdAt",["D",1789169835931],"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","deba10f2-ac00-11f1-8495-1607ee4eb77e","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",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":54,"_99":100,"_101":26},"branch",{"_13":84,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"isOwned",51,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","veltson","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNBR2hoWFBtaWhlZUdZZlg1TnNKZ2Uwc1YyQyJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":162,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":24,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":163,"_79":164,"_81":165,"_83":26},"tree",[153,154],"files",[153,154],"counts",{"_141":61,"_142":143,"_144":61,"_145":146,"_147":148},"contents",[125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":133,"_32":134,"_30":56,"_128":-5,"_40":41,"_39":135,"_129":26,"_37":136,"_13":137,"_33":138,"_35":139,"_23":26,"_131":-5,"_27":140},{"_42":127,"_32":28,"_30":31,"_128":-5,"_40":41,"_39":14,"_129":26,"_37":130,"_13":61,"_33":34,"_35":36,"_23":26,"_131":-5,"_27":132},"2f765927-0e9b-4f17-83cd-dbd47b698eee","parentId","latest",["D",1789169835931],"label",[28],"097b23f6-9045-45f6-88e3-e87073bb31a2","main.ts",21,["D",1789169788688],17,"http","/**\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 \"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 // Calls that are not leads arrive without one, and searching on an empty term\n // matches the first person in the account, so fall back to the phone instead.\n const term = args.email || args.phone || \"\";\n const fields = args.email ? \"email,custom_fields,name\" : \"phone,custom_fields,name\";\n if (term) {\n const search = await pd(\n \"GET\",\n `/api/v2/persons/search?term=${encodeURIComponent(term)}&fields=${encodeURIComponent(fields)}`,\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 }\n const body: Record = {\n name: args.name || args.email || \"Unnamed caller\",\n org_id: args.orgId,\n };\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 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 // 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};\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 [\"email\", \"email address\"],\n [\"phone\", \"phone number\"],\n [\"service_market\", \"service market\"],\n [\"facility_type\", \"facility type\"],\n [\"service_type\", \"service type\"],\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(\"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 * 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 */\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(args.timeline);\n const decision = norm(args.decision_role);\n const situation = norm(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\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\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 required = requiredFor(str(args.disposition));\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 // 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 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 // free-text customs, no option matching needed\n const WALKTHROUGH_KEY = \"29bd9c6cc3b9e3afd4d4fe27fb06e6bfa380aac3\";\n const CALL_ID_KEY = \"05745c9e083399a6a4f08183be3f6af61504211c\";\n if (str(args.walkthrough_window)) leadBody[WALKTHROUGH_KEY] = str(args.walkthrough_window);\n if (str(args.vapi_call_id)) leadBody[CALL_ID_KEY] = str(args.vapi_call_id);\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\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 ];\n const carried = CARRIED\n .map(([label, key]) => [label, str((args as Record)[key])] as const)\n .filter(([, v]) => v);\n if (carried.length) {\n noteParts.push(\n `From the call:
${carried.map(([l, v]) => `${escapeHtml(l)}: ${escapeHtml(v)}`).join(\"
\")}`,\n );\n }\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 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\napp.all(\"*\", (c) => c.json({ error: \"not_found\", message: \"Unknown route.\" }, 404));\n\nexport default app.fetch;\n",[134],"pulls","branches",1,"forks","envVars",{"_149":151,"_152":61},"connections",{"_149":61,"_150":61},"count","unfilledCount",3,"emptyCount",{"_42":133,"_32":134,"_30":56,"_128":-5,"_40":41,"_39":135,"_129":26,"_37":159,"_13":137,"_33":138,"_35":139,"_23":26,"_131":-5,"_156":160,"_27":161},{"_42":127,"_32":28,"_30":31,"_128":-5,"_40":41,"_39":14,"_129":26,"_37":155,"_13":61,"_33":34,"_35":36,"_23":26,"_131":-5,"_156":157,"_27":158},["D",1789169835931],"children",[],[28],["D",1789169788688],[],[134],["D",1788925516105],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":54,"_99":100,"_101":26},{"_13":84,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_77":-5,"_122":199,"_200":201,"_202":203,"_204":26,"_205":26,"_206":26,"_207":24,"_208":-5,"_209":-7,"_210":-7,"_211":61,"_212":26,"_213":26,"_214":-5,"_215":26,"_216":26,"_217":26,"_218":-5},"ENV",{"_170":171,"_172":173,"_174":85,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v22