[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_159":160,"_161":162},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_108":89,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":25,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",5,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":37,"_35":36,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","c31e58d8-b12a-11f1-a0a7-1607ee4eb77e","name","fileType","http","content","// Val Town — lunch keyword DM bot. ONE file, ONE val, ONE default export.\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\").\n//\n// Two jobs in one handler, chosen by how it's invoked:\n// cron (Interval arg) -> run the matcher and send DMs\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 on demand (add &force=1 to skip the guard)\n//\n// Setup in Val Town — add BOTH triggers to this one val:\n// 1. New val -> HTTP. Paste this whole file. Note the val's URL.\n// 2. Click + -> CRON. Schedule (UTC-only, so run hourly and let the code\n// guard the actual send window): 0 * * * *\n// 3. 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// 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 day that could have a menu: tomorrow, or Monday if tomorrow is a\n// weekend. Running Thu -> Fri, Fri -> Mon, Sat -> Mon, Sun -> Mon.\nfunction nextMenuDay(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// ---------------------------------------------------------------- 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 15:00–15:59 Seattle Sun–Thu: Sunday\n // covers Monday, Thursday covers Friday. Friday would cover Monday, but\n // sending on Friday afternoon for a Monday is stale by the time it matters.\n // 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 || [\"Fri\", \"Sat\"].includes(weekday))) {\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 d = nextMenuDay(now);\n let items: Item[];\n try {\n items = parseDay(await fetchMenu(accountId, isoInSeattle(d)));\n } catch (e) {\n return { status: `fetch failed for ${prettyDate(d)}: ${e}`, sent: 0, log };\n }\n if (items.length === 0) {\n return { status: `no menu for ${prettyDate(d)} — holiday?`, sent: 0, log };\n }\n\n const dayText = formatDay(items, d);\n const pretty = prettyDate(d);\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// Single entrypoint, because one val can only have one default export.\n//\n// A cron trigger calls this with an Interval object ({lastRunAt}) — NOT a\n// Request — so sniff for a real Request before touching req.url.\nexport default async function (\n arg?: Request | { lastRunAt?: Date },\n): Promise {\n await ensureSchema();\n\n const req = arg instanceof Request ? arg : undefined;\n\n if (!req) {\n // Cron invocation. The hour/day guard inside runSend keeps this to the\n // afternoon before a menu day, even though the cron itself fires hourly.\n const result = await runSend(Deno.env.get(\"FORCE_SEND\") === \"1\");\n console.log(result.status);\n for (const line of result.log) console.log(line);\n return;\n }\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}","script","createdAt",["D",1789493744901],"branchVersion","branchId","cbdada33-99ab-4c83-96b0-1631a34aebba","id","e39396cf-6bb0-4576-8691-cb2de25f4eec","dm-lunch-menu",["D",1789493264500],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Sends my coworkers dms when a keyword appears on the menu","imageUrl","ee122f3f-b6d2-476b-98fd-d8e094a2057f","pinnedFileId","pinPreview",true,"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",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned",9,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","andrewmakin","handle","displayName","Andrew Makin","avatar","https://avatars.githubusercontent.com/u/96471218?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":154,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":155,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":156,"_83":157,"_85":158,"_87":25},"tree",[149],"files",[149],"counts",{"_138":62,"_139":140,"_141":62,"_142":143,"_144":145},"contents",[130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":25,"_38":134,"_13":135,"_33":37,"_35":36,"_24":25,"_136":-5,"_27":137},"8d9d2425-d344-4b50-b642-8ba0f7f344c0","parentId","latest",["D",1789493744901],4,"label",[28],"pulls","branches",1,"forks","envVars",{"_146":62,"_148":62},"connections",{"_146":62,"_147":62},"count","unfilledCount","emptyCount",{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":25,"_38":150,"_13":135,"_33":37,"_35":36,"_24":25,"_136":-5,"_151":152,"_27":153},["D",1789493744901],"children",[],[28],["D",1789493264500],["D",1789494690166],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":55,"_104":105,"_106":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_127":192,"_193":194,"_195":196,"_197":25,"_198":25,"_199":25,"_200":58,"_201":-5,"_202":-7,"_203":-7,"_204":62,"_205":25,"_206":25,"_207":-5,"_208":25,"_209":25,"_210":25,"_211":-5},"ENV",{"_163":164,"_165":166,"_167":89,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191},"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"]

Diff · v5