[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_150":151,"_152":153},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_88":-7,"_89":43,"_29":-7,"_90":-5,"_15":91,"_92":93,"_94":95,"_96":97,"_98":99,"_100":-5,"_101":-5,"_102":-5,"_103":38,"_104":105,"_106":107,"_108":-5,"_109":-5,"_110":111},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","npaige47","name","sms-daily-protocol","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":60,"_61":60,"_62":63,"_64":63,"_65":63,"_66":60,"_67":60,"_68":69,"_70":71,"_72":73,"_74":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","cb79f119-9d4c-4dba-8bdb-0ae73c9b9b12","createdAt",["D",1780934209077],"updatedAt",["D",1784045725471],"main","projectId","dcd76490-ee9b-45c1-bfe7-0f66db15598c","version",19,"forkedBranchId","forkedBranchVersion","lockfileKey","1784045726453-esm.town_v_npaige47_sms-daily-protocol@19-main","deletedAt",["D",1780934209072],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","","imageUrl","userId","5e8cb8a5-a894-4a81-803b-eea2d3b854c9","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ea7f0-bb3d-7271-a236-f7facd998c26","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_87":83},"org",{"_11":12,"_80":81,"_82":83,"_45":46,"_84":85,"_86":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_75":-5,"_76":-5,"_77":-5,"_78":14,"_79":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Nic Paige","avatar","https://lh3.googleusercontent.com/a/ACg8ocKq30DkcGgxGQD9v62G06mbqhu1l5FS7wl9bQ3pKJkbdS1P5fs=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_20":28,"_13":14,"_22":146,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":60,"_61":60,"_62":63,"_64":63,"_65":63,"_66":60,"_67":60,"_68":147,"_70":148,"_72":149,"_74":38},"tree",[141],"files",[141],"counts",{"_130":52,"_17":131,"_132":52,"_133":134,"_135":136},"contents",[112],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_20":113,"_13":114,"_115":116,"_117":-5,"_118":21,"_119":30,"_120":107,"_22":121,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_89":129},"13f35380-9e02-4afe-af89-e588e61c5520","main.ts","fileId","a8851b9a-6352-11f1-8c73-1607ee4eb77e","parentId","branchId","branchVersion","latest",["D",1784045725471],18,"fileType","http","content","/**\n * valtown-webhook.js — Cloud half of the SMS Daily Protocol.\n *\n * Deploy as a Val Town HTTP val. This is the conversation engine: it receives\n * inbound SMS from Twilio, runs the morning/evening question flow as a state\n * machine, replies with the next question in the SAME response (so the back-\n * and-forth feels like real texting), and when a flow completes it parks the\n * collected answers in Val Town's blob store for Nic's Mac to pull.\n *\n * The Mac NEVER appears here. This code cannot see Nic's vault. Its only outputs\n * are (a) reply SMS and (b) a JSON answer-bundle left in the blob store.\n *\n * ───────────────────────────────────────────────────────────────────────────\n * WHAT YOU SET IN VAL TOWN ENVIRONMENT VARIABLES (Settings → Environment):\n * TWILIO_AUTH_TOKEN - from Twilio console (used to validate request signature)\n * ALLOWED_PHONE - Nic's mobile in E.164, e.g. \"+1303...\" (sender allowlist)\n * SHARED_SECRET - any long random string; the Mac uses the same value\n * TWILIO_ACCOUNT_SID - from Twilio console (for the trigger endpoint reply, optional)\n *\n * BLOB KEYS used (Val Town std/blob):\n * sms_state - current conversation state (which phase + step + answers)\n * sms_pending_bundles - array of completed answer-bundles waiting for the Mac\n * sms_trigger_flag - set by the Mac: { morning: bool, evening: bool, date }\n * ───────────────────────────────────────────────────────────────────────────\n *\n * ENDPOINTS (single HTTP val, routed by method + path):\n * POST / ← Twilio inbound SMS webhook (set this URL on the number)\n * POST /trigger ← Mac pushes \"run morning/evening?\" flag (auth: SHARED_SECRET)\n * GET /pull ← Mac pulls pending answer-bundles (auth: SHARED_SECRET)\n * POST /kickoff ← Mac/cron asks the cloud to SEND the opener text (auth)\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// ====================== FLOW DEFINITIONS ======================\n// Each step: key (where the answer goes in the bundle), the prompt text, and a\n// parse() that turns Nic's free reply into a stored value (or null = reject).\n\nconst YES = (s) =>\n /^(y|yes|yeah|yep|yup|done|did|sure|affirm|✓|☑)/i.test(s.trim());\nconst MAYBE = (s) =>\n /^(maybe|not sure|unsure|idk|dunno|might|tbd|later|will|plan to|hope)/i.test(\n s.trim(),\n );\n\n// Checkbox steps carry `box` (the writer's bundle key) and `defer:true` so they\n// can be parked on a \"maybe\" and re-asked next protocol. Non-checkbox steps omit\n// these and can't be deferred (per design: only the y/n checkbox questions).\nconst MORNING = {\n phase: \"morning\",\n opener:\n \"Morning Nic — your Startup isn't done yet. Ready to begin? (reply YES)\",\n closer:\n \"Startup complete. Go get after it. ☀️ Today's brief: https://npaige47--a8851b9a635211f18c731607ee4eb77e.web.val.run/brief\",\n steps: [\n // bedtime/waketime questions removed 2026-07-05 (Nic doesn't use them —\n // Planning System Redesign decision #6). Sleep score alone stays.\n { key: \"sleepscore\", prompt: \"Rate your sleep, 1–5?\", parse: parse15 },\n {\n key: \"am_feeling\",\n prompt: \"How are you feeling this morning?\",\n parse: (s) => s.trim(),\n },\n {\n key: \"morning_protocol\",\n prompt: \"Did you complete your morning standards?\",\n parse: (s) => YES(s),\n defer: true,\n box: \"morning_protocol\",\n label: \"morning standards\",\n },\n {\n key: \"spiritual_alignment\",\n prompt: \"Did you meditate?\",\n parse: (s) => YES(s),\n defer: true,\n box: \"spiritual_alignment\",\n label: \"meditate\",\n },\n {\n key: \"body_training\",\n prompt: \"Did you work out?\",\n parse: (s) => YES(s),\n defer: true,\n box: \"body_training\",\n label: \"work out\",\n },\n ],\n};\n\nconst EVENING = {\n phase: \"evening\",\n opener: \"Ready for your shutdown? (reply YES)\",\n closer:\n \"Shutdown complete. Rest well. 🌙 Journal if you have time. Evening offerings: music · read · meditate · no-tech/no-decisions · walk in nature · stretch · write yourself a letter.\",\n steps: [\n {\n key: \"pm_accomplish\",\n prompt: \"What did you accomplish today?\",\n parse: (s) => s.trim(),\n },\n {\n key: \"pm_improve\",\n prompt: \"Where can you improve?\",\n parse: (s) => s.trim(),\n },\n {\n key: \"reading\",\n prompt: \"Have you / will you read today?\",\n parse: (s) => YES(s),\n defer: true,\n box: \"reading\",\n label: \"read\",\n },\n {\n key: \"writing\",\n prompt: \"Have you / will you write today?\",\n parse: (s) => YES(s),\n defer: true,\n box: \"writing\",\n label: \"write\",\n },\n {\n key: \"piano\",\n prompt: \"Have you / will you play piano today?\",\n parse: (s) => YES(s),\n defer: true,\n box: \"piano\",\n label: \"play piano\",\n },\n { key: \"rate_mood\", prompt: \"Rate your mood today, 1–5?\", parse: parse15 },\n {\n key: \"productivity\",\n prompt: \"Rate your productivity today, 1–5?\",\n parse: parse15,\n },\n // Tomorrow's one thing → written as frog:: into TOMORROW's Captain Log\n // (via a separate target_date bundle — see parkFlowBundles). Beats all\n // auto-picks in the morning brief.\n {\n key: \"frog\",\n prompt: \"🐸 Last one — what's tomorrow's ONE thing? (a task, or 'skip')\",\n parse: (s) => s.trim(),\n },\n ],\n};\n\nfunction parse15(s) {\n const m = s.trim().match(/[1-5]/);\n return m ? Number(m[0]) : null;\n}\n\n// ---- date helpers (cloud has no vault; it just needs ISO day strings) ----\n// ALWAYS Denver time. Val Town runs in UTC — a 10pm Boulder shutdown is already\n// \"tomorrow\" in UTC, which once sent the frog to the wrong day (2026-07-08).\nfunction isoDay(d) {\n return new Intl.DateTimeFormat(\"en-CA\", {\n timeZone: \"America/Denver\",\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n }).format(d);\n}\nfunction todayStr() {\n return isoDay(new Date());\n}\nfunction yesterdayStr() {\n const d = new Date();\n d.setDate(d.getDate() - 1);\n return isoDay(d);\n}\nfunction tomorrowStr() {\n const d = new Date();\n d.setDate(d.getDate() + 1);\n return isoDay(d);\n}\n\n// ====================== DEFERRED-MAYBE STORE ======================\n// Each record: { box, label, sourceDate, sourcePhase }. A morning maybe is\n// re-asked that EVENING (sourceDate === today). An evening maybe is re-asked the\n// NEXT MORNING (sourceDate === yesterday). We compute \"due\" records at kickoff.\nasync function getDeferred() {\n try {\n return (await blob.getJSON(\"sms_deferred\")) || [];\n } catch {\n return [];\n }\n}\nasync function setDeferred(arr) {\n await blob.setJSON(\"sms_deferred\", arr);\n}\n\nasync function addDeferred(rec) {\n const arr = await getDeferred();\n // de-dup on box+sourceDate so a re-run can't stack duplicates\n if (!arr.some((r) => r.box === rec.box && r.sourceDate === rec.sourceDate)) {\n arr.push(rec);\n }\n await setDeferred(arr);\n}\n\n// Records due to be re-asked now, given the phase we're starting.\n// evening → re-ask morning-maybes from TODAY. morning → re-ask evening-maybes from YESTERDAY.\nasync function dueDeferred(phase) {\n const arr = await getDeferred();\n if (phase === \"evening\") {\n return arr.filter((r) =>\n r.sourcePhase === \"morning\" && r.sourceDate === todayStr()\n );\n }\n return arr.filter((r) =>\n r.sourcePhase === \"evening\" && r.sourceDate === yesterdayStr()\n );\n}\n\nasync function removeDeferred(box, sourceDate) {\n const arr = await getDeferred();\n await setDeferred(\n arr.filter((r) => !(r.box === box && r.sourceDate === sourceDate)),\n );\n}\n\n// Build re-ask steps to prepend before the normal flow.\nfunction reaskSteps(dueRecords) {\n return dueRecords.map((r) => ({\n reask: true,\n box: r.box,\n sourceDate: r.sourceDate,\n prompt: `Quick follow-up: ${\n r.sourceDate === todayStr() ? \"earlier today\" : \"yesterday\"\n } you weren't sure — did you end up ${verb(r.label)}? (yes/no)`,\n parse: (s) => YES(s),\n }));\n}\n// turn a label into a natural verb phrase\nfunction verb(label) {\n if (label === \"morning standards\") return \"completing your morning standards\";\n if (label === \"meditate\") return \"meditating\";\n if (label === \"work out\") return \"working out\";\n if (label === \"read\") return \"reading\";\n if (label === \"write\") return \"writing\";\n if (label === \"play piano\") return \"playing piano\";\n return label;\n}\n\n// ====================== STATE HELPERS ======================\nasync function getState() {\n try {\n return await blob.getJSON(\"sms_state\");\n } catch {\n return null;\n }\n}\nasync function setState(st) {\n await blob.setJSON(\"sms_state\", st);\n}\nasync function clearState() {\n await blob.setJSON(\"sms_state\", null);\n}\n\nasync function pushBundle(bundle) {\n let arr = [];\n try {\n arr = (await blob.getJSON(\"sms_pending_bundles\")) || [];\n } catch {}\n // Unique id so the Mac can ACK exactly the bundles it successfully wrote.\n const id = `${Date.now()}-${Math.random().toString(36).slice(2, 8)}`;\n arr.push({\n ...bundle,\n id,\n complete: true,\n createdAt: new Date().toISOString(),\n });\n await blob.setJSON(\"sms_pending_bundles\", arr);\n}\n\n// ====================== TASK-CAPTURE ======================\n// Trigger: a message starting with \"add task\". Runs a small conversation:\n// capture text → resolve/confirm project → ask for date → park a task-bundle.\n// Rides the same pull+ack pipe (kind:\"task\").\n\nconst PROJECTS = [\n \"YouTube\",\n \"Writing\",\n \"Job Hunt\",\n \"OTO\",\n \"Investing\",\n \"Piano\",\n \"Rolodex\",\n \"Strength and Conditioning\",\n \"Personal\",\n];\n// fuzzy aliases → canonical\nconst PROJECT_ALIASES = {\n yt: \"YouTube\",\n youtube: \"YouTube\",\n video: \"YouTube\",\n write: \"Writing\",\n writing: \"Writing\",\n essay: \"Writing\",\n job: \"Job Hunt\",\n jobs: \"Job Hunt\",\n \"job hunt\": \"Job Hunt\",\n work: \"Job Hunt\",\n oto: \"OTO\",\n system: \"OTO\",\n vault: \"OTO\",\n invest: \"Investing\",\n investing: \"Investing\",\n money: \"Investing\",\n piano: \"Piano\",\n music: \"Piano\",\n rolodex: \"Rolodex\",\n people: \"Rolodex\",\n contacts: \"Rolodex\",\n \"s&c\": \"Strength and Conditioning\",\n strength: \"Strength and Conditioning\",\n gym: \"Strength and Conditioning\",\n lifting: \"Strength and Conditioning\",\n personal: \"Personal\",\n life: \"Personal\",\n errand: \"Personal\",\n};\nfunction matchProject(s) {\n const k = s.trim().toLowerCase();\n if (PROJECT_ALIASES[k]) return PROJECT_ALIASES[k];\n // direct (case-insensitive) match to a canonical name\n const direct = PROJECTS.find((p) => p.toLowerCase() === k);\n if (direct) return direct;\n // partial: alias key contained in the text\n for (const [alias, canon] of Object.entries(PROJECT_ALIASES)) {\n if (k.includes(alias)) return canon;\n }\n return null;\n}\n\n// Parse \"add task [project:] \" → { text, projectHint }\nfunction parseAddTask(body) {\n const stripped = body.replace(/^add\\s+task\\s*/i, \"\").trim();\n // \"youtube: thumbnail test\" form\n const m = stripped.match(/^([^:]{1,30}):\\s*(.+)$/);\n if (m) return { projectHint: m[1].trim(), text: m[2].trim() };\n return { projectHint: null, text: stripped };\n}\n\n// Date parsing for the date question.\n// weekday name → that day in the CURRENT week (week anchored Sunday, per vault).\n// \"this week\" → {thisweek:true}. \"none\"/\"no\" → {}. else null (re-ask).\nconst WEEKDAYS = [\n \"sunday\",\n \"monday\",\n \"tuesday\",\n \"wednesday\",\n \"thursday\",\n \"friday\",\n \"saturday\",\n];\nfunction parseTaskDate(s) {\n const k = s.trim().toLowerCase();\n if (/^(none|no|n|skip)$/.test(k)) return { kind: \"none\" };\n if (/next\\s*week|#?nextweek|nw/.test(k)) {\n // next week → due next Monday (Sun-anchored weeks, so Monday of next week)\n const now = new Date();\n const nextMon = new Date(now);\n nextMon.setDate(now.getDate() - now.getDay() + 8);\n return { kind: \"due\", due: isoDay(nextMon) };\n }\n if (/this\\s*week|tw|#?thisweek/.test(k)) return { kind: \"thisweek\" };\n const wd = WEEKDAYS.findIndex((d) => k.startsWith(d.slice(0, 3)));\n if (wd !== -1) {\n // date of that weekday in the current week (Sun-anchored)\n const now = new Date();\n const sunday = new Date(now);\n sunday.setDate(now.getDate() - now.getDay()); // back to Sunday\n const target = new Date(sunday);\n target.setDate(sunday.getDate() + wd);\n return { kind: \"due\", due: isoDay(target) };\n }\n return null;\n}\n\nasync function getTaskState() {\n try {\n return await blob.getJSON(\"sms_task_state\");\n } catch {\n return null;\n }\n}\nasync function setTaskState(st) {\n await blob.setJSON(\"sms_task_state\", st);\n}\nasync function clearTaskState() {\n await blob.setJSON(\"sms_task_state\", null);\n}\n\n// ====================== PLAN FLOW STATE (\"Reply PLAN\") ======================\nasync function getPlanState() {\n try {\n return await blob.getJSON(\"sms_plan_state\");\n } catch {\n return null;\n }\n}\nasync function setPlanState(st) {\n await blob.setJSON(\"sms_plan_state\", st);\n}\nasync function clearPlanState() {\n await blob.setJSON(\"sms_plan_state\", null);\n}\n\n// ====================== FLOW COMPLETION ======================\n// Splits the frog answer out of the evening bundle: frog:: belongs to\n// TOMORROW's Captain Log (own bundle w/ target_date); everything else to today.\nasync function parkFlowBundles(flow, answers) {\n const a = { ...answers };\n if (a.frog !== undefined) {\n const frog = String(a.frog || \"\").trim();\n delete a.frog;\n if (frog && !/^(skip|none|no|nothing)$/i.test(frog)) {\n await pushBundle({ phase: \"frog\", target_date: tomorrowStr(), frog });\n }\n }\n await pushBundle({ phase: flow.phase, ...a, complete: true });\n}\n\n// ====================== SHUTDOWN CHECKLIST ======================\n// Manifest items: [{ n: \"frog\"|1..5, label, file, raw }] pushed by briefBuilder.\nfunction checklistPrompt(items) {\n const lines = items.map((it) =>\n `${it.n === \"frog\" ? \"🐸\" : it.n + \".\"} ${it.label}`\n );\n return `Today's brief —\\n${\n lines.join(\"\\n\")\n }\\n\\nWhat happened? e.g. \"frog 1 done, 2 up, 5 down\" or \"none\"`;\n}\n// ---- PRIMARY PARSER: Claude API (Haiku). Reads the reply against the actual\n// numbered list — handles any phrasing (\"Frog 1 2 none, 3 4 demote, 5 promote\").\n// Returns null on any failure → regex fallback below takes over.\nasync function parseChecklistAI(body, items) {\n const key = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!key) return null;\n try {\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": key,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"claude-haiku-4-5-20251001\",\n max_tokens: 400,\n system:\n 'You are the interpreter between a person texting about their daily task list and their task system. Items are referenced by \"frog\" or number. Actions: \"done\" (completed), \"up\" (raise priority), \"down\" (lower/defer/demote). Items unmentioned or marked none/nothing/didn\\'t get NO entry. demote/defer/drop/lower=down; promote/raise/boost=up. Reply ONLY with JSON: {\"actions\":[{\"n\":\"frog\",\"action\":\"done\"}], \"reply\":\"\", \"clarify\":false}. If the message is ambiguous or you are unsure what they meant, return {\"actions\":[], \"reply\":\"\", \"clarify\":true}. Never guess.',\n messages: [{\n role: \"user\",\n content: `Task list:\\n${\n items.map((it) => `${it.n}: ${it.label}`).join(\"\\n\")\n }\\n\\nReply: \"${body}\"`,\n }],\n }),\n });\n if (!res.ok) {\n console.error(\n \"checklist AI: HTTP \" + res.status,\n await res.text().catch(() => \"\"),\n );\n return null;\n }\n const j = await res.json();\n const txt = ((j.content && j.content[0] && j.content[0].text) || \"\")\n .replace(/^```json?\\s*|\\s*```$/g, \"\").trim();\n const parsed = JSON.parse(txt);\n if (!parsed || !Array.isArray(parsed.actions)) return null;\n const out = [];\n for (const a of parsed.actions) {\n const item = items.find((it) =>\n String(it.n).toLowerCase() === String(a.n).toLowerCase()\n );\n if (item && [\"done\", \"up\", \"down\"].includes(a.action)) {\n out.push({ item, verb: a.action });\n }\n }\n console.log(\n `checklist AI: ${out.length} action(s), clarify=${!!parsed.clarify}`,\n );\n return {\n actions: out,\n reply: String(parsed.reply || \"\").trim(),\n clarify: !!parsed.clarify,\n };\n } catch (e) {\n console.error(\"checklist AI failed:\", e.message);\n return null;\n }\n}\n\n// ---- FALLBACK PARSER (regex): \"frog 1 done, 2 up, 5 down\" → actions.\n// Per-segment \"none\" understood; demote/promote vocabulary included.\nfunction parseChecklist(body, items) {\n if (/^(none|nothing|skip|no)\\b/i.test(body.trim())) return [];\n const actions = [];\n const seen = new Set();\n for (const seg of body.split(/[,;·\\n]+/)) {\n if (/\\b(none|nothing|didn'?t|skip)\\b/i.test(seg)) continue; // \"frog 1 2 none\" → no action\n const refs = [...seg.matchAll(/\\bfrog\\b|\\b[1-9]\\b/gi)].map((m) =>\n m[0].toLowerCase()\n );\n // STRICT: a segment needs an explicit verb. A bare \"2\" gets NO default —\n // that landmine once completed a task out of a message full of \"none\"s.\n const verb = /down|lower|defer|drop|demote|less|-/i.test(seg)\n ? \"down\"\n : /\\bup\\b|raise|promote|boost|more|\\+/i.test(seg)\n ? \"up\"\n : /\\bdone\\b|\\bdid\\b|finished|completed|✅|✓/i.test(seg)\n ? \"done\"\n : null;\n if (!verb) continue;\n for (const ref of refs) {\n if (seen.has(ref)) continue;\n seen.add(ref);\n const item = items.find((it) => String(it.n).toLowerCase() === ref);\n if (item) actions.push({ item, verb });\n }\n }\n return actions;\n}\n\n// ====================== TWIML / SMS REPLY ======================\nfunction twiml(message) {\n const esc = message.replace(/&/g, \"&\").replace(//g,\n \">\",\n );\n return new Response(\n `${esc}`,\n { headers: { \"Content-Type\": \"text/xml\" } },\n );\n}\nfunction twimlSilent() {\n return new Response(\n ``,\n { headers: { \"Content-Type\": \"text/xml\" } },\n );\n}\n\n// ====================== SECURITY ======================\n// 1) sender allowlist; 2) Twilio signature validation.\nasync function validateTwilio(req, bodyParams, fullUrl) {\n const token = Deno.env.get(\"TWILIO_AUTH_TOKEN\");\n const sig = req.headers.get(\"X-Twilio-Signature\");\n if (!token || !sig) return false;\n // Twilio signature = base64( HMAC-SHA1( url + sorted(key+value) , authToken ) )\n const keys = Object.keys(bodyParams).sort();\n let data = fullUrl;\n for (const k of keys) data += k + bodyParams[k];\n const enc = new TextEncoder();\n const key = await crypto.subtle.importKey(\n \"raw\",\n enc.encode(token),\n { name: \"HMAC\", hash: \"SHA-1\" },\n false,\n [\"sign\"],\n );\n const mac = await crypto.subtle.sign(\"HMAC\", key, enc.encode(data));\n const b64 = btoa(String.fromCharCode(...new Uint8Array(mac)));\n return b64 === sig;\n}\n\nfunction authOk(req) {\n const secret = Deno.env.get(\"SHARED_SECRET\");\n return secret && req.headers.get(\"X-Shared-Secret\") === secret;\n}\n\n// ====================== MAIN HANDLER ======================\nexport default async function (req) {\n const url = new URL(req.url);\n const pathName = url.pathname;\n\n // ---- Mac → cloud: set trigger flag (has Nic done startup/shutdown today?) ----\n if (req.method === \"POST\" && pathName.endsWith(\"/trigger\")) {\n if (!authOk(req)) return new Response(\"forbidden\", { status: 403 });\n const flag = await req.json();\n await blob.setJSON(\"sms_trigger_flag\", flag);\n return Response.json({ ok: true });\n }\n\n // ---- Mac → cloud: today's Remembrance block. Computed vault-side by\n // briefBuilder at 7:50 (the cloud can't read the vault) using the SAME\n // date-seed rotation as the Captain Log's dataviewjs, so text == log.\n // Body: { date: \"YYYY-MM-DD\", text: \"...\" }. Delivered after the morning YES.\n if (req.method === \"POST\" && pathName.endsWith(\"/remembrance\")) {\n if (!authOk(req)) return new Response(\"forbidden\", { status: 403 });\n await blob.setJSON(\"sms_remembrance\", await req.json());\n return Response.json({ ok: true });\n }\n\n // ---- Mac → cloud: today's brief manifest (frog + Next Up with source\n // file/line). Powers the shutdown checklist + the \"Reply PLAN\" nudge.\n // Body: { date, noPlan, items: [{ n:\"frog\"|1..5, label, file, raw }] }\n if (req.method === \"POST\" && pathName.endsWith(\"/manifest\")) {\n if (!authOk(req)) return new Response(\"forbidden\", { status: 403 });\n await blob.setJSON(\"sms_brief_manifest\", await req.json());\n return Response.json({ ok: true });\n }\n\n // ---- Phone → cloud: tappable brief link. iMessage won't linkify obsidian://\n // URIs, so the closer SMS carries this HTTPS URL and we 302-redirect into the\n // Obsidian deep link. No auth: it exposes nothing — just a bounce to a local app.\n if (req.method === \"GET\" && pathName.endsWith(\"/brief\")) {\n const target =\n \"obsidian://open?vault=Nic%27s%20Vault&file=Multi-Scale%20Planning%2FDaily%20Briefs%2FToday%27s%20Brief\";\n return new Response(null, { status: 302, headers: { Location: target } });\n }\n\n // ---- Mac → cloud: pull completed bundles. DOES NOT DELETE THEM. ----\n // Bundles stay until the Mac confirms a successful vault write via /ack.\n // This makes data loss impossible: a failed write, a phantom puller, or a\n // crash leaves the bundle in place to be re-pulled and written next time.\n if (req.method === \"GET\" && pathName.endsWith(\"/pull\")) {\n if (!authOk(req)) return new Response(\"forbidden\", { status: 403 });\n let arr = [];\n try {\n arr = (await blob.getJSON(\"sms_pending_bundles\")) || [];\n } catch {}\n return Response.json({ bundles: arr });\n }\n\n // ---- Mac → cloud: acknowledge bundles that were SUCCESSFULLY written. ----\n // Body: { ids: [\"...\",\"...\"] }. Only these are removed from the pending list.\n if (req.method === \"POST\" && pathName.endsWith(\"/ack\")) {\n if (!authOk(req)) return new Response(\"forbidden\", { status: 403 });\n const { ids } = await req.json();\n const ackSet = new Set(ids || []);\n let arr = [];\n try {\n arr = (await blob.getJSON(\"sms_pending_bundles\")) || [];\n } catch {}\n const remaining = arr.filter((b) => !ackSet.has(b.id));\n await blob.setJSON(\"sms_pending_bundles\", remaining);\n return Response.json({\n ok: true,\n acked: arr.length - remaining.length,\n remaining: remaining.length,\n });\n }\n\n // ---- cron/Mac → cloud: kick off a phase by texting Nic the opener ----\n // (Sends an outbound SMS via Twilio REST so the conversation can START.)\n if (req.method === \"POST\" && pathName.endsWith(\"/kickoff\")) {\n if (!authOk(req)) return new Response(\"forbidden\", { status: 403 });\n const { phase } = await req.json();\n const flow = phase === \"evening\" ? EVENING : MORNING;\n // Pull any deferred maybes due to be re-asked at the start of this protocol.\n const due = await dueDeferred(flow.phase);\n const reasks = reaskSteps(due);\n // Today's brief manifest (if the Mac pushed one this morning).\n let manifest = null;\n try {\n const m = await blob.getJSON(\"sms_brief_manifest\");\n if (m && m.date === todayStr()) manifest = m;\n } catch {}\n await setState({\n phase: flow.phase,\n step: -1,\n awaitingOpener: true,\n answers: {},\n reasks, // prepended steps; consumed before the normal flow\n reaskIdx: 0,\n // evening: checklist of today's brief items, asked right after YES\n checklist:\n phase === \"evening\" && manifest && manifest.items &&\n manifest.items.length\n ? manifest.items\n : null,\n // evening: candidate pool for the tomorrow's-frog menu (priority order)\n frogPool: phase === \"evening\" && manifest && manifest.items\n ? manifest.items\n : null,\n });\n let opener = flow.opener;\n if (phase === \"morning\" && manifest && manifest.noPlan) {\n opener +=\n \" (No weekly plan yet — reply PLAN anytime for the 5-minute version.)\";\n }\n await sendSms(opener);\n return Response.json({\n ok: true,\n sent: opener,\n pendingReasks: reasks.length,\n });\n }\n\n // ---- Twilio → cloud: inbound SMS (the conversation) ----\n if (req.method === \"POST\") {\n const form = await req.formData();\n const params = {};\n for (const [k, v] of form.entries()) params[k] = v;\n\n // SECURITY 1: signature\n const valid = await validateTwilio(req, params, req.url);\n if (!valid) return new Response(\"bad signature\", { status: 403 });\n // SECURITY 2: sender allowlist\n if (params.From !== Deno.env.get(\"ALLOWED_PHONE\")) return twimlSilent();\n\n const body = (params.Body || \"\").trim();\n\n // ================= TASK-CAPTURE (fire-and-forget, anytime) =================\n // Flow (2026-07-10): \"task \" → numbered project menu → this week? →\n // priority menu → written to the project's ## Tasks. Shortcut:\n // \"task : \" skips the project question. Project list comes\n // from the morning manifest (the cloud can't read the vault).\n let ts = await getTaskState();\n const dailyState = await getState(); // guard: bare \"task\" must not hijack mid-flow answers\n\n const activeProjects = async () => {\n try {\n const m = await blob.getJSON(\"sms_brief_manifest\");\n if (m && Array.isArray(m.projects) && m.projects.length) {\n return m.projects;\n }\n } catch {}\n return [\n \"YouTube\",\n \"Job Hunt\",\n \"OTO\",\n \"Money\",\n \"Personal\",\n \"Writing\",\n \"Piano\",\n \"Rolodex\",\n \"Strength and Conditioning\",\n ];\n };\n const PRIO_MENU =\n \"Priority?\\n1. 🔺 highest\\n2. ⏫ high\\n3. 🔼 medium\\n4. (none)\\n5. 🔽 low\\n6. ⏬ lowest\";\n const PRIOS = { 1: \"🔺\", 2: \"⏫\", 3: \"🔼\", 4: null, 5: \"🔽\", 6: \"⏬\" };\n const projectMenu = (projs) =>\n projs.map((p, i) => `${i + 1}. ${p}`).join(\"\\n\");\n\n // Fresh trigger: \"task ...\" (only outside an active check-in) or \"add task ...\" (always)\n const freshCapture = /^add\\s+task\\b/i.test(body) ||\n (/^task\\b/i.test(body) && (!dailyState || dailyState.step == null));\n if (freshCapture) {\n const stripped = body.replace(/^(add\\s+)?task\\s*/i, \"\").trim();\n const m = stripped.match(/^([^:]{1,30}):\\s*(.+)$/);\n const projectHint = m ? m[1].trim() : null;\n const text = m ? m[2].trim() : stripped;\n if (!text) {\n await setTaskState({ stage: \"text\" });\n return twiml(\"What's the task?\");\n }\n const matched = projectHint ? matchProject(projectHint) : null;\n if (matched) {\n await setTaskState({ stage: \"thisweek\", project: matched, text });\n return twiml(`\"${text}\" → ${matched}. This week? (yes/no)`);\n }\n const projs = await activeProjects();\n await setTaskState({ stage: \"project\", text, projects: projs });\n return twiml(`\"${text}\" — which project?\\n${projectMenu(projs)}`);\n }\n\n // stage: waiting for the task text (user sent bare \"task\")\n if (ts && ts.stage === \"text\") {\n const projs = await activeProjects();\n await setTaskState({\n stage: \"project\",\n text: body.trim(),\n projects: projs,\n });\n return twiml(`\"${body.trim()}\" — which project?\\n${projectMenu(projs)}`);\n }\n\n // stage: numbered project pick (name/alias also accepted)\n if (ts && ts.stage === \"project\") {\n const projs = ts.projects || (await activeProjects());\n const n = body.trim().match(/^(\\d{1,2})$/);\n let matched = n && projs[+n[1] - 1]\n ? projs[+n[1] - 1]\n : matchProject(body);\n if (!matched) return twiml(`Reply a number:\\n${projectMenu(projs)}`);\n ts.project = matched;\n ts.stage = \"thisweek\";\n await setTaskState(ts);\n return twiml(`→ ${matched}. This week? (yes/no)`);\n }\n\n // stage: #thisweek yes/no\n if (ts && ts.stage === \"thisweek\") {\n ts.thisweek = YES(body);\n ts.stage = \"priority\";\n await setTaskState(ts);\n return twiml(PRIO_MENU);\n }\n\n // stage: priority pick → write it\n if (ts && ts.stage === \"priority\") {\n const n = body.trim().match(/^[1-6]$/);\n const prio = n ? PRIOS[+n[0]] : null; // \"skip\"/anything else = none\n const bundle = { kind: \"task\", project: ts.project, text: ts.text };\n if (ts.thisweek) bundle.thisweek = true;\n if (prio) bundle.priority = prio;\n await pushBundle(bundle);\n await clearTaskState();\n return twiml(\n `✅ Added to ${ts.project}: \"${ts.text}\"${prio ? \" \" + prio : \"\"}${\n ts.thisweek ? \" #thisweek\" : \"\"\n }`,\n );\n }\n // =========================================================================\n\n let st = await getState();\n\n // ---- \"Reply PLAN\" — the 5-minute weekly plan, available anytime ----\n let ps = await getPlanState();\n if (ps) {\n if (ps.stage === \"lastweek\") {\n ps.lastweek = body.trim();\n ps.stage = \"focus\";\n await setPlanState(ps);\n return twiml(\"This week's Focus? (one line)\");\n }\n if (ps.stage === \"focus\") {\n ps.focus = body.trim();\n // carry-over: offer last week's intentions before asking for new ones\n let li = [];\n try {\n const m = await blob.getJSON(\"sms_brief_manifest\");\n li = (m && m.lastIntentions) || [];\n } catch {}\n if (li.length) {\n ps.stage = \"carry\";\n ps.last = li;\n await setPlanState(ps);\n return twiml(\n `Last week's intentions:\\n${\n li.map((x, i) => `${i + 1}. ${x}`).join(\"\\n\")\n }\\nCarry any into this week? (numbers like \"1 3\", or \"none\")`,\n );\n }\n ps.stage = \"intentions\";\n await setPlanState(ps);\n return twiml(\"Up to 3 intentions, separated by commas?\");\n }\n if (ps.stage === \"carry\") {\n const picks = /^(none|no|n)\\b/i.test(body.trim())\n ? []\n : [...body.matchAll(/[1-9]/g)].map((m) => ps.last[+m[0] - 1]).filter(\n Boolean,\n );\n ps.carried = picks;\n ps.stage = \"intentions\";\n await setPlanState(ps);\n const room = Math.max(0, 3 - picks.length);\n return twiml(\n picks.length\n ? `Carrying ${picks.length}. Up to ${room} NEW intention${\n room === 1 ? \"\" : \"s\"\n }, comma-separated (or \"none\")`\n : \"Up to 3 intentions, separated by commas?\",\n );\n }\n if (ps.stage === \"intentions\") {\n const fresh = /^(none|no|n)\\b/i.test(body.trim())\n ? []\n : body.split(/[,;\\n]+/).map((s) => s.trim()).filter(Boolean);\n const intentions = [...(ps.carried || []), ...fresh].slice(0, 3);\n await pushBundle({\n kind: \"weeklyplan\",\n lastweek: ps.lastweek,\n focus: ps.focus,\n intentions,\n });\n await clearPlanState();\n return twiml(\n `Weekly plan parked ✅ — ${intentions.length} intention${\n intentions.length === 1 ? \"\" : \"s\"\n }${\n (ps.carried || []).length ? ` (${ps.carried.length} carried)` : \"\"\n }. Focus: \"${ps.focus}\"`,\n );\n }\n }\n if (/^plan$/i.test(body.trim())) {\n await setPlanState({ stage: \"lastweek\" });\n return twiml(\"5-minute weekly plan. First: last week in one line?\");\n }\n\n // No active conversation: only an opener-YES can start one, and only if the\n // Mac's trigger flag says this phase still needs doing.\n if (!st || st.step == null) {\n return twiml(\n \"No active check-in. (Your startup/shutdown texts will arrive at their scheduled times.)\",\n );\n }\n\n const flow = st.phase === \"evening\" ? EVENING : MORNING;\n const reasks = st.reasks || [];\n\n // Helper: the prompt for the step at st.step. The frog step is DYNAMIC —\n // it offers the top 3 still-open items from today's manifest (already\n // priority-ranked), so choosing tomorrow's frog never invents a new task.\n // Mutates st.frogCandidates; callers must setState AFTER calling this.\n const nextPrompt = () => {\n const step = flow.steps[st.step];\n if (step && step.key === \"frog\") {\n const done = st.doneRaws || [];\n const cands = (st.frogPool || []).filter((it) => !done.includes(it.raw))\n .slice(0, 3);\n st.frogCandidates = cands;\n if (cands.length) {\n return `🐸 Last one — tomorrow's ONE thing. Reply 1-${cands.length}, or name it:\\n` +\n cands.map((c, i) => `${i + 1}. ${c.label}`).join(\"\\n\");\n }\n }\n return step.prompt;\n };\n const firstNormalPrompt = nextPrompt;\n\n // Waiting on the opener YES → then either start re-asks (if any) or the flow.\n if (st.awaitingOpener) {\n if (!YES(body)) {\n return twiml(\n `No worries — reply YES when you're ready. ${flow.opener}`,\n );\n }\n st.awaitingOpener = false;\n // Morning only: lead with today's Remembrance (pushed up by briefBuilder\n // at 7:50). Stale (yesterday's) remembrance is silently skipped.\n let pre = \"\";\n if (flow.phase === \"morning\") {\n try {\n const rem = await blob.getJSON(\"sms_remembrance\");\n if (rem && rem.date === todayStr() && rem.text) {\n pre = rem.text + \"\\n\\n\";\n }\n } catch {}\n }\n // Evening with a brief manifest → checklist question comes first.\n if (flow.phase === \"evening\" && st.checklist && st.checklist.length) {\n st.checklistPending = true;\n await setState(st);\n return twiml(pre + checklistPrompt(st.checklist));\n }\n if (reasks.length > 0) {\n st.reaskIdx = 0;\n await setState(st);\n return twiml(pre + reasks[0].prompt);\n }\n st.step = 0;\n await setState(st);\n return twiml(pre + firstNormalPrompt());\n }\n\n // ---- CHECKLIST PHASE: close out today's brief items ----\n // The AI is the intermediary: it interprets, composes the human reply, and\n // ASKS when unsure. Regex fallback is strict (explicit verbs only).\n if (st.checklistPending) {\n const ai = await parseChecklistAI(body, st.checklist || []);\n if (ai && ai.clarify) {\n await setState(st); // stay in checklist phase — ask, don't act\n return twiml(\n ai.reply ||\n \"Didn't catch that — which numbers were done, up, or down?\",\n );\n }\n const actions = ai\n ? ai.actions\n : parseChecklist(body, st.checklist || []);\n let doneCount = 0, movedCount = 0;\n st.doneRaws = st.doneRaws || [];\n for (const { item, verb } of actions) {\n if (!item.file || !item.raw) continue; // frog:: human picks carry no source line\n if (verb === \"done\") {\n await pushBundle({\n kind: \"complete\",\n file: item.file,\n raw: item.raw,\n });\n st.doneRaws.push(item.raw); // completed items leave the frog menu\n doneCount++;\n } else {\n await pushBundle({\n kind: \"reprioritize\",\n file: item.file,\n raw: item.raw,\n delta: verb === \"up\" ? 1 : -1,\n });\n movedCount++;\n }\n }\n st.checklistPending = false;\n const ack = ai && ai.reply\n ? ai.reply + \" \"\n : actions.length\n ? `Got it — ${doneCount} done, ${movedCount} moved. `\n : \"\";\n if (reasks.length > 0) {\n st.reaskIdx = 0;\n await setState(st);\n return twiml(ack + reasks[0].prompt);\n }\n st.step = 0;\n await setState(st);\n return twiml(ack + firstNormalPrompt());\n }\n\n // ---- RE-ASK PHASE: clearing yesterday's/this-morning's deferred maybes ----\n if (st.reaskIdx != null && st.reaskIdx < reasks.length) {\n const r = reasks[st.reaskIdx];\n // yes → write a dated checkbox-only bundle to the SOURCE day's note.\n if (YES(body)) {\n const dated = {\n phase: \"reask\",\n target_date: r.sourceDate,\n [r.box]: true,\n };\n await pushBundle(dated);\n }\n // anything else (no / maybe) → drop it. No second deferral (per design).\n await removeDeferred(r.box, r.sourceDate);\n st.reaskIdx += 1;\n // more re-asks?\n if (st.reaskIdx < reasks.length) {\n await setState(st);\n return twiml(reasks[st.reaskIdx].prompt);\n }\n // done re-asking → begin the normal flow\n st.step = 0;\n await setState(st);\n return twiml(firstNormalPrompt());\n }\n\n // ---- NORMAL FLOW ----\n const step = flow.steps[st.step];\n\n // Deferrable checkbox step + \"maybe\" → park it, don't check, move on.\n if (step.defer && MAYBE(body)) {\n await addDeferred({\n box: step.box,\n label: step.label,\n sourceDate: todayStr(),\n sourcePhase: flow.phase,\n });\n st.answers[step.key] = false; // leave unchecked for now\n st.step += 1;\n if (st.step < flow.steps.length) {\n const p = nextPrompt();\n await setState(st);\n return twiml(p);\n }\n await parkFlowBundles(flow, st.answers);\n await clearState();\n const note = flow.phase === \"morning\"\n ? \" I'll check back this evening on the maybes.\"\n : \" I'll check back tomorrow morning on the maybes.\";\n return twiml(flow.closer + note);\n }\n\n let value = step.parse(body);\n if (value === null || value === undefined) {\n return twiml(`Didn't catch that — ${step.prompt}`);\n }\n // Frog menu: a bare 1-3 maps to the offered candidate → the frog is always\n // a REAL task from the vault, never a newly-invented one.\n if (step.key === \"frog\" && /^[1-9]$/.test(String(value).trim())) {\n const pick = (st.frogCandidates || [])[Number(String(value).trim()) - 1];\n if (pick) value = pick.label;\n }\n st.answers[step.key] = value;\n st.step += 1;\n\n // More steps?\n if (st.step < flow.steps.length) {\n const p = nextPrompt();\n await setState(st);\n return twiml(p);\n }\n\n // Flow complete: park the bundles, clear state, send closer.\n await parkFlowBundles(flow, st.answers);\n await clearState();\n return twiml(flow.closer);\n }\n\n return new Response(\"SMS Daily Protocol webhook is live.\", { status: 200 });\n}\n\n// ====================== OUTBOUND SMS (Twilio REST) ======================\nasync function sendSms(message) {\n const sid = Deno.env.get(\"TWILIO_ACCOUNT_SID\");\n const token = Deno.env.get(\"TWILIO_AUTH_TOKEN\");\n const from = Deno.env.get(\"TWILIO_FROM\"); // your Twilio number, E.164\n const to = Deno.env.get(\"ALLOWED_PHONE\");\n if (!sid || !token || !from || !to) return;\n const creds = btoa(`${sid}:${token}`);\n await fetch(\n `https://api.twilio.com/2010-04-01/Accounts/${sid}/Messages.json`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Basic ${creds}`,\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: new URLSearchParams({ To: to, From: from, Body: message }),\n },\n );\n}","deleted","label",[114],"pulls",1,"forks","envVars",{"_137":139,"_140":52},"connections",{"_137":52,"_138":52},"count","unfilledCount",6,"emptyCount",{"_20":113,"_13":114,"_115":116,"_117":-5,"_118":21,"_119":30,"_120":107,"_22":142,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_143":144,"_89":145},["D",1784045725471],"children",[],[114],["D",1780934209072],{"_11":12,"_87":83},{"_11":12,"_80":81,"_82":83,"_45":46,"_84":85,"_86":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_75":-5,"_76":-5,"_77":-5,"_78":14,"_79":12},"ctx",{"_68":-5,"_109":183,"_184":185,"_186":187,"_188":38,"_189":38,"_190":38,"_191":107,"_192":-5,"_193":-7,"_194":-7,"_195":52,"_196":38,"_197":38,"_198":-5,"_199":38,"_200":38,"_201":38,"_202":-5},"ENV",{"_154":155,"_156":157,"_158":26,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182},"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"]

Branches1

Branches
1