[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","tribeca_airep","name","tribeca-salesforce-agent","path","digest.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":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/tribeca_airep/tribeca-salesforce-agent/code/digest.ts","extension","id","a7586f79-5e91-48aa-8c92-37d0635a1710","fileId","72679932-ad32-11f1-8d94-1607ee4eb77e","parentId","branchId","ceda7ac1-4fbd-45e5-ab28-65082ea4218c","branchVersion",288,"latest",true,"createdAt",["D",1789217918456],"version",19,"fileType","interval","content","// The inbox digest, sent from here rather than from Apps Script.\n//\n// Runs every 15 minutes and mails whatever triage.ts has decided since the last\n// send. Living in Val Town rather than the add-on means the add-on never needs\n// permission to send mail on the office's behalf, and it means the wording can\n// be changed without touching the Apps Script editor.\n//\n// WHEN IT SENDS. Something actionable goes out on the next run, because that is\n// a customer waiting. Everything else waits until the oldest unsent item is an\n// hour old, so a quiet afternoon produces one email rather than four an hour.\n// A run with nothing pending sends nothing at all.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst HOLD_NON_URGENT_MS = 60 * 60 * 1000;\nconst MAX_ROWS = 60;\n\nfunction esc(v: unknown) {\n return String(v ?? \"\")\n .replace(/&/g, \"&\").replace(//g, \">\");\n}\n\nfunction fmt(v: unknown) {\n if (v === null || v === undefined || v === \"\") return \"(empty)\";\n if (v === true) return \"Yes\";\n if (v === false) return \"No\";\n return String(v);\n}\n\n// The mailbox these emails live in. Used to address the Gmail link by ACCOUNT\n// rather than by slot number.\nconst MAILBOX = \"info@tribecabeverage.com\";\n\nfunction threadLink(threadId: unknown) {\n if (!threadId) return null;\n // NOT /mail/u/0/. The slot number is per browser profile, not per account:\n // info@ is u/1 in one profile here and u/5 in another, so a hard-coded 0\n // opens whichever account happens to be first - someone else's inbox, or a\n // \"couldn't find that conversation\" page. authuser= names the account and\n // lets Gmail resolve the slot itself.\n return `https://mail.google.com/mail/u/?authuser=${encodeURIComponent(MAILBOX)}#all/${threadId}`;\n}\n\nfunction section(title: string, rows: any[], withActions: boolean, interactive = false) {\n if (!rows.length) return \"\";\n const colour = withActions ? \"#1a73e8\" : \"#f9ab00\";\n let html = `

${esc(title)}

`;\n for (const r of rows) {\n const link = threadLink(r.thread_id);\n const mid = esc(r.message_id);\n let recordUrl: string | null = null;\n html += `

`;\n html += `

${esc(r.account_name ?? \"(no account)\")} ${esc(r.matched_on)}

`;\n html += `

${esc(r.subject)}

`;\n if (r.summary) html += `

${esc(r.summary)}

`;\n if (withActions) {\n let actions: any[] = [];\n try {\n actions = JSON.parse(String(r.actions_json ?? \"[]\"));\n } catch { /* a malformed row should not kill the digest */ }\n // The delivery record these changes land on, so the row can link straight\n // to it. Prefer the Opportunity: an action row is nearly always about a\n // delivery, and the Account is one click from there anyway.\n recordUrl = (actions.find((a: any) => a.sobject === \"Opportunity\") ?? actions[0])?.recordUrl ?? null;\n actions.forEach((a: any, i: number) => {\n // TWO KINDS OF CHANGE ARRIVE UNTICKED.\n //\n // An assumed date, because nobody but the model chose it - that is the\n // same rule the Gmail card follows. And ending service outright, because\n // it stops every future delivery rather than the one being discussed,\n // and the difference between \"not at this time\" and \"cancel my service\"\n // is one a person should confirm. Both still show, both still explain\n // themselves; they just cannot be applied by pressing one button.\n const ending = a.field === \"Frequency__c\" && String(a.newValue) === \"Cancelled\";\n const note = a.assumed\n ? ` [date assumed]`\n : (ending ? ` [ends all future deliveries]` : \"\");\n const body = `${esc(a.label)}: ${esc(fmt(a.currentValue))} → ${esc(fmt(a.newValue))}${note}`;\n if (interactive) {\n html += `

` +\n ` ${body}

`;\n } else {\n html += `

→ ${body}

`;\n }\n });\n if (interactive && actions.length) {\n html += `

` +\n `

`;\n }\n } else if (r.needs_human) {\n html += `

${esc(r.needs_human)}

`;\n }\n // Always a new tab. From the panel, navigating away loses the ticks you had\n // already set on every other row; from the emailed digest it keeps the\n // digest open while you work through it.\n const links: string[] = [];\n if (link) links.push(`Open the email`);\n if (recordUrl) {\n links.push(`Open in Salesforce`);\n }\n if (links.length) {\n html += `

${links.join(` · `)}

`;\n }\n // THE EMAIL ITSELF, on the panel only.\n //\n // Collapsed, because the value of this page is that thirty rows can be\n // scanned at once and full bodies would destroy that. Open it when the\n // summary is not enough to judge the change - which is most of the time\n // that a proposal looks wrong. Left out of the emailed digest entirely:\n // thirty full bodies would make it enormous, and the email is a nudge to\n // come here rather than a place to work.\n if (interactive && r.body) {\n html += `

` +\n `

Read the email

` +\n `

${esc(r.body)}

` +\n `

`;\n }\n html += `

`;\n }\n return html;\n}\n\n// Only ever inlined into the panel, never into the emailed digest - a mail\n// client would strip it, and there is nothing for it to talk to from an inbox.\nconst PANEL_SCRIPT = `\n`;\n\n/** Exported so triage.ts can show the exact email without sending one. */\nexport function renderDigest(actions: any[], humans: any[], interactive = false) {\n const when = new Date().toLocaleString(\"en-US\", {\n timeZone: \"America/New_York\", hour: \"numeric\", minute: \"2-digit\", hour12: true,\n });\n // Subjects carry em dashes (every portal request does) and customer names\n // carry accents. Without this a mail client that guesses latin-1 renders them\n // as mojibake. The /digest-preview response sets the charset in its header,\n // but the emailed copy has only what is in the markup.\n let html = `` +\n `

`;\n html += `

Inbox sweep, ${esc(when)}

`;\n html += `

Unread customer mail matched to Salesforce. Nothing has been changed. ` +\n (interactive\n ? `Untick anything you disagree with, then press Apply.

`\n : `Open a message and use the Salesforce Account Lookup panel to apply anything below.

`);\n html += section(`Ready to act (${actions.length})`, actions, true, interactive);\n html += section(`Needs a person (${humans.length})`, humans, false, interactive);\n html += `

`;\n if (interactive) html += PANEL_SCRIPT;\n return html;\n}\n\n/**\n * Email content does not linger here.\n *\n * Anything inbound.ts recorded is deleted outright once it is 24 hours old.\n * The triage record is treated differently: its sender, subject, summary and\n * proposed changes are all derived from the customer's email, so those columns\n * are blanked at 24 hours too, but the message id and verdict survive to 48\n * hours so the sweep does not re-analyse something it already handled. The\n * sweep only looks back 24 hours, so nothing is lost by that.\n *\n * Runs before the enabled check, so retention happens whether or not the digest\n * is switched on.\n */\nasync function purgeOldContent() {\n const contentCutoff = Date.now() - 24 * 60 * 60 * 1000;\n const dedupeCutoff = Date.now() - 48 * 60 * 60 * 1000;\n try {\n const b = await sqlite.execute({\n sql: `UPDATE triage_v1 SET sender = NULL, subject = NULL, summary = NULL,\n needs_human = NULL, actions_json = NULL, account_name = NULL,\n body = NULL\n WHERE decided_at < ? AND subject IS NOT NULL`,\n args: [contentCutoff],\n });\n const c = await sqlite.execute({\n sql: \"DELETE FROM triage_v1 WHERE decided_at < ?\",\n args: [dedupeCutoff],\n });\n if (b.rowsAffected || c.rowsAffected) {\n console.log(`purge: ${b.rowsAffected} triage rows stripped of content, ${c.rowsAffected} dropped`);\n }\n } catch (err) {\n // A missing table on a fresh val is normal; anything else is worth seeing.\n console.log(\"purge skipped:\", String(err).slice(0, 160));\n }\n}\n\n// How long the office gets before we look. Short enough that the record has not\n// moved on for unrelated reasons, long enough that \"nobody has got to it yet\"\n// is not mistaken for \"they disagreed\".\nconst OBSERVE_AFTER_MS = 20 * 60 * 60 * 1000;\n\nconst OUTCOME_FIELDS: Record = {\n Opportunity: \"Id, CloseDate, Route_Date__c, Needs_Delivery_ASAP__c, StageName\",\n Account: \"Id, Amount_of_Bottles__c, Frequency__c, Water_Type__c, Email_Address__c, Name\",\n};\nconst OUTCOME_PERSONAL = new Set([\"Name\", \"Email_Address__c\"]);\n\nasync function hash8(v: unknown) {\n const buf = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(String(v ?? \"\")));\n return [...new Uint8Array(buf)].slice(0, 8).map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\nfunction samish(a: unknown, b: unknown) {\n // Checkboxes arrive spelled three different ways: Salesforce returns a real\n // boolean, the model proposes the string \"true\", and anything that went\n // through SQLite's json_extract comes back as \"0\"/\"1\". Comparing those\n // literally scored an untouched flag as a divergence and made\n // Needs_Delivery_ASAP__c read 0% agreement when nothing had disagreed at all.\n // Found 2026-09-12.\n const n = (v: unknown) => {\n if (v === null || v === undefined) return \"\";\n const s = typeof v === \"boolean\" ? String(v) : String(v).trim().toLowerCase();\n if (s === \"1\") return \"true\";\n if (s === \"0\") return \"false\";\n return s;\n };\n return n(a) === n(b);\n}\n\n/**\n * Look at what the office actually did with each proposal.\n *\n * AGREED the field now holds what we proposed\n * DIVERGED it holds something else, and something else changed it\n * UNTOUCHED it still holds what it held when we proposed\n *\n * This is the only way to find out whether a rule is right. It reads Salesforce\n * and writes nothing to it.\n */\nasync function observeOutcomes() {\n let rows: any[] = [];\n try {\n rows = (await sqlite.execute({\n sql: `SELECT id, sobject, record_id, field, proposed_from, proposed_to, hashed\n FROM outcome_v1 WHERE observed_at IS NULL AND proposed_at < ? LIMIT 60`,\n args: [Date.now() - OBSERVE_AFTER_MS],\n })).rows as any[];\n } catch {\n return; // table not created yet on a cold val\n }\n if (!rows.length) return;\n\n const { sfQuery } = await import(\"./salesforce.ts\");\n const byObject = new Map();\n for (const r of rows) {\n if (!OUTCOME_FIELDS[r.sobject]) continue;\n if (!byObject.has(r.sobject)) byObject.set(r.sobject, []);\n byObject.get(r.sobject)!.push(String(r.record_id));\n }\n const live: Record = {};\n for (const [sobject, ids] of byObject) {\n const uniqueIds = [...new Set(ids)].filter((id) => /^[a-zA-Z0-9]{15,18}$/.test(id));\n for (let i = 0; i < uniqueIds.length; i += 40) {\n const inList = uniqueIds.slice(i, i + 40).map((id) => `'${id}'`).join(\",\");\n const q = await sfQuery(\n `SELECT ${OUTCOME_FIELDS[sobject]}, LastModifiedBy.Name FROM ${sobject} WHERE Id IN (${inList})`,\n );\n for (const rec of q.records ?? []) live[rec.Id] = rec;\n }\n }\n\n let agreed = 0, diverged = 0, untouched = 0;\n for (const r of rows) {\n const rec = live[String(r.record_id)];\n if (!rec) continue;\n const raw = rec[r.field];\n const seen = r.hashed ? await hash8(raw) : raw;\n let verdict: string;\n if (samish(seen, r.proposed_to)) { verdict = \"agreed\"; agreed++; }\n else if (samish(seen, r.proposed_from)) { verdict = \"untouched\"; untouched++; }\n else { verdict = \"diverged\"; diverged++; }\n await sqlite.execute({\n sql: `UPDATE outcome_v1 SET observed_at = ?, observed_value = ?, observed_by = ?, verdict = ?\n WHERE id = ?`,\n args: [\n Date.now(),\n r.hashed ? String(seen) : (raw === null || raw === undefined ? null : String(raw)),\n String((rec.LastModifiedBy ?? {}).Name ?? \"\"),\n verdict,\n r.id,\n ],\n });\n }\n console.log(`outcomes: observed ${agreed + diverged + untouched} - ${agreed} agreed, ${diverged} diverged, ${untouched} untouched`);\n}\n\nexport default async function () {\n await purgeOldContent();\n try {\n await observeOutcomes();\n } catch (err) {\n // Never let measurement break the digest.\n console.log(\"outcomes skipped:\", String(err).slice(0, 160));\n }\n\n // OFF UNTIL SOMEONE SAYS OTHERWISE. Creating an interval file starts it\n // running immediately on a default schedule, so without this the first thing\n // a newly written digest does is mail the office unasked. Set the env var\n // DIGEST_ENABLED to \"true\" to start sending; everything else keeps working\n // and /triage/digest-preview still shows exactly what would go out.\n if ((Deno.env.get(\"DIGEST_ENABLED\") ?? \"\").toLowerCase() !== \"true\") {\n console.log(\"digest: disabled (set DIGEST_ENABLED=true to start sending)\");\n return;\n }\n const to = Deno.env.get(\"DIGEST_TO\") ?? \"info@tribecabeverage.com\";\n\n const pending = (await sqlite.execute({\n sql: `SELECT * FROM triage_v1 WHERE digested = 0 AND verdict IN ('action','human')\n ORDER BY decided_at ASC LIMIT ?`,\n args: [MAX_ROWS],\n })).rows as any[];\n\n if (!pending.length) {\n console.log(\"digest: nothing pending\");\n return;\n }\n\n const actions = pending.filter((r) => r.verdict === \"action\");\n const humans = pending.filter((r) => r.verdict === \"human\");\n const oldest = Math.min(...pending.map((r) => Number(r.decided_at) || Date.now()));\n const stale = Date.now() - oldest > HOLD_NON_URGENT_MS;\n\n if (!actions.length && !stale) {\n console.log(`digest: holding ${humans.length} non-urgent, oldest ${Math.round((Date.now() - oldest) / 60000)} min`);\n return;\n }\n\n const html = renderDigest(actions, humans);\n\n await email({\n to,\n subject: `Inbox sweep — ${actions.length} to act on, ${humans.length} to read`,\n html,\n text: `${actions.length} ready to act, ${humans.length} need a person. Open the HTML version.`,\n });\n\n await sqlite.batch(\n pending.map((r) => ({\n sql: \"UPDATE triage_v1 SET digested = 1 WHERE message_id = ?\",\n args: [r.message_id],\n })),\n );\n\n console.log(`digest: sent ${actions.length} action, ${humans.length} human to ${to}`);\n}\n","deleted",false,"label",[14],"0979b5fe-99f9-4673-be24-063bb9928dc3",["D",1785197056244],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Read-only Salesforce Account/Opportunity API access","imageUrl","userId","c5acd3b3-60a7-4deb-bc6d-528f83012ea9","pinnedFileId","6093920c-8a18-11f1-a4ec-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f8fe3-60c5-70ee-a317-3aded0417f73","tursoName","0979b5fe99f94673be24063bb9928dc3","tursoHostname","0979b5fe99f94673be24063bb9928dc3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789491713377],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":-5},"org",{"_9":10,"_99":100,"_101":-5,"_55":-5,"_102":103,"_104":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",290,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Tribeca_AIrep","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":63,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":90,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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"]