[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_120":-5,"_20":121,"_22":122,"_123":124,"_125":126,"_25":127,"_24":-5,"_128":-5,"_129":-5,"_130":53,"_131":132,"_133":44,"_134":-5,"_135":-5,"_136":137},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","andrewmakin","name","dm-lunch-menu","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":37,"_74":44,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":82,"_83":84,"_85":86,"_87":-5,"_88":89,"_90":89,"_91":92,"_93":92,"_94":92,"_95":89,"_96":89,"_97":98,"_99":100,"_101":102,"_103":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","bd76c267-3444-449a-93d4-6699ab3a31b6","main.ts","fileId","c31e58d8-b12a-11f1-a0a7-1607ee4eb77e","parentId","branchId","cbdada33-99ab-4c83-96b0-1631a34aebba","branchVersion",9,"latest",true,"createdAt",["D",1789494208813],8,"fileType","http","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}","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1789494208813],"children",[],[35],"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","userId","ee122f3f-b6d2-476b-98fd-d8e094a2057f","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019fa9b7-7bdc-721a-8d6b-2efb7ceeed94","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","user",{"_11":12,"_119":115},"org",{"_11":12,"_112":113,"_114":115,"_71":72,"_116":117,"_118":53},"branch",{"_17":42,"_13":16,"_33":40,"_104":61,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":-5,"_110":14,"_111":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Andrew Makin","avatar","https://avatars.githubusercontent.com/u/96471218?v=4","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":153,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":37,"_74":44,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":82,"_83":84,"_85":154,"_87":-5,"_88":89,"_90":89,"_91":92,"_93":92,"_94":92,"_95":89,"_96":89,"_97":155,"_99":156,"_101":157,"_103":53},[150],"files",[150],"counts",{"_140":78,"_141":142,"_143":78,"_31":144,"_145":146},[138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":139},[35],"pulls","branches",1,"forks",{"_147":78,"_149":78},"connections",{"_147":78,"_148":78},"count","unfilledCount","emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":151,"_18":152},[],[35],["D",1789493264500],["D",1789494690166],{"_11":12,"_119":115},{"_11":12,"_112":113,"_114":115,"_71":72,"_116":117,"_118":53},{"_17":42,"_13":16,"_33":40,"_104":61,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":-5,"_110":14,"_111":12},"ctx",{"_97":-5,"_135":191,"_192":193,"_194":195,"_196":53,"_197":53,"_198":53,"_199":44,"_200":-5,"_201":-7,"_202":-7,"_203":78,"_204":53,"_205":53,"_206":-5,"_207":53,"_208":53,"_209":53,"_210":-5},"ENV",{"_162":163,"_164":165,"_166":16,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"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"]

Code