[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_236":237,"_238":239},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_46":-7,"_187":-5,"_19":188,"_189":190,"_191":192,"_193":194,"_195":196,"_21":197,"_198":-5,"_199":-5,"_200":24,"_201":202,"_203":147,"_204":-5,"_205":-5,"_206":207},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","andrewmakin","name","dm-lunch-menu","branchName","main","path","main.ts","project",{"_40":135,"_13":14,"_44":136,"_137":-5,"_138":24,"_139":140,"_141":140,"_142":143,"_144":-5,"_30":73,"_145":69,"_146":147,"_148":-5,"_149":-5,"_150":26,"_48":49,"_151":152,"_153":154,"_155":156,"_157":-5,"_158":159,"_160":159,"_161":162,"_163":162,"_164":162,"_165":159,"_166":159,"_58":167,"_168":169,"_170":171,"_172":24},"file",{"_68":69,"_13":18,"_70":97,"_72":24,"_134":-5},"isDirectory",false,"page",0,"history",[31,32,33,34,35,36,37,38,39],"hasNext","userId",{"_40":127,"_42":43,"_44":128,"_46":129,"_48":49,"_50":120,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":130,"_21":131,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":132},{"_40":120,"_42":43,"_44":121,"_46":122,"_48":49,"_50":113,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":123,"_21":124,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":125},{"_40":113,"_42":43,"_44":114,"_46":115,"_48":49,"_50":105,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":116,"_21":117,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":118},{"_40":105,"_42":43,"_44":106,"_46":107,"_48":49,"_50":98,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":108,"_21":109,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":110},{"_40":98,"_42":43,"_44":99,"_46":100,"_48":49,"_50":90,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":101,"_21":102,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":103},{"_40":90,"_42":43,"_44":91,"_46":92,"_48":49,"_50":83,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":93,"_21":94,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":95},{"_40":83,"_42":43,"_44":84,"_46":85,"_48":49,"_50":76,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":86,"_21":87,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":88},{"_40":76,"_42":43,"_44":77,"_46":78,"_48":49,"_50":41,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":79,"_21":80,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":81},{"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":59,"_21":60,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":66},"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",{"_40":73,"_48":49,"_11":12,"_74":75},{"_68":69,"_13":18,"_70":71,"_72":24},"pull","merge","revert","multiple","commits",[67],{"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":59,"_21":60,"_61":-5,"_62":-5,"_63":-5},"fileId","c31e58d8-b12a-11f1-a0a7-1607ee4eb77e","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,{"_40":73,"_48":49,"_11":12,"_74":75},{"_68":69,"_13":18,"_70":71,"_72":24},[82],{"_40":76,"_42":43,"_44":77,"_46":78,"_48":49,"_50":41,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":79,"_21":80,"_61":-5,"_62":-5,"_63":-5},"59562d4c-97ee-41e8-b230-71f03d6cdadd",["D",1789493683704],3,{"_40":73,"_48":49,"_11":12,"_74":75},{"_68":69,"_13":18,"_70":71,"_72":24},[89],{"_40":83,"_42":43,"_44":84,"_46":85,"_48":49,"_50":76,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":86,"_21":87,"_61":-5,"_62":-5,"_63":-5},"e7830b0e-d23c-4931-a597-7e6779a6e669",["D",1789493690283],4,{"_40":73,"_48":49,"_11":12,"_74":75},{"_68":69,"_13":18,"_70":97,"_72":24},[96],{"_40":90,"_42":43,"_44":91,"_46":92,"_48":49,"_50":83,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":93,"_21":94,"_61":-5,"_62":-5,"_63":-5},"http","3459d1b3-8286-4fcb-8ebe-099723e61aa2",["D",1789493744901],5,{"_40":73,"_48":49,"_11":12,"_74":75},{"_68":69,"_13":18,"_70":71,"_72":24},[104],{"_40":98,"_42":43,"_44":99,"_46":100,"_48":49,"_50":90,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":101,"_21":102,"_61":-5,"_62":-5,"_63":-5},"76de5db0-1c6e-4728-a24c-179fdcfadd0e",["D",1789493752426],6,{"_40":73,"_48":49,"_11":12,"_74":75},{"_68":69,"_13":18,"_70":112,"_72":24},[111],{"_40":105,"_42":43,"_44":106,"_46":107,"_48":49,"_50":98,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":108,"_21":109,"_61":-5,"_62":-5,"_63":-5},"interval","d7271bcb-c58a-4b51-acbc-a6d9e18d07bc",["D",1789494080420],7,{"_40":73,"_48":49,"_11":12,"_74":75},{"_68":69,"_13":18,"_70":71,"_72":24},[119],{"_40":113,"_42":43,"_44":114,"_46":115,"_48":49,"_50":105,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":116,"_21":117,"_61":-5,"_62":-5,"_63":-5},"0add0c89-9745-45d3-9593-a0e48eb7e93f",["D",1789494085274],8,{"_40":73,"_48":49,"_11":12,"_74":75},{"_68":69,"_13":18,"_70":97,"_72":24},[126],{"_40":120,"_42":43,"_44":121,"_46":122,"_48":49,"_50":113,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":123,"_21":124,"_61":-5,"_62":-5,"_63":-5},"5e6651f4-9716-455e-979c-24aac6715229",["D",1789494208813],9,{"_40":73,"_48":49,"_11":12,"_74":75},{"_68":69,"_13":18,"_70":97,"_72":24},[133],{"_40":127,"_42":43,"_44":128,"_46":129,"_48":49,"_50":120,"_51":-5,"_52":-5,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":-5,"_58":130,"_21":131,"_61":-5,"_62":-5,"_63":-5},"deletedAtVersion","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,"_186":75},"org",{"_11":12,"_181":182,"_74":75,"_30":73,"_183":184,"_185":24},"branch",{"_46":129,"_13":16,"_40":43,"_173":135,"_174":-5,"_175":-5,"_176":-5,"_177":-5,"_178":-5,"_179":14,"_180":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Andrew Makin","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_40":135,"_13":14,"_44":231,"_137":-5,"_138":24,"_139":140,"_141":140,"_142":143,"_144":-5,"_30":73,"_145":69,"_146":147,"_148":-5,"_149":-5,"_150":26,"_48":49,"_151":152,"_153":154,"_155":232,"_157":-5,"_158":159,"_160":159,"_161":162,"_163":162,"_164":162,"_165":159,"_166":159,"_58":233,"_168":234,"_170":235,"_172":24},"tree",[226],"files",[226],"counts",{"_216":26,"_217":47,"_218":26,"_219":220,"_221":222},"contents",[],{"_40":208,"_13":18,"_68":69,"_50":-5,"_42":43,"_209":129,"_210":147,"_44":211,"_46":122,"_70":97,"_212":213,"_72":24,"_214":-5,"_17":215},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"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",[18],"pulls","branches","forks","envVars",{"_223":26,"_225":26},"connections",{"_223":26,"_224":26},"count","unfilledCount","emptyCount",{"_40":208,"_13":18,"_68":69,"_50":-5,"_42":43,"_209":129,"_210":147,"_44":227,"_46":122,"_70":97,"_212":213,"_72":24,"_214":-5,"_228":229,"_17":230},["D",1789494208813],"children",[],[18],["D",1789493264500],["D",1789494690166],{"_11":12,"_186":75},{"_11":12,"_181":182,"_74":75,"_30":73,"_183":184,"_185":24},{"_46":129,"_13":16,"_40":43,"_173":135,"_174":-5,"_175":-5,"_176":-5,"_177":-5,"_178":-5,"_179":14,"_180":12},"ctx",{"_58":-5,"_205":269,"_270":271,"_272":273,"_274":24,"_275":24,"_276":24,"_277":147,"_278":-5,"_279":-7,"_280":-7,"_281":26,"_282":24,"_283":24,"_284":-5,"_285":24,"_286":24,"_287":24,"_288":-5},"ENV",{"_240":241,"_242":243,"_244":16,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · main.ts