Waiting for the first delivery…

';\n } else {\n lb.innerHTML = s.drivers.map(function(d, i){\n return '

'\n + '

' + medal(i) + ''\n + '' + esc(d.name) + ''\n + (d.missed ? '' + d.missed + ' missed' : '') + '

'\n + '

' + d.delivered + ''\n + 'delivered

';\n }).join('');\n }\n var last = document.getElementById('last');\n if(s.last && s.last.customerName){\n last.textContent = (s.last.status === 'delivered' ? '✅ ' : '❌ ') + s.last.driver + ' → ' + s.last.customerName;\n }\n }\n function poll(){\n fetch('/api/leaderboard', { cache: 'no-store' })\n .then(function(r){ return r.json(); })\n .then(function(s){\n if(lastTotal !== null && s.total > lastTotal) celebrate();\n if(lastMissed !== null && s.missed > lastMissed) frown();\n lastTotal = s.total;\n lastMissed = s.missed;\n render(s);\n })\n .catch(function(){});\n }\n setInterval(poll, 2500);\n poll();\n})();\n`;\n\n// ---- Shared HTML shell ----\ninterface ShellOpts {\n barcode?: boolean;\n autoReload?: boolean;\n confetti?: boolean;\n bodyScript?: string;\n}\nfunction shell(title: string, body: unknown, opts: ShellOpts = {}) {\n return html`\n \n \n \n \n ${title}\n \n \n ${opts.barcode\n ? html``\n : \"\"}\n ${opts.confetti\n ? html``\n : \"\"}\n \n \n \n

${body}

\n ${opts.barcode ? html`` : \"\"}\n ${opts.autoReload ? html`` : \"\"}\n ${opts.bodyScript ? html`` : \"\"}\n \n `;\n}\n\n// ---- Dashboard: all published routes ----\nexport function dashboardPage(rows: RouteRow[]) {\n const cards = rows.length\n ? rows.map((row) => {\n const r = row.payload.route;\n const stops = row.payload.timeline.filter((t) => t.type === \"delivering_stop\").length;\n return html`\n

${r.name}

${r.date}

\n ${statusBadge(r.status)}\n

\n \n ${(r.driver?.name ?? \"—\").slice(0, 1).toUpperCase()}\n \n ${r.driver?.name ?? \"Unassigned\"}\n

${stops}

stops

${r.ordersCount}

orders

${r.distanceInKilometers}

Open packing →

\n `;\n })\n : html`

📦

No routes yet

Publish a route in Routific and it'll appear here.

`;\n\n return shell(\n \"Warehouse — Packing Queue\",\n html`\n

Warehouse Ops

Packing Queue

\n A route to pack appears here the moment a dispatcher publishes it in Routific.\n

${cards}

\n Powered by the route.published webhook · auto-refreshing ·\n delivery wall · view source\n

\n `,\n { autoReload: true },\n );\n}\n\n// ---- Packing workspace for one route ----\nexport function loadSheetPage(row: RouteRow) {\n const r = row.payload.route;\n const driver = r.driver?.name ?? \"Unassigned\";\n const orders = packOrders(row.payload);\n const stopCount = new Set(orders.map((o) => o.stopSequence)).size;\n\n // Pick / pack checklist rows (loading order).\n const checklistRows = orders.map(\n (o) => html`\n \n \n \n \n \n ${o.loadNumber}\n \n \n ${o.tote}\n \n ${o.customerName ? html`

${o.customerName}

` : \"\"}\n

${o.customerOrderNumber}

${o.routificOrderNumber}

\n \n \n stop #${o.stopSequence}
ETA ${fmtTime(o.eta)}\n \n `,\n );\n\n // Printable parcel labels (one per order).\n const labels = orders.map(\n (o) => html`

${r.name} · ${r.date}

Driver: ${driver}

${o.tote}

tote

\n Load ${o.loadNumber}\n drop stop #${o.stopSequence} · ETA ${fmtTime(o.eta)}\n

\n ${o.customerName\n ? html`

📦 ${o.customerName}

`\n : \"\"}\n

\n \n

\n ${o.customerOrderNumber}\n ${o.routificOrderNumber}\n

`,\n );\n\n return shell(\n `Packing — ${r.name}`,\n html`\n

\n ← Packing queue\n

\n\n \n

${r.name}

\n ${statusBadge(r.status)}\n

${r.date}

\n \n ${driver.slice(0, 1).toUpperCase()}\n \n ${driver}\n

${stopCount}

stops

${orders.length}

orders

${fmtDuration(r.workingTimeInSeconds)}

est. time

\n Pick each order into its tote and tick it off. Totes are numbered in loading order —\n load Tote T01 first (deepest in the van) so the first delivery sits at the doors.\n Then print the parcel labels below.\n

\n\n \n

\n Packing progress\n 0 / ${orders.length} packed\n

\n \n \n

\n\n \n

📋 Pick & pack list · loading order

\n \n \n \n \n \n \n \n \n \n \n ${checklistRows}\n

✓	Load	Tote	Order	Drop

\n\n \n

${r.name} · ${r.date}

${driver} · ${orders.length} parcels

🏷️ Parcel labels

${labels}

\n\n

\n Generated from the route.published webhook · received ${row.received_at} ·\n view source\n

\n `,\n { barcode: true },\n );\n}\n\n// ---- Delivery Wall: live leaderboard + confetti (order.status_updated) ----\nexport function leaderboardPage() {\n return shell(\n \"Delivery Wall\",\n html`\n

Live

🎉 Delivery Wall

Confetti flies every time a driver completes a delivery.

\n\n

deliveries today

0 missed

\n\n

🏆 Leaderboard

Waiting for the first delivery…

\n\n

\n Powered by the order.status_updated webhook ·\n packing queue · view source\n

\n `,\n { confetti: true, bodyScript: WALL_SCRIPT },\n );\n}\n\nexport { raw };\n","deleted","label",[113],"fed240b8-c369-4f37-aa32-3b23cc6d2a09","main.ts","496ba7dc-68e3-11f1-b401-1607ee4eb77e",23,["D",1781549203148],9,"http","import { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { dashboardPage, leaderboardPage, loadSheetPage, type RoutePayload, type RouteRow } from \"./views.ts\";\n\nconst TABLE = \"routific_routes\";\nconst COMPLETIONS = \"order_completions\";\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE} (\n uuid TEXT PRIMARY KEY,\n payload TEXT NOT NULL,\n received_at TEXT NOT NULL\n)`);\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${COMPLETIONS} (\n order_uuid TEXT PRIMARY KEY,\n route_uuid TEXT,\n driver_name TEXT,\n customer_name TEXT,\n customer_order TEXT,\n status TEXT,\n received_at TEXT NOT NULL\n)`);\n\n/** Verify the Routific HMAC-SHA256 signature against the raw body. */\nasync function verifySignature(rawBody: string, header: string | null, secret: string): Promise {\n if (!header?.startsWith(\"v0=\")) return false;\n const signatures = header.slice(3).split(\",\").map((s) => s.trim());\n const key = await crypto.subtle.importKey(\n \"raw\",\n new TextEncoder().encode(secret),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const mac = await crypto.subtle.sign(\"HMAC\", key, new TextEncoder().encode(rawBody));\n const expected = [...new Uint8Array(mac)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n // constant-time-ish comparison\n return signatures.some((sig) => sig.length === expected.length && timingSafeEqual(sig, expected));\n}\n\nfunction timingSafeEqual(a: string, b: string): boolean {\n let mismatch = a.length === b.length ? 0 : 1;\n const len = Math.max(a.length, b.length);\n for (let i = 0; i < len; i++) mismatch |= a.charCodeAt(i) ^ b.charCodeAt(i);\n return mismatch === 0;\n}\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\n// --- Webhook receiver: route.published ---\napp.post(\"/webhook\", async (c) => {\n const rawBody = await c.req.text();\n const topic = c.req.header(\"x-routific-topic\");\n const secret = Deno.env.get(\"ROUTIFIC_WEBHOOK_SECRET\");\n\n // Signature verification is opt-in: set ROUTIFIC_VERIFY_SIGNATURE=true (and a correct\n // ROUTIFIC_WEBHOOK_SECRET) to enforce it. Off by default so the demo is plug-and-play.\n if (Deno.env.get(\"ROUTIFIC_VERIFY_SIGNATURE\") === \"true\" && secret) {\n const ok = await verifySignature(rawBody, c.req.header(\"x-routific-signature\") ?? null, secret);\n if (!ok) return c.text(\"invalid signature\", 401);\n }\n\n // deno-lint-ignore no-explicit-any\n let body: any;\n try {\n body = JSON.parse(rawBody);\n } catch {\n return c.text(\"invalid json\", 400);\n }\n const type = body.type ?? topic;\n\n // route.published → store the full route for packing.\n if (type === \"route.published\" && body.data?.route?.uuid) {\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE} (uuid, payload, received_at) VALUES (?, ?, ?)\n ON CONFLICT(uuid) DO UPDATE SET payload = excluded.payload, received_at = excluded.received_at`,\n args: [body.data.route.uuid, JSON.stringify(body.data), new Date().toISOString()],\n });\n return c.json({ ok: true, stored: body.data.route.uuid });\n }\n\n // order.status_updated → record a completion for the Delivery Wall, attributing it to the route's driver.\n if (type === \"order.status_updated\" && body.data?.order?.uuid) {\n const order = body.data.order;\n const routeUuid: string = body.data.route?.uuid ?? \"\";\n let driver = \"Unknown driver\";\n let customerName: string | undefined = order.customerName;\n\n if (routeUuid) {\n const rr = await sqlite.execute({ sql: `SELECT payload FROM ${TABLE} WHERE uuid = ?`, args: [routeUuid] });\n if (rr.rows.length) {\n const p = JSON.parse(rr.rows[0].payload as string) as RoutePayload;\n driver = p.route?.driver?.name ?? driver;\n if (!customerName) {\n for (const t of p.timeline ?? []) {\n for (const o of t.orders ?? []) {\n if (o.routificOrderNumber === order.routificOrderNumber) customerName = o.customerName;\n }\n }\n }\n }\n }\n customerName = customerName ?? order.customerOrderNumber;\n\n await sqlite.execute({\n sql: `INSERT INTO ${COMPLETIONS} (order_uuid, route_uuid, driver_name, customer_name, customer_order, status, received_at)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(order_uuid) DO UPDATE SET\n status = excluded.status, driver_name = excluded.driver_name,\n customer_name = excluded.customer_name, received_at = excluded.received_at`,\n args: [order.uuid, routeUuid, driver, customerName, order.customerOrderNumber, order.status, new Date().toISOString()],\n });\n return c.json({ ok: true, recorded: order.uuid, driver, status: order.status });\n }\n\n // Acknowledge other topics so Routific doesn't retry.\n return c.json({ ok: true, ignored: type ?? \"unknown\" });\n});\n\nasync function loadRows(): Promise {\n const res = await sqlite.execute(`SELECT uuid, payload, received_at FROM ${TABLE} ORDER BY received_at DESC`);\n return res.rows.map((row) => ({\n uuid: row.uuid as string,\n payload: JSON.parse(row.payload as string) as RoutePayload,\n received_at: new Date(row.received_at as string).toLocaleString(),\n }));\n}\n\n// --- Lightweight state signature for auto-refresh polling ---\napp.get(\"/api/state\", async (c) => {\n const res = await sqlite.execute(\n `SELECT COUNT(*) AS count, COALESCE(MAX(received_at), '') AS latest FROM ${TABLE}`,\n );\n const r = res.rows[0];\n return c.json({ count: Number(r.count), latest: r.latest as string });\n});\n\n// --- Warehouse dashboard ---\napp.get(\"/\", async (c) => c.html(dashboardPage(await loadRows()).toString()));\n\n// --- Load & pick sheet for one route ---\napp.get(\"/route/:uuid\", async (c) => {\n const res = await sqlite.execute({\n sql: `SELECT uuid, payload, received_at FROM ${TABLE} WHERE uuid = ?`,\n args: [c.req.param(\"uuid\")],\n });\n if (res.rows.length === 0) return c.text(\"Route not found\", 404);\n const row = res.rows[0];\n const data: RouteRow = {\n uuid: row.uuid as string,\n payload: JSON.parse(row.payload as string) as RoutePayload,\n received_at: new Date(row.received_at as string).toLocaleString(),\n };\n return c.html(loadSheetPage(data).toString());\n});\n\n// --- Delivery Wall leaderboard data ---\napp.get(\"/api/leaderboard\", async (c) => {\n const agg = await sqlite.execute(`\n SELECT driver_name,\n SUM(CASE WHEN status = 'delivered' THEN 1 ELSE 0 END) AS delivered,\n SUM(CASE WHEN status = 'missed' THEN 1 ELSE 0 END) AS missed\n FROM ${COMPLETIONS} GROUP BY driver_name`);\n const drivers = agg.rows\n .map((r) => ({ name: r.driver_name as string, delivered: Number(r.delivered), missed: Number(r.missed) }))\n .filter((d) => d.delivered + d.missed > 0)\n .sort((a, b) => b.delivered - a.delivered);\n const total = drivers.reduce((s, d) => s + d.delivered, 0);\n const missed = drivers.reduce((s, d) => s + d.missed, 0);\n const lastRes = await sqlite.execute(\n `SELECT driver_name, customer_name, status FROM ${COMPLETIONS} ORDER BY received_at DESC LIMIT 1`,\n );\n const lr = lastRes.rows[0];\n const last = lr\n ? { driver: lr.driver_name as string, customerName: lr.customer_name as string, status: lr.status as string }\n : null;\n return c.json({ total, missed, drivers, last });\n});\n\napp.get(\"/wall\", (c) => c.html(leaderboardPage().toString()));\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\nexport default app.fetch;\n",[130],"pulls","branches",1,"forks","envVars",{"_146":140,"_148":40},"connections",{"_146":40,"_147":40},"count","unfilledCount","emptyCount",{"_18":129,"_20":130,"_114":131,"_116":-5,"_117":69,"_118":132,"_119":105,"_22":155,"_66":134,"_122":135,"_124":136,"_126":26,"_127":-5,"_152":156,"_87":157},{"_18":112,"_20":113,"_114":115,"_116":-5,"_117":69,"_118":67,"_119":105,"_22":151,"_66":121,"_122":123,"_124":125,"_126":26,"_127":-5,"_152":153,"_87":154},["D",1781549445011],"children",[],[113],["D",1781549203148],[],[130],["D",1781545960614],["D",1789498239291],{"_16":17,"_85":81},{"_16":17,"_78":79,"_80":81,"_33":34,"_82":83,"_84":26},{"_66":67,"_20":68,"_18":69,"_70":19,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":21,"_77":17},"ctx",{"_59":-5,"_107":196,"_197":198,"_199":200,"_201":26,"_202":26,"_203":26,"_204":105,"_205":-5,"_206":-7,"_207":-7,"_208":40,"_209":26,"_210":26,"_211":-5,"_212":26,"_213":26,"_214":26,"_215":-5},"ENV",{"_167":168,"_169":170,"_171":68,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195},"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"]

Search