[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_252":253,"_254":255},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":49,"_124":125,"_126":25,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":49,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":25,"_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":49},"version",17,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",true,"deletedHere","path","frontend/components/Counter.tsx","latestPath","fileId","01a039bc-e9a8-70ef-b2b9-5ef4e29ba49e","name","Counter.tsx","fileType","script","content","/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\n\nexport function Counter() {\n const [count, setCount] = useState(0);\n return (\n

\n Clicked\n setCount((c) => c + 1)}\n class=\"bg-blue-500 hover:bg-blue-600 text-white font-medium px-4 py-2 rounded-lg transition-colors cursor-pointer\"\n >\n {count}\n \n times\n

\n );\n}\n","createdAt",["D",1787675568210],"branchVersion","branchId","ca2b6d75-11b8-4bf8-878c-dbef0cd08245","id","0753a160-c80e-414e-b313-966a3063d928","tribeca-afterhours-chat",["D",1787675076940],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","After-hours AI chat widget for tribecabeverage.com","imageUrl","c5acd3b3-60a7-4deb-bc6d-528f83012ea9","pinnedFileId","01a039bc-e9a8-70ef-b2b9-7ddecd13d603","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f8fe2-cdfc-775d-a845-a69af13d39cb","tursoName","0753a160c80e414eb313966a3063d928","tursoHostname","0753a160c80e414eb313966a3063d928-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789500689328],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":56,"_105":106,"_107":49},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",77,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Tribeca_Rep","handle","displayName","M A","avatar","https://lh3.googleusercontent.com/a/ACg8ocI9znhXn2hWp1wjjyWzeuOyoO_JrDgJo8aD0umFraR7bAG3UAmc=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":247,"_47":-5,"_48":49,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":25,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":248,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":249,"_84":250,"_86":251,"_88":49},"tree",[207,209,210,211,212,213,214,215],"files",[207,208,209,210,211,212,213,214,215],"counts",{"_197":63,"_198":181,"_199":63,"_200":201,"_202":203},"contents",[131,132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":191,"_32":192,"_30":193,"_142":-5,"_41":42,"_40":181,"_144":25,"_38":194,"_13":63,"_34":195,"_36":-5,"_24":49,"_148":-5,"_27":196},{"_43":185,"_32":186,"_30":187,"_142":-5,"_41":42,"_40":181,"_144":25,"_38":188,"_13":63,"_34":20,"_36":189,"_24":49,"_148":-5,"_27":190},{"_43":178,"_32":179,"_30":180,"_142":-5,"_41":42,"_40":181,"_144":49,"_38":182,"_13":63,"_34":20,"_36":183,"_24":49,"_148":-5,"_27":184},{"_43":171,"_32":172,"_30":173,"_142":-5,"_41":42,"_40":174,"_144":49,"_38":175,"_13":63,"_34":35,"_36":176,"_24":49,"_148":-5,"_27":177},{"_43":165,"_32":166,"_30":167,"_142":-5,"_41":42,"_40":146,"_144":49,"_38":168,"_13":63,"_34":35,"_36":169,"_24":49,"_148":-5,"_27":170},{"_43":157,"_32":158,"_30":58,"_142":-5,"_41":42,"_40":159,"_144":49,"_38":160,"_13":161,"_34":162,"_36":163,"_24":49,"_148":-5,"_27":164},{"_43":150,"_32":151,"_30":152,"_142":-5,"_41":42,"_40":153,"_144":49,"_38":154,"_13":63,"_34":35,"_36":155,"_24":49,"_148":-5,"_27":156},{"_43":139,"_32":140,"_30":141,"_142":-5,"_41":42,"_40":143,"_144":25,"_38":145,"_13":146,"_34":35,"_36":147,"_24":49,"_148":-5,"_27":149},"317aefb1-fd6e-414b-b510-5e556948c205","widget.ts","fe38147a-a0a1-11f1-88e9-1607ee4eb77e","parentId",7,"latest",["D",1787675329407],2,"// The embeddable widget, served as plain JS from GET /widget.js.\n// __BASE__ is replaced with this val's origin at serve time so the script works\n// no matter which page embeds it.\n//\n// Kept in a shadow root on purpose: WordPress themes and their plugins throw a\n// lot of global CSS around, and this has to survive all of it.\nexport const WIDGET_JS = String.raw`\n(function () {\n if (window.__tribecaAfterHours) return;\n window.__tribecaAfterHours = true;\n\n var BASE = \"__BASE__\";\n var PREVIEW = __PREVIEW__;\n var GREETING =\n \"Hi! The office is closed right now, but I can answer questions about water delivery and cooler rentals — and make sure someone follows up with you in the morning. What can I help with?\";\n\n if (PREVIEW) {\n init();\n } else {\n fetch(BASE + \"/api/status\")\n .then(function (r) { return r.json(); })\n .then(function (s) { if (s && s.bot) init(); })\n .catch(function () { /* val unreachable: show nothing, leave the page alone */ });\n }\n\n function init() {\n var sessionId = null;\n try {\n sessionId = localStorage.getItem(\"tribeca-chat-session\");\n if (!sessionId) {\n sessionId = (crypto.randomUUID && crypto.randomUUID()) ||\n String(Date.now()) + Math.random().toString(16).slice(2);\n localStorage.setItem(\"tribeca-chat-session\", sessionId);\n }\n } catch (e) {\n sessionId = String(Date.now()) + Math.random().toString(16).slice(2);\n }\n\n var host = document.createElement(\"div\");\n host.style.cssText = \"position:fixed;bottom:0;right:0;z-index:2147483000;\";\n document.body.appendChild(host);\n var root = host.attachShadow({ mode: \"open\" });\n\n var style = document.createElement(\"style\");\n style.textContent = [\n \":host,*{box-sizing:border-box}\",\n \".bubble{position:fixed;bottom:20px;right:20px;width:56px;height:56px;border-radius:50%;\",\n \"background:#0b6ab0;border:none;cursor:pointer;box-shadow:0 4px 14px rgba(0,0,0,.28);\",\n \"display:flex;align-items:center;justify-content:center;transition:transform .15s}\",\n \".bubble:hover{transform:scale(1.06)}\",\n \".bubble svg{width:26px;height:26px;fill:#fff}\",\n \".panel{position:fixed;bottom:20px;right:20px;width:360px;max-width:calc(100vw - 24px);\",\n \"height:520px;max-height:calc(100vh - 40px);background:#fff;border-radius:12px;display:none;\",\n \"flex-direction:column;overflow:hidden;box-shadow:0 10px 40px rgba(0,0,0,.3);\",\n \"font-family:-apple-system,BlinkMacSystemFont,'Segoe UI',Roboto,Helvetica,Arial,sans-serif}\",\n \".panel.open{display:flex}\",\n \".hd{background:#0b6ab0;color:#fff;padding:14px 16px;display:flex;align-items:center;justify-content:space-between}\",\n \".hd h3{margin:0;font-size:15px;font-weight:600}\",\n \".hd p{margin:2px 0 0;font-size:12px;opacity:.85}\",\n \".x{background:none;border:none;color:#fff;font-size:22px;line-height:1;cursor:pointer;padding:0 4px}\",\n \".msgs{flex:1;overflow-y:auto;padding:16px;background:#f6f8fa}\",\n \".m{margin-bottom:12px;display:flex}\",\n \".m.u{justify-content:flex-end}\",\n \".b{max-width:82%;padding:9px 13px;border-radius:14px;font-size:14px;line-height:1.45;white-space:pre-wrap;word-wrap:break-word}\",\n \".m.a .b{background:#fff;color:#1a1a1a;border:1px solid #e3e8ee;border-bottom-left-radius:4px}\",\n \".m.u .b{background:#0b6ab0;color:#fff;border-bottom-right-radius:4px}\",\n \".dots span{display:inline-block;width:6px;height:6px;margin-right:3px;border-radius:50%;\",\n \"background:#9aa5b1;animation:bl 1.2s infinite}\",\n \".dots span:nth-child(2){animation-delay:.2s}.dots span:nth-child(3){animation-delay:.4s}\",\n \"@keyframes bl{0%,60%,100%{opacity:.3}30%{opacity:1}}\",\n \".ft{border-top:1px solid #e3e8ee;padding:10px;display:flex;gap:8px;background:#fff}\",\n \".ft textarea{flex:1;resize:none;border:1px solid #d5dce4;border-radius:8px;padding:9px 11px;\",\n \"font-size:14px;font-family:inherit;height:38px;max-height:96px;outline:none}\",\n \".ft textarea:focus{border-color:#0b6ab0}\",\n \".ft button{background:#0b6ab0;color:#fff;border:none;border-radius:8px;padding:0 15px;\",\n \"font-size:14px;font-weight:500;cursor:pointer}\",\n \".ft button:disabled{background:#a9bccd;cursor:default}\",\n \".note{font-size:11px;color:#8a94a0;text-align:center;padding:0 10px 8px;background:#fff}\",\n ].join(\"\");\n root.appendChild(style);\n\n var wrap = document.createElement(\"div\");\n wrap.innerHTML = [\n '\",\n '

',\n '

TriBeCa Beverage

Office closed — automated assistant

',\n '

',\n \"

\",\n '

Answers are automated and may be wrong. The office confirms all pricing and scheduling.

',\n \"

\",\n ].join(\"\");\n root.appendChild(wrap);\n\n var bubble = root.querySelector(\".bubble\");\n var panel = root.querySelector(\".panel\");\n var msgs = root.querySelector(\".msgs\");\n var input = root.querySelector(\"textarea\");\n var send = root.querySelector(\".send\");\n var closeBtn = root.querySelector(\".x\");\n var busy = false;\n var started = false;\n\n function add(role, text) {\n var m = document.createElement(\"div\");\n m.className = \"m \" + (role === \"user\" ? \"u\" : \"a\");\n var b = document.createElement(\"div\");\n b.className = \"b\";\n b.textContent = text;\n m.appendChild(b);\n msgs.appendChild(m);\n msgs.scrollTop = msgs.scrollHeight;\n return b;\n }\n\n function open() {\n panel.classList.add(\"open\");\n bubble.style.display = \"none\";\n if (!started) { started = true; add(\"assistant\", GREETING); }\n input.focus();\n }\n function close() { panel.classList.remove(\"open\"); bubble.style.display = \"flex\"; }\n\n bubble.addEventListener(\"click\", open);\n closeBtn.addEventListener(\"click\", close);\n input.addEventListener(\"keydown\", function (e) {\n if (e.key === \"Enter\" && !e.shiftKey) { e.preventDefault(); submit(); }\n });\n input.addEventListener(\"input\", function () {\n input.style.height = \"38px\";\n input.style.height = Math.min(input.scrollHeight, 96) + \"px\";\n });\n send.addEventListener(\"click\", submit);\n\n function submit() {\n var text = input.value.trim();\n if (!text || busy) return;\n input.value = \"\";\n input.style.height = \"38px\";\n add(\"user\", text);\n busy = true;\n send.disabled = true;\n\n var typing = document.createElement(\"div\");\n typing.className = \"m a\";\n typing.innerHTML = '

';\n msgs.appendChild(typing);\n msgs.scrollTop = msgs.scrollHeight;\n\n var bubbleEl = null;\n var acc = \"\";\n function ensureBubble() {\n if (!bubbleEl) { typing.remove(); bubbleEl = add(\"assistant\", \"\"); }\n return bubbleEl;\n }\n\n fetch(BASE + \"/api/chat\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ sessionId: sessionId, message: text }),\n })\n .then(function (res) {\n if (!res.ok || !res.body) throw new Error(\"bad response\");\n var reader = res.body.getReader();\n var dec = new TextDecoder();\n var buf = \"\";\n function pump() {\n return reader.read().then(function (r) {\n if (r.done) return;\n buf += dec.decode(r.value, { stream: true });\n var parts = buf.split(\"\\n\\n\");\n buf = parts.pop();\n parts.forEach(function (chunk) {\n var line = chunk.split(\"\\n\").find(function (l) { return l.indexOf(\"data: \") === 0; });\n if (!line) return;\n var payload;\n try { payload = JSON.parse(line.slice(6)); } catch (e) { return; }\n if (payload.t) { acc += payload.t; ensureBubble().textContent = acc; msgs.scrollTop = msgs.scrollHeight; }\n if (payload.error) { ensureBubble().textContent = payload.error; }\n });\n return pump();\n });\n }\n return pump();\n })\n .catch(function () {\n ensureBubble().textContent =\n \"Sorry — I couldn't reach our system. Please call 973-913-4568 (8am‑5pm Mon‑Sat) or email info@tribecabeverage.com.\";\n })\n .then(function () {\n if (typing.parentNode) typing.remove();\n busy = false;\n send.disabled = false;\n input.focus();\n });\n }\n }\n})();\n`;\n","label",[140],"f0c13996-06b1-484f-ae02-a34290b1efb8","store.ts","c876991a-a0a1-11f1-a410-1607ee4eb77e",3,["D",1787675213815],"// Blob-backed storage. Same pattern the SMS rep val uses — low volume,\n// no schema to migrate, and transcripts stay readable as plain JSON.\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { HOURS, forceBot } from \"./config.ts\";\n\nexport type Turn = { role: \"user\" | \"assistant\"; content: string };\n\nexport type Lead = {\n sessionId: string;\n name?: string | null;\n phone?: string | null;\n email?: string | null;\n location?: string | null;\n interest?: string | null;\n firstSeen: string;\n lastSeen: string;\n notified?: boolean;\n};\n\nconst histKey = (id: string) => `afterhours-chat-history-${id}`;\nconst leadKey = (id: string) => `afterhours-chat-lead-${id}`;\nconst LEAD_PREFIX = \"afterhours-chat-lead-\";\n\nexport async function getHistory(sessionId: string): Promise {\n return (await blob.getJSON(histKey(sessionId)).catch(() => null)) ?? [];\n}\n\nexport async function saveHistory(sessionId: string, turns: Turn[], max: number) {\n const trimmed = turns.length > max ? turns.slice(turns.length - max) : turns;\n // Context has to start on a user turn.\n while (trimmed.length && trimmed[0].role !== \"user\") trimmed.shift();\n await blob.setJSON(histKey(sessionId), trimmed);\n}\n\nexport async function getLead(sessionId: string): Promise {\n return (await blob.getJSON(leadKey(sessionId)).catch(() => null)) ?? null;\n}\n\nexport async function saveLead(lead: Lead) {\n await blob.setJSON(leadKey(lead.sessionId), lead);\n}\n\nexport async function listLeads(): Promise {\n const items = await blob.list(LEAD_PREFIX);\n const leads = await Promise.all(\n items.map((i: { key: string }) => blob.getJSON(i.key).catch(() => null)),\n );\n return (leads.filter(Boolean) as Lead[]).sort((a, b) => b.lastSeen.localeCompare(a.lastSeen));\n}\n\n/** A lead is worth emailing once we can actually reach them. */\nexport function isReachable(lead: Lead | null): boolean {\n return !!(lead && (lead.phone || lead.email));\n}\n\n/** Is the office open right now? */\nexport function isOfficeOpen(now: Date = new Date()): boolean {\n const parts = Object.fromEntries(\n new Intl.DateTimeFormat(\"en-US\", {\n timeZone: HOURS.timeZone,\n weekday: \"short\",\n hour: \"2-digit\",\n hourCycle: \"h23\",\n minute: \"2-digit\",\n })\n .formatToParts(now)\n .map((p) => [p.type, p.value]),\n );\n const dayIndex = [\"Sun\", \"Mon\", \"Tue\", \"Wed\", \"Thu\", \"Fri\", \"Sat\"].indexOf(parts.weekday);\n const window = HOURS.open[dayIndex];\n if (!window) return false;\n const minutes = Number(parts.hour) * 60 + Number(parts.minute);\n return minutes >= window[0] * 60 && minutes < window[1] * 60;\n}\n\n/** The bot answers when the office is shut (or when you're testing). */\nexport function botShouldAnswer(now: Date = new Date()): boolean {\n return forceBot() || !isOfficeOpen(now);\n}\n",[151],"00004d0f-3c89-45e6-93af-a5e89ab799fb","index.ts",15,["D",1787675470435],5,"http","// After-hours AI chat for tribecabeverage.com\n//\n// tawk.to keeps the daytime. When the office is closed this answers instead,\n// captures a lead, and emails it to the office. It does NOT touch tawk.to —\n// the two never run at the same time because the widget only renders when\n// /api/status says the office is shut.\n//\n// Routes:\n// GET / install instructions + live preview of the widget\n// GET /widget.js the embeddable script (add ?preview=1 to force it open)\n// GET /api/status { open, bot } — the widget asks before rendering\n// POST /api/chat { sessionId, message } -> SSE stream of reply deltas\n// GET /leads?key= captured leads + transcripts (needs LEADS_KEY)\n//\n// Env vars (Val Town sidebar > Environment Variables):\n// ANTHROPIC_API_KEY required — from platform.claude.com\n// LEADS_KEY required to view /leads (it's PII; no key = no page)\n// NOTIFY_EMAIL optional — where lead emails go; defaults to val owner\n// FORCE_BOT optional — \"true\" makes the bot answer around the clock\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono\";\nimport { FALLBACK_REPLY, forceBot, MAX_HISTORY_MESSAGES } from \"./config.ts\";\nimport { extractLead, looksLikeContactInfo, replyStream } from \"./agent.ts\";\nimport { botShouldAnswer, getHistory, isOfficeOpen, listLeads, saveHistory, type Turn } from \"./store.ts\";\nimport { WIDGET_JS } from \"./widget.ts\";\n\nconst app = new Hono();\n\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n};\n\napp.options(\"/api/*\", (c) => new Response(null, { status: 204, headers: CORS }));\n\n// ---------------------------------------------------------------- status\napp.get(\"/api/status\", (c) =>\n new Response(JSON.stringify({ open: isOfficeOpen(), bot: botShouldAnswer() }), {\n headers: { ...CORS, \"Content-Type\": \"application/json\", \"Cache-Control\": \"no-store\" },\n }));\n\n// ---------------------------------------------------------------- widget\napp.get(\"/widget.js\", (c) => {\n const base = new URL(c.req.url).origin;\n const preview = c.req.query(\"preview\") === \"1\";\n const js = WIDGET_JS\n .replaceAll(\"__BASE__\", base)\n .replaceAll(\"__PREVIEW__\", String(preview));\n return new Response(js, {\n headers: {\n ...CORS,\n \"Content-Type\": \"application/javascript; charset=utf-8\",\n // Short cache: you'll be tweaking copy, and a stale widget is confusing.\n \"Cache-Control\": \"public, max-age=300\",\n },\n });\n});\n\n// ---------------------------------------------------------------- chat\napp.post(\"/api/chat\", async (c) => {\n let body: { sessionId?: string; message?: string };\n try {\n body = await c.req.json();\n } catch {\n return new Response(\"Bad JSON\", { status: 400, headers: CORS });\n }\n\n const sessionId = (body.sessionId ?? \"\").slice(0, 100);\n const message = (body.message ?? \"\").trim().slice(0, 2000);\n if (!sessionId || !message) return new Response(\"Missing sessionId or message\", { status: 400, headers: CORS });\n\n // Don't let the bot talk over a human who's on shift.\n if (!botShouldAnswer()) {\n return sse((send) => {\n send({ t: \"Our office is open right now — please use the chat at the bottom of the page and someone will be right with you.\" });\n });\n }\n\n const history: Turn[] = await getHistory(sessionId);\n history.push({ role: \"user\", content: message });\n\n const encoder = new TextEncoder();\n const stream = new ReadableStream({\n async start(controller) {\n const push = (obj: unknown) =>\n controller.enqueue(encoder.encode(`data: ${JSON.stringify(obj)}\\n\\n`));\n let text = \"\";\n try {\n const s = replyStream(history);\n for await (const event of s) {\n if (event.type === \"content_block_delta\" && event.delta.type === \"text_delta\") {\n text += event.delta.text;\n push({ t: event.delta.text });\n }\n }\n await s.finalMessage();\n } catch (err) {\n console.error(\"Claude call failed:\", err);\n if (!text) push({ error: FALLBACK_REPLY });\n }\n\n if (text) {\n history.push({ role: \"assistant\", content: text });\n await saveHistory(sessionId, history, MAX_HISTORY_MESSAGES);\n }\n push({ done: true });\n\n // Lead extraction runs after the visitor already has their reply, so its\n // latency is invisible. Gated so we don't bill a call on every turn.\n if (text && looksLikeContactInfo(message)) {\n try {\n await extractLead(sessionId, history);\n } catch (err) {\n console.error(\"Lead extraction failed:\", err);\n }\n }\n controller.close();\n },\n });\n\n return new Response(stream, {\n headers: {\n ...CORS,\n \"Content-Type\": \"text/event-stream; charset=utf-8\",\n \"Cache-Control\": \"no-cache, no-transform\",\n \"X-Accel-Buffering\": \"no\",\n },\n });\n});\n\nfunction sse(fill: (send: (obj: unknown) => void) => void): Response {\n const encoder = new TextEncoder();\n const stream = new ReadableStream({\n start(controller) {\n fill((obj) => controller.enqueue(encoder.encode(`data: ${JSON.stringify(obj)}\\n\\n`)));\n controller.enqueue(encoder.encode(`data: ${JSON.stringify({ done: true })}\\n\\n`));\n controller.close();\n },\n });\n return new Response(stream, {\n headers: { ...CORS, \"Content-Type\": \"text/event-stream; charset=utf-8\", \"Cache-Control\": \"no-cache\" },\n });\n}\n\n// ---------------------------------------------------------------- leads\napp.get(\"/leads\", async (c) => {\n const expected = Deno.env.get(\"LEADS_KEY\");\n if (!expected) {\n return c.text(\n \"Set a LEADS_KEY environment variable on this val, then visit /leads?key=YOUR_KEY.\\n\" +\n \"This page shows customer names, phone numbers, and chat transcripts, so it stays closed until you do.\",\n 503,\n );\n }\n if (c.req.query(\"key\") !== expected) return c.text(\"Not found\", 404);\n\n const leads = await listLeads();\n const esc = (s: unknown) =>\n String(s ?? \"-\").replace(/[&<>]/g, (m) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\" }[m]!));\n const rows = leads.map((l) =>\n \"\" +\n [l.lastSeen.replace(\"T\", \" \").slice(0, 16), l.name, l.phone, l.email, l.location, l.interest,\n l.notified ? \"sent\" : \"-\"]\n .map((v) => `${esc(v)}`).join(\"\") +\n \"\"\n ).join(\"\");\n\n return c.html(\n `After-hours leads\n\n

After-hours chat leads (${leads.length})

\n${\n leads.length\n ? `${rows}

Last seen	Name	Phone	Email	Location	Wants	Emailed

`\n : `

Nothing captured yet.

`\n }`,\n );\n});\n\n// ---------------------------------------------------------------- home\napp.get(\"/\", (c) => {\n const base = new URL(c.req.url).origin;\n const open = isOfficeOpen();\n // A testing override that's silently on is a footgun — say so loudly.\n const forced = forceBot();\n return c.html(\n `Tribeca after-hours chat\n\n\n

After-hours chat widget

Answers on tribecabeverage.com when the office is closed. The live widget is in the corner of this page →

\n${\n forced\n ? `

FORCE_BOT is on. The bot will answer during business hours too, on top of tawk.to. Fine for testing — set FORCE_BOT to false in this val's Environment Variables before you leave the widget live on the site.

`\n : \"\"\n }\n

Office right now: ${\n open ? \"OPEN — tawk.to handles it\" : \"CLOSED — bot answers\"\n }${forced ? ` bot forced on` : \"\"}

\n\n

Install

Paste this once into the site footer (WordPress: Appearance → Theme File Editor, or a \"custom HTML/scripts\" plugin):

<script src=\"${base}/widget.js\" defer></script>

It leaves tawk.to completely alone — the bubble only renders when the office is closed, so the two never appear together.

\n\n

Before it works

ANTHROPIC_API_KEY — set it in this val's Environment Variables.
LEADS_KEY — any random string; then /leads?key=… shows what's been captured.
NOTIFY_EMAIL — optional; where lead emails go. Unset means they go to the val owner.
FORCE_BOT=true — optional; makes the bot answer during business hours too, for testing.

\n\n

Hours

8am–5pm Mon–Sat, closed Sunday, America/New_York — same as the SMS rep. Change them in config.ts.

View source

\n`,\n );\n});\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\napp.onError((err) => Promise.reject(err));\n\nexport default app.fetch;\n",[158],"bee9e452-ab12-4a90-94d3-b15eb9af58a4","config.ts","c202bdca-a0a1-11f1-ac87-1607ee4eb77e",["D",1787675203026],"// ============================================================================\n// CONFIG — everything you'd want to tune lives here.\n//\n// The business profile and guardrails below are lifted from the SMS sales rep\n// val on purpose: the after-hours web chat should say exactly what the SMS rep\n// says. If you change pricing or service areas, change it in BOTH places.\n// ============================================================================\n\n/** Business hours, in America/New_York. Outside these, the bot takes over. */\nexport const HOURS = {\n timeZone: \"America/New_York\",\n // 0 = Sunday. Closed Sunday; 8am-5pm Mon-Sat.\n open: { 1: [8, 17], 2: [8, 17], 3: [8, 17], 4: [8, 17], 5: [8, 17], 6: [8, 17] } as Record<\n number,\n [number, number]\n >,\n};\n\n/** Force the bot on regardless of the clock — set env FORCE_BOT=true while testing. */\nexport const forceBot = () => Deno.env.get(\"FORCE_BOT\") === \"true\";\n\nexport const MODEL = \"claude-opus-5\";\nexport const MAX_TOKENS = 2000;\n/** Chat replies are short; low effort keeps time-to-first-token snappy. */\nexport const EFFORT = \"low\";\n/** Per-session turns kept in context. Oldest dropped first. */\nexport const MAX_HISTORY_MESSAGES = 30;\n\nexport const FALLBACK_REPLY =\n \"Sorry — I'm having a technical problem on my end. Please call the office at 973-913-4568 (8am-5pm Mon-Sat) or email info@tribecabeverage.com and we'll take care of you.\";\n\nconst BUSINESS_PROFILE = `\nBusiness name: TriBeCa Beverage Company\nWhat we do: Bottled water delivery for homes and businesses, plus water cooler\nrentals and service.\n\nProducts and services:\n - 5-gallon bottled water delivery (spring, alkaline, or distilled) —\n starting at $24.98/month, minimum 2 bottles per delivery. Orders of more\n than 8 bottles need a custom delivery schedule set up by the office.\n - 3-gallon jugs (plastic or glass)\n - 5-gallon glass bottles (spring, alkaline, distilled)\n - Name brands: Poland Spring 5-gallon; Poland Spring 16.9oz 40-packs;\n Saratoga spring/sparkling glass 28oz 12-packs; Mountain Valley\n spring/sparkling glass 1-liter 12-packs (office confirms pricing on these)\n - Water cooler rental: $8/month cold-only, $12/month hot & cold.\n Bottom-load cooler +$8/month; hot & cold top-load +$4/month.\n - Water pump: one-time $16\n - Dispenser cleaning, water filtration systems, private-label bottled water\n (office quotes these)\n\nDelivery frequency: weekly, biweekly, monthly, or every other month.\n\nService areas: NYC, Long Island, Rockland County NY; North/Central/South\nJersey and Hudson County NJ; Connecticut; Washington DC; Florida (Tampa,\nMiami, West Palm Beach, Sarasota); California (Los Angeles, Orange County).\n\nOffice / escalation contact: 973-913-4568 or info@tribecabeverage.com,\n23 Carol Street, Clifton NJ 07014. Hours 8am-5pm Monday-Saturday, closed\nSunday. Website: tribecabeverage.com\n`;\n\nexport const SYSTEM_PROMPT =\n `You are the after-hours chat assistant on tribecabeverage.com, the website for TriBeCa Beverage Company. The office is CLOSED right now — that is the whole reason you are answering instead of a person.\n\n${BUSINESS_PROFILE}\n\nYour job, in priority order:\n1. Answer the visitor's question if the profile above covers it.\n2. Get enough contact information that the office can follow up: a name, a phone number or email, and roughly where they are (town or ZIP).\n3. Set the right expectation — someone from the office will follow up the next business day (the office is open 8am-5pm Monday-Saturday, closed Sunday).\n\nStyle:\n- This is a small chat window. Keep replies to 2-4 short sentences. No markdown, no bullet lists, no headings, no emoji unless they use one first.\n- Warm and direct. Answer what was asked, then ask at most one thing back.\n- Ask for contact details naturally, once you've actually been helpful — not in your first message.\n\nHard rules — these matter more than being helpful:\n- Only quote prices that appear in the profile above. For anything without a listed price (name brands, filtration, dispenser cleaning, private label, orders over 8 bottles), say the office will confirm pricing. Never invent or estimate a number.\n- Never promise a specific delivery date, delivery window, or discount. The office confirms all scheduling.\n- You cannot place an order, change an existing order, process a payment, or cancel service. You take the details down and the office handles it. Say so plainly if asked.\n- If you don't know something, say you don't know and that the office will confirm. Do not guess.\n- If they are upset, ask for a human, or raise anything outside the profile above, give them the office number: 973-913-4568, open 8am-5pm Monday-Saturday.\n- Never claim to be a human. If asked, say you're an automated assistant and the office follows up in the morning.`;\n",[166],"cea14d3e-6069-4afe-b970-cf9def9673cf","agent.ts","df287cfa-a0a1-11f1-afef-1607ee4eb77e",4,["D",1787675251919],"import Anthropic from \"npm:@anthropic-ai/sdk\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { EFFORT, MAX_TOKENS, MODEL, SYSTEM_PROMPT } from \"./config.ts\";\nimport { getLead, isReachable, type Lead, saveLead, type Turn } from \"./store.ts\";\n\nlet _client: Anthropic | null = null;\nfunction client(): Anthropic {\n if (!_client) {\n const apiKey = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!apiKey) throw new Error(\"ANTHROPIC_API_KEY is not set on this val\");\n _client = new Anthropic({ apiKey });\n }\n return _client;\n}\n\n/**\n * Stream the assistant's reply. Returns the Anthropic stream so the caller can\n * relay deltas to the browser and still await the final message afterwards.\n */\nexport function replyStream(history: Turn[]) {\n return client().messages.stream({\n model: MODEL,\n max_tokens: MAX_TOKENS,\n // Stable prefix first so it can cache; note the minimum cacheable prefix is\n // ~1024 tokens — under that this is a no-op rather than an error.\n system: [{ type: \"text\", text: SYSTEM_PROMPT, cache_control: { type: \"ephemeral\" } }],\n thinking: { type: \"adaptive\" },\n output_config: { effort: EFFORT },\n messages: history.map((t) => ({ role: t.role, content: t.content })),\n });\n}\n\nconst EXTRACT_TOOL = {\n name: \"record_lead\",\n description:\n \"Record whatever contact details the visitor has given so far. Use null for anything they have not actually said — never guess or infer.\",\n input_schema: {\n type: \"object\" as const,\n properties: {\n name: { type: [\"string\", \"null\"], description: \"Visitor's name, if given\" },\n phone: { type: [\"string\", \"null\"], description: \"Phone number, digits as given\" },\n email: { type: [\"string\", \"null\"], description: \"Email address\" },\n location: { type: [\"string\", \"null\"], description: \"Town, city, or ZIP\" },\n interest: {\n type: [\"string\", \"null\"],\n description: \"One short line on what they want (product, quantity, cooler, problem)\",\n },\n },\n required: [\"name\", \"phone\", \"email\", \"location\", \"interest\"],\n },\n};\n\n/** Worth running an extraction pass? Cheap gate so we don't bill a call per turn. */\nexport function looksLikeContactInfo(text: string): boolean {\n return /\\d{3}|@|\\bzip\\b|\\bcall me\\b|\\bemail\\b|\\bmy name is\\b/i.test(text);\n}\n\n/**\n * Pull contact details out of the transcript and merge them into the stored\n * lead. Never clears a field we already have — visitors correct themselves, but\n * a later turn that simply doesn't mention the phone shouldn't erase it.\n */\nexport async function extractLead(sessionId: string, history: Turn[]): Promise {\n const transcript = history\n .map((t) => `${t.role === \"user\" ? \"Visitor\" : \"Assistant\"}: ${t.content}`)\n .join(\"\\n\");\n\n const res = await client().messages.create({\n model: MODEL,\n max_tokens: 1000,\n output_config: { effort: \"low\" },\n tools: [EXTRACT_TOOL],\n tool_choice: { type: \"tool\", name: \"record_lead\" },\n messages: [{\n role: \"user\",\n content:\n `Extract the visitor's contact details from this website chat transcript.\\n\\n${transcript}`,\n }],\n });\n\n const block = res.content.find((b) => b.type === \"tool_use\");\n if (!block || block.type !== \"tool_use\") return null;\n const found = block.input as Record;\n\n const now = new Date().toISOString();\n const existing = await getLead(sessionId);\n const merged: Lead = {\n sessionId,\n name: found.name ?? existing?.name ?? null,\n phone: found.phone ?? existing?.phone ?? null,\n email: found.email ?? existing?.email ?? null,\n location: found.location ?? existing?.location ?? null,\n interest: found.interest ?? existing?.interest ?? null,\n firstSeen: existing?.firstSeen ?? now,\n lastSeen: now,\n notified: existing?.notified ?? false,\n };\n await saveLead(merged);\n\n // Email the office the first time we can actually reach this person.\n if (!merged.notified && isReachable(merged)) {\n try {\n await notifyOffice(merged, transcript);\n merged.notified = true;\n await saveLead(merged);\n } catch (err) {\n // Leave notified=false so the next turn retries the send.\n console.error(\"Lead notification email failed:\", err);\n }\n }\n return merged;\n}\n\nasync function notifyOffice(lead: Lead, transcript: string) {\n const to = Deno.env.get(\"NOTIFY_EMAIL\"); // unset -> std/email defaults to the val owner\n const line = (label: string, v?: string | null) => `${label}: ${v || \"-\"}`;\n await email({\n ...(to ? { to } : {}),\n subject: `After-hours web chat lead — ${lead.name || lead.phone || lead.email || \"unknown\"}`,\n text: [\n \"Someone chatted with the after-hours assistant on tribecabeverage.com.\",\n \"\",\n line(\"Name\", lead.name),\n line(\"Phone\", lead.phone),\n line(\"Email\", lead.email),\n line(\"Location\", lead.location),\n line(\"Wants\", lead.interest),\n line(\"Started\", lead.firstSeen),\n \"\",\n \"--- transcript ---\",\n transcript,\n ].join(\"\\n\"),\n });\n}\n",[172],"5ec37cbd-809b-4d06-a911-40810dc29c4f","README.md","01a039bc-e9a8-70ef-b2b9-7a918f882bb2",1,["D",1787675076940],"# React + Hono Starter\n\nA minimal starter template for building client-side React apps with a Hono\nbackend on Val Town. Click **Remix** to get your own copy.\n\n## Picking a starter\n\n| Starter | When to pick it |\n| --- | --- |\n| [`basic-html-starter`](https://www.val.town/x/templates/basic-html-starter) | Static HTML pages. Sprinkle of vanilla JS. No server-side rendering. |\n| [`hono-jsx-starter`](https://www.val.town/x/templates/hono-jsx-starter) | Dynamic server-rendered HTML with JSX. API routes. No React, no SPA. |\n| **[`react-hono-starter`](https://www.val.town/x/templates/react-hono-starter)** *(you're here)* | Client-side React SPA with a Hono API backend. |\n\n**Want to build UI?** Start writing React components in\n[`frontend/components/`](/frontend/components/). Import them into `App.tsx` and\nyou're good to go. Styling is [Twind](https://twind.style/) — just use Tailwind\nutility classes, zero config.\n\n**Want to add an API?** Add routes in [`index.ts`](/index.ts) (there's a\ncommented-out example). Fetch them from your React components.\n\n## Architecture\n\n```mermaid\ngraph LR\n Browser -->|\"GET /\"| Hono[\"index.ts
(Hono server)\"]\n Hono -->|serves| HTML[\"root.tsx\"]\n HTML -->|loads| Entry[\"index.tsx\"]\n Entry -->|renders| App[\"App.tsx\"]\n App -->|renders| Counter[\"Counter.tsx\"]\n```\n\n## File structure\n\n```\nindex.ts ← Hono backend (serves frontend + API routes)\nfrontend/\n root.tsx ← HTML shell (stamps immutable asset URLs)\n index.tsx ← React entrypoint (mounts )\n favicon.svg ← App icon\n components/\n App.tsx ← Root component (layout + view source link)\n Counter.tsx ← Example component with state\n```\n\n## How it works\n\n1. **`index.ts`** is the HTTP entrypoint — a Hono server that serves the\n frontend and any API routes you add.\n2. **`frontend/root.tsx`** is the HTML shell — it loads Twind and stamps\n immutable asset URLs for the favicon and React entrypoint.\n3. **`frontend/index.tsx`** mounts the React app.\n4. **`frontend/components/App.tsx`** is the root layout — add new components\n alongside it.\n5. **`frontend/components/Counter.tsx`** is an example stateful component —\n replace it with your own!\n\n## Next steps\n\n- Add API routes in `index.ts`\n- Add new components in `frontend/components/`\n- Add a SQLite database — see the\n [React Hono Example](https://www.val.town/x/stevekrouse/reactHonoExample) for\n a full-stack example with database, queries, and shared types\n\nTemplate updates and upgrade paths for existing remixes: [CHANGELOG.md](/CHANGELOG.md)\n",[179],"5518f1a0-f980-467d-85ce-59331b3e55d0","CHANGELOG.md","01a039bc-e9a8-70ef-b2b9-7551e658384c",["D",1787675076940],"# Changelog\n\n## 2026-07-30 — Immutable asset caching\n\nFrontend files are now served at version-addressed URLs\n(`/__immutable/45/frontend/index.tsx`) with\n`Cache-Control: public, max-age=31536000, immutable`, so repeat visits load the\nwhole client graph from the browser cache — roughly 3× faster (~665ms → ~157ms\nmeasured). Publishing your val bumps its version, which changes every URL, so\ncaches invalidate automatically. Old-version URLs return 404 after a publish\n(like Next.js build assets); a reload picks up the new version.\n\nWhat changed in the template:\n\n- `frontend/index.html` → [`frontend/root.tsx`](/frontend/root.tsx): the HTML\n shell is now JSX and stamps asset URLs with `immutableFileUrl()`\n- [`index.ts`](/index.ts): serves `Root()` at `/`, and one\n `app.get(\"/__immutable/*\", (c) => serveImmutableFile(c.req.path))` route\n serves all frontend files\n\n### Upgrading an existing remix\n\nYour copy of this template doesn't update automatically. Two options:\n\n**Minimal (most of the benefit):** point both routes at `serveImmutableFile` —\nyour existing bare URLs redirect into versioned space, the new route serves\nthem, and the whole module graph gets cached (costs one redirect per page view):\n\n```ts\nimport { serveImmutableFile } from \"https://esm.town/v/std/utils/index.ts\";\n\napp.get(\"/__immutable/*\", (c) => serveImmutableFile(c.req.path));\napp.get(\"/frontend/**/*\", (c) => serveImmutableFile(c.req.path)); // was serveFile\n```\n\n**Full upgrade (also removes the redirect):** three self-contained steps —\nno other files needed. Adjust the ``, favicon, and body of `Root()` to\nmatch your app's existing `index.html`, and stamp anything else your shell\nreferences directly (images, css) with `immutableFileUrl()`.\n\n1. Create `frontend/root.tsx`:\n\n```tsx\n/** @jsxImportSource npm:hono@4/jsx */\nimport { raw } from \"npm:hono@4/html\";\nimport { immutableFileUrl } from \"https://esm.town/v/std/utils/index.ts\";\n\n// The HTML shell for the app. It is never cached, so immutableFileUrl can stamp\n// the current val version into each asset URL — the browser caches those\n// immutably, and publishing the val changes the URLs, refetching exactly once.\nexport function Root() {\n return (\n <>\n {raw(\"<!DOCTYPE html>\")}\n <html lang=\"en\">\n <head>\n <meta charSet=\"UTF-8\" />\n <meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\" />\n <title>React Hono Val Town Starter\n

Diff · v17