[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_104":105,"_106":107},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","niteshgarg","name","xpanse","path","new-file-5192.ts","project",{"_22":46,"_11":12,"_33":47,"_48":-5,"_49":42,"_50":51,"_52":51,"_53":54,"_55":-5,"_56":57,"_58":25,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_13":45},"permalink","https://www.val.town/x/niteshgarg/xpanse/code/new-file-5192.ts","extension","id","d122e261-3ac8-49e6-b567-5888516fbec1","fileId","adbda594-ae27-11f1-addd-1607ee4eb77e","parentId","branchId","9509c19b-cd54-48fd-9577-26d89f1fc9cc","branchVersion",52,"latest",true,"createdAt",["D",1789332872449],"version",6,"fileType","http","content","// 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","deleted",false,"label","xpanse-dashboard",[14],"c444b125-c0e4-4e1f-9773-378ed6c62e9f",["D",1789161653473],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Xpanse Kamla Nagar sales reports and live dashboard","imageUrl","userId","9fb27c8d-12ff-4687-8d23-4c57f7106bcc","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f568a-526e-749f-bfce-9d7116ddbe2c","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_103":99},"org",{"_9":10,"_96":97,"_98":99,"_56":57,"_100":101,"_102":42},"branch",{"_35":86,"_11":87,"_22":28,"_88":46,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":12,"_95":10},"isOwned",58,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Nitesh Garg","avatar","https://lh3.googleusercontent.com/a/ACg8ocI3s1ahWykesQS62y9kulHCxNb4oEZxdLUspwqUjPgDKzd0QA=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_79":-5,"_137":138,"_139":140,"_141":142,"_143":42,"_144":42,"_145":42,"_146":32,"_147":-5,"_148":-7,"_149":-7,"_150":63,"_151":42,"_152":42,"_153":-5,"_154":42,"_155":42,"_156":42,"_157":-5},"ENV",{"_108":109,"_110":111,"_112":87,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]