[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_105":106,"_107":108},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","andrewmakin","name","dm-lunch-menu","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_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":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/andrewmakin/dm-lunch-menu/code/main.ts","extension","id","bd76c267-3444-449a-93d4-6699ab3a31b6","fileId","c31e58d8-b12a-11f1-a0a7-1607ee4eb77e","parentId","branchId","cbdada33-99ab-4c83-96b0-1631a34aebba","branchVersion",9,"latest",true,"createdAt",["D",1789494208813],"version",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",[14],"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",{"_9":10,"_104":100},"org",{"_9":10,"_97":98,"_99":100,"_55":56,"_101":102,"_103":42},"branch",{"_35":30,"_11":88,"_22":28,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":12,"_96":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Andrew Makin","avatar","https://avatars.githubusercontent.com/u/96471218?v=4","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_138":139,"_140":141,"_142":143,"_144":42,"_145":42,"_146":42,"_147":32,"_148":-5,"_149":-7,"_150":-7,"_151":62,"_152":42,"_153":42,"_154":-5,"_155":42,"_156":42,"_157":42,"_158":-5},"ENV",{"_109":110,"_111":112,"_113":88,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]