CRD Inventory Tracker

[{"_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","derrickrunger","name","inventory-tracker-v1","path","main.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":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":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/derrickrunger/inventory-tracker-v1/code/main.ts","extension","id","fb957a3c-22b6-4d6a-ac50-29bfdf34dab5","fileId","26940810-abb6-11f1-9cb9-1607ee4eb77e","parentId","branchId","14ec610f-0b41-45b4-8a67-de9e2a917eef","branchVersion",117,"latest",true,"createdAt",["D",1789399960644],"version",116,"fileType","http","content","import { sqlite as s } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst x = Deno.env.get(\"GRANT_KEY\") ?? \"\",\n I = Deno.env.get(\"ADMIN_KEY\") ?? \"\",\n M = Deno.env.get(\"ORG_ID\") ?? \"22PPpRKWTXeh\",\n D = \"https://api.jobtread.com/pave\",\n U = \"Material\",\n $ = \"Project Status\",\n P = [\n \"In Production\",\n \"Pre-Construction\",\n \"Production Queue\",\n \"Completion List\",\n ];\nlet A = null;\nfunction F() {\n return A ??= (async () => {\n await s.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS jobs (\n id TEXT PRIMARY KEY, name TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS items (\n id TEXT PRIMARY KEY,\n job_id TEXT, job_name TEXT,\n cost_group TEXT, name TEXT, description TEXT,\n custom_fields TEXT, order_status TEXT,\n updated_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS items_staging (\n id TEXT PRIMARY KEY,\n job_id TEXT, job_name TEXT,\n cost_group TEXT, name TEXT, description TEXT,\n custom_fields TEXT, order_status TEXT,\n updated_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS barcodes (\n code TEXT PRIMARY KEY, item_id TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS users (\n id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT UNIQUE\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS activity (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n item_id TEXT, item_name TEXT, job_name TEXT,\n user_name TEXT, fields TEXT, ts TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS sync_state (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n status TEXT, job_ids TEXT, job_cursor INTEGER,\n page_cursor TEXT, items_synced INTEGER, last_error TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS presence (\n user_name TEXT PRIMARY KEY,\n action TEXT,\n updated_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS warehouse_items (\n barcode TEXT PRIMARY KEY,\n name TEXT, description TEXT, location TEXT,\n quantity INTEGER DEFAULT 0,\n unit TEXT DEFAULT 'units',\n category TEXT, subcategory TEXT,\n photo TEXT,\n updated_at TEXT\n )`,\n },\n { sql: \"CREATE INDEX IF NOT EXISTS idx_items_name ON items(name)\" },\n {\n sql:\n \"CREATE INDEX IF NOT EXISTS idx_items_job ON items(job_name, name)\",\n },\n {\n sql:\n \"CREATE INDEX IF NOT EXISTS idx_activity_job ON activity(job_name, id DESC)\",\n },\n ]);\n try {\n await s.execute(\"ALTER TABLE items ADD COLUMN description TEXT\");\n } catch {}\n try {\n await s.execute(\"ALTER TABLE items ADD COLUMN order_status TEXT\");\n } catch {}\n try {\n await s.execute(\"ALTER TABLE items_staging ADD COLUMN order_status TEXT\");\n } catch {}\n try {\n await s.execute(\"ALTER TABLE warehouse_items ADD COLUMN photo TEXT\");\n } catch {}\n try {\n await s.execute(\n \"ALTER TABLE warehouse_items ADD COLUMN unit TEXT DEFAULT 'units'\",\n );\n } catch {}\n try {\n await s.execute(\"ALTER TABLE warehouse_items ADD COLUMN category TEXT\");\n } catch {}\n try {\n await s.execute(\n \"ALTER TABLE warehouse_items ADD COLUMN subcategory TEXT\",\n );\n } catch {}\n })(),\n A;\n}\nfunction L(t) {\n return { query: { $: { grantKey: x }, ...t } };\n}\nasync function C(t) {\n const i = await fetch(D, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(t),\n }),\n n = await i.text();\n let e;\n try {\n e = JSON.parse(n);\n } catch {\n const o = new Error(\n `JobTread returned non-JSON (status ${i.status}): ${n.slice(0, 500)}`,\n );\n throw o.status = i.status, o;\n }\n if (e?.errors) throw new Error(JSON.stringify(e.errors));\n return e;\n}\nasync function N(t, i, n) {\n let e;\n for (const o of i) {\n try {\n const d = await C(t(o));\n return n?.(o), d;\n } catch (d) {\n if (e = d, d?.status !== 413) throw d;\n }\n }\n throw e;\n}\nlet O = 40, _ = 25;\nfunction B(t, i) {\n return Array.from(new Set([t, ...i]));\n}\nasync function H() {\n const i = [];\n let n;\n for (; i.length < 100;) {\n const e = await N(\n (c) =>\n L({\n organization: {\n $: { id: M },\n id: {},\n jobs: {\n $: { size: c, ...n ? { page: n } : {} },\n nextPage: {},\n nodes: {\n id: {},\n name: {},\n customFieldValues: {\n $: { size: 10 },\n nodes: { value: {}, customField: { name: {} } },\n },\n },\n },\n },\n }),\n B(O, [20, 10, 5, 2, 1]),\n (c) => {\n O = c;\n },\n ),\n o = e?.organization?.jobs?.nodes ?? [];\n for (const c of o) {\n const a = (c.customFieldValues?.nodes ?? []).find((l) =>\n l.customField?.name === $\n );\n a && P.includes(a.value) && i.push({ id: c.id, name: c.name });\n }\n const d = e?.organization?.jobs?.nextPage;\n if (!d) break;\n n = d;\n }\n return i.slice(0, 100);\n}\nasync function W(t, i) {\n const n = await N(\n (e) =>\n L({\n job: {\n $: { id: t },\n id: {},\n name: {},\n costItems: {\n $: { size: e, ...i ? { page: i } : {} },\n nextPage: {},\n nodes: {\n id: {},\n name: {},\n description: {},\n costGroup: { id: {}, name: {} },\n costType: { id: {}, name: {} },\n customFieldValues: {\n $: { size: 10 },\n nodes: {\n id: {},\n value: {},\n customField: { id: {}, name: {}, options: {} },\n },\n },\n },\n },\n },\n }),\n B(_, [10, 5, 2, 1]),\n (e) => {\n _ = e;\n },\n );\n return {\n jobName: n?.job?.name ?? \"\",\n nodes: n?.job?.costItems?.nodes ?? [],\n nextPage: n?.job?.costItems?.nextPage ?? null,\n };\n}\nlet T = null;\nconst z = 300 * 1e3;\nasync function R(t = !1) {\n if (!t && T && Date.now() - T.at < z) return T.jobs;\n try {\n const i = await H();\n return i.sort((n, e) => n.name.localeCompare(e.name)),\n T = { jobs: i, at: Date.now() },\n await s.batch([\n { sql: \"DELETE FROM jobs\" },\n ...i.map((n) => ({\n sql: \"INSERT INTO jobs (id, name) VALUES (?, ?)\",\n args: [n.id, n.name],\n })),\n ]),\n i;\n } catch (i) {\n const { rows: n } = await s.execute(\n \"SELECT id, name FROM jobs ORDER BY name\",\n );\n if (!n.length) throw i;\n return n;\n }\n}\nconst k = \"\";\nfunction J(t, i, n) {\n const e = { id: t, customFieldValues: i };\n return n !== void 0 && (e.description = n),\n L({ updateCostItem: { $: e, costItem: { $: { id: t }, id: {} } } });\n}\nasync function X(t) {\n const i = await R(), n = t ? i.filter((e) => e.id === t) : i;\n if (t && n.length === 0) {\n throw new Error(\n \"That job wasn't in the current list \\u2014 tap 'Refresh job list' and try again.\",\n );\n }\n return await s.execute(\"DELETE FROM items_staging\"),\n await s.execute({\n sql:\n `INSERT INTO sync_state (id, status, job_ids, job_cursor, page_cursor, items_synced, last_error)\n VALUES (1, 'running', ?, 0, NULL, 0, NULL)\n ON CONFLICT(id) DO UPDATE SET status='running', job_ids=excluded.job_ids,\n job_cursor=0, page_cursor=NULL, items_synced=0, last_error=NULL`,\n args: [JSON.stringify(n)],\n }),\n { totalJobs: n.length };\n}\nasync function q() {\n const { rows: t } = await s.execute(\"SELECT * FROM sync_state WHERE id = 1\"),\n i = t[0];\n if (!i || i.status !== \"running\") {\n return { done: !0, message: \"No sync in progress.\" };\n }\n const n = JSON.parse(i.job_ids);\n if (i.job_cursor >= n.length) {\n return await s.batch([\n { sql: \"DELETE FROM items\" },\n {\n sql:\n `INSERT INTO items (id, job_id, job_name, cost_group, name, description, custom_fields, order_status, updated_at)\n SELECT id, job_id, job_name, cost_group, name, description, custom_fields, order_status, updated_at\n FROM items_staging`,\n },\n { sql: \"DELETE FROM items_staging\" },\n { sql: \"UPDATE sync_state SET status='done' WHERE id=1\" },\n ]),\n { done: !0, itemsSynced: i.items_synced };\n }\n const e = n[i.job_cursor];\n try {\n const o = await W(e.id, i.page_cursor || void 0);\n let d = i.items_synced;\n const c = new Date().toISOString(), u = [];\n for (const a of o.nodes) {\n if (a.costType?.name !== U) continue;\n const l = (a.customFieldValues?.nodes ?? []).map((m) => ({\n id: m.customField?.id,\n name: m.customField?.name,\n value: m.value ?? \"\",\n options: Array.isArray(m.customField?.options)\n ? m.customField.options.filter(Boolean)\n : [],\n })\n ),\n h = l.find((m) => m.name === \"Order Status\")?.value || \"\";\n u.push({\n sql:\n `INSERT INTO items_staging (id, job_id, job_name, cost_group, name, description, custom_fields, order_status, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET job_id=excluded.job_id, job_name=excluded.job_name,\n cost_group=excluded.cost_group, name=excluded.name, description=excluded.description,\n custom_fields=excluded.custom_fields, order_status=excluded.order_status, updated_at=excluded.updated_at`,\n args: [\n a.id,\n e.id,\n o.jobName || e.name,\n a.costGroup?.name ?? \"\",\n a.name,\n a.description || \"\",\n JSON.stringify(l),\n h,\n c,\n ],\n }), d++;\n }\n return u.length && await s.batch(u),\n o.nextPage\n ? (await s.execute({\n sql: \"UPDATE sync_state SET page_cursor=?, items_synced=? WHERE id=1\",\n args: [o.nextPage, d],\n }),\n {\n done: !1,\n currentJob: e.name,\n jobIndex: i.job_cursor,\n totalJobs: n.length,\n itemsSynced: d,\n })\n : (await s.execute({\n sql:\n \"UPDATE sync_state SET job_cursor=?, page_cursor=NULL, items_synced=? WHERE id=1\",\n args: [i.job_cursor + 1, d],\n }),\n {\n done: !1,\n currentJob: e.name,\n jobIndex: i.job_cursor + 1,\n totalJobs: n.length,\n itemsSynced: d,\n });\n } catch (o) {\n return await s.execute({\n sql: \"UPDATE sync_state SET status='error', last_error=? WHERE id=1\",\n args: [String(o)],\n }),\n { done: !0, error: String(o), currentJob: e.name };\n }\n}\nfunction r(t, i = 200) {\n return new Response(JSON.stringify(t), {\n status: i,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\nfunction V(t, i = 200) {\n return new Response(t, {\n status: i,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}\nfunction v(t) {\n return I\n ? t.headers.get(\"x-admin-key\") === I\n ? !0\n : new URL(t.url).searchParams.get(\"key\") === I\n : !1;\n}\nasync function ne(t) {\n await F();\n const i = new URL(t.url), n = i.pathname;\n if (n === \"/\") return V(ee);\n if (n === \"/manifest.json\") return r(Q);\n if (\n n === \"/logo-icon.png\" || n === \"/logo-full.png\" || n === \"/logo-mark.png\"\n ) {\n const o = Uint8Array.from(\n atob(n === \"/logo-icon.png\" ? K : n === \"/logo-full.png\" ? G : Y),\n (d) => d.charCodeAt(0),\n );\n return new Response(o, {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"public, max-age=31536000, immutable\",\n },\n });\n }\n if (n === \"/sw.js\") {\n return new Response(Z, {\n headers: { \"Content-Type\": \"application/javascript\" },\n });\n }\n if (n === \"/api/sync/start\" && t.method === \"POST\") {\n if (!x) return r({ error: \"GRANT_KEY not set.\" }, 500);\n let e;\n try {\n e = (await t.json())?.jobId || void 0;\n } catch {}\n if (!e) {\n return r({\n error:\n \"Select a specific job before syncing \\u2014 syncing all jobs at once is disabled.\",\n }, 400);\n }\n try {\n return r(await X(e));\n } catch (o) {\n return r({ error: String(o) }, 500);\n }\n }\n if (n === \"/api/sync/joblist\" && t.method === \"GET\") {\n if (!x) return r({ error: \"GRANT_KEY not set.\" }, 500);\n try {\n const e = await R(i.searchParams.get(\"refresh\") === \"1\");\n return r(e);\n } catch (e) {\n return r({ error: String(e) }, 500);\n }\n }\n if (n === \"/api/sync/step\" && t.method === \"POST\") {\n try {\n return r(await q());\n } catch (e) {\n return r({ error: String(e) }, 500);\n }\n }\n if (n === \"/api/sync/status\") {\n const { rows: e } = await s.execute(\n \"SELECT status, job_cursor, items_synced, last_error FROM sync_state WHERE id=1\",\n );\n return r(e[0] ?? { status: \"never_run\" });\n }\n if (n === \"/api/users\" && t.method === \"GET\") {\n const { rows: e } = await s.execute(\"SELECT name FROM users ORDER BY name\");\n return r(e.map((o) => o.name));\n }\n if (n === \"/api/users\" && t.method === \"POST\") {\n if (!v(t)) return r({ error: \"Admin key required.\" }, 401);\n const { name: e } = await t.json();\n return !e || !e.trim()\n ? r({ error: \"Name required.\" }, 400)\n : (await s.execute({\n sql: \"INSERT INTO users (name) VALUES (?) ON CONFLICT(name) DO NOTHING\",\n args: [e.trim()],\n }),\n r({ ok: !0 }));\n }\n if (n === \"/api/users\" && t.method === \"DELETE\") {\n if (!v(t)) return r({ error: \"Admin key required.\" }, 401);\n const { name: e } = await t.json();\n return await s.execute({\n sql: \"DELETE FROM users WHERE name = ?\",\n args: [e],\n }),\n await s.execute({\n sql: \"DELETE FROM presence WHERE user_name = ?\",\n args: [e],\n }),\n r({ ok: !0 });\n }\n if (n === \"/api/items\" && t.method === \"GET\") {\n const e = i.searchParams.get(\"q\") || \"\",\n { rows: o } = await s.execute({\n sql: `SELECT id, job_name, cost_group, name, description, order_status\n FROM items WHERE name LIKE ? ORDER BY job_name, name LIMIT 200`,\n args: [`%${e}%`],\n });\n return r(o);\n }\n if (n === \"/api/item\" && t.method === \"GET\") {\n const e = i.searchParams.get(\"id\"),\n { rows: o } = await s.execute({\n sql: \"SELECT * FROM items WHERE id = ?\",\n args: [e],\n });\n return r(o[0] ?? null);\n }\n if (n === \"/api/warehouse/lookup\" && t.method === \"GET\") {\n const e = i.searchParams.get(\"code\"),\n { rows: o } = await s.execute({\n sql: \"SELECT * FROM warehouse_items WHERE barcode = ?\",\n args: [e],\n });\n return r(o[0] ?? null);\n }\n if (n === \"/api/warehouse/upsert\" && t.method === \"POST\") {\n try {\n const {\n barcode: e,\n name: o,\n description: d,\n location: c,\n quantityDelta: u,\n photo: a,\n clearPhoto: l,\n unit: h,\n userName: m,\n category: f,\n subcategory: y,\n } = await t.json();\n if (!e) return r({ error: \"barcode required.\" }, 400);\n if (a && a.length > 6e4) {\n return r({ error: \"Photo too large after compression.\" }, 400);\n }\n const g = parseInt(u, 10) || 0,\n { rows: w } = await s.execute({\n sql: \"SELECT * FROM warehouse_items WHERE barcode = ?\",\n args: [e],\n }),\n p = w[0],\n E = p ? p.quantity + g : g;\n await s.execute({\n sql:\n `INSERT INTO warehouse_items (barcode, name, description, location, quantity, unit, category, subcategory, photo, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(barcode) DO UPDATE SET\n name = COALESCE(NULLIF(excluded.name, ''), warehouse_items.name),\n description = COALESCE(NULLIF(excluded.description, ''), warehouse_items.description),\n location = COALESCE(NULLIF(excluded.location, ''), warehouse_items.location),\n photo = CASE WHEN ? = 1 THEN '' ELSE COALESCE(NULLIF(excluded.photo, ''), warehouse_items.photo) END,\n unit = COALESCE(NULLIF(excluded.unit, ''), warehouse_items.unit),\n category = COALESCE(NULLIF(excluded.category, ''), warehouse_items.category),\n subcategory = COALESCE(NULLIF(excluded.subcategory, ''), warehouse_items.subcategory),\n quantity = excluded.quantity, updated_at = excluded.updated_at`,\n args: [\n e,\n o || \"\",\n d || \"\",\n c || \"\",\n E,\n h || \"units\",\n f || \"\",\n y || \"\",\n a || \"\",\n new Date().toISOString(),\n l ? 1 : 0,\n ],\n });\n const S = h || p && p.unit || \"units\";\n let b = \"\";\n p\n ? g > 0\n ? b = `Added ${g} ${S} (now ${E})`\n : g < 0\n ? b = `Removed ${Math.abs(g)} ${S} (now ${E})`\n : l\n ? b = \"Removed photo\"\n : a\n ? b = \"Added photo\"\n : b = \"Edited details\"\n : b = `Created with ${E} ${S}`,\n await s.execute({\n sql:\n `INSERT INTO activity (item_id, item_name, job_name, user_name, fields, ts)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [\n \"wh:\" + e,\n o || p && p.name || e,\n \"Warehouse\",\n m || \"unknown\",\n b,\n new Date().toISOString(),\n ],\n });\n const { rows: j } = await s.execute({\n sql: \"SELECT * FROM warehouse_items WHERE barcode = ?\",\n args: [e],\n });\n return r({ ok: !0, item: j[0] });\n } catch (e) {\n return r({ error: String(e) }, 500);\n }\n }\n if (n === \"/api/admin/storage\" && t.method === \"GET\") {\n if (!v(t)) return r({ error: \"Admin key required.\" }, 401);\n const e = async (w) => Number((await s.execute(w)).rows[0]?.v ?? 0),\n o = await e(\n \"SELECT COALESCE(SUM(LENGTH(photo)),0) v FROM warehouse_items\",\n ),\n d = await e(\n \"SELECT COUNT(*) v FROM warehouse_items WHERE photo IS NOT NULL AND photo <> ''\",\n ),\n c = await e(\"SELECT COUNT(*) v FROM warehouse_items\"),\n u = await e(\n \"SELECT COALESCE(SUM(LENGTH(COALESCE(name,''))+LENGTH(COALESCE(description,''))+LENGTH(COALESCE(location,''))+40),0) v FROM warehouse_items\",\n ),\n a = await e(\n \"SELECT COALESCE(SUM(LENGTH(COALESCE(custom_fields,''))+LENGTH(COALESCE(name,''))+LENGTH(COALESCE(description,''))+80),0) v FROM items\",\n ),\n l = await e(\"SELECT COUNT(*) v FROM items\"),\n h = await e(\n \"SELECT COALESCE(SUM(LENGTH(COALESCE(fields,''))+LENGTH(COALESCE(item_name,''))+60),0) v FROM activity\",\n ),\n m = await e(\"SELECT COUNT(*) v FROM activity\"),\n f = o + u + a + h,\n y = 10 * 1024 * 1024,\n g = d ? Math.round(o / d) : 8e3;\n return r({\n photoBytes: o,\n photoCount: d,\n whCount: c,\n itemBytes: a,\n itemCount: l,\n actBytes: h,\n actCount: m,\n used: f,\n limit: y,\n pctUsed: Math.round(f / y * 1e3) / 10,\n avgPhoto: g,\n photosRemaining: Math.max(0, Math.floor((y - f) / Math.max(g, 1))),\n });\n }\n if (n === \"/api/warehouse/seed\" && t.method === \"POST\") {\n if (!v(t)) return r({ error: \"Admin key required.\" }, 401);\n try {\n const { userName: e } = await t.json().catch(() => ({}));\n if (!k.trim()) return r({ ok: !0, added: 0, skipped: 0, empty: !0 });\n let o = \"\", d = 0, c = 0;\n const u = new Date().toISOString();\n for (\n const a of k.split(`\n`)\n ) {\n const l = a.trim();\n if (!l) continue;\n if (!l.includes(\"|\")) {\n o = l;\n continue;\n }\n const [h, m, f] = l.split(\"|\"),\n { rows: y } = await s.execute({\n sql: \"SELECT barcode FROM warehouse_items WHERE barcode = ?\",\n args: [h],\n });\n if (y.length) {\n c++;\n continue;\n }\n await s.execute({\n sql:\n `INSERT INTO warehouse_items (barcode, name, description, location, quantity, unit, category, subcategory, photo, updated_at)\n VALUES (?, ?, '', '', ?, 'units', 'Tools', ?, '', ?)`,\n args: [h, f, parseInt(m, 10) || 0, o, u],\n }), d++;\n }\n return await s.execute({\n sql:\n \"INSERT INTO activity (item_id, item_name, job_name, user_name, fields, ts) VALUES (?, ?, ?, ?, ?, ?)\",\n args: [\n \"wh:seed\",\n \"Tool list import\",\n \"Warehouse\",\n e || \"Admin\",\n `Imported ${d} tools (${c} already existed)`,\n u,\n ],\n }),\n r({ ok: !0, added: d, skipped: c });\n } catch (e) {\n return r({ error: String(e) }, 500);\n }\n }\n if (n === \"/api/warehouse/similar\" && t.method === \"GET\") {\n const e = (i.searchParams.get(\"name\") || \"\").trim();\n if (!e) return r([]);\n const o = (a) => a.toLowerCase().replace(/[^a-z0-9]/g, \"\"), d = o(e);\n if (!d) return r([]);\n const { rows: c } = await s.execute(\n \"SELECT barcode, name, quantity, unit, location FROM warehouse_items LIMIT 500\",\n ),\n u = c.filter((a) => {\n const l = o(a.name || \"\");\n return l\n ? l === d ||\n l.length > 3 && d.length > 3 && (l.includes(d) || d.includes(l))\n : !1;\n }).slice(0, 5);\n return r(u);\n }\n if (n === \"/api/warehouse/list\" && t.method === \"GET\") {\n const e = i.searchParams.get(\"q\") || \"\",\n o =\n [\"name\", \"quantity\", \"location\"].includes(\n i.searchParams.get(\"sort\") || \"\",\n )\n ? i.searchParams.get(\"sort\")\n : \"name\",\n d = i.searchParams.get(\"cat\") || \"\",\n c = i.searchParams.get(\"sub\") || \"\",\n u = [\"name LIKE ?\"],\n a = [`%${e}%`];\n d && (u.push(\"category = ?\"), a.push(d)),\n c && (u.push(\"subcategory = ?\"), a.push(c));\n const { rows: l } = await s.execute({\n sql:\n `SELECT barcode, name, description, location, quantity, unit, category, subcategory, photo\n FROM warehouse_items WHERE ${\n u.join(\" AND \")\n } ORDER BY ${o} LIMIT 300`,\n args: a,\n });\n return r(l);\n }\n if (n === \"/api/barcode\" && t.method === \"GET\") {\n const e = i.searchParams.get(\"code\"),\n { rows: o } = await s.execute({\n sql:\n \"SELECT b.code, i.* FROM barcodes b JOIN items i ON i.id = b.item_id WHERE b.code = ?\",\n args: [e],\n });\n return r(o[0] ?? null);\n }\n if (n === \"/api/barcode\" && t.method === \"POST\") {\n const { code: e, itemId: o } = await t.json();\n return !e || !o\n ? r({ error: \"code and itemId required.\" }, 400)\n : (await s.execute({\n sql: `INSERT INTO barcodes (code, item_id) VALUES (?, ?)\n ON CONFLICT(code) DO UPDATE SET item_id = excluded.item_id`,\n args: [e, o],\n }),\n r({ ok: !0 }));\n }\n if (n === \"/api/scan\" && t.method === \"POST\") {\n const e = await t.json(),\n { itemId: o, userName: d, fields: c, description: u } = e;\n if (!o || !d || !c) {\n return r({ error: \"itemId, userName, fields required.\" }, 400);\n }\n const { rows: a } = await s.execute({\n sql: \"SELECT * FROM items WHERE id = ?\",\n args: [o],\n }),\n l = a[0];\n if (!l) return r({ error: \"Unknown item.\" }, 404);\n let h = !0, m = null;\n if (x) {\n try {\n await C(J(o, c, u));\n } catch (p) {\n h = !1, m = String(p);\n }\n } else h = !1, m = \"GRANT_KEY not set on server.\";\n const y = JSON.parse(l.custom_fields || \"[]\").map((p) =>\n c[p.id] !== void 0 ? { ...p, value: c[p.id] } : p\n ),\n g = y.find((p) => p.name === \"Order Status\")?.value || \"\",\n w = u !== void 0 ? u : l.description;\n return await s.execute({\n sql:\n \"UPDATE items SET custom_fields = ?, order_status = ?, description = ?, updated_at = ? WHERE id = ?\",\n args: [JSON.stringify(y), g, w, new Date().toISOString(), o],\n }),\n await s.execute({\n sql:\n `INSERT INTO activity (item_id, item_name, job_name, user_name, fields, ts)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [\n o,\n l.name,\n l.job_name,\n d,\n JSON.stringify(c),\n new Date().toISOString(),\n ],\n }),\n r({ ok: !0, jobtreadUpdated: h, jobtreadError: m });\n }\n if (n === \"/api/activity\" && t.method === \"GET\") {\n const e = i.searchParams.get(\"job\"),\n { rows: o } = e\n ? await s.execute({\n sql:\n \"SELECT * FROM activity WHERE job_name = ? ORDER BY id DESC LIMIT 100\",\n args: [e],\n })\n : await s.execute(\"SELECT * FROM activity ORDER BY id DESC LIMIT 100\");\n return r(o);\n }\n if (n === \"/api/presence\" && t.method === \"POST\") {\n try {\n const { userName: e, action: o } = await t.json();\n return e\n ? (await s.execute({\n sql:\n `INSERT INTO presence (user_name, action, updated_at) VALUES (?, ?, ?)\n ON CONFLICT(user_name) DO UPDATE SET action=excluded.action, updated_at=excluded.updated_at`,\n args: [e, o || \"\", new Date().toISOString()],\n }),\n await s.execute({\n sql: \"DELETE FROM presence WHERE updated_at < ?\",\n args: [new Date(Date.now() - 300 * 1e3).toISOString()],\n }),\n r({ ok: !0 }))\n : r({ error: \"userName required.\" }, 400);\n } catch (e) {\n return r({ error: String(e) }, 500);\n }\n }\n if (n === \"/api/presence\" && t.method === \"GET\") {\n if (!v(t)) return r({ error: \"Admin key required.\" }, 401);\n await s.execute({\n sql: \"DELETE FROM presence WHERE updated_at < ?\",\n args: [new Date(Date.now() - 1440 * 60 * 1e3).toISOString()],\n });\n const { rows: e } = await s.execute(\n \"SELECT user_name, action, updated_at FROM presence ORDER BY updated_at DESC\",\n );\n return r(e);\n }\n if (n === \"/api/export.csv\") {\n if (!v(t)) return r({ error: \"Admin key required to export.\" }, 401);\n const e =\n (await s.execute(\"SELECT * FROM items ORDER BY job_name, name\")).rows,\n o = (await s.execute(\"SELECT * FROM activity ORDER BY id\")).rows,\n d = (a) => `\"${String(a ?? \"\").replace(/\"/g, '\"\"')}\"`;\n let c = `== ITEMS ==\nid,job_name,cost_group,name,description,custom_fields,updated_at\n`;\n for (const a of e) {\n c +=\n [\n a.id,\n a.job_name,\n a.cost_group,\n a.name,\n a.description,\n a.custom_fields,\n a.updated_at,\n ].map(d).join(\",\") + `\n`;\n }\n c += `\n== ACTIVITY ==\nid,item_id,item_name,job_name,user_name,fields,ts\n`;\n for (const a of o) {\n c +=\n [a.id, a.item_id, a.item_name, a.job_name, a.user_name, a.fields, a.ts]\n .map(d).join(\",\") + `\n`;\n }\n const u =\n (await s.execute(\"SELECT * FROM warehouse_items ORDER BY name\")).rows;\n c += `\n== WAREHOUSE ==\nbarcode,name,description,location,quantity,updated_at\n`;\n for (const a of u) {\n c +=\n [a.barcode, a.name, a.description, a.location, a.quantity, a.updated_at]\n .map(d).join(\",\") + `\n`;\n }\n return new Response(c, {\n headers: {\n \"Content-Type\": \"text/csv\",\n \"Content-Disposition\": \"attachment; filename=dock-log-export.csv\",\n },\n });\n }\n return r({\n status: \"CRD Inventory Tracker app is running\",\n note: \"GET / for the app itself.\",\n }, 200);\n}\nconst K =\n \"iVBORw0KGgoAAAANSUhEUgAAAIAAAACAAQMAAAD58POIAAAABlBMVEX////3l0pNQAJ4AAAA3ElEQVR42u2VsQ6CMBCGfxCDMSZ2cHAggdHRkdHR0TeQR/GxHBl5DEl4AMKEUXIOxSZ3xFQNYSD8yzVfr4X/rk2BSX/JJ0r1yNNh7iDRI1eHNdGJgQDYMRADGwZKYMkAGuVx8KzBwf0mQLUVwGiMQJUCNNL+Qi7xY7lp+vVn227kznuqDSFR3b+5/CAzZLMh7c+ug7ThKAB1MvYCOLB6udjMdf8jtmYEvHMI8OihHvUAxyGPbPUIrc0uxnz3G3kKoSRI+MozUcUyFMBBZmrmmgpmbI8VEH14Cib9qhcD4TKTFFhNKAAAAABJRU5ErkJggg==\",\n G =\n \"iVBORw0KGgoAAAANSUhEUgAAAJYAAACQAQMAAADQlgC8AAAABlBMVEX////4nVRG/JCsAAAB/0lEQVR42u2Wv24TQRCHv9k7xVdYjkVFpIS4og4dRWQH0eRBKCh5AJTsI6SkBN4DYYnGRYR4AnyREKLjMBSH7dykuNzh/YO4AkKT7e7Tb3dnZ347tyIVIGwOYwCsw9JUQN66ut6p6mrkMHZVtXrm6vYAmblsDPDEnftVVfW9qysAdlwGOqTvs8WCzGeFusfAQI43Unj3c2vt69ItXzjXnurK12W+zBCOW/ZPWBlhtgrZchWySRZ6Y0RY81LCmvcGkfiK/5GDCxGRDMZM7HMppUj6Zl9VtYRHYE2dk3bua/uNY33KsbfeEphF9zj6YyyjgA04i+hmwAEvDciwJgs+QRNLW8wFMK1ZeytLIOeDASL13c4j8amLcgMMm6+pF9+d63OMgLluF7qCUyb2RMqkTHbTRvcG7EPl8gtFq+tQt5g3LkKvDSJeC9Y0dc8KWNbNQxKLrwQ45IEdM03ymlmAx9eiuxv1+AF8rHNlgCOAyrbFMl5zbdi9jh5XAGMdNgQ2W/6vX5QNc7Bwti+w65u7l34OBnbAfQ7JG88lMGafMeukAOaq2tFDN8Bk+DtveGwdMj0J/ax55GyRPc4ifbfz3bplf59F+lX5KqwRSaRGXXpTGrTnJpYy8v777rIXAJ9ddg5w7i64o6p64LK+qlbu38IsRSTx2KWqVlOHSeStfAWnHrBACwfVlAAAAABJRU5ErkJggg==\",\n Y =\n \"iVBORw0KGgoAAAANSUhEUgAAAAkAAAAcAQMAAACJRAd7AAAABlBMVEX6uIL1giYePnDaAAAANElEQVR42mXKIQ6AMADAwEvVBBK5fyL5LBKJQKKmSOqucOjWJqtHE5y6NESvaGj/kTVM+ABWYAeorDtmzAAAAABJRU5ErkJggg==\",\n Q = {\n name: \"CRD Inventory Tracker\",\n short_name: \"CRD Inventory\",\n start_url: \"/\",\n display: \"standalone\",\n background_color: \"#ffffff\",\n theme_color: \"#171717\",\n icons: [{\n src: \"/logo-icon.png\",\n sizes: \"512x512\",\n type: \"image/png\",\n purpose: \"any\",\n }, {\n src: \"/logo-icon.png\",\n sizes: \"512x512\",\n type: \"image/png\",\n purpose: \"maskable\",\n }],\n },\n Z =\n 'const CACHE_V=\"crd-inv-v2\",SHELL=[\"/\",\"/logo-full.png\",\"/logo-mark.png\",\"/logo-icon.png\"];self.addEventListener(\"install\",e=>{e.waitUntil(caches.open(CACHE_V).then(e=>e.addAll(SHELL)).then(()=>self.skipWaiting()))}),self.addEventListener(\"activate\",e=>{e.waitUntil(caches.keys().then(e=>Promise.all(e.filter(e=>e!==CACHE_V).map(e=>caches.delete(e)))).then(()=>self.clients.claim()))}),self.addEventListener(\"fetch\",e=>{const t=e.request;\"GET\"===t.method&&new URL(t.url).origin===self.location.origin&&e.respondWith(fetch(t).then(e=>{if(e&&200===e.status){const n=e.clone();caches.open(CACHE_V).then(e=>e.put(t,n))}return e}).catch(()=>caches.match(t).then(e=>e||caches.match(\"/\"))))});',\n ee =\n 'CRD Inventory Tracker