\\n

Xpanse

\\n

\\n \\n

\\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 \\n\\n \\n\\n \\n

\\n\\n\\n\\n\";\n",[177],"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}",[186],"2854138b-399d-48fa-8cad-8f840c9120d7","report.ts","914ea44c-aeba-11f1-a7cf-1607ee4eb77e",53,["D",1789383399494],2,"// Xpanse hourly + close report builder/sender (replaces the Mac Python client).\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport {\n customerHistory,\n ddmmyyyy,\n hourOf,\n inr,\n isLive,\n loadDays,\n monthFirst,\n net,\n newVsReturning,\n Panel,\n pct,\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}\n\n// ---------- combined KN-centric report (one email per run) ----------\n\n// Guarded fetch of the closing date plus the MTD window. Hard-fails per the\n// close-report rules: never compose an email from a status:false or zeroed close.\nasync function guardedDay(o: any, now: any, closingDate: string, isClose: boolean) {\n const slug = slugify(o.name);\n const panel = new Panel(o.username, o.password);\n await panel.login();\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 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 orders = await Promise.all(\n rawList.map(async (x: any) => slim(x, await sha(salt() + (x.userPhone ?? \"\")))),\n );\n if (isClose && orders.length === 0) {\n throw new Error(`guard: closing date ${closingDate} has zero orders - refusing to send a zeroed close report`);\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] = orders;\n if (closingDate < now.date) {\n try { await store.set(`xp:${slug}:${closingDate}`, orders); } catch { /* best-effort */ }\n }\n return { days, orders };\n}\n\nfunction mtdOf(days: any, closingDate: string) {\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 return { mtdOrders, mtdRevenue: +mtdRevenue.toFixed(2) };\n}\n\nconst hr12 = (h: number) => `${((h + 11) % 12) + 1} ${h < 12 || h === 24 ? \"AM\" : \"PM\"}`;\n\n// One combined email: Kamla Nagar (outlets[0]) in full detail, the other\n// outlets as one-line benchmark/guardrail numbers for the same window.\nexport async function runCombined(outlets: 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 primary = outlets[0];\n const others = outlets.slice(1);\n\n // --- primary (KN): hard guards, full detail ---\n const { days, orders } = await guardedDay(primary, now, closingDate, isClose);\n const d = summarizeDay(orders);\n const lwFull = summarizeDay(days[shift(closingDate, -7)] ?? []);\n const lwSameHour = summarizeDay(days[shift(closingDate, -7)] ?? [], now.hour);\n const { mtdOrders, mtdRevenue } = mtdOf(days, closingDate);\n const first = customerHistory(days);\n const nr = newVsReturning(orders, first, closingDate);\n const tops = topItems(orders, 3);\n const topStr = tops.length ? tops.map((t: any) => `${t.name} (${t.qty})`).join(\", \") : \"none yet\";\n\n // --- benchmarks: soft-fail, one line each ---\n const bench: string[] = [];\n for (const o of others) {\n try {\n const g = await guardedDay(o, now, closingDate, isClose);\n const s = summarizeDay(g.orders);\n const lwB = isClose\n ? summarizeDay(g.days[shift(closingDate, -7)] ?? [])\n : summarizeDay(g.days[shift(closingDate, -7)] ?? [], now.hour);\n const short = o.name.replace(\"Xpanse \", \"\");\n bench.push(\n `- ${short}: ${s.orders} orders, ${inr(s.revenue)}, AOV ${inr(s.aov)} · F69 ${pct(s.first69_share)} · food ${pct(s.food_attach)} (last wk ${isClose ? \"same day\" : \"by now\"}: ${lwB.orders} / ${inr(lwB.revenue)})`,\n );\n } catch (e: any) {\n bench.push(`- ${o.name.replace(\"Xpanse \", \"\")}: unavailable this run (${String(e?.message ?? e).slice(0, 80)})`);\n }\n }\n\n const lines: string[] = [];\n let subject: string;\n if (isClose) {\n const diff = +(d.revenue - lwFull.revenue).toFixed(2);\n subject = `KN closed: ${d.orders} orders · ${inr(d.revenue)} · AOV ${inr(d.aov)}`;\n lines.push(\n `KAMLA NAGAR - day closed (${closingDate}): ${d.orders} orders, ${inr(d.revenue)}, AOV ${inr(d.aov)}.`,\n `- ${inr(Math.abs(diff))} ${diff >= 0 ? \"ahead of\" : \"behind\"} same weekday last week (${lwFull.orders} orders, ${inr(lwFull.revenue)}).`,\n `- Returning share ${pct(nr.returning_share)} (${nr.returning} returning, ${nr.new} new). FIRST69 ${pct(d.first69_share)}, food attach ${pct(d.food_attach)}.`,\n `- Month to date: ${mtdOrders} orders, ${inr(mtdRevenue)}.`,\n `- Top sellers: ${topStr}.`,\n );\n } else {\n const fromHour = (now.hour - 3 + 24) % 24;\n const since = orders.filter((x: any) => isLive(x) && hourOf(x) >= fromHour);\n const sinceRev = +since.reduce((a: number, x: any) => a + net(x), 0).toFixed(2);\n subject = `KN: ${d.orders} orders · ${inr(d.revenue)} by ${hr12(now.hour)} (+${since.length} since ${hr12(fromHour)})`;\n lines.push(\n `KAMLA NAGAR - today so far (as of ${hr12(now.hour)}): ${d.orders} orders, ${inr(d.revenue)}, AOV ${inr(d.aov)}.`,\n `- Since ${hr12(fromHour)}: +${since.length} orders, +${inr(sinceRev)}.`,\n `- Same weekday last week by now: ${lwSameHour.orders} orders / ${inr(lwSameHour.revenue)} (closed ${lwFull.orders} / ${inr(lwFull.revenue)}).`,\n `- Returning share ${pct(nr.returning_share)} (${nr.returning} of ${d.orders}). FIRST69 ${pct(d.first69_share)}, food attach ${pct(d.food_attach)}.`,\n `- Month to date: ${mtdOrders} orders, ${inr(mtdRevenue)}.`,\n `- Top sellers: ${topStr}.`,\n );\n }\n lines.push(\"\", \"Benchmarks (same window):\", ...bench);\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 { mode: isClose ? \"close\" : \"hourly\", closingDate, subject: finalSubject, orders: d.orders, revenue: d.revenue, recipients: to.length, to };\n}\n",[193],"d122e261-3ac8-49e6-b567-5888516fbec1","new-file-5192.ts",52,["D",1789332872449],6,"// Val Town HTTP val: Xpanse live dashboard + full-history analytics.\n// GET / dashboard UI (key-gated; DASH_KEY env)\n// GET /api/data?... live + selected-period view (unchanged behaviour)\n// GET /api/agg?outlet= full-history per-day aggregates (incremental blob cache)\n// GET /api/items?outlet= per-item totals with realised unit prices\n// Closed days are cached in blob forever; today is fetched live (memoised 60 s).\n// Self-contained: only reads stable primitives from lib.ts and never writes its keys,\n// so the hourly/close-report cron (main.ts) and weekly-metrics.ts are unaffected.\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport {\n buildDashboard,\n customerHistory,\n hourly,\n istNow,\n isLive,\n loadDays,\n net,\n newVsReturning,\n outletsFromEnv,\n Panel,\n salt,\n shift,\n slugify,\n summarizeDay,\n topItems,\n} from \"./lib.ts\";\nimport { TEMPLATE } from \"./template.ts\";\n\nconst store = {\n get: (k: string) => blob.getJSON(k),\n set: (k: string, v: unknown) => blob.setJSON(k, v),\n};\nconst panels = new Map();\nconst cache = new Map();\nconst AGG_V = \"v1\";\nconst CHUNK = 40; // closed days processed per request; client polls until done\n\n// ---- config (env-overridable) ----\nfunction jsonEnv(name: string, fallback: Record) {\n try {\n const raw = Deno.env.get(name);\n if (!raw) return fallback;\n const v = JSON.parse(raw);\n return v && typeof v === \"object\" ? v : fallback;\n } catch {\n return fallback;\n }\n}\nconst OPEN_DEFAULT: Record = {\n \"Xpanse Kamla Nagar\": \"2026-09-01\",\n \"Xpanse Gogol\": \"2025-07-08\",\n \"Xpanse Rajarampuri\": \"2025-10-25\",\n};\nconst RENT_DEFAULT: Record = {\n \"Xpanse Kamla Nagar\": 300000,\n \"Xpanse Gogol\": 45000,\n};\nconst openDates = () =>\n ({ ...OPEN_DEFAULT, ...(jsonEnv(\"OPEN_JSON\", {}) as Record) });\nconst rents = () =>\n ({ ...RENT_DEFAULT, ...(jsonEnv(\"RENT_JSON\", {}) as Record) });\n\nasync function panelFor(slug: string) {\n if (!panels.has(slug)) {\n const o = outletsFromEnv().find((x) => slugify(x?.name ?? \"\") === slug);\n if (!o) throw new Error(`unknown outlet slug: ${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\nfunction keyOk(given: string) {\n const key = Deno.env.get(\"DASH_KEY\") ?? \"\";\n if (!key) return true;\n if (given.length !== key.length) return false;\n let diff = 0;\n for (let i = 0; i < key.length; i++) {\n diff |= given.charCodeAt(i) ^ key.charCodeAt(i);\n }\n return diff === 0;\n}\n\nconst isF69 = (c: unknown) =>\n String(c ?? \"\").toUpperCase().trim() === \"FIRST69\";\n\ninterface DayAgg {\n o: number; rev: number; f69o: number; f69rev: number;\n repO: number; repRev: number; newC: number; can: number;\n}\ninterface CustRec { f: string; s: string | null }\ninterface AggState {\n daily: Record;\n cust: Record;\n items: Record;\n}\n\nconst emptyState = (): AggState => ({ daily: {}, cust: {}, items: {} });\n\nasync function readState(slug: string): Promise {\n try {\n const s = await store.get(`xp2:agg:${AGG_V}:${slug}`);\n if (s && s.daily && s.cust && s.items) return s as AggState;\n } catch { /* rebuild */ }\n return emptyState();\n}\n\n// Fold one closed day of raw orders into the aggregate state.\n// Guards every nested access: a malformed order or item can never throw here.\nfunction foldDay(st: AggState, d: string, orders: unknown) {\n const list = Array.isArray(orders) ? orders : [];\n const agg: DayAgg = {\n o: 0, rev: 0, f69o: 0, f69rev: 0, repO: 0, repRev: 0, newC: 0, can: 0,\n };\n const firstToday = new Set();\n for (const ord of list) {\n if (!ord || typeof ord !== \"object\") continue;\n if (!isLive(ord)) { agg.can++; continue; }\n const g = net(ord);\n agg.o++; agg.rev += g;\n if (isF69((ord as any).coupon)) { agg.f69o++; agg.f69rev += g; }\n const c = (ord as any).userPhone;\n if (c) {\n const cu = st.cust[c];\n if (cu) {\n if (cu.f < d) { agg.repO++; agg.repRev += g; }\n if (!cu.s && cu.f < d) cu.s = d;\n } else {\n firstToday.add(c);\n }\n }\n const items = (ord as any).orderItems;\n if (Array.isArray(items)) {\n for (const it of items) {\n if (!it || typeof it !== \"object\") continue;\n const nm = String((it as any).name ?? \"\").trim() || \"Unknown item\";\n const q = +(it as any).quantity || 1;\n const e = st.items[nm] ??= {\n qty: 0,\n rev: 0,\n cat: String((it as any).category ?? \"\"),\n };\n e.qty += q;\n e.rev += +(it as any).grandTotal || 0;\n }\n }\n }\n for (const c of firstToday) {\n if (!st.cust[c]) { st.cust[c] = { f: d, s: null }; agg.newC++; }\n }\n agg.rev = +agg.rev.toFixed(2);\n agg.f69rev = +agg.f69rev.toFixed(2);\n agg.repRev = +agg.repRev.toFixed(2);\n st.daily[d] = agg;\n}\n\n// Process up to CHUNK missing closed days; returns true when history is complete.\nasync function buildChunk(slug: string, force = false): Promise<{ done: boolean; remaining: number; through: string | null }> {\n const today = istNow().date;\n const yday = shift(today, -1);\n const outlet = outletsFromEnv().find((x) => slugify(x?.name ?? \"\") === slug);\n const open = openDates()[outlet?.name ?? \"\"] ?? \"2026-09-01\";\n const st = force ? emptyState() : await readState(slug);\n const missing: string[] = [];\n for (let d = open; d <= yday; d = shift(d, 1)) {\n if (!st.daily[d]) missing.push(d);\n }\n const todo = missing.slice(0, CHUNK);\n if (todo.length) {\n const panel = await panelFor(slug);\n const days = await loadDays(\n panel, slug, todo[0], todo[todo.length - 1], today, salt(), store,\n );\n for (const d of todo) foldDay(st, d, days[d] ?? []);\n await store.set(`xp2:agg:${AGG_V}:${slug}`, st);\n }\n const remaining = Math.max(0, missing.length - todo.length);\n return {\n done: remaining === 0,\n remaining,\n through: todo.length ? todo[todo.length - 1] : null,\n };\n}\n\nfunction weekKey(iso: string) { // Monday-start week label = the Monday's date\n const t = new Date(iso + \"T00:00:00Z\");\n t.setUTCDate(t.getUTCDate() - ((t.getUTCDay() + 6) % 7));\n return t.toISOString().slice(0, 10);\n}\n\nfunction aggResponse(slug: string, st: AggState, done: boolean, remaining: number) {\n const today = istNow().date;\n const dates = Object.keys(st.daily).sort();\n const daily = dates.map((d) => {\n const a = st.daily[d];\n const ex = a.o - a.f69o;\n return {\n d, o: a.o, rev: a.rev,\n aov: a.o ? +(a.rev / a.o).toFixed(2) : 0,\n f69s: a.o ? +(a.f69o / a.o * 100).toFixed(1) : 0,\n f69rev: a.f69rev,\n exAOV: ex ? +((a.rev - a.f69rev) / ex).toFixed(2) : 0,\n repS: a.o ? +(a.repO / a.o * 100).toFixed(1) : 0,\n repO: a.repO, newC: a.newC, can: a.can,\n };\n });\n // weekly rollup (Mon-Sun)\n const wk: Record = {};\n for (const d of dates) {\n const a = st.daily[d];\n const k = weekKey(d);\n const w = wk[k] ??= { o: 0, rev: 0, f69o: 0, f69rev: 0, repO: 0 };\n w.o += a.o; w.rev += a.rev; w.f69o += a.f69o; w.f69rev += a.f69rev; w.repO += a.repO;\n }\n const weekly = Object.keys(wk).sort().map((k) => {\n const w = wk[k];\n const ex = w.o - w.f69o;\n return {\n wk: k, o: w.o, rev: +w.rev.toFixed(2),\n aov: w.o ? +(w.rev / w.o).toFixed(2) : 0,\n f69s: w.o ? +(w.f69o / w.o * 100).toFixed(1) : 0,\n exAOV: ex ? +((w.rev - w.f69rev) / ex).toFixed(2) : 0,\n repS: w.o ? +(w.repO / w.o * 100).toFixed(1) : 0,\n };\n });\n // monthly cohorts from the customer map\n const co: Record = {};\n let sepC = 0, sepR7 = 0, sepR30 = 0;\n for (const cu of Object.values(st.cust)) {\n if (!cu?.f) continue;\n const m = cu.f.slice(0, 7);\n const c = co[m] ??= { customers: 0, r7: 0, r30: 0 };\n c.customers++;\n if (cu.s) {\n const gap = (Date.parse(cu.s) - Date.parse(cu.f)) / 864e5;\n if (gap <= 7) c.r7++;\n if (gap <= 30) c.r30++;\n if (m === \"2026-09\") {\n if (gap <= 7) sepR7++;\n if (gap <= 30) sepR30++;\n }\n }\n if (m === \"2026-09\") sepC++;\n }\n const cohorts = Object.keys(co).sort().map((m) => ({\n month: m,\n customers: co[m].customers,\n r7: +(co[m].r7 / co[m].customers * 100).toFixed(1),\n r30: +(co[m].r30 / co[m].customers * 100).toFixed(1),\n }));\n const totO = dates.reduce((s, d) => s + st.daily[d].o, 0);\n const totRev = dates.reduce((s, d) => s + st.daily[d].rev, 0);\n const totRep = dates.reduce((s, d) => s + st.daily[d].repO, 0);\n const open = dates.find((d) => st.daily[d].o > 0) ?? dates[0] ?? null;\n return {\n slug,\n open,\n built_through: dates[dates.length - 1] ?? null,\n done,\n remaining,\n generated: istNow().human,\n daily,\n weekly,\n cohorts,\n sepCohort: {\n customers: sepC,\n r7: sepC ? +(sepR7 / sepC * 100).toFixed(1) : 0,\n r30: sepC ? +(sepR30 / sepC * 100).toFixed(1) : 0,\n },\n totals: {\n orders: totO,\n revenue: +totRev.toFixed(2),\n customers: Object.keys(st.cust).length,\n aov: totO ? +(totRev / totO).toFixed(2) : 0,\n repeatShare: totO ? +(totRep / totO * 100).toFixed(1) : 0,\n },\n today, // client treats this date as \"live, fetch from /api/data\"\n };\n}\n\nfunction outletsMeta() {\n const opens = openDates(), rnts = rents();\n return outletsFromEnv().map((o) => ({\n name: o.name,\n slug: slugify(o?.name ?? \"\"),\n open: opens[o.name] ?? null,\n rent: rnts[o.name] ?? null,\n }));\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const given = url.searchParams.get(\"key\") ?? req.headers.get(\"x-dash-key\") ?? \"\";\n if (!keyOk(given)) {\n const api = url.pathname.startsWith(\"/api/\");\n return new Response(\n api ? JSON.stringify({ error: \"unauthorised\" }) : \"Add ?key=YOUR_KEY to the address.\",\n { status: 401, headers: { \"content-type\": api ? \"application/json\" : \"text/plain\" } },\n );\n }\n const json = (v: unknown, status = 200) =>\n new Response(JSON.stringify(v), {\n status,\n headers: { \"content-type\": \"application/json; charset=utf-8\", \"cache-control\": \"no-store\" },\n });\n\n if (url.pathname === \"/api/agg\" || url.pathname === \"/api/items\") {\n const meta = outletsMeta();\n const slug = url.searchParams.get(\"outlet\") || meta[0]?.slug || \"\";\n const force = url.searchParams.get(\"reset\") === \"1\";\n if (!meta.some((m) => m.slug === slug)) return json({ error: \"unknown outlet\" }, 404);\n const ck = `agg:${slug}:${url.pathname}`;\n if (!force) {\n const hit = cache.get(ck);\n if (hit && Date.now() - hit.at < 60_000) return json(hit.data);\n }\n try {\n const r = await buildChunk(slug, force);\n const st = await readState(slug);\n if (url.pathname === \"/api/items\") {\n const items = Object.entries(st.items)\n .map(([name, v]) => ({\n name,\n cat: v?.cat ?? \"\",\n qty: v?.qty ?? 0,\n rev: +(+((v?.rev ?? 0).toFixed?.(2) ?? 0)).valueOf(),\n unit: v?.qty ? +((v.rev ?? 0) / v.qty).toFixed(2) : 0,\n }))\n .sort((a, b) => b.qty - a.qty);\n const out = { slug, done: r.done, remaining: r.remaining, items, outlets: meta };\n if (r.done) cache.set(ck, { at: Date.now(), data: out });\n return json(out);\n }\n const out = { ...aggResponse(slug, st, r.done, r.remaining), outlets: meta };\n if (r.done) cache.set(ck, { at: Date.now(), data: out });\n return json(out);\n } catch (e) {\n return json({ error: `${(e as Error)?.name ?? \"Error\"}: ${(e as Error)?.message ?? e}` }, 500);\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(7, Math.min(120, +(url.searchParams.get(\"days\") ?? 30)));\n const iso = (v: string | null) => v && /^\\d{4}-\\d{2}-\\d{2}$/.test(v) ? v : undefined;\n const from = iso(url.searchParams.get(\"from\")), 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(slug, ndays, store, panelFor, from, to, mode);\n cache.set(ck, { at: Date.now(), data });\n } catch (e) {\n return json({ error: `${(e as Error)?.name ?? \"Error\"}: ${(e as Error)?.message ?? e}` }, 500);\n }\n }\n return json(data);\n }\n\n return new Response(TEMPLATE, {\n headers: { \"content-type\": \"text/html; charset=utf-8\", \"cache-control\": \"no-store\" },\n });\n}\n","xpanse-dashboard",[201],"ff2cedd6-2915-4395-96fa-ea823f30bac4","main.ts","ab88dccc-ae26-11f1-88d3-1607ee4eb77e",54,["D",1789383399818],"interval","// Xpanse combined sales reports (one email per run, Kamla Nagar-centric).\n// Schedule (Val Town cron UI): 35 3,6,9,12,15,18 * * * UTC =\n// 9:05 AM, 12:05 PM, 3:05 PM, 6:05 PM, 9:05 PM IST so-far-today + 12:05 AM IST day-close.\nimport { email as alertEmail } from \"https://esm.town/v/std/email\";\nimport { istNow, outletsFromEnv } from \"./lib.ts\";\nimport { runCombined } from \"./report.ts\";\n\nexport default async function () {\n const now = istNow();\n try {\n const r = await runCombined(outletsFromEnv(), now);\n console.log(\"sent:\", r.subject);\n } catch (e: any) {\n console.error(\"FAILED combined report:\", e?.stack ?? e);\n try {\n await alertEmail({\n subject: `Xpanse monitor: combined report skipped on ${now.date} ${now.hour}:05 IST`,\n text:\n \"The combined report was NOT sent (data guard tripped or fetch/send failed). No zeroed payload was sent.\\n\\n\" +\n (e?.message ?? String(e)),\n });\n } catch (e2) {\n console.error(\"alert email failed\", e2);\n }\n }\n}\n",[209],"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}",[217],"pulls","branches",1,"forks","envVars",{"_232":234,"_235":26},"connections",{"_232":26,"_233":26},"count","unfilledCount",10,"emptyCount",{"_34":216,"_13":217,"_63":218,"_44":-5,"_36":37,"_168":219,"_170":86,"_38":262,"_40":221,"_65":182,"_172":222,"_67":24,"_174":-5,"_244":263,"_17":264},{"_34":208,"_13":209,"_63":210,"_44":-5,"_36":37,"_168":211,"_170":86,"_38":259,"_40":181,"_65":213,"_172":214,"_67":24,"_174":-5,"_244":260,"_17":261},{"_34":200,"_13":201,"_63":99,"_44":-5,"_36":37,"_168":202,"_170":86,"_38":256,"_40":204,"_65":66,"_172":205,"_67":24,"_174":206,"_244":257,"_17":258},{"_34":192,"_13":193,"_63":194,"_44":-5,"_36":37,"_168":195,"_170":86,"_38":253,"_40":197,"_65":182,"_172":198,"_67":24,"_174":-5,"_244":254,"_17":255},{"_34":185,"_13":186,"_63":187,"_44":-5,"_36":37,"_168":188,"_170":86,"_38":250,"_40":26,"_65":21,"_172":190,"_67":24,"_174":-5,"_244":251,"_17":252},{"_34":176,"_13":177,"_63":178,"_44":-5,"_36":37,"_168":179,"_170":86,"_38":247,"_40":181,"_65":182,"_172":183,"_67":24,"_174":-5,"_244":248,"_17":249},{"_34":165,"_13":166,"_63":167,"_44":-5,"_36":37,"_168":169,"_170":86,"_38":243,"_40":26,"_65":66,"_172":173,"_67":24,"_174":-5,"_244":245,"_17":246},["D",1789309006852],"children",[],[166],["D",1789332871807],[],[177],["D",1789225174687],[],[186],["D",1789383399494],[],[193],["D",1789332872449],[],[201],["D",1789383399818],[],[209],["D",1789225171018],[],[217],["D",1789161653473],{"_11":12,"_137":70},{"_11":12,"_132":133,"_69":70,"_30":68,"_134":135,"_136":24},{"_40":123,"_13":16,"_34":37,"_124":88,"_125":-5,"_126":-5,"_127":-5,"_128":-5,"_129":-5,"_130":14,"_131":12},"ctx",{"_53":-5,"_155":302,"_303":304,"_305":306,"_307":24,"_308":24,"_309":24,"_310":86,"_311":-5,"_312":-7,"_313":-7,"_314":26,"_315":24,"_316":24,"_317":-5,"_318":24,"_319":24,"_320":24,"_321":-5},"ENV",{"_273":274,"_275":276,"_277":16,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301},"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"]

Xpanse

Today

Month against the \\u20b920 lakh target

Live

Orders by hour today vs yesterday vs same weekday last week

Top sellers today

Trend

Orders and net revenue per day

AOV and discount depth

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

Food attach, kiosk share, FIRST69 share

Customers

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

Orders per customer

Mix

Coupons orders \\u00b7 net AOV

Categories items

Top items quantity

Average orders by weekday and hour closed days in window

Bought together

Other outlets

Outlets side by side

Net revenue per month

Daily net revenue last 120 days

Repeat share 7-day rolling, orders from returning customers

FIRST69 share 7-day rolling

Launch benchmark each outlet aligned to its own day 1; KN vs how GG and RR launched

Cumulative net revenue by day since opening

Orders per day 7-day average since opening

FIRST69 share decay 7-day average since opening

Repeat share build 7-day average since opening

Kamla Nagar hypothesis tracker

Weekly revenue and repeat share

Weekly FIRST69 share and ex-FIRST69 AOV

Monthly cohorts share of new customers who returned within 7 / 30 days

Item economics realised price per unit (amount actually paid, sizes aggregated); full history through yesterday

Top sellers

Other outlets

${title}

History · analysis.ts