\\n

Xpanse

\\n

loading\\u2026

\\n

\\n \\n From to \\n

\\n

Today

\\n

\\n\\n

Month against the \\u20b920 lakh target

\\n

\\n\\n

Live

\\n

Orders by hour today vs yesterday vs same weekday last week

\\n

Top sellers today

\\n

\\n\\n

Trend

\\n

Orders and net revenue per day

\\n

AOV and discount depth

\\n

New vs returning orders per day returning share on the right axis

\\n

Food attach, kiosk share, FIRST69 share

\\n

\\n\\n

Customers

\\n

Weekly cohorts share of new customers who ordered again within 7 / 14 / 30 days

\\n

Orders per customer

\\n

\\n\\n

Mix

\\n

Coupons orders \\u00b7 net AOV

\\n

Categories items

\\n

Top items quantity

\\n

Average orders by weekday and hour closed days in window

\\n

Bought together

\\n

\\n\\n

Other outlets

\\n

\\n\\n\\n\\n\";","label",[134],"8fa3c193-09c3-4b4a-8e4b-c4b1c21aac99","smtp.ts","911d8ce0-aeba-11f1-9863-1607ee4eb77e",33,["D",1789225174687],"// Minimal SMTP client for Gmail app-password auth.\n// Implicit TLS when SMTP_PORT=465, otherwise plain connect + STARTTLS.\nconst enc = new TextEncoder();\nconst dec = new TextDecoder();\n\nfunction b64(s: string): string {\n const bytes = enc.encode(s);\n let bin = \"\";\n for (const b of bytes) bin += String.fromCharCode(b);\n return btoa(bin);\n}\n\nfunction b64Wrapped(s: string): string {\n const b = b64(s);\n const lines: string[] = [];\n for (let i = 0; i < b.length; i += 76) lines.push(b.slice(i, i + 76));\n return lines.join(\"\\r\\n\");\n}\n\nclass Smtp {\n conn: any;\n buf = new Uint8Array(65536);\n filled = 0;\n constructor(conn: any) { this.conn = conn; }\n async readLine(): Promise {\n for (;;) {\n const idx = this.buf.subarray(0, this.filled).indexOf(10);\n if (idx >= 0) {\n const line = dec.decode(this.buf.subarray(0, idx + 1));\n this.buf.copyWithin(0, idx + 1, this.filled);\n this.filled -= idx + 1;\n return line;\n }\n const n = await this.conn.read(this.buf.subarray(this.filled));\n if (n === null) throw new Error(\"smtp: connection closed\");\n this.filled += n;\n }\n }\n async reply(): Promise {\n let out = \"\";\n for (;;) {\n const line = await this.readLine();\n out += line;\n if (/^\\d{3} /.test(line)) return out;\n if (!/^\\d{3}-/.test(line)) return out;\n }\n }\n async cmd(c: string): Promise {\n await this.conn.write(enc.encode(c + \"\\r\\n\"));\n return await this.reply();\n }\n close() { try { this.conn.close(); } catch { /* ignore */ } }\n}\n\nexport interface Mail { from: string; to: string[]; subject: string; text: string; }\n\nexport async function sendMail(m: Mail): Promise {\n const host = Deno.env.get(\"SMTP_HOST\") ?? \"smtp.gmail.com\";\n const port = +(Deno.env.get(\"SMTP_PORT\") ?? \"587\");\n const user = Deno.env.get(\"SMTP_USER\") ?? \"\";\n const pass = (Deno.env.get(\"SMTP_PASSWORD\") ?? \"\").replace(/\\s+/g, \"\");\n if (!user || !pass) throw new Error(\"smtp: SMTP_USER/SMTP_PASSWORD missing\");\n const s = new Smtp(port === 465\n ? await Deno.connectTls({ hostname: host, port })\n : await Deno.connect({ hostname: host, port }));\n const expect = (r: string, ok: number[], what: string) => {\n const code = +(r.slice(0, 3) || 0);\n if (!ok.includes(code)) throw new Error(`smtp ${what}: ${r.trim().slice(0, 200)}`);\n };\n try {\n expect(await s.reply(), [220], \"banner\");\n expect(await s.cmd(\"EHLO val-town\"), [250], \"ehlo\");\n if (port !== 465) {\n expect(await s.cmd(\"STARTTLS\"), [220], \"starttls\");\n s.conn = await Deno.startTls(s.conn, { hostname: host });\n s.filled = 0;\n expect(await s.cmd(\"EHLO val-town\"), [250], \"ehlo-tls\");\n }\n expect(await s.cmd(\"AUTH LOGIN\"), [334], \"auth\");\n expect(await s.cmd(b64(user)), [334], \"user\");\n expect(await s.cmd(b64(pass)), [235], \"pass\");\n expect(await s.cmd(`MAIL FROM:<${m.from}>`), [250], \"mail-from\");\n for (const rcpt of m.to) expect(await s.cmd(`RCPT TO:<${rcpt}>`), [250, 251], \"rcpt\");\n expect(await s.cmd(\"DATA\"), [354], \"data\");\n const headers = [\n `From: ${m.from}`,\n `To: ${m.to.join(\", \")}`,\n `Subject: =?UTF-8?B?${b64(m.subject)}?=`,\n `Date: ${new Date().toUTCString()}`,\n \"MIME-Version: 1.0\",\n 'Content-Type: text/plain; charset=\"UTF-8\"',\n \"Content-Transfer-Encoding: base64\",\n ].join(\"\\r\\n\");\n expect(await s.cmd(headers + \"\\r\\n\\r\\n\" + b64Wrapped(m.text) + \"\\r\\n.\"), [250], \"body\");\n await s.cmd(\"QUIT\").catch(() => \"\");\n } finally {\n s.close();\n }\n}",[146],"9a3c0ba3-6b25-4b52-8bb7-fc4539b6b4de","report.ts","914ea44c-aeba-11f1-a7cf-1607ee4eb77e",36,["D",1789225226792],1,"// Xpanse hourly + close report builder/sender (replaces the Mac Python client).\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport {\n ddmmyyyy,\n hourOf,\n inr,\n isLive,\n loadDays,\n monthFirst,\n net,\n Panel,\n salt,\n sha,\n shift,\n slim,\n slugify,\n summarizeDay,\n topItems,\n} from \"./lib.ts\";\nimport { sendMail } from \"./smtp.ts\";\n\nconst store = {\n get: (k: string) => blob.getJSON(k),\n set: (k: string, v: unknown) => blob.setJSON(k, v),\n};\n\nexport interface RunOpts {\n mode?: \"auto\" | \"hourly\" | \"close\";\n toOverride?: string[];\n subjectPrefix?: string;\n dateOverride?: string; // test harness only\n}\n\n// ONE shared closing-date variable: prose and the trailing JSON both read this.\nexport function closingDateFor(now: any, isClose: boolean): string {\n return isClose ? shift(now.date, -1) : now.date;\n}\n\nexport async function runOutlet(o: any, now: any, opts: RunOpts = {}) {\n const isClose = opts.mode === \"close\" ? true : opts.mode === \"hourly\" ? false : now.hour === 0;\n const closingDate = opts.dateOverride ?? closingDateFor(now, isClose);\n const slug = slugify(o.name);\n const panel = new Panel(o.username, o.password);\n await panel.login();\n\n // Hard-fail guard: check the panel's raw status for the closing date before composing anything.\n const raw = await panel.get(\"summary/orders/get\", { date: ddmmyyyy(closingDate) });\n if (!raw.status) {\n if (isClose) {\n throw new Error(\n `guard: panel returned status:false for closing date ${closingDate} (${raw?.data?.title ?? \"unknown\"}) - close report skipped, no zeroed payload sent`,\n );\n }\n // Hourly on today's date: status:false can simply mean \"no orders yet\". Verify the API is\n // healthy by checking yesterday before treating zeros as truthful.\n const y = await panel.get(\"summary/orders/get\", { date: ddmmyyyy(shift(now.date, -1)) });\n if (!y.status) {\n throw new Error(`guard: panel unhealthy - ${closingDate} and ${shift(now.date, -1)} both status:false - report skipped`);\n }\n }\n const rawList = raw.status ? (raw?.data?.list ?? []) : [];\n const closingOrders = await Promise.all(\n rawList.map(async (x: any) => slim(x, await sha(salt() + (x.userPhone ?? \"\")))),\n );\n if (isClose && closingOrders.length === 0) {\n throw new Error(`guard: closing date ${closingDate} has zero orders - refusing to send a zeroed close report`);\n }\n\n const winStart = [monthFirst(closingDate), shift(closingDate, -7)].sort()[0];\n const days = await loadDays(panel, slug, winStart, closingDate, now.date, salt(), store);\n days[closingDate] = closingOrders; // fresh guarded data wins over any cached copy\n if (closingDate < now.date) {\n try {\n await store.set(`xp:${slug}:${closingDate}`, closingOrders);\n } catch { /* cache best-effort */ }\n }\n\n const d = summarizeDay(closingOrders);\n const lw = summarizeDay(days[shift(closingDate, -7)] ?? []);\n let mtdOrders = 0, mtdRevenue = 0;\n for (let dd = monthFirst(closingDate); dd <= closingDate; dd = shift(dd, 1)) {\n const s = summarizeDay(days[dd] ?? []);\n mtdOrders += s.orders;\n mtdRevenue += s.revenue;\n }\n mtdRevenue = +mtdRevenue.toFixed(2);\n const tops = topItems(closingOrders, 3);\n const topStr = tops.length ? tops.map((t: any) => `${t.name} (${t.qty})`).join(\", \") : \"none yet\";\n\n let subject: string;\n const lines: string[] = [];\n if (isClose) {\n const diff = +(d.revenue - lw.revenue).toFixed(2);\n subject = `${o.name} — day closed: ${d.orders} orders · ${inr(d.revenue)}`;\n lines.push(\n `Day closed: ${d.orders} orders, ${inr(d.revenue)} revenue, AOV ${inr(d.aov)}.`,\n `- ${inr(Math.abs(diff))} ${diff >= 0 ? \"ahead of\" : \"behind\"} same weekday last week (${lw.orders} orders).`,\n `- Month to date: ${mtdOrders} orders, ${inr(mtdRevenue)}.`,\n `- Top sellers: ${topStr}.`,\n );\n } else {\n const h = now.hour;\n const hh = ((h + 11) % 12) + 1, ap = h < 12 ? \"AM\" : \"PM\";\n const lh = closingOrders.filter((x: any) => isLive(x) && hourOf(x) === (h + 23) % 24);\n const lhRev = +lh.reduce((a: number, x: any) => a + net(x), 0).toFixed(2);\n subject = `${o.name}: ${d.orders} orders · ${inr(d.revenue)} · ${hh} ${ap} (+${lh.length} last hr)`;\n lines.push(\n `Today so far: ${d.orders} orders, ${inr(d.revenue)} revenue, AOV ${inr(d.aov)}.`,\n `- Month to date: ${mtdOrders} orders, ${inr(mtdRevenue)}.`,\n `- Last hour: +${lh.length} orders, +${inr(lhRev)}.`,\n `- Same weekday last week closed at ${lw.orders} orders / ${inr(lw.revenue)}.`,\n `- Top sellers: ${topStr}.`,\n );\n }\n\n // Prose and JSON both come from closingDate + d; they can never disagree.\n const json = `{\"start\": \"${closingDate}\", \"end\": \"${closingDate}\", \"orders\": ${d.orders}, \"revenue\": ${d.revenue}, \"cancelled\": ${d.cancelled}, \"beverages\": ${d.beverages}, \"food\": ${d.food}, \"aov\": ${d.aov}, \"ok\": true}`;\n const text = lines.join(\"\\n\") + \"\\n\\n\" + json;\n\n const to = opts.toOverride ??\n (Deno.env.get(\"EMAIL_TO\") ?? \"\").split(/[,;]/).map((x) => x.trim()).filter(Boolean);\n if (!to.length) throw new Error(\"EMAIL_TO is empty\");\n const from = Deno.env.get(\"EMAIL_FROM\") ?? Deno.env.get(\"SMTP_USER\") ?? \"\";\n const finalSubject = (opts.subjectPrefix ?? \"\") + subject;\n await sendMail({ from, to, subject: finalSubject, text });\n return { outlet: o.name, mode: isClose ? \"close\" : \"hourly\", closingDate, subject: finalSubject, orders: d.orders, revenue: d.revenue, recipients: to.length };\n}",[153],"24efb342-22a3-4ebf-a565-ab41f0f371f6","new-file-5192.ts",27,["D",1789163947156],5,"// Val Town HTTP val: the live dashboard. GET /?key=DASH_KEY (outlet tabs + 14/30/60/90 days in the page)\n// JSON: GET /api/data?key=...&outlet=&days=30\n// Closed days are cached in blob forever; today is fetched live from the panel (memoised 60 s).\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { buildDashboard, outletsFromEnv, Panel, slugify } from \"./lib.ts\";\nimport { TEMPLATE } from \"./template.ts\";\n\nconst store = {\n get: (k: string) => blob.getJSON(k),\n set: (k: string, v: any) => blob.setJSON(k, v),\n};\nconst panels = new Map();\nconst cache = new Map();\n\nasync function panelFor(slug: string) {\n if (!panels.has(slug)) {\n const o = outletsFromEnv().find((x) => slugify(x.name) === slug)!;\n const p = new Panel(o.username, o.password);\n await p.login();\n panels.set(slug, p);\n }\n return panels.get(slug)!;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const key = Deno.env.get(\"DASH_KEY\");\n const given = url.searchParams.get(\"key\") ?? req.headers.get(\"x-dash-key\") ??\n \"\";\n if (key && given !== key) {\n return new Response(\n url.pathname.startsWith(\"/api/\")\n ? JSON.stringify({ error: \"unauthorised\" })\n : \"Add ?key=YOUR_KEY to the address.\",\n {\n status: 401,\n headers: {\n \"content-type\": url.pathname.startsWith(\"/api/\")\n ? \"application/json\"\n : \"text/plain\",\n },\n },\n );\n }\n if (url.pathname === \"/api/data\") {\n const outlets = outletsFromEnv();\n const slug = url.searchParams.get(\"outlet\") || slugify(outlets[0].name);\n const ndays = Math.max(\n 7,\n Math.min(120, +(url.searchParams.get(\"days\") ?? 30)),\n );\n const iso = (v: string | null) =>\n v && /^\\d{4}-\\d{2}-\\d{2}$/.test(v) ? v : undefined;\n const from = iso(url.searchParams.get(\"from\")),\n to = iso(url.searchParams.get(\"to\"));\n const mode = url.searchParams.get(\"mode\") === \"today\" ? \"today\" : \"period\";\n const ck = `${slug}:${mode}:${from ?? \"\"}:${to ?? \"\"}`;\n const hit = cache.get(ck);\n let data = hit && Date.now() - hit.at < 60_000 ? hit.data : null;\n if (!data) {\n try {\n data = await buildDashboard(\n slug,\n ndays,\n store,\n panelFor,\n from,\n to,\n mode,\n );\n cache.set(ck, { at: Date.now(), data });\n } catch (e) {\n return new Response(\n JSON.stringify({\n error: `${(e as Error).name}: ${(e as Error).message}`,\n }),\n { status: 500, headers: { \"content-type\": \"application/json\" } },\n );\n }\n }\n return new Response(JSON.stringify(data), {\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n }\n return new Response(TEMPLATE, {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n}","xpanse-dashboard",[161],"2a05ffa8-fa30-43f9-afe7-a708de614d10","main.ts","ab88dccc-ae26-11f1-88d3-1607ee4eb77e",38,["D",1789229140644],"interval","// Xpanse hourly sales reports + midnight close report (replaces the Mac Python client).\n// Schedule (Val Town cron UI): 35 5-18 * * * UTC = hourly 11:05 AM-11:05 PM IST + 12:05 AM close.\nimport { email as alertEmail } from \"https://esm.town/v/std/email\";\nimport { istNow, outletsFromEnv } from \"./lib.ts\";\nimport { runOutlet } from \"./report.ts\";\n\nexport default async function () {\n const now = istNow();\n const failures: string[] = [];\n const sent: string[] = [];\n for (const o of outletsFromEnv()) {\n try {\n const r = await runOutlet(o, now);\n sent.push(r.subject);\n console.log(\"sent:\", r.subject);\n } catch (e: any) {\n failures.push(`${o.name}: ${e?.message ?? e}`);\n console.error(`FAILED ${o.name}:`, e?.stack ?? e);\n }\n }\n if (failures.length) {\n console.error(\"failures:\", failures);\n try {\n await alertEmail({\n subject: `Xpanse monitor: ${failures.length} report(s) skipped on ${now.date}`,\n text:\n \"These reports were NOT sent (data guard tripped or fetch/send failed). No zeroed payload was sent.\\n\\n\" +\n failures.join(\"\\n\\n\"),\n });\n } catch (e) {\n console.error(\"alert email failed\", e);\n }\n }\n console.log(`done: ${sent.length} sent, ${failures.length} skipped`);\n}",[169],"59978d3f-639b-4cee-b410-cca9562f15e6","lib.ts","b6ee60a0-ae26-11f1-ba7d-1607ee4eb77e",32,["D",1789225171018],7,"// Xpanse shared library for Val Town: panel client, blob-cached day loader, metrics, report builders,\n// email rendering. Pure Deno/TS, no external deps except Val Town std (imported by the glue vals).\n//\n// Order shape (from summary/orders/get): createdDate, createdTime \"HH:MM:SS\", orderStatus, source,\n// coupon, userPhone (we hash it before storing), totalQuantity, grandTotal, totalTaxable, totalDiscount,\n// orderItems[{name, category, quantity, grandTotal, addons[{selectedValue}]}]\n\nexport type Order = Record;\nexport type Days = Record;\n\nexport const BASE = \"https://franchise.xpansecafe.com/\";\nexport const TZ = \"Asia/Kolkata\";\nexport const SLOTS = [9, 12, 15, 18, 21];\nexport const FOOD_CATS = new Set([\n \"Snacks\",\n \"Pizzap\",\n \"Bakes\",\n \"Sandwich\",\n \"Meal Deal\",\n \"₹149 Combo\",\n]);\nconst NON_BEV = new Set([...FOOD_CATS, \"Extras\"]);\nconst CANCELLED = new Set([\"CANCELLED\", \"REJECTED\", \"FAILED\"]);\n\n// ---------- time helpers (IST) ----------\nexport function istNow(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 second: \"2-digit\",\n hour12: false,\n weekday: \"short\",\n });\n const p: Record = Object.fromEntries(\n f.formatToParts(d).map((x) => [x.type, x.value]),\n );\n const date = `${p.year}-${p.month}-${p.day}`;\n return {\n date,\n hour: +p.hour % 24,\n minute: +p.minute,\n wd: p.weekday,\n human: humanDateTime(d),\n };\n}\nexport function humanDateTime(d = new Date()) {\n return new Intl.DateTimeFormat(\"en-IN\", {\n timeZone: TZ,\n weekday: \"short\",\n day: \"2-digit\",\n month: \"short\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n hour12: true,\n }).format(d);\n}\nexport const shift = (iso: string, days: number) => {\n const t = new Date(iso + \"T00:00:00Z\");\n t.setUTCDate(t.getUTCDate() + days);\n return t.toISOString().slice(0, 10);\n};\nexport const ddmmyyyy = (iso: string) => iso.split(\"-\").reverse().join(\"-\");\nexport const dow = (iso: string) =>\n [\n \"Sun\",\n \"Mon\",\n \"Tue\",\n \"Wed\",\n \"Thu\",\n \"Fri\",\n \"Sat\",\n ][new Date(iso + \"T00:00:00Z\").getUTCDay()];\nexport const dowLong = (iso: string) =>\n [\n \"Sunday\",\n \"Monday\",\n \"Tuesday\",\n \"Wednesday\",\n \"Thursday\",\n \"Friday\",\n \"Saturday\",\n ][new Date(iso + \"T00:00:00Z\").getUTCDay()];\nexport const weekday0 = (iso: string) =>\n (new Date(iso + \"T00:00:00Z\").getUTCDay() + 6) % 7; // Mon=0\nexport const monthFirst = (iso: string) => iso.slice(0, 8) + \"01\";\nexport const daysInMonth = (iso: string) =>\n new Date(Date.UTC(+iso.slice(0, 4), +iso.slice(5, 7), 0)).getUTCDate();\nexport const humanDay = (iso: string) =>\n `${dowLong(iso)} ${+iso.slice(8, 10)} ${\n [\n \"Jan\",\n \"Feb\",\n \"Mar\",\n \"Apr\",\n \"May\",\n \"Jun\",\n \"Jul\",\n \"Aug\",\n \"Sep\",\n \"Oct\",\n \"Nov\",\n \"Dec\",\n ][+iso.slice(5, 7) - 1]\n }`;\nexport const inr = (n: number) =>\n \"₹\" + Math.round(n || 0).toLocaleString(\"en-IN\");\nexport const pct = (x: number) => `${Math.round((x || 0) * 100)}%`;\nexport const num = (v: unknown) => {\n const n = parseFloat(String(v ?? \"0\").replace(/[₹,\\s]/g, \"\"));\n return isNaN(n) ? 0 : n;\n};\nexport const slugify = (s: string) =>\n s.toLowerCase().replace(/[^a-z0-9]+/g, \"-\").replace(/^-|-$/g, \"\");\nconst esc = (s: unknown) =>\n String(s ?? \"\").replace(\n /[&<>\"']/g,\n (\n c,\n ) => ({\n \"&\": \"&\",\n \"<\": \"<\",\n \">\": \">\",\n '\"': \""\",\n \"'\": \"'\",\n }[c] as string),\n );\n\nexport async function sha(s: string) {\n const b = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(s));\n return [...new Uint8Array(b)].slice(0, 6).map((x) =>\n x.toString(16).padStart(2, \"0\")\n ).join(\"\");\n}\n\n// ---------- panel client ----------\n// The panel (Apache + PHP) reads the auth header case-sensitively as \"Authorization\" and speaks HTTP/1.1 only.\n// Deno's fetch lowercases header names, so we write the HTTP/1.1 request ourselves over a TLS socket.\nexport interface RawResponse {\n status: number;\n headers: Record;\n setCookies: string[];\n body: string;\n}\nconst HOST = new URL(BASE).hostname;\n\nexport async function rawRequest(\n method: string,\n path: string,\n headers: Record,\n body = \"\",\n): Promise {\n const conn = await Deno.connectTls({ hostname: HOST, port: 443 });\n const enc = new TextEncoder(), dec = new TextDecoder();\n const lines = [\n `${method} ${path} HTTP/1.1`,\n `Host: ${HOST}`,\n \"Connection: close\",\n \"Accept-Encoding: identity\",\n ...Object.entries(headers).map(([k, v]) => `${k}: ${v}`),\n ];\n if (body) lines.push(`Content-Length: ${enc.encode(body).byteLength}`);\n await conn.write(enc.encode(lines.join(\"\\r\\n\") + \"\\r\\n\\r\\n\" + body));\n const chunks: Uint8Array[] = [];\n const buf = new Uint8Array(65536);\n while (true) {\n const n = await conn.read(buf);\n if (n === null) break;\n chunks.push(buf.slice(0, n));\n }\n conn.close();\n const total = new Uint8Array(chunks.reduce((a, c) => a + c.length, 0));\n let off = 0;\n for (const c of chunks) {\n total.set(c, off);\n off += c.length;\n }\n const raw = dec.decode(total);\n const sep = raw.indexOf(\"\\r\\n\\r\\n\");\n const head = raw.slice(0, sep).split(\"\\r\\n\");\n let bodyText = raw.slice(sep + 4);\n const status = +(head[0].split(\" \")[1] ?? \"0\");\n const hdrs: Record = {};\n const setCookies: string[] = [];\n for (const l of head.slice(1)) {\n const i = l.indexOf(\":\");\n if (i < 0) continue;\n const k = l.slice(0, i).trim().toLowerCase(), v = l.slice(i + 1).trim();\n if (k === \"set-cookie\") setCookies.push(v);\n else hdrs[k] = v;\n }\n if ((hdrs[\"transfer-encoding\"] ?? \"\").includes(\"chunked\")) {\n // decode chunked body (work on bytes to keep multi-byte characters intact)\n const bytes = total.slice(sep + 4);\n let pos = 0;\n const out: number[] = [];\n while (pos < bytes.length) {\n let le = pos;\n while (le < bytes.length && !(bytes[le] === 13 && bytes[le + 1] === 10)) {\n le++;\n }\n const size = parseInt(\n dec.decode(bytes.slice(pos, le)).split(\";\")[0].trim(),\n 16,\n );\n if (!size) break;\n pos = le + 2;\n for (let i = 0; i < size; i++) out.push(bytes[pos + i]);\n pos += size + 2;\n }\n bodyText = dec.decode(new Uint8Array(out));\n }\n return { status, headers: hdrs, setCookies, body: bodyText };\n}\n\nexport class 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: RawResponse) {\n for (const c of r.setCookies) {\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(\n method: string,\n path: string,\n extra: Record = {},\n body = \"\",\n ) {\n const r = await rawRequest(method, \"/\" + path, {\n \"User-Agent\": \"Mozilla/5.0 (xpanse-sales-monitor)\",\n \"X-Requested-With\": \"XMLHttpRequest\",\n Accept: \"application/json, text/javascript, */*; q=0.01\",\n Cookie: this.cookieHeader(),\n ...(this.token ? { Authorization: this.token } : {}),\n ...extra,\n }, body);\n this.absorb(r);\n return r;\n }\n async login() {\n await this.req(\"GET\", \"\");\n const body = new URLSearchParams({\n _token: this.cookies.get(\"_token_cookie\") ?? \"\",\n username: this.user,\n password: this.pass,\n }).toString();\n const r = await this.req(\"POST\", \"auth/franchise\", {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n }, body);\n let j: any = {};\n try {\n j = JSON.parse(r.body);\n } catch {\n throw new Error(\n `login non-JSON (HTTP ${r.status}): ${r.body.slice(0, 160)}`,\n );\n }\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 async get(path: string, params: Record) {\n if (!this.token) await this.login();\n const q = new URLSearchParams({\n _token: this.cookies.get(\"_token_cookie\") ?? \"\",\n ...params,\n });\n let r = await this.req(\"GET\", `${path}?${q}`);\n if (r.status === 401 || r.status === 403) {\n await this.login();\n r = await this.req(\"GET\", `${path}?${q}`);\n }\n try {\n return { http: r.status, ...JSON.parse(r.body) };\n } catch {\n return {\n http: r.status,\n status: false,\n data: { title: \"non-JSON\", message: r.body.slice(0, 120) },\n };\n }\n }\n async orders(iso: string, salt: string): Promise {\n const j = await this.get(\"summary/orders/get\", { date: ddmmyyyy(iso) });\n if (\n !j.status &&\n (j.http >= 500 || j.data?.title === \"Service Failure\" ||\n j.data?.title === \"non-JSON\")\n ) {\n throw new Error(\n `orders ${iso}: HTTP ${j.http} ${j.data?.title}: ${j.data?.message}`,\n );\n }\n const list: Order[] = j.status ? (j.data?.list ?? []) : [];\n return Promise.all(\n list.map(async (o) => slim(o, await sha(salt + (o.userPhone ?? \"\")))),\n );\n }\n}\n\n// keep only what the maths needs; phone replaced by a salted hash\nexport function slim(o: Order, ph: string): Order {\n return {\n createdDate: o.createdDate,\n createdTime: o.createdTime,\n orderStatus: o.orderStatus,\n source: o.source,\n coupon: o.coupon,\n userPhone: o.userPhone ? ph : null,\n totalQuantity: o.totalQuantity,\n grandTotal: num(o.grandTotal),\n totalTaxable: num(o.totalTaxable),\n totalDiscount: num(o.totalDiscount),\n orderItems: (o.orderItems ?? []).map((it: any) => ({\n name: (it.name ?? \"\").trim(),\n category: it.category ?? \"\",\n quantity: +it.quantity || 1,\n grandTotal: num(it.grandTotal),\n addons: (it.addons ?? []).map((a: any) => ({\n selectedValue: a?.selectedValue,\n })),\n })),\n };\n}\n\n// ---------- blob-cached loader ----------\nexport interface Store {\n get(key: string): Promise;\n set(key: string, v: any): Promise;\n}\n\nexport async function loadDays(\n panel: Panel,\n slug: string,\n start: string,\n end: string,\n today: string,\n salt: string,\n store: Store,\n concurrency = 8,\n): Promise {\n const out: Days = {};\n const dates: string[] = [];\n for (let d = start; d <= end; d = shift(d, 1)) dates.push(d);\n const cached = await Promise.all(\n dates.map((d) =>\n d < today\n ? store.get(`xp:${slug}:${d}`).catch(() => null)\n : Promise.resolve(null)\n ),\n );\n const missing: string[] = [];\n dates.forEach((d, i) => {\n if (cached[i]) out[d] = cached[i];\n else missing.push(d);\n });\n // fetch missing days in parallel batches (each is its own TLS connection; the panel copes fine with 8 at a time)\n for (let i = 0; i < missing.length; i += concurrency) {\n const batch = missing.slice(i, i + concurrency);\n const got = await Promise.all(batch.map((d) => panel.orders(d, salt)));\n await Promise.all(batch.map((d, j) => {\n out[d] = got[j];\n return d < today\n ? store.set(`xp:${slug}:${d}`, got[j])\n : Promise.resolve();\n }));\n }\n return out;\n}\n\n// ---------- metrics ----------\nexport const isLive = (o: Order) =>\n !CANCELLED.has((o.orderStatus ?? \"\").toUpperCase());\nexport const hourOf = (o: Order) => +((o.createdTime ?? \"00\").slice(0, 2));\nexport const isRefCode = (c: string | null) =>\n !!c && c.length === 8 && /^[A-Za-z]{4}\\d{4}$/.test(c);\nexport const couponClass = (c: string | null) =>\n c == null\n ? \"No coupon\"\n : c === \"FIRST69\"\n ? \"FIRST69\"\n : (c === \"REFER69\" || isRefCode(c))\n ? \"Referral\"\n : \"Other promo\";\nexport const net = (o: Order) => +o.grandTotal || 0;\n\nexport function summarizeDay(orders: Order[], upToHour?: number) {\n let live = orders.filter(isLive);\n if (upToHour != null) live = live.filter((o) => hourOf(o) <= upToHour);\n const n = live.length;\n let rev = 0, gross = 0, items = 0, bev = 0, food = 0, foodOrders = 0;\n const sources: Record = {},\n coupons: Record = {},\n sizes: Record = {};\n let last: string | null = null;\n for (const o of live) {\n rev += net(o);\n gross += (+o.totalTaxable || 0) + (+o.totalDiscount || 0);\n const s = (o.source ?? \"APP\").toUpperCase();\n sources[s] = (sources[s] ?? 0) + 1;\n const cc = couponClass(o.coupon);\n coupons[cc] = (coupons[cc] ?? 0) + 1;\n let hasFood = false;\n for (const it of o.orderItems ?? []) {\n const q = +it.quantity || 1;\n items += q;\n if (FOOD_CATS.has(it.category)) {\n food += q;\n hasFood = true;\n } else if (!NON_BEV.has(it.category)) bev += q;\n for (const a of it.addons ?? []) {\n const v = (a?.selectedValue ?? \"\").trim();\n if ([\"Small\", \"Medium\", \"Large\"].includes(v)) {\n sizes[v] = (sizes[v] ?? 0) + q;\n }\n }\n }\n if (hasFood) foodOrders++;\n if (o.createdTime && (!last || o.createdTime > last)) last = o.createdTime;\n }\n return {\n orders: n,\n revenue: +rev.toFixed(2),\n aov: n ? +(rev / n).toFixed(2) : 0,\n cancelled: orders.length - live.length -\n (upToHour != null ? orders.filter(isLive).length - n : 0),\n items,\n items_per_order: n ? +(items / n).toFixed(2) : 0,\n beverages: bev,\n food,\n food_attach: n ? foodOrders / n : 0,\n discount_depth: gross ? 1 - (rev / 1.05) / gross : 0,\n list_value: +gross.toFixed(2),\n sources,\n kiosk_share: n ? (sources.KIOSK ?? 0) / n : 0,\n coupons,\n first69_share: n ? (coupons.FIRST69 ?? 0) / n : 0,\n sizes,\n last_order_time: last,\n };\n}\nexport type Summary = ReturnType;\n\nexport function hourly(orders: Order[]) {\n const c = Array(24).fill(0), r = Array(24).fill(0);\n for (const o of orders) {\n if (isLive(o)) {\n c[hourOf(o)]++;\n r[hourOf(o)] += net(o);\n }\n }\n return c.map((orders, hour) => ({\n hour,\n orders,\n revenue: +r[hour].toFixed(2),\n }));\n}\nexport function topItems(orders: Order[], n = 10) {\n const q: Record = {},\n r: Record = {},\n cat: Record = {};\n for (const o of orders) {\n if (isLive(o)) {\n for (const it of o.orderItems ?? []) {\n q[it.name] = (q[it.name] ?? 0) + (+it.quantity || 1);\n r[it.name] = (r[it.name] ?? 0) + (+it.grandTotal || 0);\n cat[it.name] = it.category;\n }\n }\n }\n return Object.keys(q).sort((a, b) => q[b] - q[a]).slice(0, n).map((k) => ({\n name: k,\n category: cat[k],\n qty: q[k],\n revenue: +r[k].toFixed(2),\n }));\n}\nexport function categoryMix(orders: Order[]) {\n const q: Record = {}, r: Record = {};\n for (const o of orders) {\n if (isLive(o)) {\n for (const it of o.orderItems ?? []) {\n const c = it.category || \"Other\";\n q[c] = (q[c] ?? 0) + (+it.quantity || 1);\n r[c] = (r[c] ?? 0) + (+it.grandTotal || 0);\n }\n }\n }\n return Object.keys(q).sort((a, b) => q[b] - q[a]).map((k) => ({\n category: k,\n qty: q[k],\n revenue: +r[k].toFixed(2),\n }));\n}\nexport function couponMix(orders: Order[]) {\n const g: Record = {};\n for (const o of orders) {\n if (!isLive(o)) continue;\n const k = isRefCode(o.coupon)\n ? \"Personal referral code\"\n : (o.coupon ?? \"No coupon\");\n const x = g[k] ??= [0, 0, 0];\n x[0]++;\n x[1] += net(o);\n x[2] += +o.totalDiscount || 0;\n }\n return Object.entries(g).map(([coupon, [n, r, d]]) => ({\n coupon,\n orders: n,\n aov: +(r / n).toFixed(2),\n avg_discount: +(d / n).toFixed(2),\n })).sort((a, b) => b.orders - a.orders);\n}\nexport function customerHistory(days: Days) {\n const first: Record = {};\n for (const d of Object.keys(days).sort()) {\n for (const o of days[d]) {\n if (o.userPhone && isLive(o) && !(o.userPhone in first)) {\n first[o.userPhone] = d;\n }\n }\n }\n return first;\n}\nexport function newVsReturning(\n orders: Order[],\n first: Record,\n day: string,\n) {\n let n = 0, r = 0, nr = 0, rr = 0;\n for (const o of orders) {\n if (!isLive(o)) continue;\n if (o.userPhone && (first[o.userPhone] ?? day) < day) {\n r++;\n rr += net(o);\n } else {\n n++;\n nr += net(o);\n }\n }\n const t = n + r;\n return {\n new: n,\n returning: r,\n returning_share: t ? r / t : 0,\n new_aov: n ? +(nr / n).toFixed(2) : 0,\n returning_aov: r ? +(rr / r).toFixed(2) : 0,\n };\n}\nexport function dailySeries(days: Days) {\n const first = customerHistory(days);\n return Object.keys(days).sort().map((d) => ({\n date: d,\n dow: dow(d),\n ...summarizeDay(days[d]),\n ...newVsReturning(days[d], first, d),\n }));\n}\nexport function cohorts(days: Days) {\n const first = customerHistory(days);\n const by: Record = {};\n for (const d of Object.keys(days).sort()) {\n for (const o of days[d]) {\n if (o.userPhone && isLive(o)) (by[o.userPhone] ??= []).push(d);\n }\n }\n const weekKey = (iso: string) => {\n const t = new Date(iso + \"T00:00:00Z\");\n const day = (t.getUTCDay() + 6) % 7;\n t.setUTCDate(t.getUTCDate() - day + 3);\n const y = t.getUTCFullYear();\n const j4 = new Date(Date.UTC(y, 0, 4));\n const w = 1 +\n Math.round(\n ((t.getTime() - j4.getTime()) / 864e5 - 3 +\n ((j4.getUTCDay() + 6) % 7)) / 7,\n );\n return `${y}-W${String(w).padStart(2, \"0\")}`;\n };\n const g: Record = {};\n for (const [p, fd] of Object.entries(first)) {\n const k = weekKey(fd);\n const x = g[k] ??= {\n cohort: k,\n start: fd,\n customers: 0,\n r7: 0,\n r14: 0,\n r30: 0,\n orders: 0,\n };\n if (fd < x.start) x.start = fd;\n x.customers++;\n x.orders += by[p].length;\n const later = by[p].filter((d) => d > fd);\n if (later.length) {\n const gap =\n (new Date(later.sort()[0] + \"T00:00:00Z\").getTime() -\n new Date(fd + \"T00:00:00Z\").getTime()) / 864e5;\n if (gap <= 7) x.r7++;\n if (gap <= 14) x.r14++;\n if (gap <= 30) x.r30++;\n }\n }\n return Object.values(g).sort((a: any, b: any) => a.start < b.start ? -1 : 1)\n .map((x: any) => ({\n ...x,\n r7_pct: x.r7 / x.customers,\n r14_pct: x.r14 / x.customers,\n r30_pct: x.r30 / x.customers,\n orders_per_customer: +(x.orders / x.customers).toFixed(2),\n }));\n}\nexport function customerStats(days: Days) {\n const ph: Record = {}, dates: Record = {};\n for (const d of Object.keys(days).sort()) {\n for (const o of days[d]) {\n if (o.userPhone && isLive(o)) {\n ph[o.userPhone] = (ph[o.userPhone] ?? 0) + 1;\n (dates[o.userPhone] ??= []).push(d);\n }\n }\n }\n const vals = Object.values(ph),\n n = vals.length,\n total = vals.reduce((a, b) => a + b, 0);\n const dist: Record = {};\n for (const v of vals) {\n const k = String(Math.min(v, 10));\n dist[k] = (dist[k] ?? 0) + 1;\n }\n const gaps: number[] = [];\n for (const ds of Object.values(dates)) {\n for (let i = 1; i < ds.length; i++) {\n const g =\n (new Date(ds[i] + \"T00:00:00Z\").getTime() -\n new Date(ds[i - 1] + \"T00:00:00Z\").getTime()) / 864e5;\n if (g > 0) gaps.push(g);\n }\n }\n gaps.sort((a, b) => a - b);\n const rep = vals.filter((v) => v >= 2).length;\n return {\n unique_customers: n,\n repeat_customers: rep,\n repeat_rate: n ? rep / n : 0,\n orders_from_repeaters_share: total\n ? vals.filter((v) => v >= 2).reduce((a, b) => a + b, 0) / total\n : 0,\n orders_per_customer: n ? +(total / n).toFixed(2) : 0,\n distribution: Object.fromEntries(\n Object.keys(dist).sort((a, b) => +a - +b).map((k) => [k, dist[k]]),\n ),\n median_gap_days: gaps.length ? gaps[Math.floor(gaps.length / 2)] : null,\n };\n}\nexport function heatmap(days: Days) {\n const cnt: Record = {}, dd: Record = {};\n for (const [d, lst] of Object.entries(days)) {\n const w = weekday0(d);\n dd[w] = (dd[w] ?? 0) + 1;\n for (const o of lst) {\n if (isLive(o)) {\n cnt[`${w}-${hourOf(o)}`] = (cnt[`${w}-${hourOf(o)}`] ?? 0) + 1;\n }\n }\n }\n const out = [];\n for (let w = 0; w < 7; w++) {\n for (let h = 0; h < 24; h++) {\n out.push({\n dow: w,\n hour: h,\n avg: dd[w] ? +((cnt[`${w}-${h}`] ?? 0) / dd[w]).toFixed(2) : 0,\n });\n }\n }\n return out;\n}\nexport function pairs(orders: Order[], n = 8) {\n const pc: Record = {};\n for (const o of orders) {\n if (!isLive(o)) continue;\n const names = [...new Set((o.orderItems ?? []).map((it: any) => it.name))]\n .sort();\n for (let i = 0; i < names.length; i++) {\n for (let j = i + 1; j < names.length; j++) {\n pc[`${names[i]}|${names[j]}`] = (pc[`${names[i]}|${names[j]}`] ?? 0) +\n 1;\n }\n }\n }\n return Object.entries(pc).sort((a, b) => b[1] - a[1]).slice(0, n).map(\n ([k, count]) => {\n const [a, b] = k.split(\"|\");\n return { a, b, count };\n },\n );\n}\nexport function mtdBlock(\n days: Days,\n through: string,\n partialLast: boolean,\n target: number,\n) {\n const first = monthFirst(through);\n let orders = 0, rev = 0;\n for (const [d, lst] of Object.entries(days)) {\n if (d >= first && d <= through) {\n const s = summarizeDay(lst);\n orders += s.orders;\n rev += s.revenue;\n }\n }\n const dim = daysInMonth(through), elapsed = +through.slice(8, 10);\n const closedDays = partialLast ? elapsed - 1 : elapsed;\n const closedRev = rev -\n (partialLast ? summarizeDay(days[through] ?? []).revenue : 0);\n const perDay = closedDays ? closedRev / closedDays : rev,\n remaining = dim - elapsed;\n return {\n orders,\n revenue: Math.round(rev),\n aov: orders ? Math.round(rev / orders) : 0,\n days_elapsed: elapsed,\n days_in_month: dim,\n per_day: Math.round(perDay),\n projection: Math.round(rev + perDay * remaining),\n target,\n needed_per_day: remaining ? Math.round((target - rev) / remaining) : 0,\n };\n}\n\n// ---------- report builders ----------\nexport function buildPrimary(\n days: Days,\n name: string,\n now: ReturnType,\n slotHour: number,\n isDigest: boolean,\n target: number,\n) {\n const today = now.date, yday = shift(today, -1), lw = shift(today, -7);\n const first = customerHistory(days);\n const slotLabel = isDigest\n ? \"midnight digest\"\n : `${slotHour % 12 || 12} ${slotHour < 12 ? \"am\" : \"pm\"} report`;\n const delayedMin = isDigest\n ? now.hour * 60 + now.minute\n : (now.hour - slotHour) * 60 + now.minute;\n const p: any = {\n outlet: name,\n is_digest: isDigest,\n hour: now.hour,\n dow: dowLong(today),\n as_of_human: now.human,\n slot_label: slotLabel,\n delayed: delayedMin > 20,\n };\n if (isDigest) {\n const closed = days[yday] ?? [], lwo = days[shift(yday, -7)] ?? [];\n Object.assign(p, {\n closed_day: yday,\n closed_day_human: humanDay(yday),\n closed: summarizeDay(closed),\n closed_lw: summarizeDay(lwo),\n closed_hourly: hourly(closed),\n closed_lw_hourly: hourly(lwo),\n closed_nr: newVsReturning(closed, first, yday),\n closed_top: topItems(closed),\n closed_coupons: couponMix(closed),\n mtd: mtdBlock(days, yday, false, target),\n });\n p.today = p.closed;\n return p;\n }\n const t = days[today] ?? [], y = days[yday] ?? [];\n const idx = SLOTS.indexOf(slotHour);\n const from = idx > 0 ? SLOTS[idx - 1] : 0;\n const since = t.filter((o) => isLive(o) && hourOf(o) >= from);\n Object.assign(p, {\n today: summarizeDay(t),\n hourly_today: hourly(t),\n hourly_yesterday: hourly(y),\n yesterday_same_hour: summarizeDay(y, now.hour),\n last_week_same_hour: summarizeDay(days[lw] ?? [], now.hour),\n yesterday_full: summarizeDay(y),\n since_last: {\n orders: since.length,\n revenue: Math.round(since.reduce((a, o) => a + net(o), 0)),\n from_label: from === 0\n ? \"midnight\"\n : `${from % 12 || 12} ${from < 12 ? \"am\" : \"pm\"}`,\n },\n nr: newVsReturning(t, first, today),\n top_today: topItems(t),\n mtd: mtdBlock(days, today, true, target),\n });\n return p;\n}\nexport function buildOther(\n days: Days,\n name: string,\n now: ReturnType,\n isDigest: boolean,\n target: number,\n) {\n const today = now.date, yday = shift(today, -1);\n if (isDigest) {\n const y2 = days[shift(yday, -2 + 1)] ?? [];\n return {\n outlet: name,\n today: summarizeDay(days[yday] ?? []),\n yesterday_same_hour: summarizeDay(y2),\n yesterday: summarizeDay(y2),\n mtd: mtdBlock(days, yday, false, target),\n };\n }\n const y = days[yday] ?? [];\n return {\n outlet: name,\n today: summarizeDay(days[today] ?? []),\n yesterday_same_hour: summarizeDay(y, now.hour),\n yesterday: summarizeDay(y),\n mtd: mtdBlock(days, today, true, target),\n };\n}\n\n// ---------- summary text ----------\nexport function ruleBased(p: any, others: any[]) {\n const t = p.today, L: string[] = [];\n if (p.is_digest) {\n const lw = p.closed_lw;\n L.push(\n `${p.closed_day_human} closed at ${t.orders} orders, ${\n inr(t.revenue)\n }, AOV ${inr(t.aov)}.`,\n );\n const d = t.revenue - lw.revenue;\n L.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 L.push(\n `- Returning share ${\n pct(p.closed_nr.returning_share)\n } (${p.closed_nr.returning} returning, ${p.closed_nr.new} new). FIRST69 ${\n pct(t.first69_share)\n }, food attach ${pct(t.food_attach)}, kiosk ${pct(t.kiosk_share)}.`,\n );\n } else {\n const ys = p.yesterday_same_hour, s = p.since_last;\n L.push(\n `Today so far: ${t.orders} orders, ${inr(t.revenue)}, AOV ${inr(t.aov)}.`,\n );\n L.push(`- Since ${s.from_label}: +${s.orders} orders, +${inr(s.revenue)}.`);\n const d = t.revenue - ys.revenue;\n L.push(\n `- ${inr(Math.abs(d))} ${\n d >= 0 ? \"ahead of\" : \"behind\"\n } yesterday at this hour (${ys.orders} orders then); same weekday last week had ${p.last_week_same_hour.orders}.`,\n );\n L.push(\n `- Returning share ${\n pct(p.nr.returning_share)\n } (${p.nr.returning} of ${t.orders}). FIRST69 ${\n pct(t.first69_share)\n }, food attach ${pct(t.food_attach)}, kiosk ${pct(t.kiosk_share)}.`,\n );\n }\n const m = p.mtd;\n if (m?.orders) {\n L.push(\n `- Month to date ${inr(m.revenue)} (${m.orders} orders); projected ${\n inr(m.projection)\n } vs ${inr(m.target)} target.`,\n );\n }\n const top = p.is_digest ? p.closed_top : p.top_today;\n if (top?.length) {\n L.push(\n \"- Top sellers: \" + top.slice(0, 3).map((x: any) =>\n `${x.name} (${x.qty})`\n ).join(\", \") + \".\",\n );\n }\n if (others.length) {\n L.push(\n \"- Others: \" + others.map((o) =>\n `${o.outlet.replace(\"Xpanse \", \"\")} ${o.today.orders} orders ${\n inr(o.today.revenue)\n }`\n ).join(\"; \") + \".\",\n );\n }\n return L.join(\"\\n\");\n}\nconst SYSTEM =\n `You write sales briefs for the owner of Xpanse Cafe franchise outlets in India. The JSON has \"primary\" (Kamla Nagar, Delhi University North Campus, opened 1 Sep 2026, target ₹20 lakh net sales a month) and \"others\" (two outlets the owner only wants at a glance). All numbers were computed by code from the live order list; quote them as given, never recompute or invent.\nWrite for a busy owner reading on a phone: 1 headline sentence with the most important fact about the primary outlet; 3 to 5 short bullets (movement since last report, today vs yesterday at the same hour and vs same weekday last week, returning share, FIRST69 / food attach / kiosk if notable, top sellers, month-to-date pace vs ₹20 lakh); if primary.is_digest is true it is the closing report for primary.closed_day (use \"closed\", \"closed_lw\", \"closed_top\", \"closed_nr\"); 1 line on the other outlets only if unusual; at most 2 watch items. INR. Terse. No preamble, no headers, plain '-' bullets.`;\nexport async function summarize(\n p: any,\n others: any[],\n): Promise<[string, string]> {\n const key = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!key) return [ruleBased(p, others), \"rules\"];\n try {\n const slim = { ...p };\n delete slim.hourly_today;\n delete slim.hourly_yesterday;\n delete slim.closed_hourly;\n delete slim.closed_lw_hourly;\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": key,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: Deno.env.get(\"CLAUDE_MODEL\") || \"claude-sonnet-5\",\n max_tokens: 700,\n system: SYSTEM,\n messages: [{\n role: \"user\",\n content: JSON.stringify({ primary: slim, others }),\n }],\n }),\n });\n if (!r.ok) throw new Error(`HTTP ${r.status}`);\n const j = await r.json();\n const text = (j.content ?? []).filter((b: any) => b.type === \"text\").map((\n b: any,\n ) => b.text).join(\"\").trim();\n return [text || ruleBased(p, others), j.model ?? \"claude\"];\n } catch (e) {\n return [\n ruleBased(p, others) +\n `\\n\\n(AI summary unavailable: ${(e as Error).message})`,\n \"rules (fallback)\",\n ];\n }\n}\n\n// ---------- email HTML ----------\nfunction delta(cur: number, ref: number, money = false) {\n const d = cur - ref;\n const v = money ? inr(Math.abs(d)) : String(Math.abs(Math.round(d)));\n return `${d >= 0 ? \"+\" : \"−\"}${v}`;\n}\nfunction kpi(l: string, v: string, s = \"\") {\n return `

${l}

${v}

${s}

`;\n}\nfunction bars(today: any[], ref: any[], refLabel: string, upto: number) {\n const hours = [];\n for (let h = 8; h <= Math.max(upto, 8) && h < 24; h++) hours.push(h);\n const mx = Math.max(\n 1,\n ...today.map((x) => x.orders),\n ...ref.map((x) => x.orders),\n );\n const rows = hours.map((h) =>\n `${\n String(h).padStart(2, \"0\")\n }:00

${\n today[h].orders\n } / ${ref[h].orders}`\n ).join(\"\");\n return `

Orders by hour: ■ today ■ ${\n esc(refLabel)\n }

${rows}

`;\n}\nfunction topTable(items: any[]) {\n if (!items?.length) return \"\";\n return `

Top sellers

${\n items.slice(0, 8).map((x) =>\n ``\n ).join(\"\")\n }

${\n esc(x.name)\n } (${\n esc(x.category)\n })

${x.qty}

${\n inr(x.revenue)\n }

`;\n}\nexport function renderCombined(\n p: any,\n others: any[],\n summary: string,\n engine: string,\n) {\n const t = p.today;\n const delayed = p.delayed\n ? `

Delayed: this is the ${\n esc(p.slot_label)\n }, sent at ${esc(p.as_of_human)}.

`\n : \"\";\n const box =\n `

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

`;\n let title: string, kpis: string, barsHtml: string, top: string;\n if (p.is_digest) {\n const y = p.closed, lw = p.closed_lw;\n title = `${esc(p.outlet)} — ${esc(p.closed_day_human)} closed`;\n kpis = `${\n kpi(\n \"Orders\",\n `${y.orders}`,\n `vs same weekday last week ${lw.orders} (${\n delta(y.orders, lw.orders)\n })`,\n )\n }${\n kpi(\n \"Net revenue\",\n inr(y.revenue),\n `last week ${inr(lw.revenue)} (${delta(y.revenue, lw.revenue, true)})`,\n )\n }${kpi(\"AOV\", inr(y.aov), `items/order ${y.items_per_order}`)}${\n kpi(\n \"Returning share\",\n pct(p.closed_nr.returning_share),\n `${p.closed_nr.returning} returning · ${p.closed_nr.new} new`,\n )\n }${\n kpi(\n \"Food attach\",\n pct(y.food_attach),\n `${y.food} food items · ${y.beverages} drinks`,\n )\n }${\n kpi(\n \"FIRST69 share\",\n pct(y.first69_share),\n `discount depth ${pct(y.discount_depth)} · kiosk ${pct(y.kiosk_share)}`,\n )\n }

`;\n barsHtml = bars(\n p.closed_hourly,\n p.closed_lw_hourly,\n \"same weekday last week\",\n 23,\n );\n top = topTable(p.closed_top);\n } else {\n const ys = p.yesterday_same_hour,\n lws = p.last_week_same_hour,\n s = p.since_last;\n title = `${esc(p.outlet)} — ${esc(p.slot_label)}`;\n kpis = `${\n kpi(\n \"Orders today\",\n `${t.orders}`,\n `yesterday by now ${ys.orders} (${delta(t.orders, ys.orders)}) · last ${\n esc(p.dow)\n } ${lws.orders}`,\n )\n }${\n kpi(\n \"Net revenue today\",\n inr(t.revenue),\n `yesterday by now ${inr(ys.revenue)} (${\n delta(t.revenue, ys.revenue, true)\n })`,\n )\n }${\n kpi(\n \"AOV\",\n inr(t.aov),\n `items/order ${t.items_per_order} · last order ${\n esc((t.last_order_time ?? \"—\").slice(0, 5))\n }`,\n )\n }${\n kpi(`Since ${esc(s.from_label)}`, `+${s.orders}`, `+${inr(s.revenue)}`)\n }${\n kpi(\n \"Returning share today\",\n pct(p.nr.returning_share),\n `${p.nr.returning} returning · ${p.nr.new} new customers`,\n )\n }${\n kpi(\n \"Mix today\",\n `F69 ${pct(t.first69_share)}`,\n `food attach ${pct(t.food_attach)} · kiosk ${pct(t.kiosk_share)}`,\n )\n }

`;\n barsHtml = bars(p.hourly_today, p.hourly_yesterday, \"yesterday\", p.hour);\n top = topTable(p.top_today);\n }\n const m = p.mtd;\n const pace =\n `${\n kpi(\n \"Month to date\",\n inr(m.revenue),\n `${m.orders} orders · AOV ${inr(m.aov)}`,\n )\n }${\n kpi(\n \"Projected month\",\n inr(m.projection),\n `${m.days_elapsed} of ${m.days_in_month} days · ${inr(m.per_day)}/day`,\n )\n }${\n kpi(\n \"Target ₹20 L\",\n pct(m.projection / m.target) + \" of target\",\n `need ${inr(m.needed_per_day)}/day for the rest of the month`,\n )\n }

`;\n const oth = others.length\n ? `

Other outlets

${\n others.map((o) =>\n ``\n ).join(\"\")\n }

	${\n p.is_digest ? \"Closed day\" : \"Today\"\n }	Yday by now	Yday full	MTD
${\n esc(o.outlet)\n }	${o.today.orders} · ${\n inr(o.today.revenue)\n }	${o.yesterday_same_hour.orders} · ${\n inr(o.yesterday_same_hour.revenue)\n }	${o.yesterday.orders} · ${\n inr(o.yesterday.revenue)\n }	${o.mtd.orders} · ${\n inr(o.mtd.revenue)\n }

`\n : \"\";\n const foot =\n `

Summary by ${\n esc(engine)\n } · live order list from franchise.xpansecafe.com · reports at 9am, 12pm, 3pm, 6pm, 9pm and midnight IST · Val Town

`;\n return `

${title}

as of ${\n esc(p.as_of_human)\n }

${delayed}${box}${kpis}${barsHtml}${top}${pace}${oth}${foot}

`;\n}\n\n// ---------- config ----------\nexport function outletsFromEnv(): {\n name: string;\n username: string;\n password: string;\n}[] {\n const raw = Deno.env.get(\"OUTLETS\") ?? \"[]\";\n let arr: any = JSON.parse(raw);\n if (typeof arr === \"string\") arr = JSON.parse(arr);\n return arr;\n}\nexport const target = () => +(Deno.env.get(\"MONTHLY_TARGET\") ?? \"2000000\");\nexport const salt = () => Deno.env.get(\"PHONE_SALT\") ?? \"xpanse\";\n\n// ---------- dashboard data (used by dashboardHttp.ts and the local test) ----------\nexport function periodBlock(\n days: Days,\n from: string,\n to: string,\n first: Record,\n) {\n const dates = Object.keys(days).filter((d) => d >= from && d <= to).sort();\n const orders = dates.flatMap((d) => days[d]);\n const h = Array(24).fill(0), r = Array(24).fill(0);\n let nw = 0, ret = 0, nrev = 0, rrev = 0;\n for (const d of dates) {\n for (const o of days[d]) {\n if (!isLive(o)) continue;\n h[hourOf(o)]++;\n r[hourOf(o)] += net(o);\n if (o.userPhone && (first[o.userPhone] ?? d) < d) {\n ret++;\n rrev += net(o);\n } else {\n nw++;\n nrev += net(o);\n }\n }\n }\n const t = nw + ret;\n return {\n from,\n to,\n days: dates.length,\n summary: summarizeDay(orders),\n hourly: h.map((orders, hour) => ({\n hour,\n orders,\n revenue: +r[hour].toFixed(2),\n })),\n nr: {\n new: nw,\n returning: ret,\n returning_share: t ? ret / t : 0,\n new_aov: nw ? +(nrev / nw).toFixed(2) : 0,\n returning_aov: ret ? +(rrev / ret).toFixed(2) : 0,\n },\n top: topItems(orders, 10),\n coupons: couponMix(orders).slice(0, 10),\n daily: dates.map((d) => ({\n date: d,\n dow: dow(d),\n ...summarizeDay(days[d]),\n })),\n };\n}\n\nexport async function buildDashboard(\n slug: string,\n ndays: number,\n store: Store,\n panelFor: (slug: string) => Promise,\n from?: string,\n to?: string,\n mode = \"period\",\n) {\n const now = istNow(),\n today = now.date,\n yday = shift(today, -1),\n lw = shift(today, -7);\n const outlets = outletsFromEnv();\n const name = outlets.find((o) => slugify(o.name) === slug)?.name ?? slug;\n if (!from || !to || mode === \"today\") {\n from = today;\n to = today;\n mode = \"today\";\n }\n if (to > today) to = today;\n if (from > to) from = to;\n const len =\n Math.round(\n (new Date(to + \"T00:00:00Z\").getTime() -\n new Date(from + \"T00:00:00Z\").getTime()) / 864e5,\n ) + 1;\n // analysis window: the selected period, or 30 days of context ending on the selected day\n const winTo = to, winFrom = len >= 2 ? from : shift(to, -29);\n const prevFrom = shift(from, -len), prevTo = shift(from, -1);\n const start = [winFrom, prevFrom, monthFirst(today)].sort()[0];\n const days = await loadDays(\n await panelFor(slug),\n slug,\n start,\n today,\n today,\n salt(),\n store,\n );\n const window: Days = Object.fromEntries(\n Object.entries(days).filter(([d]) => d >= winFrom && d <= winTo),\n );\n const first = customerHistory(days);\n const t = days[today] ?? [], y = days[yday] ?? [], w = days[lw] ?? [];\n const all = Object.values(window).flat();\n const others = [];\n for (const o of outlets) {\n const s2 = slugify(o.name);\n if (s2 === slug) continue;\n const d2 = await loadDays(\n await panelFor(s2),\n s2,\n shift(monthFirst(today), -1),\n today,\n today,\n salt(),\n store,\n );\n const y2 = d2[yday] ?? [];\n others.push({\n outlet: o.name,\n slug: s2,\n today: summarizeDay(d2[today] ?? []),\n yesterday_same_hour: summarizeDay(y2, now.hour),\n yesterday: summarizeDay(y2),\n mtd: mtdBlock(d2, today, true, target()),\n });\n }\n return {\n outlet: name,\n slug,\n generated_at: now.human,\n live: true,\n hour: now.hour,\n today: {\n summary: summarizeDay(t),\n hourly: hourly(t),\n top: topItems(t, 10),\n nr: newVsReturning(t, first, today),\n coupons: couponMix(t),\n },\n yesterday: {\n summary: summarizeDay(y),\n same_hour: summarizeDay(y, now.hour),\n hourly: hourly(y),\n },\n last_week: {\n summary: summarizeDay(w),\n same_hour: summarizeDay(w, now.hour),\n hourly: hourly(w),\n },\n daily: dailySeries(window),\n cohorts: cohorts(days),\n customers: customerStats(window),\n heatmap: heatmap(\n Object.fromEntries(Object.entries(window).filter(([d]) => d < today)),\n ),\n categories: categoryMix(all),\n top: topItems(all, 15),\n coupons: couponMix(all).slice(0, 14),\n pairs: pairs(all, 8),\n window_summary: summarizeDay(all),\n window: {\n from: winFrom,\n to: winTo,\n days: Object.keys(window).length,\n context: len < 2,\n },\n mtd: mtdBlock(days, today, true, target()),\n others,\n outlets: outlets.map((o) => ({ name: o.name, slug: slugify(o.name) })),\n period: mode === \"today\"\n ? null\n : {\n ...periodBlock(days, from, to, first),\n prev: periodBlock(days, prevFrom, prevTo, first),\n },\n };\n}",[177],"pulls","branches","forks","envVars",{"_191":193,"_194":62},"connections",{"_191":62,"_192":62},"count","unfilledCount",10,"emptyCount",{"_42":176,"_32":177,"_30":178,"_136":-5,"_40":41,"_39":179,"_138":25,"_37":217,"_13":181,"_33":141,"_35":182,"_24":48,"_143":-5,"_202":218,"_27":219},{"_42":168,"_32":169,"_30":170,"_136":-5,"_40":41,"_39":171,"_138":48,"_37":214,"_13":140,"_33":173,"_35":174,"_24":48,"_143":-5,"_202":215,"_27":216},{"_42":160,"_32":161,"_30":57,"_136":-5,"_40":41,"_39":162,"_138":48,"_37":211,"_13":164,"_33":34,"_35":165,"_24":48,"_143":166,"_202":212,"_27":213},{"_42":152,"_32":153,"_30":154,"_136":-5,"_40":41,"_39":155,"_138":48,"_37":208,"_13":157,"_33":20,"_35":158,"_24":48,"_143":-5,"_202":209,"_27":210},{"_42":145,"_32":146,"_30":147,"_136":-5,"_40":41,"_39":148,"_138":25,"_37":205,"_13":62,"_33":20,"_35":150,"_24":48,"_143":-5,"_202":206,"_27":207},{"_42":133,"_32":134,"_30":135,"_136":-5,"_40":41,"_39":137,"_138":48,"_37":201,"_13":140,"_33":141,"_35":142,"_24":48,"_143":-5,"_202":203,"_27":204},["D",1789163933610],"children",[],[134],["D",1789225174687],[],[146],["D",1789225226792],[],[153],["D",1789163947156],[],[161],["D",1789229140644],[],[169],["D",1789225171018],[],[177],["D",1789161653473],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":48},{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"ctx",{"_78":-5,"_124":257,"_258":259,"_260":261,"_262":48,"_263":48,"_264":48,"_265":25,"_266":-5,"_267":-7,"_268":-7,"_269":62,"_270":48,"_271":48,"_272":-5,"_273":48,"_274":48,"_275":48,"_276":-5},"ENV",{"_228":229,"_230":231,"_232":86,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256},"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 · v41