[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_234":235,"_236":237},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_183":184,"_41":-7,"_185":-5,"_17":186,"_187":188,"_189":190,"_191":192,"_193":194,"_55":-5,"_195":-5,"_196":-5,"_197":24,"_198":199,"_200":143,"_201":-5,"_202":-5,"_203":204},"routes/_app.x.$handle.$name.branch.$branch.history",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5},"handle","andrewmakin","name","dm-lunch-menu","branchName","main","project",{"_35":131,"_13":14,"_39":132,"_133":-5,"_134":24,"_135":136,"_137":136,"_138":139,"_140":-5,"_25":70,"_141":65,"_142":143,"_144":-5,"_145":-5,"_146":20,"_43":44,"_147":148,"_149":150,"_151":152,"_153":-5,"_154":155,"_156":155,"_157":158,"_159":158,"_160":158,"_161":155,"_162":155,"_53":163,"_164":165,"_166":167,"_168":24},"page",0,"history",[26,27,28,29,30,31,32,33,34],"hasNext",false,"userId",{"_35":124,"_37":38,"_39":125,"_41":126,"_43":44,"_45":117,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":127,"_55":128,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":129},{"_35":117,"_37":38,"_39":118,"_41":119,"_43":44,"_45":110,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":120,"_55":121,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":122},{"_35":110,"_37":38,"_39":111,"_41":112,"_43":44,"_45":102,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":113,"_55":114,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":115},{"_35":102,"_37":38,"_39":103,"_41":104,"_43":44,"_45":95,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":105,"_55":106,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":107},{"_35":95,"_37":38,"_39":96,"_41":97,"_43":44,"_45":87,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":98,"_55":99,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":100},{"_35":87,"_37":38,"_39":88,"_41":89,"_43":44,"_45":80,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":90,"_55":91,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":92},{"_35":80,"_37":38,"_39":81,"_41":82,"_43":44,"_45":73,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":83,"_55":84,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":85},{"_35":73,"_37":38,"_39":74,"_41":75,"_43":44,"_45":36,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":76,"_55":77,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":78},{"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":54,"_55":56,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":62},"id","881c03f8-ac40-4ee7-ad22-97d66f6533aa","branchId","cbdada33-99ab-4c83-96b0-1631a34aebba","createdAt",["D",1789493264531],"version",1,"orgId","019fa9b7-7bdc-721a-8d6b-2efb7ceeed94","parentId","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_35":70,"_43":44,"_11":12,"_71":72},"file",{"_64":65,"_13":66,"_67":68,"_69":24},"pull","merge","revert","multiple","commits",[63],{"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":54,"_55":56,"_57":-5,"_58":-5,"_59":-5},"fileId","c31e58d8-b12a-11f1-a0a7-1607ee4eb77e","main.ts","fileType","script","deleted","ee122f3f-b6d2-476b-98fd-d8e094a2057f","avatar","https://avatars.githubusercontent.com/u/96471218?v=4","56fc812d-882c-44b3-89ef-e50bd3eab42b",["D",1789493406927],2,{"_35":70,"_43":44,"_11":12,"_71":72},{"_64":65,"_13":66,"_67":68,"_69":24},[79],{"_35":73,"_37":38,"_39":74,"_41":75,"_43":44,"_45":36,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":76,"_55":77,"_57":-5,"_58":-5,"_59":-5},"59562d4c-97ee-41e8-b230-71f03d6cdadd",["D",1789493683704],3,{"_35":70,"_43":44,"_11":12,"_71":72},{"_64":65,"_13":66,"_67":68,"_69":24},[86],{"_35":80,"_37":38,"_39":81,"_41":82,"_43":44,"_45":73,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":83,"_55":84,"_57":-5,"_58":-5,"_59":-5},"e7830b0e-d23c-4931-a597-7e6779a6e669",["D",1789493690283],4,{"_35":70,"_43":44,"_11":12,"_71":72},{"_64":65,"_13":66,"_67":94,"_69":24},[93],{"_35":87,"_37":38,"_39":88,"_41":89,"_43":44,"_45":80,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":90,"_55":91,"_57":-5,"_58":-5,"_59":-5},"http","3459d1b3-8286-4fcb-8ebe-099723e61aa2",["D",1789493744901],5,{"_35":70,"_43":44,"_11":12,"_71":72},{"_64":65,"_13":66,"_67":68,"_69":24},[101],{"_35":95,"_37":38,"_39":96,"_41":97,"_43":44,"_45":87,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":98,"_55":99,"_57":-5,"_58":-5,"_59":-5},"76de5db0-1c6e-4728-a24c-179fdcfadd0e",["D",1789493752426],6,{"_35":70,"_43":44,"_11":12,"_71":72},{"_64":65,"_13":66,"_67":109,"_69":24},[108],{"_35":102,"_37":38,"_39":103,"_41":104,"_43":44,"_45":95,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":105,"_55":106,"_57":-5,"_58":-5,"_59":-5},"interval","d7271bcb-c58a-4b51-acbc-a6d9e18d07bc",["D",1789494080420],7,{"_35":70,"_43":44,"_11":12,"_71":72},{"_64":65,"_13":66,"_67":68,"_69":24},[116],{"_35":110,"_37":38,"_39":111,"_41":112,"_43":44,"_45":102,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":113,"_55":114,"_57":-5,"_58":-5,"_59":-5},"0add0c89-9745-45d3-9593-a0e48eb7e93f",["D",1789494085274],8,{"_35":70,"_43":44,"_11":12,"_71":72},{"_64":65,"_13":66,"_67":94,"_69":24},[123],{"_35":117,"_37":38,"_39":118,"_41":119,"_43":44,"_45":110,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":120,"_55":121,"_57":-5,"_58":-5,"_59":-5},"5e6651f4-9716-455e-979c-24aac6715229",["D",1789494208813],9,{"_35":70,"_43":44,"_11":12,"_71":72},{"_64":65,"_13":66,"_67":94,"_69":24},[130],{"_35":124,"_37":38,"_39":125,"_41":126,"_43":44,"_45":117,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":127,"_55":128,"_57":-5,"_58":-5,"_59":-5},"e39396cf-6bb0-4576-8691-cb2de25f4eec",["D",1789493264500],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Sends my coworkers dms when a keyword appears on the menu","imageUrl","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","tursoName","e39396cf6bb045768691cb2de25f4eec","tursoHostname","e39396cf6bb045768691cb2de25f4eec-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789494690166],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_182":72},"org",{"_11":12,"_177":178,"_71":72,"_25":70,"_179":180,"_181":24},"branch",{"_41":126,"_13":16,"_35":38,"_169":131,"_170":-5,"_171":-5,"_172":-5,"_173":-5,"_174":-5,"_175":14,"_176":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Andrew Makin","tier","free","canRestrictVals","profileImageUrl","path","","adoptOrgId",{"_35":131,"_13":14,"_39":229,"_133":-5,"_134":24,"_135":136,"_137":136,"_138":139,"_140":-5,"_25":70,"_141":65,"_142":143,"_144":-5,"_145":-5,"_146":20,"_43":44,"_147":148,"_149":150,"_151":230,"_153":-5,"_154":155,"_156":155,"_157":158,"_159":158,"_160":158,"_161":155,"_162":155,"_53":231,"_164":232,"_166":233,"_168":24},"tree",[224],"files",[224],"counts",{"_214":20,"_215":42,"_216":20,"_217":218,"_219":220},"contents",[205],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_35":206,"_13":66,"_64":65,"_45":-5,"_37":38,"_207":126,"_208":143,"_39":209,"_41":119,"_67":94,"_210":211,"_69":24,"_212":-5,"_183":213},"bd76c267-3444-449a-93d4-6699ab3a31b6","branchVersion","latest",["D",1789494208813],"content","// Val Town — lunch keyword DM bot. The \"everything\" val: storage + matching.\n//\n// DMs a subscriber the afternoon BEFORE a day whose menu matches one of their\n// keywords (\"heads up, your thing is on tomorrow\"). Friday covers Monday.\n//\n// A val can only have ONE trigger, so this one is HTTP-only and a separate\n// tiny cron val (valtown-dm-cron.ts) pokes ?action=send on a schedule. That\n// keeps SQLite val-scoped here, in a single place.\n//\n// POST / -> store a subscription pushed from a Slack list workflow\n// GET / -> show what's stored (eyeball the cache in a browser)\n// ?action=send&secret=.. -> run the matcher (add &force=1 to skip the time guard)\n//\n// Setup in Val Town:\n// 1. New val -> HTTP. Paste this whole file. Note the val's URL.\n// 2. Settings -> Environment Variables:\n// SUB_WEBHOOK_SECRET = any random string you invent\n// DM_TRIGGER_URL = the Slack workflow trigger URL\n// SEND_SECRET = any random string (guards ?action=send)\n// DM_SEND_HOUR = optional, defaults to 15 (3pm Seattle)\n// 3. Create the cron val from valtown-dm-cron.ts and point it here.\n// 4. In Slack: new workflow, trigger \"When a list item is updated\" on list\n// F0C2VL3MY2U, then a \"Send a web request\" step to this val's URL with body:\n// { \"secret\": \"\", \"user\": \"{Person}\", \"keyword\": \"{Keywords}\" }\n// 5. Seed existing rows: the trigger only fires on CHANGE, so edit and re-save\n// each existing list row once to push it through.\n//\n// Reading the Slack list directly would need a `lists:read` token, which needs\n// an installed app — not available in this workspace. Hence the push model: the\n// list stays the source of truth and this table is a cache that can drift.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst ENTROPY = \"sea\";\nconst SLUG = \"anduril\";\nconst API = \"https://eat.sifted.co/api\";\n\n// Same exclusions as the channel bot, so DMs describe the same menu people see.\nconst SKIP_TYPES = [\"dressing\", \"condiment\", \"sauce\"];\n\n// ---------------------------------------------------------------- storage\n\nasync function ensureSchema(): Promise {\n // Keyed on (user_id, keyword) so a repeated push heals the row instead of\n // duplicating it.\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS subscriptions (\n user_id TEXT NOT NULL,\n keyword TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n PRIMARY KEY (user_id, keyword)\n )\n `);\n}\n\n// ---------------------------------------------------------------- menu fetch\n\n// Sifted's API intermittently 5xxes on individual day-fetches, so retry with a\n// short backoff before giving up on a day.\nasync function fetchWithRetry(url: string, attempts = 4): Promise {\n let last: Response | undefined;\n for (let i = 0; i < attempts; i++) {\n const r = await fetch(url, { headers: { Accept: \"application/json\" } });\n if (r.ok) return r;\n last = r;\n await new Promise((res) => setTimeout(res, 300 * (i + 1)));\n }\n return last as Response;\n}\n\nasync function fetchAccountId(): Promise {\n const r = await fetchWithRetry(`${API}/accounts/${ENTROPY}/${SLUG}`);\n if (!r.ok) throw new Error(`accounts ${r.status}`);\n return (await r.json()).data.id;\n}\n\nasync function fetchMenu(accountId: string, isoDate: string): Promise {\n const r = await fetchWithRetry(\n `${API}/accounts/meals?id=${accountId}&date=${isoDate}`,\n );\n if (!r.ok) throw new Error(`meals ${r.status}`);\n return (await r.json()).data;\n}\n\n// ---------------------------------------------------------------- dates (Seattle)\n\nfunction isoInSeattle(d: Date): string {\n return d.toLocaleDateString(\"en-CA\", { timeZone: \"America/Los_Angeles\" });\n}\n\nfunction weekdayInSeattle(d: Date): string {\n return d.toLocaleDateString(\"en-US\", {\n weekday: \"short\",\n timeZone: \"America/Los_Angeles\",\n });\n}\n\nfunction prettyDate(d: Date): string {\n return d.toLocaleDateString(\"en-US\", {\n weekday: \"long\",\n month: \"short\",\n day: \"numeric\",\n timeZone: \"America/Los_Angeles\",\n });\n}\n\n// The next weekday after `from`, skipping Sat/Sun. Friday lands on Monday.\nfunction nextWeekday(from: Date): Date {\n const cursor = new Date(from.getTime());\n do {\n cursor.setUTCDate(cursor.getUTCDate() + 1);\n } while ([\"Sat\", \"Sun\"].includes(weekdayInSeattle(cursor)));\n return cursor;\n}\n\n// Walk forward from `from` to the next weekday that actually HAS a menu, so a\n// holiday doesn't silently swallow the heads-up: if Monday is Labor Day, Friday\n// announces Tuesday instead. `maxDays` bounds the API calls (a week of\n// consecutive closures gives up rather than looping).\nasync function nextServedDay(\n accountId: string,\n from: Date,\n maxDays = 5,\n): Promise<{ day: Date; items: Item[]; skipped: string[] }> {\n const skipped: string[] = [];\n let cursor = from;\n for (let i = 0; i < maxDays; i++) {\n cursor = nextWeekday(cursor);\n let items: Item[];\n try {\n items = parseDay(await fetchMenu(accountId, isoInSeattle(cursor)));\n } catch (e) {\n // A fetch failure is not the same as a holiday — don't claim it's closed.\n skipped.push(`${prettyDate(cursor)} (fetch failed: ${e})`);\n continue;\n }\n if (items.length > 0) return { day: cursor, items, skipped };\n skipped.push(`${prettyDate(cursor)} (no menu — holiday?)`);\n }\n return { day: cursor, items: [], skipped };\n}\n\n// ---------------------------------------------------------------- parsing\n\nfunction titleCase(s: string): string {\n return s.toLowerCase().replace(/\\b\\w/g, (c) => c.toUpperCase());\n}\n\n// A single menu item, with every field a keyword might legitimately match.\n// Sifted spreads matchable text across FOUR places: the item name, its tags,\n// the menu name, and the brand name. Verified against live data, e.g.\n// menu \"Shadae's Soul Food\" / brand \"Cast Iron\"\n// menu \"Dominican Lunch\" / brand \"Avocado & Lime\"\ntype Item = {\n name: string;\n type: string;\n tags: string[];\n menuName: string;\n brandName: string;\n};\n\n// Item names arrive ALL CAPS and sometimes padded (\" POLLO GUISADO\",\n// \"HABICHUELAS GUISADAS (STEWED RED BEANS) \") — always trim before comparing.\nfunction parseDay(serviceLines: any[]): Item[] {\n const items: Item[] = [];\n for (const service of serviceLines ?? []) {\n for (const menu of service.menus ?? []) {\n const menuName = (menu.name ?? \"\").trim();\n const brandName = (menu.brand?.name ?? \"\").trim();\n for (const el of menu.scheduledElements ?? []) {\n const type = (el.type ?? \"\").trim();\n if (SKIP_TYPES.some((s) => type.toLowerCase().includes(s))) continue;\n items.push({\n name: (el.name ?? \"\").trim(),\n type,\n tags: (el.tags ?? []).map((t: string) => t.trim()),\n menuName,\n brandName,\n });\n }\n }\n }\n return items;\n}\n\nfunction formatDay(items: Item[], d: Date): string {\n if (items.length === 0) {\n return `🍽️ ${prettyDate(d)}\\n(No menu — weekend or holiday?)`;\n }\n const lines: string[] = [`🍽️ ${prettyDate(d)}`];\n let currentMenu = \"\";\n for (const it of items) {\n const label = `${it.menuName}${\n it.brandName ? ` — by ${it.brandName}` : \"\"\n }`;\n if (label !== currentMenu) {\n lines.push(`\\n${label}`);\n currentMenu = label;\n }\n const tagStr = it.tags.length ? ` (${it.tags.join(\", \")})` : \"\";\n lines.push(` • ${titleCase(it.name)} — ${it.type}${tagStr}`);\n }\n return lines.join(\"\\n\");\n}\n\n// ---------------------------------------------------------------- matching\n\n// Case-insensitive substring match across all four fields.\n//\n// NOTE: the list description says \"must be exact text match\", but substring is\n// what people actually expect — a \"salmon\" keyword should hit \"GRILLED SALMON\n// FILET\". To honour the stricter contract, compare the fields with === instead\n// (and update the list description to match).\nfunction matchedKeywords(item: Item, keywords: string[]): string[] {\n const haystack = [item.name, item.menuName, item.brandName, ...item.tags]\n .join(\" \")\n .toLowerCase();\n return keywords.filter((k) => haystack.includes(k.toLowerCase()));\n}\n\n// ---------------------------------------------------------------- send\n\n// The trigger requires ALL FOUR keys — omitting one returns HTTP 400\n// {\"ok\":false,\"error\":\"invalid_workflow_input\"}.\nasync function sendDm(\n triggerUrl: string,\n user: string,\n day: string,\n menu: string,\n keyword: string,\n): Promise {\n const r = await fetch(triggerUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n Day: day,\n User: user,\n Menu: menu,\n Keyword: keyword,\n }),\n });\n const text = await r.text();\n // The trigger returns ok:true even for a user ID it cannot resolve; the only\n // signal for that is an error DM to the workflow owner. A 200 here means\n // \"accepted\", NOT \"delivered\".\n if (!r.ok) throw new Error(`trigger ${r.status}: ${text}`);\n}\n\nasync function runSend(\n force: boolean,\n): Promise<{ status: string; sent: number; log: string[] }> {\n const log: string[] = [];\n const triggerUrl = Deno.env.get(\"DM_TRIGGER_URL\");\n if (!triggerUrl) throw new Error(\"DM_TRIGGER_URL not set\");\n\n const now = new Date();\n const hour = parseInt(\n now.toLocaleString(\"en-US\", {\n hour: \"numeric\",\n hour12: false,\n timeZone: \"America/Los_Angeles\",\n }),\n 10,\n );\n const weekday = weekdayInSeattle(now);\n\n // Heads-up the afternoon before, so Sun–Fri at DM_SEND_HOUR Seattle. Friday\n // covers Monday; only Saturday is idle (Sunday already covers Monday, so a\n // Saturday run would duplicate it). DST-proof via the timezone.\n const skipGuard = force || Deno.env.get(\"LUNCH_SKIP_HOUR_CHECK\") === \"1\";\n const sendHour = parseInt(Deno.env.get(\"DM_SEND_HOUR\") ?? \"15\", 10);\n if (!skipGuard && (hour !== sendHour || weekday === \"Sat\")) {\n return {\n status: `skipped — ${weekday}, hour ${hour} in Seattle`,\n sent: 0,\n log,\n };\n }\n\n const subs = await sqlite.execute(\n \"SELECT user_id, keyword FROM subscriptions\",\n );\n if (subs.rows.length === 0) {\n return { status: \"no subscriptions stored\", sent: 0, log };\n }\n\n const byUser = new Map();\n for (const row of subs.rows as any[]) {\n const userId = String(row.user_id ?? row[0]);\n const keyword = String(row.keyword ?? row[1]);\n if (!byUser.has(userId)) byUser.set(userId, []);\n byUser.get(userId)!.push(keyword);\n }\n log.push(`${byUser.size} subscriber(s), ${subs.rows.length} keyword(s)`);\n\n const accountId = await fetchAccountId();\n let sent = 0;\n\n const { day: d, items, skipped } = await nextServedDay(accountId, now);\n for (const s of skipped) log.push(`skipped ${s}`);\n if (items.length === 0) {\n return { status: `no served day found within 5 weekdays`, sent: 0, log };\n }\n\n const dayText = formatDay(items, d);\n const pretty = prettyDate(d);\n log.push(`targeting ${pretty} (${items.length} items)`);\n\n for (const [userId, keywords] of byUser) {\n // Collect the distinct keywords hitting anywhere in the day, so a\n // subscriber gets ONE DM instead of one per matching item. This matters for\n // tag keywords: \"vegan\" is on nearly every item, so per-item DMs would mean\n // ~5 messages for a single subscriber.\n const hits = new Set();\n for (const it of items) {\n for (const k of matchedKeywords(it, keywords)) hits.add(k);\n }\n if (hits.size === 0) continue;\n\n const matched = [...hits].join(\", \");\n try {\n await sendDm(triggerUrl, userId, pretty, dayText, matched);\n sent++;\n log.push(`${pretty}: DM -> ${userId} [${matched}]`);\n } catch (e) {\n // One bad recipient shouldn't stop the rest of the run.\n log.push(`${pretty}: DM -> ${userId} FAILED — ${e}`);\n }\n }\n\n return { status: \"ok\", sent, log };\n}\n\n// ---------------------------------------------------------------- store\n\nasync function handleStore(body: any): Promise {\n const secret = Deno.env.get(\"SUB_WEBHOOK_SECRET\");\n if (!secret || body.secret !== secret) {\n return Response.json({ ok: false, error: \"unauthorized\" }, { status: 401 });\n }\n\n // Slack person cells may render as \"<@U123>\" or \"<@U123|name>\" depending on\n // how the workflow interpolates the variable; keep just the bare ID.\n const raw = String(body.user ?? \"\").trim();\n const userId = raw.replace(/^<@/, \"\").replace(/\\|.*$/, \"\").replace(/>$/, \"\");\n const keyword = String(body.keyword ?? \"\").trim();\n\n if (!/^[UW][A-Z0-9]+$/.test(userId)) {\n return Response.json({ ok: false, error: \"bad_user_id\", got: raw }, {\n status: 400,\n });\n }\n if (!keyword) {\n return Response.json({ ok: false, error: \"empty_keyword\" }, {\n status: 400,\n });\n }\n\n await sqlite.execute({\n sql: `INSERT INTO subscriptions (user_id, keyword, updated_at)\n VALUES (?, ?, datetime('now'))\n ON CONFLICT (user_id, keyword) DO UPDATE SET updated_at = excluded.updated_at`,\n args: [userId, keyword],\n });\n\n return Response.json({ ok: true, user_id: userId, keyword });\n}\n\n// ---------------------------------------------------------------- entrypoint\n\n// HTTP-only: a val gets one trigger, and this one's is HTTP. The schedule lives\n// in the separate cron val, which calls ?action=send.\nexport default async function (req: Request): Promise {\n await ensureSchema();\n\n const url = new URL(req.url);\n const action = url.searchParams.get(\"action\");\n\n if (action === \"send\") {\n const sendSecret = Deno.env.get(\"SEND_SECRET\");\n if (!sendSecret || url.searchParams.get(\"secret\") !== sendSecret) {\n return Response.json({ ok: false, error: \"unauthorized\" }, {\n status: 401,\n });\n }\n // ?force=1 bypasses the Friday-noon guard for testing.\n const result = await runSend(url.searchParams.get(\"force\") === \"1\");\n return Response.json({ ok: true, ...result });\n }\n\n if (req.method === \"POST\") {\n let body: any;\n try {\n body = await req.json();\n } catch {\n return Response.json({ ok: false, error: \"invalid_json\" }, {\n status: 400,\n });\n }\n return handleStore(body);\n }\n\n // GET: show the cache. Drift from the Slack list is expected by design.\n const r = await sqlite.execute(\n \"SELECT user_id, keyword, updated_at FROM subscriptions ORDER BY user_id, keyword\",\n );\n return Response.json({ count: r.rows.length, rows: r.rows });\n}","label",[66],"pulls","branches","forks","envVars",{"_221":20,"_223":20},"connections",{"_221":20,"_222":20},"count","unfilledCount","emptyCount",{"_35":206,"_13":66,"_64":65,"_45":-5,"_37":38,"_207":126,"_208":143,"_39":225,"_41":119,"_67":94,"_210":211,"_69":24,"_212":-5,"_226":227,"_183":228},["D",1789494208813],"children",[],[66],["D",1789493264500],["D",1789494690166],{"_11":12,"_182":72},{"_11":12,"_177":178,"_71":72,"_25":70,"_179":180,"_181":24},{"_41":126,"_13":16,"_35":38,"_169":131,"_170":-5,"_171":-5,"_172":-5,"_173":-5,"_174":-5,"_175":14,"_176":12},"ctx",{"_53":-5,"_202":267,"_268":269,"_270":271,"_272":24,"_273":24,"_274":24,"_275":143,"_276":-5,"_277":-7,"_278":-7,"_279":20,"_280":24,"_281":24,"_282":-5,"_283":24,"_284":24,"_285":24,"_286":-5},"ENV",{"_238":239,"_240":241,"_242":16,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266},"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"]

History