\\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",[132],"5d9a02b0-ac54-46d9-b03a-939c9260b88f",["D",1789224815542],[28],"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",[147],"1948f1be-9bc5-4a37-b0a1-0b239a51e3fa","main.ts","ab88dccc-ae26-11f1-88d3-1607ee4eb77e",12,["D",1789162075581],3,"interval","// Val Town CRON val. Schedule (UTC): 35 3,6,9,12,15,18 * * * -> 9:05am, 12:05pm, 3:05pm, 6:05pm, 9:05pm, 12:05am IST.\n// One combined email per slot: primary outlet (first in OUTLETS) in full, the others as a strip.\n// Env: OUTLETS (json list of {name, username, password}), EMAIL_TO (optional; defaults to your Val Town email),\n// ANTHROPIC_API_KEY (optional), MONTHLY_TARGET (default 2000000), PHONE_SALT (any string).\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport {\n buildOther,\n buildPrimary,\n inr,\n istNow,\n loadDays,\n monthFirst,\n outletsFromEnv,\n Panel,\n renderCombined,\n salt,\n shift,\n SLOTS,\n slugify,\n summarize,\n target,\n} from \"./lib.ts\";\n\nconst store = {\n get: (k: string) => blob.getJSON(k),\n set: (k: string, v: any) => blob.setJSON(k, v),\n};\n\nexport default async function (interval?: any) {\n const now = istNow();\n const forceSlot = interval?.slot as string | undefined; // manual runs: {slot:\"15\"} or {slot:\"00\"}\n let slotHour: number, isDigest: boolean;\n if (forceSlot != null) {\n slotHour = +forceSlot;\n isDigest = slotHour === 0;\n } else if (now.hour < SLOTS[0]) {\n slotHour = 0;\n isDigest = true;\n } else {\n slotHour = Math.max(...SLOTS.filter((s) => s <= now.hour));\n isDigest = false;\n }\n\n const outlets = outletsFromEnv();\n if (!outlets.length) throw new Error(\"OUTLETS env not set\");\n const today = now.date;\n let primary: any = null;\n const others: any[] = [];\n for (let i = 0; i < outlets.length; i++) {\n const o = outlets[i],\n slug = slugify(o.name),\n panel = new Panel(o.username, o.password);\n await panel.login();\n if (i === 0) {\n const days = await loadDays(\n panel,\n slug,\n shift(today, -35),\n today,\n today,\n salt(),\n store,\n );\n primary = buildPrimary(days, o.name, now, slotHour, isDigest, target());\n } else {\n const start = [monthFirst(today), shift(today, -8)].sort()[0];\n const days = await loadDays(\n panel,\n slug,\n shift(start, -1),\n today,\n today,\n salt(),\n store,\n );\n others.push(buildOther(days, o.name, now, isDigest, target()));\n }\n }\n const [summary, engine] = await summarize(primary, others);\n const t = primary.today;\n const tail = others.length\n ? \" | \" +\n others.map((x) => `${x.outlet.replace(\"Xpanse \", \"\")} ${x.today.orders}`)\n .join(\" · \")\n : \"\";\n const subject = isDigest\n ? `${primary.outlet} ${primary.closed_day_human}: ${t.orders} orders · ${\n inr(t.revenue)\n } · AOV ${inr(t.aov)}${tail}`\n : `${primary.outlet} ${slotHour % 12 || 12}${\n slotHour < 12 ? \"am\" : \"pm\"\n }: ${t.orders} orders · ${\n inr(t.revenue)\n } (+${primary.since_last.orders} since ${primary.since_last.from_label})${tail}`;\n const html = renderCombined(primary, others, summary, engine);\n const to = (Deno.env.get(\"EMAIL_TO\") ?? \"\").split(\",\").map((x) => x.trim())\n .filter(Boolean);\n await email({ subject, html, text: summary, ...(to.length ? { to } : {}) });\n console.log(`sent [${engine}] ${subject}`);\n return subject;\n}",[155],"284a1d78-6df6-4ec2-be8e-5ec2843da015","lib.ts","b6ee60a0-ae26-11f1-ba7d-1607ee4eb77e",25,["D",1789163920564],6,"// 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\nfunction 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}",[164],"pulls","branches",1,"forks","envVars",{"_179":181,"_182":61},"connections",{"_179":61,"_180":61},"count","unfilledCount",10,"emptyCount",{"_42":163,"_32":164,"_30":165,"_134":-5,"_40":41,"_39":166,"_136":26,"_37":201,"_13":168,"_33":139,"_35":169,"_23":26,"_141":-5,"_189":202,"_27":203},{"_42":154,"_32":155,"_30":156,"_134":-5,"_40":41,"_39":157,"_136":26,"_37":198,"_13":159,"_33":160,"_35":161,"_23":26,"_141":-5,"_189":199,"_27":200},{"_42":146,"_32":147,"_30":56,"_134":-5,"_40":41,"_39":148,"_136":26,"_37":195,"_13":150,"_33":34,"_35":151,"_23":26,"_141":152,"_189":196,"_27":197},{"_42":143,"_32":28,"_30":31,"_134":-5,"_40":41,"_39":14,"_136":26,"_37":192,"_13":61,"_33":34,"_35":36,"_23":26,"_141":-5,"_189":193,"_27":194},{"_42":131,"_32":132,"_30":133,"_134":-5,"_40":41,"_39":135,"_136":26,"_37":188,"_13":138,"_33":139,"_35":140,"_23":26,"_141":-5,"_189":190,"_27":191},["D",1789163933610],"children",[],[132],["D",1789224815542],[],[28],["D",1789163947156],[],[147],["D",1789162075581],[],[155],["D",1789163920564],[],[164],["D",1789161653473],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":54,"_100":101,"_102":26},{"_13":84,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_77":-5,"_123":241,"_242":243,"_244":245,"_246":26,"_247":26,"_248":26,"_249":24,"_250":-5,"_251":-7,"_252":-7,"_253":61,"_254":26,"_255":26,"_256":-5,"_257":26,"_258":26,"_259":26,"_260":-5},"ENV",{"_212":213,"_214":215,"_216":85,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240},"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 · v28