[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":25,"_122":-5,"_123":-5,"_124":125},"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":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",21,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_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","b371b546-ac8f-11f1-ad88-1607ee4eb77e","name","fileType","interval","content","// Xpanse Kamla Nagar — hourly sales brief (Val Town cron, runs at :05 every hour UTC = every hour IST)\n// Env vars needed: XPANSE_USERNAME, XPANSE_PASSWORD, EMAIL_TO (comma list)\n// Optional: GEMINI_API_KEY (preferred, header X-goog-api-key) or ANTHROPIC_API_KEY; SMTP_USER + SMTP_PASSWORD (Gmail send)\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst BASE = \"https://franchise.xpansecafe.com/\";\nconst OUTLET = \"Xpanse Kamla Nagar\";\nconst TZ = \"Asia/Kolkata\";\nconst OPEN_HOUR = 8, CLOSE_HOUR = 23; // store hours IST\nconst DIGEST_HOUR = 0; // the midnight run is the end-of-day digest for the day just closed\n\ntype Stats = {\n start: string;\n end: string;\n orders: number;\n revenue: number;\n cancelled: number;\n beverages: number;\n food: number;\n aov: number;\n ok: boolean;\n};\ntype Top = { name: string; category: string; qty: number; revenue: number };\n\n// ---------- date helpers (IST) ----------\nfunction istParts(d = new Date()) {\n const f = new Intl.DateTimeFormat(\"en-GB\", {\n timeZone: TZ,\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n hour12: false,\n weekday: \"short\",\n });\n const p = Object.fromEntries(\n f.formatToParts(d).map((x) => [x.type, x.value]),\n );\n return {\n y: +p.year,\n m: +p.month,\n d: +p.day,\n hour: +p.hour % 24,\n minute: +p.minute,\n wd: p.weekday,\n };\n}\nconst iso = (y: number, m: number, d: number) =>\n `${y}-${String(m).padStart(2, \"0\")}-${String(d).padStart(2, \"0\")}`;\nconst ddmmyyyy = (isoDate: string) => isoDate.split(\"-\").reverse().join(\"-\");\nfunction shift(isoDate: string, days: number) {\n const t = new Date(isoDate + \"T00:00:00Z\");\n t.setUTCDate(t.getUTCDate() + days);\n return t.toISOString().slice(0, 10);\n}\nconst num = (v: unknown) => {\n const n = parseFloat(String(v ?? \"0\").replace(/[₹,\\s]/g, \"\"));\n return isNaN(n) ? 0 : n;\n};\nconst inr = (n: number) => \"₹\" + Math.round(n).toLocaleString(\"en-IN\");\n\n// ---------- panel client ----------\nclass Panel {\n private cookies = new Map();\n private token = \"\";\n constructor(private user: string, private pass: string) {}\n private cookieHeader() {\n return [...this.cookies].map(([k, v]) => `${k}=${v}`).join(\"; \");\n }\n private absorb(r: Response) {\n for (const c of r.headers.getSetCookie?.() ?? []) {\n const [kv] = c.split(\";\");\n const i = kv.indexOf(\"=\");\n this.cookies.set(kv.slice(0, i).trim(), kv.slice(i + 1).trim());\n }\n }\n private async req(path: string, init: RequestInit = {}) {\n const h = new Headers(init.headers as HeadersInit | undefined);\n h.set(\"User-Agent\", \"Mozilla/5.0 (xpanse-sales-monitor)\");\n h.set(\"X-Requested-With\", \"XMLHttpRequest\");\n h.set(\"Accept\", \"application/json, text/javascript, */*; q=0.01\");\n const ck = this.cookieHeader();\n if (ck) h.set(\"Cookie\", ck);\n if (this.token) h.set(\"Authorization\", this.token);\n const r = await fetch(BASE + path, {\n ...init,\n redirect: \"manual\",\n headers: h,\n });\n this.absorb(r);\n return r;\n }\n async login() {\n await this.req(\"\");\n const body = new URLSearchParams({\n _token: this.cookies.get(\"_token_cookie\") ?? \"\",\n username: this.user,\n password: this.pass,\n });\n const r = await this.req(\"auth/franchise\", {\n method: \"POST\",\n body,\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n });\n const j = await r.json().catch(() => ({}));\n if (!j.status) {\n throw new Error(\n \"Login failed: \" + JSON.stringify(j.data ?? j).slice(0, 200),\n );\n }\n this.token = j.data.access_token;\n this.cookies.set(\"authorization\", this.token);\n }\n private async get(path: string, params: Record) {\n const q = new URLSearchParams({\n _token: this.cookies.get(\"_token_cookie\") ?? \"\",\n ...params,\n });\n let r = await this.req(`${path}?${q}`);\n if (r.status === 401 || r.status === 403) {\n await this.login();\n r = await this.req(`${path}?${q}`);\n }\n const body = await r.text();\n if (path === \"summary/analytics\" && r.status !== 200) {\n console.log(\n ` analytics http=${r.status} body=${\n body.slice(0, 240).replace(/\\\\s+/g, \" \")\n }`,\n );\n }\n try {\n return JSON.parse(body);\n } catch {\n return { status: false };\n }\n }\n async analytics(start: string, end: string): Promise {\n const j = await this.get(\"summary/analytics\", {\n start_date: ddmmyyyy(start),\n end_date: ddmmyyyy(end),\n });\n const s: Stats = {\n start,\n end,\n orders: 0,\n revenue: 0,\n cancelled: 0,\n beverages: 0,\n food: 0,\n aov: 0,\n ok: !!j.status,\n };\n if (!j.status) return s;\n const p = j.data.params;\n s.orders = Math.round(num(p.ordersCount));\n s.revenue = Math.round(num(p.totalRevenue) * 100) / 100;\n s.cancelled = Math.round(num(p.cancelledOrders));\n s.beverages = Math.round(num(p.beveragesSold));\n s.food = Math.round(num(p.foodSold));\n s.aov = s.orders ? Math.round(s.revenue / s.orders * 100) / 100 : 0;\n return s;\n }\n async topSelling(start: string, end: string): Promise {\n const j = await this.get(\"summary/top-selling\", {\n start_date: ddmmyyyy(start),\n end_date: ddmmyyyy(end),\n });\n if (!j.status) return [];\n return (j.data.list ?? []).map((it: any) => ({\n name: it.name,\n category: it.category,\n qty: Math.round(num(it.totalSoldQuantity)),\n revenue: Math.round(num(it.totalRevenue) * 100) / 100,\n }));\n }\n}\n\n// ---------- snapshots (blob, one array per day) ----------\ntype Snap = { taken_at: string; hour: number; today: Stats; top_today: Top[] };\nconst slugify = (name: string) =>\n name.toLowerCase().replace(/[^a-z0-9]+/g, \"-\").replace(/^-|-$/g, \"\");\nconst dayKey = (slug: string, d: string) => `snap:${slug}:${d}`;\nasync function loadDay(slug: string, d: string): Promise {\n return (await blob.getJSON(dayKey(slug, d))) ?? [];\n}\nasync function snapAtHour(slug: string, d: string, hour: number) {\n let best: Snap | undefined;\n for (const s of await loadDay(slug, d)) if (s.hour <= hour) best = s;\n return best;\n}\n\n// ---------- summary ----------\nfunction ruleBased(m: any): string {\n const t = m.today, y = m.yesterday_full, lines: string[] = [];\n if (m.is_end_of_day_digest && y) {\n const lw = m.closed_day_same_weekday_last_week;\n lines.push(\n `Day closed (${ddmmyyyy(m.closed_day)}): ${y.orders} orders, ${\n inr(y.revenue)\n } revenue, AOV ${inr(y.aov)}.`,\n );\n if (lw?.orders) {\n const d = y.revenue - lw.revenue;\n lines.push(\n `- ${inr(Math.abs(d))} ${\n d >= 0 ? \"ahead of\" : \"behind\"\n } same weekday last week (${lw.orders} orders, ${inr(lw.revenue)}).`,\n );\n }\n if (y.cancelled) lines.push(`- Cancellations: ${y.cancelled}.`);\n lines.push(`- Beverages ${y.beverages} / Food ${y.food}.`);\n if (m.mtd?.orders) {\n lines.push(\n `- Month to date: ${m.mtd.orders} orders, ${inr(m.mtd.revenue)}.`,\n );\n }\n if (m.top_closed_day?.length) {\n lines.push(\n \"- Top sellers: \" + m.top_closed_day.slice(0, 3).map((x: Top) =>\n `${x.name} (${x.qty})`\n ).join(\", \") + \".\",\n );\n }\n return lines.join(\"\\n\");\n }\n if (t.orders === 0 && y?.orders) {\n lines.push(\n `No orders yet today. Yesterday closed at ${y.orders} orders, ${\n inr(y.revenue)\n } revenue, AOV ${inr(y.aov)}.`,\n );\n } else {lines.push(\n `Today so far: ${t.orders} orders, ${inr(t.revenue)} revenue, AOV ${\n inr(t.aov)\n }.`,\n );}\n if (m.mtd?.orders) {\n lines.push(\n `- Month to date: ${m.mtd.orders} orders, ${inr(m.mtd.revenue)}.`,\n );\n }\n if (m.delta_last_hour) {\n lines.push(\n `- Last hour: +${m.delta_last_hour.orders} orders, +${\n inr(m.delta_last_hour.revenue)\n }.`,\n );\n }\n const ys = m.yesterday_same_hour;\n if (ys) {\n const diff = t.revenue - ys.revenue;\n lines.push(\n `- ${inr(Math.abs(diff))} ${\n diff >= 0 ? \"ahead of\" : \"behind\"\n } yesterday at this hour (${ys.orders} orders then).`,\n );\n }\n const lw = m.same_weekday_last_week_full;\n if (lw?.orders) {\n lines.push(\n `- Same weekday last week closed at ${lw.orders} orders / ${\n inr(lw.revenue)\n }.`,\n );\n }\n if (t.cancelled) lines.push(`- Cancellations today: ${t.cancelled}.`);\n if (m.top_today?.length) {\n lines.push(\n \"- Top sellers: \" + m.top_today.slice(0, 3).map((x: Top) =>\n `${x.name} (${x.qty})`\n ).join(\", \") + \".\",\n );\n }\n return lines.join(\"\\n\");\n}\n\nconst SYSTEM =\n `You write hourly sales briefs for the owner of a single Xpanse Cafe franchise outlet in India.\nYou get a JSON bundle of metrics computed by code (do not recompute or invent numbers; quote them as given).\nWrite for a busy owner reading on a phone:\n- 1 headline sentence with the single most important fact right now.\n- 3 to 5 short bullets: last-hour movement, today vs yesterday at the same hour, today vs same weekday last week, cancellations/AOV if notable, top seller shifts.\n- If is_end_of_day_digest is true, this is the closing report for closed_day: lead with yesterday_full, compare with closed_day_same_weekday_last_week, use top_closed_day.\n- End with at most 2 \"watch\" items or suggested actions, only if the data supports them.\nCurrency is INR (₹). Be concrete and terse. No preamble, no sign-off, no markdown headers. Use plain '-' bullets.`;\n\nasync function summarizeGemini(m: any, key: string): Promise<[string, string]> {\n const model = Deno.env.get(\"GEMINI_MODEL\") || \"gemini-flash-latest\";\n const url =\n `https://generativelanguage.googleapis.com/v1beta/models/${model}:generateContent`;\n const r = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"X-goog-api-key\": key },\n body: JSON.stringify({\n system_instruction: { parts: [{ text: SYSTEM }] },\n contents: [{ role: \"user\", parts: [{ text: JSON.stringify(m) }] }],\n generationConfig: { temperature: 0.3, maxOutputTokens: 1200 },\n }),\n });\n if (!r.ok) {\n throw new Error(\n `Gemini HTTP ${r.status}: ${(await r.text()).slice(0, 160)}`,\n );\n }\n const j = await r.json();\n const text = (j.candidates?.[0]?.content?.parts ?? []).map((p: any) =>\n p.text ?? \"\"\n ).join(\"\").trim();\n return [text || ruleBased(m), model];\n}\n\nasync function summarizeClaude(m: any): Promise<[string, string]> {\n const { default: Anthropic } = await import(\"npm:@anthropic-ai/sdk\");\n const client = new Anthropic();\n const model = Deno.env.get(\"CLAUDE_MODEL\") || \"claude-opus-5\";\n const resp = await client.messages.create(\n {\n model,\n max_tokens: 4000,\n thinking: { type: \"adaptive\" },\n output_config: { effort: \"low\" },\n system: SYSTEM,\n messages: [{ role: \"user\", content: JSON.stringify(m) }],\n } as any,\n );\n if (resp.stop_reason === \"refusal\") {\n return [ruleBased(m), \"rules (model declined)\"];\n }\n const text = resp.content.filter((b: any) => b.type === \"text\").map((\n b: any,\n ) => b.text).join(\"\").trim();\n return [text || ruleBased(m), model];\n}\n\nasync function summarize(m: any): Promise<[string, string]> {\n const gem = Deno.env.get(\"GEMINI_API_KEY\"),\n ant = Deno.env.get(\"ANTHROPIC_API_KEY\");\n try {\n if (gem) return await summarizeGemini(m, gem); // Gemini preferred if its key is set\n if (ant) return await summarizeClaude(m);\n return [ruleBased(m), \"rules\"];\n } catch (e) {\n return [\n ruleBased(m),\n \"rules (fallback: \" + String((e as Error).message).slice(0, 80) + \")\",\n ];\n }\n}\n\n// ---------- email ----------\nconst esc = (s: unknown) =>\n String(s).replace(\n /[&<>\"]/g,\n (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\" }[c]!),\n );\nfunction renderHtml(m: any, summary: string, engine: string) {\n const t = m.today,\n row = (l: string, v: string) =>\n `${l}${v}`;\n if (m.is_end_of_day_digest) {\n const y = m.yesterday_full;\n const rows = [\n row(\"Orders\", `${y.orders}`),\n row(\"Revenue\", inr(y.revenue)),\n row(\"AOV\", inr(y.aov)),\n row(\"Cancelled\", `${y.cancelled}`),\n row(\"Beverages / Food\", `${y.beverages} / ${y.food}`),\n ];\n const lw = m.closed_day_same_weekday_last_week;\n if (lw?.orders) {\n rows.push(\n row(\n \"Same weekday last week\",\n `${lw.orders} orders \\u00b7 ${inr(lw.revenue)}`,\n ),\n );\n }\n if (m.mtd?.orders) {\n rows.push(\n row(\n \"Month to date\",\n `${m.mtd.orders} orders \\u00b7 ${inr(m.mtd.revenue)}`,\n ),\n );\n }\n const top = (m.top_closed_day ?? []).slice(0, 8).map((x: Top) =>\n `${\n esc(x.name)\n } (${\n esc(x.category)\n })${x.qty}${\n inr(x.revenue)\n }`\n ).join(\"\");\n return `

${\n esc(m.outlet)\n } \\u2014 day closed

${\n ddmmyyyy(m.closed_day)\n }

${\n summary.split(\"\\n\").map(esc).join(\"
\")\n }

${\n rows.join(\"\")\n }

${\n top\n ? `

Top sellers

${top}

`\n : \"\"\n }

Summary by ${\n esc(engine)\n } \\u00b7 Val Town cron

`;\n }\n const rows = [\n row(\"Orders today\", `${t.orders}`),\n row(\"Revenue today\", inr(t.revenue)),\n row(\"AOV\", inr(t.aov)),\n row(\"Cancelled\", `${t.cancelled}`),\n row(\"Beverages / Food\", `${t.beverages} / ${t.food}`),\n ];\n if (m.delta_last_hour) {\n rows.unshift(\n row(\n \"Last hour\",\n `+${m.delta_last_hour.orders} orders · +${\n inr(m.delta_last_hour.revenue)\n }`,\n ),\n );\n }\n if (m.yesterday_same_hour) {\n rows.push(\n row(\n \"Yesterday at this hour\",\n `${m.yesterday_same_hour.orders} orders · ${\n inr(m.yesterday_same_hour.revenue)\n }`,\n ),\n );\n }\n if (m.yesterday_full?.orders) {\n rows.push(\n row(\n \"Yesterday (full day)\",\n `${m.yesterday_full.orders} orders · ${inr(m.yesterday_full.revenue)}`,\n ),\n );\n }\n if (m.mtd?.orders) {\n rows.push(\n row(\"Month to date\", `${m.mtd.orders} orders · ${inr(m.mtd.revenue)}`),\n );\n }\n const top = (m.top_today ?? []).slice(0, 8).map((x: Top) =>\n `${\n esc(x.name)\n } (${\n esc(x.category)\n })${x.qty}${\n inr(x.revenue)\n }`\n ).join(\"\");\n return `

${\n esc(m.outlet)\n }

${\n esc(m.taken_at_human)\n }

${\n summary.split(\"\\n\").map(esc).join(\"
\")\n }

\n${\n rows.join(\"\")\n }

\n${\n top\n ? `

Top sellers today

${top}

`\n : \"\"\n }\n

Summary by ${\n esc(engine)\n } · franchise.xpansecafe.com · Val Town cron, hourly

`;\n}\n\nasync function sendMail(\n to: string[],\n subject: string,\n html: string,\n text: string,\n) {\n try {\n await email({ to, subject, html, text });\n return \"valtown\";\n } catch (e) {\n const user = Deno.env.get(\"SMTP_USER\"),\n pass = Deno.env.get(\"SMTP_PASSWORD\");\n if (!user || !pass) throw e;\n const nodemailer = (await import(\"npm:nodemailer\")).default;\n const tr = nodemailer.createTransport({\n host: \"smtp.gmail.com\",\n port: 465,\n secure: true,\n auth: { user, pass },\n });\n await tr.sendMail({ from: user, to: to.join(\", \"), subject, text, html });\n return \"gmail\";\n }\n}\n\n// ---------- outlets config ----------\ntype OutletCfg = { name: string; username: string; password: string };\nfunction parseOutlets(raw: string): OutletCfg[] | null {\n // The .env import can mangle the value: outer quotes kept, or inner \\\" left escaped\n // without the outer quotes (invalid JSON on first parse). Try several recoveries.\n const stripOuter = (x: string) => x.replace(/^\\s*\"([\\s\\S]*)\"\\s*$/, \"$1\");\n const candidates = [\n raw,\n stripOuter(raw),\n raw.replace(/\\\\\"/g, '\"'),\n stripOuter(raw).replace(/\\\\\"/g, '\"'),\n ];\n for (const c of candidates) {\n try {\n let arr: any = JSON.parse(c);\n if (typeof arr === \"string\") arr = JSON.parse(arr); // double-encoded\n if (Array.isArray(arr) && arr.length) return arr as OutletCfg[];\n } catch { /* try next */ }\n }\n return null;\n}\n\nfunction outletsFromEnv(): OutletCfg[] {\n const raw = Deno.env.get(\"OUTLETS\");\n if (raw) {\n const arr = parseOutlets(raw);\n if (arr) return arr;\n console.error(\n \"OUTLETS present but unparseable; using single-outlet fallback\",\n );\n }\n const u = Deno.env.get(\"XPANSE_USERNAME\"),\n p = Deno.env.get(\"XPANSE_PASSWORD\");\n return u && p ? [{ name: OUTLET, username: u, password: p }] : [];\n}\n\n// ---------- per-outlet run ----------\nasync function runOutlet(\n cfg: OutletCfg,\n now: ReturnType,\n isDigest: boolean,\n force: boolean,\n to: string[],\n): Promise {\n const slug = slugify(cfg.name);\n const today = iso(now.y, now.m, now.d),\n yday = shift(today, -1),\n lastWeek = shift(today, -7),\n mtdStart = today.slice(0, 8) + \"01\";\n\n const panel = new Panel(cfg.username, cfg.password);\n await panel.login();\n // Sequential (not Promise.all): the panel session cannot handle concurrent requests and returns empty for some.\n const t = await panel.analytics(today, today);\n const yf = await panel.analytics(yday, yday);\n const lw = await panel.analytics(lastWeek, lastWeek);\n const mtd = await panel.analytics(mtdStart, today);\n const top = await panel.topSelling(today, today);\n const ylw = await panel.analytics(shift(yday, -7), shift(yday, -7));\n const ytop = isDigest ? await panel.topSelling(yday, yday) : ([] as Top[]);\n\n const dayRows = await loadDay(slug, today);\n const prev = dayRows.at(-1);\n const delta = prev\n ? {\n orders: t.orders - prev.today.orders,\n revenue: Math.round((t.revenue - prev.today.revenue) * 100) / 100,\n since: prev.taken_at,\n }\n : null;\n const ySame = await snapAtHour(slug, yday, now.hour),\n lwSame = await snapAtHour(slug, lastWeek, now.hour);\n\n const m = {\n outlet: cfg.name,\n taken_at: `${today}T${String(now.hour).padStart(2, \"0\")}:${\n String(now.minute).padStart(2, \"0\")\n }+05:30`,\n taken_at_human: `${now.wd} ${now.d}/${now.m}/${now.y}, ${\n String(now.hour).padStart(2, \"0\")\n }:${String(now.minute).padStart(2, \"0\")} IST`,\n local_hour: now.hour,\n today: t,\n delta_last_hour: delta,\n yesterday_same_hour: ySame?.today ?? null,\n yesterday_full: yf,\n same_weekday_last_week_same_hour: lwSame?.today ?? null,\n same_weekday_last_week_full: lw,\n mtd,\n top_today: top,\n top_prev_run: prev?.top_today ?? null,\n is_end_of_day_digest: isDigest,\n closed_day: isDigest ? yday : null,\n closed_day_same_weekday_last_week: ylw,\n top_closed_day: ytop,\n };\n\n dayRows.push({\n taken_at: m.taken_at,\n hour: now.hour,\n today: t,\n top_today: top,\n });\n await blob.setJSON(dayKey(slug, today), dayRows);\n for (const { key } of await blob.list(`snap:${slug}:`)) {\n if (key.slice(`snap:${slug}:`.length) < shift(today, -21)) {\n await blob.delete(key);\n }\n }\n\n const noChange = delta !== null && delta.orders === 0;\n if (noChange && !isDigest && !force) {\n return `${cfg.name}: no new orders (today=${t.orders}), email skipped`;\n }\n\n const [summary, engine] = await summarize(m);\n const h12 = `${now.hour % 12 || 12} ${now.hour < 12 ? \"AM\" : \"PM\"}`;\n const subject = isDigest\n ? `${cfg.name} — day closed: ${yf.orders} orders · ${inr(yf.revenue)}`\n : `${cfg.name}: ${t.orders} orders · ${inr(t.revenue)} · ${h12}` +\n (delta ? ` (+${delta.orders} last hr)` : \"\");\n const via = await sendMail(\n to,\n subject,\n renderHtml(m, summary, engine),\n summary + \"\\n\\n\" + JSON.stringify(t),\n );\n return `sent via ${via} [${engine}]: ${subject}`;\n}\n\n// ---------- main ----------\nexport default async function (interval: Interval) {\n const force = (interval as any)?.force === true;\n const now = istParts();\n const isDigest = now.hour === DIGEST_HOUR;\n if (!force && !isDigest && (now.hour < OPEN_HOUR || now.hour > CLOSE_HOUR)) {\n console.log(`${now.hour}:00 IST store closed, skipping`);\n return;\n }\n\n const to = (Deno.env.get(\"EMAIL_TO\") ?? \"\").split(\",\").map((x) => x.trim())\n .filter(Boolean);\n const outlets = outletsFromEnv();\n if (!outlets.length) {\n console.error(\n \"No outlets configured (set OUTLETS json or XPANSE_USERNAME/PASSWORD)\",\n );\n return;\n }\n\n for (const cfg of outlets) {\n try {\n console.log(await runOutlet(cfg, now, isDigest, force, to));\n } catch (e) {\n console.error(`${cfg.name}: FAILED — ${(e as Error).message}`);\n }\n }\n}","// Xpanse Kamla Nagar — hourly sales brief (Val Town cron, runs at :05 every hour UTC = every hour IST)\n// Env vars needed: XPANSE_USERNAME, XPANSE_PASSWORD, EMAIL_TO (comma list)\n// Optional: GEMINI_API_KEY (preferred, header X-goog-api-key) or ANTHROPIC_API_KEY; SMTP_USER + SMTP_PASSWORD (Gmail send)\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst BASE = \"https://franchise.xpansecafe.com/\";\nconst OUTLET = \"Xpanse Kamla Nagar\";\nconst TZ = \"Asia/Kolkata\";\nconst OPEN_HOUR = 8, CLOSE_HOUR = 23; // store hours IST\nconst DIGEST_HOUR = 0; // the midnight run is the end-of-day digest for the day just closed\n\ntype Stats = {\n start: string;\n end: string;\n orders: number;\n revenue: number;\n cancelled: number;\n beverages: number;\n food: number;\n aov: number;\n ok: boolean;\n};\ntype Top = { name: string; category: string; qty: number; revenue: number };\n\n// ---------- date helpers (IST) ----------\nfunction istParts(d = new Date()) {\n const f = new Intl.DateTimeFormat(\"en-GB\", {\n timeZone: TZ,\n year: \"numeric\",\n month: \"2-digit\",\n day: \"2-digit\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n hour12: false,\n weekday: \"short\",\n });\n const p = Object.fromEntries(\n f.formatToParts(d).map((x) => [x.type, x.value]),\n );\n return {\n y: +p.year,\n m: +p.month,\n d: +p.day,\n hour: +p.hour % 24,\n minute: +p.minute,\n wd: p.weekday,\n };\n}\nconst iso = (y: number, m: number, d: number) =>\n `${y}-${String(m).padStart(2, \"0\")}-${String(d).padStart(2, \"0\")}`;\nconst ddmmyyyy = (isoDate: string) => isoDate.split(\"-\").reverse().join(\"-\");\nfunction shift(isoDate: string, days: number) {\n const t = new Date(isoDate + \"T00:00:00Z\");\n t.setUTCDate(t.getUTCDate() + days);\n return t.toISOString().slice(0, 10);\n}\nconst num = (v: unknown) => {\n const n = parseFloat(String(v ?? \"0\").replace(/[₹,\\s]/g, \"\"));\n return isNaN(n) ? 0 : n;\n};\nconst inr = (n: number) => \"₹\" + Math.round(n).toLocaleString(\"en-IN\");\n\n// ---------- panel client ----------\nclass Panel {\n private cookies = new Map();\n private token = \"\";\n constructor(private user: string, private pass: string) {}\n private cookieHeader() {\n return [...this.cookies].map(([k, v]) => `${k}=${v}`).join(\"; \");\n }\n private absorb(r: Response) {\n for (const c of r.headers.getSetCookie?.() ?? []) {\n const [kv] = c.split(\";\");\n const i = kv.indexOf(\"=\");\n this.cookies.set(kv.slice(0, i).trim(), kv.slice(i + 1).trim());\n }\n }\n private async req(path: string, init: RequestInit = {}) {\n const h = new Headers(init.headers as HeadersInit | undefined);\n h.set(\"User-Agent\", \"Mozilla/5.0 (xpanse-sales-monitor)\");\n h.set(\"X-Requested-With\", \"XMLHttpRequest\");\n h.set(\"Accept\", \"application/json, text/javascript, */*; q=0.01\");\n if (this.token) {\n h.set(\"Authorization\", this.token); // data phase: token in header, no Cookie (avoids panel misreading cookie token)\n } else {\n const ck = this.cookieHeader();\n if (ck) h.set(\"Cookie\", ck); // login phase: need _token cookie\n }\n const r = await fetch(BASE + path, {\n ...init,\n redirect: \"manual\",\n headers: h,\n });\n this.absorb(r);\n return r;\n }\n async login() {\n await this.req(\"\");\n const body = new URLSearchParams({\n _token: this.cookies.get(\"_token_cookie\") ?? \"\",\n username: this.user,\n password: this.pass,\n });\n const r = await this.req(\"auth/franchise\", {\n method: \"POST\",\n body,\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n });\n const j = await r.json().catch(() => ({}));\n if (!j.status) {\n throw new Error(\n \"Login failed: \" + JSON.stringify(j.data ?? j).slice(0, 200),\n );\n }\n this.token = j.data.access_token;\n }\n private async get(path: string, params: Record) {\n const q = new URLSearchParams({\n _token: this.cookies.get(\"_token_cookie\") ?? \"\",\n ...params,\n });\n let r = await this.req(`${path}?${q}`);\n if (r.status === 401 || r.status === 403) {\n await this.login();\n r = await this.req(`${path}?${q}`);\n }\n const body = await r.text();\n if (path === \"summary/analytics\" && r.status !== 200) {\n console.log(\n ` analytics http=${r.status} body=${\n body.slice(0, 240).replace(/\\\\s+/g, \" \")\n }`,\n );\n }\n try {\n return JSON.parse(body);\n } catch {\n return { status: false };\n }\n }\n async analytics(start: string, end: string): Promise {\n const j = await this.get(\"summary/analytics\", {\n start_date: ddmmyyyy(start),\n end_date: ddmmyyyy(end),\n });\n const s: Stats = {\n start,\n end,\n orders: 0,\n revenue: 0,\n cancelled: 0,\n beverages: 0,\n food: 0,\n aov: 0,\n ok: !!j.status,\n };\n if (!j.status) return s;\n const p = j.data.params;\n s.orders = Math.round(num(p.ordersCount));\n s.revenue = Math.round(num(p.totalRevenue) * 100) / 100;\n s.cancelled = Math.round(num(p.cancelledOrders));\n s.beverages = Math.round(num(p.beveragesSold));\n s.food = Math.round(num(p.foodSold));\n s.aov = s.orders ? Math.round(s.revenue / s.orders * 100) / 100 : 0;\n return s;\n }\n async topSelling(start: string, end: string): Promise {\n const j = await this.get(\"summary/top-selling\", {\n start_date: ddmmyyyy(start),\n end_date: ddmmyyyy(end),\n });\n if (!j.status) return [];\n return (j.data.list ?? []).map((it: any) => ({\n name: it.name,\n category: it.category,\n qty: Math.round(num(it.totalSoldQuantity)),\n revenue: Math.round(num(it.totalRevenue) * 100) / 100,\n }));\n }\n}\n\n// ---------- snapshots (blob, one array per day) ----------\ntype Snap = { taken_at: string; hour: number; today: Stats; top_today: Top[] };\nconst slugify = (name: string) =>\n name.toLowerCase().replace(/[^a-z0-9]+/g, \"-\").replace(/^-|-$/g, \"\");\nconst dayKey = (slug: string, d: string) => `snap:${slug}:${d}`;\nasync function loadDay(slug: string, d: string): Promise {\n return (await blob.getJSON(dayKey(slug, d))) ?? [];\n}\nasync function snapAtHour(slug: string, d: string, hour: number) {\n let best: Snap | undefined;\n for (const s of await loadDay(slug, d)) if (s.hour <= hour) best = s;\n return best;\n}\n\n// ---------- summary ----------\nfunction ruleBased(m: any): string {\n const t = m.today, y = m.yesterday_full, lines: string[] = [];\n if (m.is_end_of_day_digest && y) {\n const lw = m.closed_day_same_weekday_last_week;\n lines.push(\n `Day closed (${ddmmyyyy(m.closed_day)}): ${y.orders} orders, ${\n inr(y.revenue)\n } revenue, AOV ${inr(y.aov)}.`,\n );\n if (lw?.orders) {\n const d = y.revenue - lw.revenue;\n lines.push(\n `- ${inr(Math.abs(d))} ${\n d >= 0 ? \"ahead of\" : \"behind\"\n } same weekday last week (${lw.orders} orders, ${inr(lw.revenue)}).`,\n );\n }\n if (y.cancelled) lines.push(`- Cancellations: ${y.cancelled}.`);\n lines.push(`- Beverages ${y.beverages} / Food ${y.food}.`);\n if (m.mtd?.orders) {\n lines.push(\n `- Month to date: ${m.mtd.orders} orders, ${inr(m.mtd.revenue)}.`,\n );\n }\n if (m.top_closed_day?.length) {\n lines.push(\n \"- Top sellers: \" + m.top_closed_day.slice(0, 3).map((x: Top) =>\n `${x.name} (${x.qty})`\n ).join(\", \") + \".\",\n );\n }\n return lines.join(\"\\n\");\n }\n if (t.orders === 0 && y?.orders) {\n lines.push(\n `No orders yet today. Yesterday closed at ${y.orders} orders, ${\n inr(y.revenue)\n } revenue, AOV ${inr(y.aov)}.`,\n );\n } else {lines.push(\n `Today so far: ${t.orders} orders, ${inr(t.revenue)} revenue, AOV ${\n inr(t.aov)\n }.`,\n );}\n if (m.mtd?.orders) {\n lines.push(\n `- Month to date: ${m.mtd.orders} orders, ${inr(m.mtd.revenue)}.`,\n );\n }\n if (m.delta_last_hour) {\n lines.push(\n `- Last hour: +${m.delta_last_hour.orders} orders, +${\n inr(m.delta_last_hour.revenue)\n }.`,\n );\n }\n const ys = m.yesterday_same_hour;\n if (ys) {\n const diff = t.revenue - ys.revenue;\n lines.push(\n `- ${inr(Math.abs(diff))} ${\n diff >= 0 ? \"ahead of\" : \"behind\"\n } yesterday at this hour (${ys.orders} orders then).`,\n );\n }\n const lw = m.same_weekday_last_week_full;\n if (lw?.orders) {\n lines.push(\n `- Same weekday last week closed at ${lw.orders} orders / ${\n inr(lw.revenue)\n }.`,\n );\n }\n if (t.cancelled) lines.push(`- Cancellations today: ${t.cancelled}.`);\n if (m.top_today?.length) {\n lines.push(\n \"- Top sellers: \" + m.top_today.slice(0, 3).map((x: Top) =>\n `${x.name} (${x.qty})`\n ).join(\", \") + \".\",\n );\n }\n return lines.join(\"\\n\");\n}\n\nconst SYSTEM =\n `You write hourly sales briefs for the owner of a single Xpanse Cafe franchise outlet in India.\nYou get a JSON bundle of metrics computed by code (do not recompute or invent numbers; quote them as given).\nWrite for a busy owner reading on a phone:\n- 1 headline sentence with the single most important fact right now.\n- 3 to 5 short bullets: last-hour movement, today vs yesterday at the same hour, today vs same weekday last week, cancellations/AOV if notable, top seller shifts.\n- If is_end_of_day_digest is true, this is the closing report for closed_day: lead with yesterday_full, compare with closed_day_same_weekday_last_week, use top_closed_day.\n- End with at most 2 \"watch\" items or suggested actions, only if the data supports them.\nCurrency is INR (₹). Be concrete and terse. No preamble, no sign-off, no markdown headers. Use plain '-' bullets.`;\n\nasync function summarizeGemini(m: any, key: string): Promise<[string, string]> {\n const model = Deno.env.get(\"GEMINI_MODEL\") || \"gemini-flash-latest\";\n const url =\n `https://generativelanguage.googleapis.com/v1beta/models/${model}:generateContent`;\n const r = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", \"X-goog-api-key\": key },\n body: JSON.stringify({\n system_instruction: { parts: [{ text: SYSTEM }] },\n contents: [{ role: \"user\", parts: [{ text: JSON.stringify(m) }] }],\n generationConfig: { temperature: 0.3, maxOutputTokens: 1200 },\n }),\n });\n if (!r.ok) {\n throw new Error(\n `Gemini HTTP ${r.status}: ${(await r.text()).slice(0, 160)}`,\n );\n }\n const j = await r.json();\n const text = (j.candidates?.[0]?.content?.parts ?? []).map((p: any) =>\n p.text ?? \"\"\n ).join(\"\").trim();\n return [text || ruleBased(m), model];\n}\n\nasync function summarizeClaude(m: any): Promise<[string, string]> {\n const { default: Anthropic } = await import(\"npm:@anthropic-ai/sdk\");\n const client = new Anthropic();\n const model = Deno.env.get(\"CLAUDE_MODEL\") || \"claude-opus-5\";\n const resp = await client.messages.create(\n {\n model,\n max_tokens: 4000,\n thinking: { type: \"adaptive\" },\n output_config: { effort: \"low\" },\n system: SYSTEM,\n messages: [{ role: \"user\", content: JSON.stringify(m) }],\n } as any,\n );\n if (resp.stop_reason === \"refusal\") {\n return [ruleBased(m), \"rules (model declined)\"];\n }\n const text = resp.content.filter((b: any) => b.type === \"text\").map((\n b: any,\n ) => b.text).join(\"\").trim();\n return [text || ruleBased(m), model];\n}\n\nasync function summarize(m: any): Promise<[string, string]> {\n const gem = Deno.env.get(\"GEMINI_API_KEY\"),\n ant = Deno.env.get(\"ANTHROPIC_API_KEY\");\n try {\n if (gem) return await summarizeGemini(m, gem); // Gemini preferred if its key is set\n if (ant) return await summarizeClaude(m);\n return [ruleBased(m), \"rules\"];\n } catch (e) {\n return [\n ruleBased(m),\n \"rules (fallback: \" + String((e as Error).message).slice(0, 80) + \")\",\n ];\n }\n}\n\n// ---------- email ----------\nconst esc = (s: unknown) =>\n String(s).replace(\n /[&<>\"]/g,\n (c) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\" }[c]!),\n );\nfunction renderHtml(m: any, summary: string, engine: string) {\n const t = m.today,\n row = (l: string, v: string) =>\n `${l}${v}`;\n if (m.is_end_of_day_digest) {\n const y = m.yesterday_full;\n const rows = [\n row(\"Orders\", `${y.orders}`),\n row(\"Revenue\", inr(y.revenue)),\n row(\"AOV\", inr(y.aov)),\n row(\"Cancelled\", `${y.cancelled}`),\n row(\"Beverages / Food\", `${y.beverages} / ${y.food}`),\n ];\n const lw = m.closed_day_same_weekday_last_week;\n if (lw?.orders) {\n rows.push(\n row(\n \"Same weekday last week\",\n `${lw.orders} orders \\u00b7 ${inr(lw.revenue)}`,\n ),\n );\n }\n if (m.mtd?.orders) {\n rows.push(\n row(\n \"Month to date\",\n `${m.mtd.orders} orders \\u00b7 ${inr(m.mtd.revenue)}`,\n ),\n );\n }\n const top = (m.top_closed_day ?? []).slice(0, 8).map((x: Top) =>\n `${\n esc(x.name)\n } (${\n esc(x.category)\n })${x.qty}${\n inr(x.revenue)\n }`\n ).join(\"\");\n return `

${\n esc(m.outlet)\n } \\u2014 day closed

${\n ddmmyyyy(m.closed_day)\n }

${\n summary.split(\"\\n\").map(esc).join(\"
\")\n }

${\n rows.join(\"\")\n }

${\n top\n ? `

Top sellers

${top}

`\n : \"\"\n }

Summary by ${\n esc(engine)\n } \\u00b7 Val Town cron

${\n esc(m.outlet)\n }

${\n esc(m.taken_at_human)\n }

${\n summary.split(\"\\n\").map(esc).join(\"
\")\n }

\n${\n rows.join(\"\")\n }

\n${\n top\n ? `

Top sellers today

${top}

`\n : \"\"\n }\n

Summary by ${\n esc(engine)\n } · franchise.xpansecafe.com · Val Town cron, hourly

Diff · v21