[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_265":266,"_267":268},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_200":-5,"_20":201,"_22":202,"_203":204,"_205":206,"_26":207,"_24":208,"_209":-5,"_210":-5,"_211":69,"_212":213,"_214":63,"_215":-5,"_216":-5,"_217":218},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","kineticalrisk","name","whatsapp-listener","branchName","main","version","path","jobs/digest.ts","project",{"_33":143,"_13":14,"_47":144,"_145":-5,"_146":69,"_147":148,"_149":148,"_150":151,"_152":-5,"_153":154,"_155":60,"_156":63,"_157":-5,"_158":-5,"_159":44,"_160":161,"_162":163,"_164":165,"_166":167,"_168":-5,"_169":170,"_171":170,"_172":173,"_174":173,"_175":173,"_176":170,"_177":170,"_178":179,"_180":181,"_182":183,"_184":69},"tree",[54,55,56,57],"file",{"_33":34,"_35":36,"_37":38,"_13":39,"_40":41,"_42":43,"_17":44,"_45":46,"_47":48,"_49":50,"_51":-5,"_18":52},"contents",[],"upstream","pull","ahead","behind","envVars","id","c8e4d8b7-d066-4c7b-9134-4f5bab930c8c","branchId","f125ce17-24a9-4fbd-86e5-905953dff4dc","fileId","a2fbeb24-ad51-11f1-bf89-1607ee4eb77e","digest.ts","content","/**\n * Scheduled digest job.\n *\n * Runs on cron `0 5,12 * * *` (05:00 and 12:00 UTC = 08:00 and 15:00\n * UTC+3), collecting messages received since the last digest and emailing\n * them. See lib/digest.ts for the send logic.\n */\n\nimport { generateAndSendDigest } from \"../lib/digest.ts\";\n\nexport default async function () {\n const report = await generateAndSendDigest();\n if (report.sent) {\n console.log(`Digest sent: ${report.messageCount} message(s) — ${report.subject}`);\n } else {\n console.log(\"Digest: no new messages since last run; nothing sent.\");\n }\n}\n","fileType","interval",0,"parentId","94b254c4-4a07-4a8e-a36f-427f8ed944b2","createdAt",["D",1789070156341],"branchVersion",21,"label",[53,39],"jobs",{"_33":135,"_13":53,"_37":46,"_45":-5,"_35":36,"_49":50,"_62":63,"_47":136,"_17":44,"_42":86,"_40":-5,"_68":69,"_51":-5,"_70":137,"_18":138},{"_33":82,"_13":83,"_37":84,"_45":-5,"_35":36,"_49":78,"_62":63,"_47":85,"_17":44,"_42":86,"_40":-5,"_68":69,"_51":-5,"_70":87,"_18":88},{"_33":73,"_13":74,"_37":75,"_45":-5,"_35":36,"_49":76,"_62":63,"_47":77,"_17":78,"_42":24,"_40":79,"_68":69,"_51":-5,"_70":80,"_18":81},{"_33":58,"_13":59,"_37":60,"_45":-5,"_35":36,"_49":61,"_62":63,"_47":64,"_17":65,"_42":66,"_40":67,"_68":69,"_51":14,"_70":71,"_18":72},"04a89cb9-f76c-4bd3-8e38-ade897a62bb0","main.ts","f754747c-ad4f-11f1-a6bd-1607ee4eb77e",24,"latest",true,["D",1789070196160],6,"http","/**\n * WhatsApp Cloud API webhook listener.\n *\n * Receives Meta's webhook notifications for a WhatsApp Business account,\n * picks out group messages, translates them, and summarizes them. Results\n * are stored in the val's SQLite database and viewable at /status. A\n * scheduled job emails a digest of new messages twice daily.\n *\n * Routes handled:\n * GET / — Meta verification handshake (hub.challenge)\n * POST / — webhook event notifications\n * GET /status — view recent processed messages (JSON)\n * POST /test — simulate a group-message webhook\n * POST /digest — email any outstanding messages (on-demand trigger)\n *\n * Env vars:\n * WA_VERIFY_TOKEN — secret string; must match what you set in Meta App\n * Dashboard -> WhatsApp -> Configuration -> Webhook\n * DIGEST_EMAIL — optional digest recipient (defaults to val owner)\n * TARGET_LANGUAGE — target language, default \"en\"\n * SOURCE_LANGUAGE — source language, default \"he\" (Hebrew)\n * MYMEMORY_EMAIL — optional; raises MyMemory free quota (~5K -> ~50K chars/day)\n * LLM_ENDPOINT / LLM_API_KEY / LLM_MODEL — optional OpenAI-compatible\n * summarizer (falls back to extractive if unset)\n */\n\nimport { processWebhook } from \"./lib/process.ts\";\nimport { recentMessages } from \"./lib/store.ts\";\nimport { generateAndSendDigest } from \"./lib/digest.ts\";\n\nconst VERIFY_TOKEN = Deno.env.get(\"WA_VERIFY_TOKEN\") ?? \"changeme\";\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const method = req.method;\n\n // ---- Status (GET /status) ----------------------------------------------\n if (method === \"GET\" && url.pathname === \"/status\") {\n const msgs = await recentMessages();\n return Response.json({ ok: true, count: msgs.length, messages: msgs });\n }\n\n // ---- Verification handshake (GET?mode=subscribe) ------------------------\n if (method === \"GET\" && url.searchParams.get(\"hub.mode\") === \"subscribe\") {\n const token = url.searchParams.get(\"hub.verify_token\");\n const challenge = url.searchParams.get(\"hub.challenge\");\n\n if (token === VERIFY_TOKEN && challenge != null) {\n return new Response(challenge, { status: 200 });\n }\n return new Response(\"Verification failed\", { status: 403 });\n }\n\n // ---- Digest trigger (POST /digest) --------------------------------------\n if (method === \"POST\" && url.pathname === \"/digest\") {\n const report = await generateAndSendDigest();\n return Response.json({ ok: true, ...report });\n }\n\n // ---- Test endpoint (POST /test) -----------------------------------------\n if (method === \"POST\" && url.pathname === \"/test\") {\n const sample = sampleWebhook();\n const result = await processWebhook(sample);\n return Response.json({ ok: true, ...result });\n }\n\n // ---- Event notifications (POST /) ---------------------------------------\n if (method === \"POST\") {\n let body: any;\n try {\n body = await req.json();\n } catch {\n return new Response(\"Invalid JSON\", { status: 400 });\n }\n\n // Meta requires we always acknowledge receipt with 200 promptly.\n try {\n const result = await processWebhook(body);\n console.log(\n `processed ${result.messages.length} group message(s), skipped ${result.skipped}`,\n );\n } catch (err) {\n console.error(\"webhook processing error:\", err);\n }\n\n return Response.json({ received: true, status: 200 });\n }\n\n return new Response(\"Method not allowed\", { status: 405 });\n}\n\n/** A representative inbound group-message webhook payload for /test. */\nfunction sampleWebhook() {\n return {\n object: \"whatsapp_business_account\",\n entry: [{\n id: \"WHATSAPP_BUSINESS_ACCOUNT_ID\",\n changes: [{\n value: {\n messaging_product: \"whatsapp\",\n metadata: {\n display_phone_number: \"15551234567\",\n phone_number_id: \"PHONE_NUMBER_ID\",\n },\n contacts: [{ profile: { name: \"Ada Lovelace\" }, wa_id: \"15550000000\" }],\n messages: [{\n from: \"15550000000\",\n id: \"wamid.ABEG\",\n timestamp: Math.floor(Date.now() / 1000).toString(),\n type: \"text\",\n group_id: \"120363000000000000@g.us\",\n text: { body: \"Good morning! The meeting is moved to 3pm tomorrow. Please bring the updated budget.\" },\n }],\n },\n field: \"messages\",\n }],\n }],\n };\n}\n","deleted",false,"children",[],[59],"5818c07e-801a-402a-98ff-7333fa2a2f4c","README.md","22a6bc4c-ad51-11f1-abad-1607ee4eb77e",26,["D",1789070239610],2,"# WhatsApp Group Listener\n\nReceives [WhatsApp Business Cloud API](https://developers.facebook.com/docs/whatsapp/cloud-api) webhooks, picks out **group** messages, **translates** them to English (from Hebrew by default), **summarizes** them, and stores every record in SQLite. Results are viewable at the `/status` endpoint.\n\nThe listener lives at:\n\n- Live endpoint: [url:main.ts] (webhook root)\n- Recent messages: [url:main.ts/status]\n\n## How it works\n\n```mermaid\nflowchart LR\n WA[Meta WhatsApp Cloud API] -->|webhook POST| VT[Val Town / main.ts]\n VT --> P[lib/process.ts
extract group text messages]\n P --> T[lib/translate.ts
Hebrew → English · MyMemory]\n T --> S[lib/summarize.ts
extractive summary]\n S --> DB[(SQLite: messages)]\n DB --> API[GET /status]\n```\n\n1. Meta sends a **GET** verification handshake containing `hub.challenge` — we echo it back if the `hub.verify_token` matches.\n2. Meta sends **POST** notification events. We extract `text` messages that carry a `group_id`, translate each, summarize it, and store it.\n3. `GET /status` returns the latest processed messages as JSON.\n\n## Routes\n\n| Method | Path | Purpose |\n| ------ | ---------- | --------------------------------------------------------------- |\n| GET | `/` | Meta webhook verification handshake (`hub.*` query params) |\n| POST | `/` | Receive webhook events (translate + summarize + store) |\n| GET | `/status` | View recent processed messages as JSON |\n| POST | `/test` | Simulate a group-message webhook to test the pipeline |\n| POST | `/digest` | Email outstanding messages now (on-demand digest trigger) |\n\n## Daily digest\n\nIn addition to storing messages, a scheduled job emails you a digest of everything new since the last run. New messages are marked \"digested\" once included, so nothing is double-sent.\n\n- **Schedule:** `0 5,12 * * *` — 05:00 and 12:00 UTC (08:00 and 15:00 UTC+3).\n- **Job file:** `jobs/digest.ts` (interval type); logic lives in `lib/digest.ts`.\n- **Trigger on demand:** `curl -X POST https://whatsapp-listener.val.run/digest`\n- **Recipient:** defaults to the val owner's address; set `DIGEST_EMAIL` to override.\n\n## Setup\n\n### 1. Configure env vars\n\nRequired before Meta can talk to us:\n\n- `WA_VERIFY_TOKEN` — a secret string. Set the **same value** in Meta's App Dashboard so webhook verification passes.\n\nOptional:\n\n- `SOURCE_LANGUAGE` — source language code. **Defaults to `he` (Hebrew)** since that's the expected group language. Override (e.g. `es`, `nl`) for other groups, or leave unset to auto-detect each message with `franc`.\n- `TARGET_LANGUAGE` — target language, default `en`.\n- `MYMEMORY_EMAIL` — your email; raises MyMemory's free translation quota from ~5K to ~50K chars/day.\n- `SUMMARY_MAX_SENTENCES` — extractive summary length, default `3`.\n- `DIGEST_EMAIL` — digest recipient. If unset, mail goes to the val owner's address.\n- `LLM_ENDPOINT` / `LLM_API_KEY` / `LLM_MODEL` — *optional*; if all three are set, use an OpenAI-compatible chat-completions endpoint for higher-quality abstractive summaries (falls back to extractive otherwise).\n\nKey env var URLs (set these in the Val Town UI):\n\n👉 Add WA_VERIFY_TOKEN here: https://www.val.town/x/kineticalrisk/whatsapp-listener/environment-variables?key=WA_VERIFY_TOKEN\n👉 Add SOURCE_LANGUAGE here: https://www.val.town/x/kineticalrisk/whatsapp-listener/environment-variables?key=SOURCE_LANGUAGE\n👉 Add DIGEST_EMAIL here: https://www.val.town/x/kineticalrisk/whatsapp-listener/environment-variables?key=DIGEST_EMAIL\n👉 Add MYMEMORY_EMAIL here: https://www.val.town/x/kineticalrisk/whatsapp-listener/environment-variables?key=MYMEMORY_EMAIL\n\n### 2. Test the pipeline\n\n```bash\ncurl -X POST https://whatsapp-listener.val.run/test\n```\n\nThen open https://whatsapp-listener.val.run/status to see the processed message.\n\n### 3. Register the webhook with Meta\n\n1. Create a **WhatsApp Business** account and number (Business Manager → WhatsApp).\n2. In the **Meta App Dashboard**, add the **WhatsApp** product and the `whatsapp_business_messaging` permission.\n3. Under **WhatsApp → Configuration**, set:\n - **Callback URL:** `https://whatsapp-listener.val.run/`\n - **Verify token:** the same value as `WA_VERIFY_TOKEN`\n4. Click **Verify and save** — Meta calls your endpoint with the handshake.\n5. Subscribe to the `messages` webhook field.\n6. Make sure your business number is a **participant of the group** whose messages you want to listen to. Test by sending a message in that group.\n\n## Notes & limitations\n\n- **Only group messages** are processed (messages with a `group_id`); 1:1 chats are ignored.\n- The official API only surfaces messages while your **business number is in the group** — there's no way to read arbitrary personal groups.\n- Media messages (images/videos/audio) are stored as `[Image]` / `[Video]` / `[Audio]` placeholders.\n- Translation uses **MyMemory** (free tier). It's fine for low-volume groups; for heavy volume add `MYMEMORY_EMAIL` or an LLM key.\n",[],[74],"d1cd93ea-75fb-41bb-8612-94f82072bc0f","lib","60e360d1-b22a-4b45-9c13-68d9edd658c0",["D",1789069454681],"directory",[89,90,91,92,93],[83],{"_33":128,"_13":39,"_37":129,"_45":84,"_35":36,"_49":130,"_62":63,"_47":131,"_17":124,"_42":100,"_40":132,"_68":69,"_51":-5,"_70":133,"_18":134},{"_33":120,"_13":121,"_37":122,"_45":84,"_35":36,"_49":65,"_62":63,"_47":123,"_17":124,"_42":100,"_40":125,"_68":69,"_51":-5,"_70":126,"_18":127},{"_33":112,"_13":113,"_37":114,"_45":84,"_35":36,"_49":115,"_62":63,"_47":116,"_17":107,"_42":100,"_40":117,"_68":69,"_51":-5,"_70":118,"_18":119},{"_33":104,"_13":105,"_37":106,"_45":84,"_35":36,"_49":107,"_62":63,"_47":108,"_17":44,"_42":100,"_40":109,"_68":69,"_51":-5,"_70":110,"_18":111},{"_33":94,"_13":95,"_37":96,"_45":84,"_35":36,"_49":97,"_62":63,"_47":98,"_17":99,"_42":100,"_40":101,"_68":69,"_51":-5,"_70":102,"_18":103},"4be1ed1e-4277-4d2d-b23d-51ac6f1cfb58","translate.ts","00c3fa32-ad50-11f1-9ec2-1607ee4eb77e",15,["D",1789069853456],5,"script","/**\n * Translation.\n *\n * Free, no API key required.\n *\n * Pipeline:\n * 1. SOURCE_LANGUAGE defaults to \"he\" (the group is expected to be almost\n * always Hebrew, and the README documents the typical setup). Set it to\n * another code (e.g. \"es\", \"nl\") if your group is different.\n * 2. Detect the source language offline with `franc` (pure JS, no network)\n * only when SOURCE_LANGUAGE is not set, then translate with MyMemory.\n *\n * Env vars:\n * TARGET_LANGUAGE — target language code, default \"en\"\n * SOURCE_LANGUAGE — source language; default \"he\" (Hebrew). Override for\n * other groups, or leave unset to auto-detect per message.\n * MYMEMORY_EMAIL — optional; raises MyMemory free quota (~5K -> ~50K chars/day)\n */\n\nimport { franc } from \"npm:franc@6.1.0\";\n\nexport const TARGET_LANGUAGE = Deno.env.get(\"TARGET_LANGUAGE\") ?? \"en\";\nconst SOURCE_LANGUAGE = Deno.env.get(\"SOURCE_LANGUAGE\") ?? \"he\";\nconst MYMEMORY_EMAIL = Deno.env.get(\"MYMEMORY_EMAIL\");\n\nexport interface TranslationResult {\n original: string;\n translated: string;\n source: string;\n target: string;\n via: \"mymemory\" | \"passthrough\";\n}\n\n/** Map franc's ISO 639-3 codes to the 2-letter codes MyMemory accepts. */\nconst ISO3_TO_ISO1: Record = {\n eng: \"en\", spa: \"es\", fra: \"fr\", deu: \"de\", nld: \"nl\", ita: \"it\",\n por: \"pt\", rus: \"ru\", hin: \"hi\", ara: \"ar\", ben: \"bn\", jpn: \"ja\",\n zho: \"zh\", kor: \"ko\", tur: \"tr\", tam: \"ta\", tel: \"te\", vie: \"vi\",\n tha: \"th\", ind: \"id\", heb: \"he\", pol: \"pl\", ukr: \"uk\", swe: \"sv\",\n nor: \"no\", dan: \"da\", fin: \"fi\", ell: \"el\", ces: \"cs\", hun: \"hu\",\n ron: \"ro\", bul: \"bg\", cat: \"ca\", slv: \"sl\", srp: \"sr\", hrv: \"hr\",\n sqi: \"sq\", mkd: \"mk\", lit: \"lt\", lvs: \"lv\", est: \"et\", gle: \"ga\",\n isl: \"is\", slk: \"sk\", fas: \"fa\", urd: \"ur\", mal: \"ml\", kan: \"kn\",\n guj: \"gu\", pan: \"pa\", mar: \"mr\", nep: \"ne\", sin: \"si\", khm: \"km\",\n lao: \"lo\", mya: \"my\", fil: \"tl\", swa: \"sw\", amh: \"am\", zul: \"zu\",\n};\n\n/**\n * Detect the source language code (ISO 639-1) using `franc`. Returns null\n * when it cannot decide (\"und\") or the text is unknown.\n */\nfunction detectSource(text: string): string | null {\n const detected = franc(text, { minLength: 3 });\n if (!detected || detected === \"und\") return null;\n return ISO3_TO_ISO1[detected] ?? null;\n}\n\n/**\n * Translate text to TARGET_LANGUAGE.\n *\n * Behavior:\n * - If SOURCE_LANGUAGE is set, use it directly.\n * - Otherwise detect the source with franc; if franc flags the text as\n * already being the target language, pass it through unchanged.\n * - Returns null when the source can't be determined (avoids storing\n * garbage or mangled translations).\n */\nexport async function translate(text: string): Promise {\n const clean = text?.trim();\n if (!clean) return null;\n\n // Determine the source language.\n let source = SOURCE_LANGUAGE;\n if (!source) source = detectSource(clean);\n\n if (!source) {\n // Couldn't determine source language; don't store a garbage translation.\n return null;\n }\n\n if (source === TARGET_LANGUAGE) {\n return {\n original: clean, translated: clean,\n source, target: TARGET_LANGUAGE, via: \"passthrough\",\n };\n }\n\n return translateViaMyMemory(clean, source);\n}\n\nasync function translateViaMyMemory(text: string, source: string): Promise {\n const params = new URLSearchParams({\n q: text,\n langpair: `${source}|${TARGET_LANGUAGE}`,\n });\n if (MYMEMORY_EMAIL) params.set(\"de\", MYMEMORY_EMAIL);\n\n const res = await fetch(`https://api.mymemory.translated.net/get?${params}`);\n if (!res.ok) throw new Error(`MyMemory translate failed: HTTP ${res.status}`);\n const data = await res.json();\n\n const translated: string | undefined = data?.responseData?.translatedText;\n if (!translated) {\n // Annotated responses arrive as an array after a \".\" element.\n if (Array.isArray(data?.matches)) {\n const last = [...data.matches].reverse().find((m) => typeof m?.translation === \"string\");\n if (last?.translation) {\n return { original: text, translated: last.translation, source, target: TARGET_LANGUAGE, via: \"mymemory\" };\n }\n }\n throw new Error(`MyMemory returned no translation (source=\"${source}\")`);\n }\n\n return { original: text, translated, source, target: TARGET_LANGUAGE, via: \"mymemory\" };\n}\n",[],[83,95],"2725fe18-2378-450e-b86d-54caa62599cc","summarize.ts","17f1ca4a-ad50-11f1-9876-1607ee4eb77e",3,["D",1789069493581],"/**\n * Summarization.\n *\n * Default: a lightweight extractive summarizer (frequency-based sentence\n * scoring) that needs no API key, so the listener works out of the box.\n *\n * Optional: set an LLM endpoint env var to get higher-quality abstractive\n * summaries. See README for providers (OpenAI-compatible chat completions).\n */\n\nconst LLM_ENDPOINT = Deno.env.get(\"LLM_ENDPOINT\"); // e.g. OpenAI chat completions URL\nconst LLM_API_KEY = Deno.env.get(\"LLM_API_KEY\");\nconst LLM_MODEL = Deno.env.get(\"LLM_MODEL\");\nconst SUMMARY_MAX_SENTENCES = Number(Deno.env.get(\"SUMMARY_MAX_SENTENCES\") ?? 3);\n\nexport interface SummaryResult {\n summary: string;\n method: \"extractive\" | \"llm\";\n}\n\n/**\n * Summarize a (usually translated) body of text.\n */\nexport async function summarize(text: string): Promise {\n const clean = text?.trim();\n if (!clean) return { summary: \"\", method: \"extractive\" };\n\n if (LLM_ENDPOINT && LLM_API_KEY && LLM_MODEL) {\n try {\n const llm = await summarizeWithLLM(clean);\n if (llm) return { summary: llm, method: \"llm\" };\n } catch (err) {\n console.error(\"LLM summarization failed, falling back to extractive:\", err);\n }\n }\n\n return { summary: extractiveSummary(clean), method: \"extractive\" };\n}\n\n/** Frequency-based extractive summary. No network or API key needed. */\nfunction extractiveSummary(text: string, maxSentences = SUMMARY_MAX_SENTENCES): string {\n const sentences = splitSentences(text);\n if (sentences.length <= maxSentences) return sentences.join(\" \");\n\n const wordFreq = new Map();\n sentences.forEach((s) => {\n for (const w of s.toLowerCase().match(/[a-z0-9']+/g) ?? []) {\n wordFreq.set(w, (wordFreq.get(w) ?? 0) + 1);\n }\n });\n\n const scored = sentences.map((sentence, idx) => {\n const words = sentence.toLowerCase().match(/[a-z0-9']+/g) ?? [];\n let score = 0;\n for (const w of words) score += wordFreq.get(w) ?? 0;\n // Prefer earlier sentences, weigh by inverse of length.\n score = (score / Math.max(1, words.length)) * (1 / (idx + 1));\n return { sentence, index: idx, score };\n });\n\n const top = scored.sort((a, b) => b.score - a.score).slice(0, maxSentences);\n top.sort((a, b) => a.index - b.index);\n return top.map((t) => t.sentence).join(\" \");\n}\n\nfunction splitSentences(text: string): string[] {\n return text\n .split(/(?<=[.!?])\\s+|\\n+/)\n .map((s) => s.trim())\n .filter((s) => s.length > 1);\n}\n\n/** Abstractive summary via an OpenAI-compatible chat completions endpoint. */\nasync function summarizeWithLLM(text: string): Promise {\n const body = {\n model: LLM_MODEL,\n messages: [\n {\n role: \"system\",\n content: \"You summarize WhatsApp group messages. Be concise; capture the key points in a few sentences in the same language as the input.\",\n },\n { role: \"user\", content: text },\n ],\n temperature: 0.3,\n max_tokens: 250,\n };\n\n const res = await fetch(LLM_ENDPOINT!, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${LLM_API_KEY}`,\n },\n body: JSON.stringify(body),\n });\n if (!res.ok) throw new Error(`LLM HTTP ${res.status}`);\n const data = await res.json();\n const content: string | undefined = data?.choices?.[0]?.message?.content;\n return content?.trim() ? content.trim() : null;\n}\n",[],[83,105],"f368772f-1b77-488d-a9c2-a73eefc68215","store.ts","29f9a640-ad50-11f1-be2e-1607ee4eb77e",18,["D",1789070137581],"/**\n * Persistent storage for incoming group messages using the val's\n * project-scoped SQLite database.\n *\n * Tables:\n * messages — every WhatsApp message event we receive.\n * summaries — rolling per-group digest we build up.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport interface StoredMessage {\n id: string; // WhatsApp message id (wamid.X)\n from: string; // sender phone number / wa_id\n fromName: string | null;\n groupId: string | null;\n groupName: string | null;\n timestamp: number; // epoch seconds\n type: string; // text | image | ...\n text: string | null;\n translated: string | null;\n summary: string | null;\n summarizeMethod: string | null;\n processedAt: string;\n}\n\nexport async function initSchema(): Promise {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS messages (\n id TEXT PRIMARY KEY,\n from_wa TEXT,\n from_name TEXT,\n group_id TEXT,\n group_name TEXT,\n ts INTEGER,\n type TEXT,\n body TEXT,\n translated TEXT,\n summary TEXT,\n summarize_method TEXT,\n processed_at TEXT,\n digested INTEGER DEFAULT 0\n )`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS summaries (\n group_id TEXT,\n start_ts INTEGER,\n end_ts INTEGER,\n message_count INTEGER,\n summary TEXT,\n created_at TEXT,\n PRIMARY KEY (group_id, start_ts)\n )`);\n\n // Migration: add `digested` column to tables created before this field\n // existed. Safe to run once; subsequent runs hit the \"duplicate column\"\n // path and are caught.\n try {\n await sqlite.execute(`ALTER TABLE messages ADD COLUMN digested INTEGER DEFAULT 0`);\n } catch {\n // column already exists — ignore\n }\n}\n\nexport async function insertMessage(m: StoredMessage): Promise {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO messages\n (id, from_wa, from_name, group_id, group_name, ts, type, body, translated, summary, summarize_method, processed_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n m.id, m.from, m.fromName, m.groupId, m.groupName, m.timestamp, m.type,\n m.text, m.translated, m.summary, m.summarizeMethod, m.processedAt,\n ],\n });\n}\n\nexport interface RecentMessage {\n id: string;\n fromName: string | null;\n text: string | null;\n translated: string | null;\n ts: number;\n}\n\nexport async function recentMessages(limit = 20): Promise {\n await initSchema();\n const res = await sqlite.execute(\n `SELECT id, from_name AS fromName, body AS text, translated, ts\n FROM messages ORDER BY ts DESC LIMIT ?`,\n [limit],\n );\n return (res.rows as unknown as RecentMessage[]).reverse();\n}\nexport interface DigestMessage extends RecentMessage {\n fromWa: string | null;\n type: string | null;\n summary: string | null;\n}\n\n/**\n * Messages that haven't been included in a digest yet, oldest first.\n */\nexport async function pendingDigestMessages(limit = 500): Promise {\n await initSchema();\n const res = await sqlite.execute(\n `SELECT id, from_wa AS fromWa, from_name AS fromName, body AS text,\n translated, summary, type, ts\n FROM messages\n WHERE digested IS NOT 1\n ORDER BY ts ASC\n LIMIT ?`,\n [limit],\n );\n return res.rows as unknown as DigestMessage[];\n}\n\n/** Mark message ids as included in a digest. */\nexport async function markDigested(ids: string[]): Promise {\n if (ids.length === 0) return;\n const placeholders = ids.map(() => \"?\").join(\",\");\n await sqlite.execute({\n sql: `UPDATE messages SET digested = 1 WHERE id IN (${placeholders})`,\n args: ids,\n });\n}\n",[],[83,113],"2c2fcba5-983a-4a18-a96c-9387f62aabd9","process.ts","29ff63d2-ad50-11f1-be2e-1607ee4eb77e",["D",1789069527155],1,"/**\n * Parses a Meta WhatsApp Cloud API webhook payload and turns each group\n * message into a stored, translated, summarized record.\n *\n * Webhook reference:\n * https://developers.facebook.com/docs/whatsapp/cloud-api/webhooks/payload-examples\n */\n\nimport { translate } from \"./translate.ts\";\nimport { summarize } from \"./summarize.ts\";\nimport { initSchema, insertMessage, type StoredMessage } from \"./store.ts\";\n\nexport interface ParsedEvent {\n messages: StoredMessage[];\n skipped: number;\n}\n\n/**\n * Extract group text messages from a webhook body and process them.\n * Returns the resulting records so the handler can log/forward them.\n */\nexport async function processWebhook(body: unknown): Promise {\n await initSchema();\n\n if (body?.object !== \"whatsapp_business_account\") {\n return { messages: [], skipped: 0 };\n }\n\n const entries: any[] = body?.entry ?? [];\n const out: StoredMessage[] = [];\n let skipped = 0;\n\n for (const entry of entries) {\n const changes: any[] = entry?.changes ?? [];\n for (const change of changes) {\n if (change?.field !== \"messages\") continue;\n const value = change.value ?? {};\n const messages: any[] = value.messages ?? [];\n const contactsById = new Map();\n for (const c of value?.contacts ?? []) {\n contactsById.set(c.wa_id, c);\n }\n for (const msg of messages) {\n // Only handle group-originated text messages.\n const groupId = msg.group_id ?? null;\n const type = msg.type ?? \"\";\n if (!groupId) continue;\n\n const text =\n msg?.text?.body ??\n (type === \"image\" ? \"[Image]\" : type === \"video\" ? \"[Video]\" : type === \"audio\" ? \"[Audio]\" : null);\n\n skipped += text == null ? 1 : 0;\n\n const record: StoredMessage = {\n id: msg.id ?? `${Date.now()}-${Math.random()}`,\n from: msg.from ?? \"\",\n fromName: contactsById.get(msg.from)?.profile?.name ?? null,\n groupId,\n groupName: value?.contacts_name ?? null, // groups may carry a group name field\n timestamp: Number(msg.timestamp ?? 0),\n type,\n text,\n translated: null,\n summary: null,\n summarizeMethod: null,\n processedAt: new Date().toISOString(),\n };\n\n if (text) {\n try {\n const t = await translate(text);\n record.translated = t?.translated ?? null;\n } catch (err) {\n console.error(\"translate failed:\", err);\n }\n\n if (record.translated) {\n try {\n const s = await summarize(record.translated);\n record.summary = s.summary;\n record.summarizeMethod = s.method;\n } catch (err) {\n console.error(\"summarize failed:\", err);\n }\n }\n }\n\n await insertMessage(record);\n out.push(record);\n }\n }\n }\n\n return { messages: out, skipped };\n}\n",[],[83,121],"41513cce-6643-4c10-a0b8-b023616169c1","9c2cea8c-ad51-11f1-a61d-1607ee4eb77e",20,["D",1789070149207],"/**\n * Builds and sends the periodic WhatsApp digest email.\n *\n * Collects messages that haven't been digested yet (oldest first), renders\n * them into a readable email, sends it, then marks them as digested so\n * nothing is sent twice.\n *\n * Env vars:\n * DIGEST_EMAIL — optional recipient. If unset, mail goes to the val\n * owner's address (std/email default).\n */\n\nimport { email } from \"https://esm.town/v/std/email\";\nimport { pendingDigestMessages, markDigested } from \"./store.ts\";\n\nconst DIGEST_EMAIL = Deno.env.get(\"DIGEST_EMAIL\");\n\nexport interface DigestReport {\n sent: boolean;\n messageCount: number;\n receivedSince: string; // unix secs, start of period\n subject?: string;\n}\n\n/** Fetch pending messages, build + send an email, mark them digested. */\nexport async function generateAndSendDigest(): Promise {\n const messages = await pendingDigestMessages();\n if (messages.length === 0) {\n return { sent: false, messageCount: 0, receivedSince: String(Math.floor(Date.now() / 1000)) };\n }\n\n const firstTs = messages[0].ts;\n\n const subject = `WhatsApp digest — ${messages.length} message(s)`;\n const text = renderDigest(messages);\n\n await email({\n to: DIGEST_EMAIL || undefined,\n subject,\n text,\n });\n\n await markDigested(messages.map((m) => m.id));\n\n return {\n sent: true,\n messageCount: messages.length,\n receivedSince: String(firstTs),\n subject,\n };\n}\n\n/** Render pending messages as a plain-text email body. */\nexport function renderDigest(\n messages: Array<{\n ts: number;\n fromName: string | null;\n translated: string | null;\n text: string | null;\n summary: string | null;\n type: string | null;\n }>,\n): string {\n const lines: string[] = [];\n lines.push(`WhatsApp group digest — ${messages.length} message(s) since last digest`);\n lines.push(\"\");\n\n let currentDay = \"\";\n for (const m of messages) {\n const day = new Date(m.ts * 1000).toISOString().slice(0, 10);\n if (day !== currentDay) {\n currentDay = day;\n lines.push(`━━ ${day} ━━`);\n }\n\n const time = new Date(m.ts * 1000).toISOString().slice(11, 16);\n const sender = m.fromName ?? \"(unknown)\";\n const body = m.translated ?? m.text ?? \"—\";\n\n lines.push(`[${time}] ${sender}`);\n lines.push(` ${body}`);\n if (m.summary && m.summary !== body) {\n lines.push(` → ${m.summary}`);\n }\n lines.push(\"\");\n }\n\n return lines.join(\"\\n\");\n}\n",[],[83,39],"79c07e8c-e029-42d9-905a-cba79fe4916c",["D",1789070156341],[139],[53],{"_33":34,"_13":39,"_37":38,"_45":46,"_35":36,"_49":50,"_62":63,"_47":140,"_17":44,"_42":43,"_40":41,"_68":69,"_51":-5,"_70":141,"_18":142},["D",1789070156341],[],[53,39],"67bafc4b-c45d-426f-8450-bacefc1a7742",["D",1789069438780],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","WhatsApp Cloud API webhook: translate & summarize group messages","imageUrl","userId","a4d27070-4c1e-11f0-8f2a-2bb90bc7a681","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","9fdbdc59-64a3-4913-a787-641c22636321","tursoName","67bafc4bc45d426f8450bacefc1a7742","tursoHostname","67bafc4bc45d426f8450bacefc1a7742-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789503703835],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_199":195},"org",{"_11":12,"_193":-5,"_194":195,"_153":154,"_196":197,"_198":69},"branch",{"_17":76,"_13":16,"_33":36,"_185":143,"_186":-5,"_187":-5,"_188":-5,"_189":-5,"_190":-5,"_191":14,"_192":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ5ZnBUMzNrSnE2S0VCdVo5c0ZUU1RnYUhiRyJ9","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":143,"_13":14,"_47":260,"_145":-5,"_146":69,"_147":148,"_149":148,"_150":151,"_152":-5,"_153":154,"_155":60,"_156":63,"_157":-5,"_158":-5,"_159":44,"_160":161,"_162":163,"_164":165,"_166":261,"_168":-5,"_169":170,"_171":170,"_172":173,"_174":173,"_175":173,"_176":170,"_177":170,"_178":262,"_180":263,"_182":264,"_184":69},[230,232,238,239],"files",[230,231,232,233,234,235,236,237,238,239],"counts",{"_221":44,"_222":124,"_223":44,"_32":224,"_225":226},[],{"_33":34,"_13":39,"_37":38,"_45":46,"_35":36,"_49":50,"_62":63,"_47":219,"_17":44,"_42":43,"_40":41,"_68":69,"_51":-5,"_18":220},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1789070156341],[53,39],"pulls","branches","forks",{"_227":44,"_229":44},"connections",{"_227":44,"_228":44},"count","unfilledCount","emptyCount",{"_33":135,"_13":53,"_37":46,"_45":-5,"_35":36,"_49":50,"_62":63,"_47":136,"_17":44,"_42":86,"_40":-5,"_68":69,"_51":-5,"_70":258,"_18":259},{"_33":34,"_13":39,"_37":38,"_45":46,"_35":36,"_49":50,"_62":63,"_47":140,"_17":44,"_42":43,"_40":41,"_68":69,"_51":-5,"_70":256,"_18":257},{"_33":82,"_13":83,"_37":84,"_45":-5,"_35":36,"_49":78,"_62":63,"_47":85,"_17":44,"_42":86,"_40":-5,"_68":69,"_51":-5,"_70":254,"_18":255},{"_33":128,"_13":39,"_37":129,"_45":84,"_35":36,"_49":130,"_62":63,"_47":131,"_17":124,"_42":100,"_40":132,"_68":69,"_51":-5,"_70":252,"_18":253},{"_33":120,"_13":121,"_37":122,"_45":84,"_35":36,"_49":65,"_62":63,"_47":123,"_17":124,"_42":100,"_40":125,"_68":69,"_51":-5,"_70":250,"_18":251},{"_33":112,"_13":113,"_37":114,"_45":84,"_35":36,"_49":115,"_62":63,"_47":116,"_17":107,"_42":100,"_40":117,"_68":69,"_51":-5,"_70":248,"_18":249},{"_33":104,"_13":105,"_37":106,"_45":84,"_35":36,"_49":107,"_62":63,"_47":108,"_17":44,"_42":100,"_40":109,"_68":69,"_51":-5,"_70":246,"_18":247},{"_33":94,"_13":95,"_37":96,"_45":84,"_35":36,"_49":97,"_62":63,"_47":98,"_17":99,"_42":100,"_40":101,"_68":69,"_51":-5,"_70":244,"_18":245},{"_33":73,"_13":74,"_37":75,"_45":-5,"_35":36,"_49":76,"_62":63,"_47":77,"_17":78,"_42":24,"_40":79,"_68":69,"_51":-5,"_70":242,"_18":243},{"_33":58,"_13":59,"_37":60,"_45":-5,"_35":36,"_49":61,"_62":63,"_47":64,"_17":65,"_42":66,"_40":67,"_68":69,"_51":14,"_70":240,"_18":241},[],[59],[],[74],[],[83,95],[],[83,105],[],[83,113],[],[83,121],[],[83,39],[233,234,235,236,237],[83],[],[53,39],[231],[53],["D",1789069438780],["D",1789503703835],{"_11":12,"_199":195},{"_11":12,"_193":-5,"_194":195,"_153":154,"_196":197,"_198":69},{"_17":76,"_13":16,"_33":36,"_185":143,"_186":-5,"_187":-5,"_188":-5,"_189":-5,"_190":-5,"_191":14,"_192":12},"ctx",{"_178":-5,"_216":298,"_299":300,"_301":302,"_303":69,"_304":69,"_305":69,"_306":63,"_307":-5,"_308":-7,"_309":-7,"_310":44,"_311":69,"_312":69,"_313":-5,"_314":69,"_315":69,"_316":69,"_317":-5},"ENV",{"_269":270,"_271":272,"_273":16,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297},"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"]