RMT Dispatch Board

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_103":84,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":121,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",33,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","70935c84-5b40-11f1-9a74-ee650bb23af1","name","fileType","http","content","import { blob } from \"https://esm.town/v/std/blob\";\n\nconst FIXED_DRIVERS = [\n { name: \"Kittipong\", plate: \"Camry 7ขจ5110\" },\n { name: \"Kaiyawich\", plate: \"Innova 4ขต520\" },\n { name: \"Natee\", plate: \"Majesty 1นช3827\" },\n { name: \"Yutthana\", plate: \"BR-V 4ขห2052\" },\n { name: \"Jaturong\", plate: \"Cross 4ขธ5094\" },\n { name: \"Chanat\", plate: \"Cross 4ขว5036\" },\n { name: \"Manop\", plate: \"Cross 6ขท1593\" },\n { name: \"KongKamchai\", plate: \"Cross 5ขข4188\" },\n { name: \"Chanachai\", plate: \"Cross 6ขท1603\" },\n { name: \"Wanchot\", plate: \"Cross 5ขก4327\" },\n { name: \"Tanoangsak\", plate: \"Cross 7ขฐ7010\" },\n { name: \"Paphonthanai\", plate: \"Cross 5ขก4318\" },\n { name: \"Sakchai\", plate: \"5ขก1307\" },\n { name: \"Pichet\", plate: \"5ขข210\" },\n { name: \"Pakorn\", plate: \"6ขถ4665\" },\n { name: \"Thawanchai\", plate: \"6ขถ6725\" },\n { name: \"Kwanchai APB\", plate: \"Innova 6ขภ1045\" },\n { name: \"Monchai APB\", plate: \"Innova 6ขภ1067\" },\n];\n\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n};\n\nfunction jsonRes(data: any, status = 200) {\n return new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\", ...CORS },\n });\n}\n\nasync function getBoard() {\n try {\n return await blob.getJSON(\"dispatch_board\") || { boardData: {}, dates: [] };\n } catch {\n return { boardData: {}, dates: [] };\n }\n}\nasync function getPhotos() {\n try {\n return await blob.getJSON(\"driver_photos\") || {};\n } catch {\n return {};\n }\n}\nasync function getWarnings(): Promise {\n try {\n return await blob.getJSON(\"warnings\") || [];\n } catch {\n return [];\n }\n}\nasync function saveWarnings(list: any[]) {\n await blob.setJSON(\"warnings\", list);\n}\nasync function getTasks(): Promise {\n try {\n return await blob.getJSON(\"my_tasks\") || [];\n } catch {\n return [];\n }\n}\nasync function saveTasks(list: any[]) {\n await blob.setJSON(\"my_tasks\", list);\n}\nasync function getFurniture(): Promise {\n try {\n return await blob.getJSON(\"furniture\") || [];\n } catch {\n return [];\n }\n}\nasync function saveFurniture(list: any[]) {\n await blob.setJSON(\"furniture\", list);\n}\n\n// ── PROJECT WORKS ──\nasync function getProjects(): Promise {\n try {\n return await blob.getJSON(\"my_projects\") || [];\n } catch {\n return [];\n }\n}\nasync function saveProjects(list: any[]) {\n await blob.setJSON(\"my_projects\", list);\n}\n\nexport default async function (req: Request) {\n if (req.method === \"OPTIONS\") return new Response(\"ok\", { headers: CORS });\n const url = new URL(req.url);\n\n // ── WARNING LOG ──\n if (req.method === \"GET\" && url.pathname === \"/warnings\") {\n const warnings = await getWarnings();\n const driver = url.searchParams.get(\"driver\");\n const list = driver\n ? warnings.filter((w) =>\n w.driverName.toLowerCase().includes(driver.toLowerCase())\n )\n : warnings;\n list.sort((a: any, b: any) =>\n new Date(b.createdAt).getTime() - new Date(a.createdAt).getTime()\n );\n return jsonRes({ warnings: list, total: list.length });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/warnings\") {\n const body = await req.json();\n const warnings = await getWarnings();\n\n if (body.action === \"add\") {\n const w = {\n id: `w_${Date.now()}_${Math.random().toString(36).slice(2, 7)}`,\n driverName: body.driverName || \"\",\n date: body.date || new Date().toISOString().split(\"T\")[0],\n topic: body.topic || \"\",\n severity: body.severity || \"verbal\",\n note: body.note || \"\",\n recordedBy: body.recordedBy || \"\",\n acknowledged: false,\n createdAt: new Date().toISOString(),\n };\n warnings.push(w);\n await saveWarnings(warnings);\n return jsonRes({ ok: true, warning: w });\n }\n if (body.action === \"delete\") {\n const idx = warnings.findIndex((w: any) => w.id === body.id);\n if (idx === -1) return jsonRes({ ok: false }, 404);\n warnings.splice(idx, 1);\n await saveWarnings(warnings);\n return jsonRes({ ok: true });\n }\n if (body.action === \"acknowledge\") {\n const w = warnings.find((w: any) => w.id === body.id);\n if (!w) return jsonRes({ ok: false }, 404);\n w.acknowledged = true;\n w.acknowledgedAt = new Date().toISOString();\n await saveWarnings(warnings);\n return jsonRes({ ok: true, warning: w });\n }\n if (body.action === \"edit\") {\n const w = warnings.find((w: any) => w.id === body.id);\n if (!w) return jsonRes({ ok: false }, 404);\n [\"topic\", \"severity\", \"note\", \"date\", \"recordedBy\", \"driverName\"].forEach(\n (k) => {\n if (body[k] !== undefined) w[k] = body[k];\n },\n );\n w.updatedAt = new Date().toISOString();\n await saveWarnings(warnings);\n return jsonRes({ ok: true, warning: w });\n }\n return jsonRes({ ok: false, error: \"Unknown action\" }, 400);\n }\n\n // ── MY TASKS (Tim's personal schedule) ──\n if (req.method === \"GET\" && url.pathname === \"/mytasks\") {\n const tasks = await getTasks();\n tasks.sort((a: any, b: any) => {\n const da = a.date + (a.startTime || \"00:00\");\n const db = b.date + (b.startTime || \"00:00\");\n return da.localeCompare(db);\n });\n return jsonRes({ tasks, total: tasks.length });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/mytasks\") {\n const body = await req.json();\n const tasks = await getTasks();\n\n if (body.action === \"add\") {\n const t = {\n id: `t_${Date.now()}_${Math.random().toString(36).slice(2, 7)}`,\n title: body.title || \"\",\n type: body.type || \"task\",\n date: body.date || new Date().toISOString().split(\"T\")[0],\n startTime: body.startTime || \"\",\n endTime: body.endTime || \"\",\n priority: body.priority || \"normal\",\n note: body.note || \"\",\n status: \"pending\",\n createdAt: new Date().toISOString(),\n };\n tasks.push(t);\n await saveTasks(tasks);\n return jsonRes({ ok: true, task: t });\n }\n if (body.action === \"delete\") {\n const idx = tasks.findIndex((t: any) => t.id === body.id);\n if (idx === -1) return jsonRes({ ok: false }, 404);\n tasks.splice(idx, 1);\n await saveTasks(tasks);\n return jsonRes({ ok: true });\n }\n if (body.action === \"toggle\") {\n const t = tasks.find((t: any) => t.id === body.id);\n if (!t) return jsonRes({ ok: false }, 404);\n t.status = t.status === \"done\" ? \"pending\" : \"done\";\n t.completedAt = t.status === \"done\" ? new Date().toISOString() : null;\n await saveTasks(tasks);\n return jsonRes({ ok: true, task: t });\n }\n if (body.action === \"edit\") {\n const t = tasks.find((t: any) => t.id === body.id);\n if (!t) return jsonRes({ ok: false }, 404);\n [\"title\", \"type\", \"date\", \"startTime\", \"endTime\", \"priority\", \"note\"]\n .forEach((k) => {\n if (body[k] !== undefined) t[k] = body[k];\n });\n t.updatedAt = new Date().toISOString();\n await saveTasks(tasks);\n return jsonRes({ ok: true, task: t });\n }\n return jsonRes({ ok: false, error: \"Unknown action\" }, 400);\n }\n\n // ── OFFICE FURNITURE REGISTRY ──\n if (req.method === \"GET\" && url.pathname === \"/furniture\") {\n const items = await getFurniture();\n items.sort((a: any, b: any) =>\n (a.location || \"\").localeCompare(b.location || \"\") ||\n (a.name || \"\").localeCompare(b.name || \"\")\n );\n return jsonRes({ items, total: items.length });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/furniture\") {\n const body = await req.json();\n const items = await getFurniture();\n\n if (body.action === \"add\") {\n const f = {\n id: `f_${Date.now()}_${Math.random().toString(36).slice(2, 7)}`,\n category: body.category || \"\",\n name: body.name || \"\",\n assetCode: body.assetCode || \"\",\n location: body.location || \"\",\n condition: body.condition || \"good\", // good | damaged | repair | disposed\n quantity: body.quantity ? Number(body.quantity) : 1,\n photo: body.photo || \"\",\n note: body.note || \"\",\n createdAt: new Date().toISOString(),\n };\n items.push(f);\n await saveFurniture(items);\n return jsonRes({ ok: true, item: f });\n }\n if (body.action === \"edit\") {\n const f = items.find((x: any) => x.id === body.id);\n if (!f) return jsonRes({ ok: false }, 404);\n [\n \"category\",\n \"name\",\n \"assetCode\",\n \"location\",\n \"condition\",\n \"quantity\",\n \"photo\",\n \"note\",\n ]\n .forEach((k) => {\n if (body[k] !== undefined) {\n f[k] = k === \"quantity\" ? Number(body[k]) : body[k];\n }\n });\n f.updatedAt = new Date().toISOString();\n await saveFurniture(items);\n return jsonRes({ ok: true, item: f });\n }\n if (body.action === \"delete\") {\n const idx = items.findIndex((x: any) => x.id === body.id);\n if (idx === -1) return jsonRes({ ok: false }, 404);\n items.splice(idx, 1);\n await saveFurniture(items);\n return jsonRes({ ok: true });\n }\n return jsonRes({ ok: false, error: \"Unknown action\" }, 400);\n }\n\n if (req.method === \"GET\" && url.pathname === \"/sw.js\") {\n const sw = `\nself.addEventListener('install', e => self.skipWaiting());\nself.addEventListener('activate', e => clients.claim());\nself.addEventListener('fetch', function(e) {\n if (e.request.url.includes('/data') || e.request.url.includes('/warnings') || e.request.url.includes('/mytasks')) return;\n e.respondWith(fetch(e.request).then(function(response) {\n var clone = response.clone();\n caches.open('rmt-v1').then(function(cache) { cache.put(e.request, clone); });\n return response;\n }).catch(function() { return caches.match(e.request); }));\n});`;\n return new Response(sw, {\n headers: { \"Content-Type\": \"application/javascript\", ...CORS },\n });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/manifest.json\") {\n const manifest = {\n name: \"RMT Dispatch Board\",\n short_name: \"RMT Board\",\n start_url: \"/\",\n display: \"standalone\",\n background_color: \"#0f1117\",\n theme_color: \"#0f1117\",\n orientation: \"landscape\",\n icons: [{\n src:\n \"data:image/svg+xml,\",\n sizes: \"512x512\",\n type: \"image/svg+xml\",\n }],\n };\n return new Response(JSON.stringify(manifest), {\n headers: { \"Content-Type\": \"application/manifest+json\", ...CORS },\n });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/\") {\n return new Response(getHTML(), {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/data\") {\n const board = await getBoard();\n const photos = await getPhotos();\n return jsonRes({ ...board, photos, fixedDrivers: FIXED_DRIVERS });\n }\n\n // ── BOARD MUTATIONS ──\n if (req.method === \"POST\") {\n const body = await req.json();\n\n if (url.pathname === \"/save\") {\n const existing = await getBoard();\n const newBoardData = body.boardData || {};\n const merged = { ...existing.boardData };\n Object.keys(newBoardData).forEach((date) => {\n if (!merged[date]) merged[date] = {};\n Object.keys(newBoardData[date]).forEach((drv) => {\n if (!merged[date][drv]) merged[date][drv] = newBoardData[date][drv];\n else {\n const existingKeys = new Set(\n merged[date][drv].jobs.map((j: any) => j.key),\n );\n const newJobs = newBoardData[date][drv].jobs.filter((j: any) =>\n !existingKeys.has(j.key)\n );\n merged[date][drv].jobs = [...merged[date][drv].jobs, ...newJobs];\n }\n });\n });\n const allDates = [\n ...new Set([...(existing.dates || []), ...(body.dates || [])]),\n ].sort(\n (a: string, b: string) =>\n new Date(a.replace(/\\//g, \"-\")).getTime() -\n new Date(b.replace(/\\//g, \"-\")).getTime(),\n );\n await blob.setJSON(\"dispatch_board\", {\n boardData: merged,\n dates: allDates,\n });\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/photo\") {\n const photos = await getPhotos();\n photos[body.name] = body.photo;\n await blob.setJSON(\"driver_photos\", photos);\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/special\") {\n const board = await getBoard();\n if (!board.boardData[body.date]) board.boardData[body.date] = {};\n if (!board.boardData[body.date][body.driver]) {\n board.boardData[body.date][body.driver] = { jobs: [], specials: [] };\n }\n if (!board.boardData[body.date][body.driver].specials) {\n board.boardData[body.date][body.driver].specials = [];\n }\n if (body.action === \"add\") {\n board.boardData[body.date][body.driver].specials.push({\n type: body.type,\n label: body.label,\n });\n } else if (body.action === \"remove\") {\n board.boardData[body.date][body.driver].specials.splice(body.idx, 1);\n }\n await blob.setJSON(\"dispatch_board\", board);\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/removedate\") {\n const board = await getBoard();\n board.dates = board.dates.filter((d: string) => d !== body.date);\n delete board.boardData[body.date];\n await blob.setJSON(\"dispatch_board\", board);\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/newmonth\") {\n await blob.setJSON(\"dispatch_board\", { boardData: {}, dates: [] });\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/addjob\") {\n const board = await getBoard();\n const { date, driver, job } = body;\n if (!board.boardData[date]) board.boardData[date] = {};\n if (!board.boardData[date][driver]) {\n board.boardData[date][driver] = { jobs: [], specials: [] };\n }\n board.boardData[date][driver].jobs.push(job);\n if (!board.dates.includes(date)) board.dates.push(date);\n board.dates.sort((a: string, b: string) =>\n new Date(a.replace(/\\//g, \"-\")).getTime() -\n new Date(b.replace(/\\//g, \"-\")).getTime()\n );\n await blob.setJSON(\"dispatch_board\", board);\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/removejob\") {\n const board = await getBoard();\n const { date, driver, key } = body;\n if (board.boardData[date]?.[driver]) {\n board.boardData[date][driver].jobs = board.boardData[date][driver].jobs\n .filter((j: any) => j.key !== key);\n }\n await blob.setJSON(\"dispatch_board\", board);\n return jsonRes({ ok: true });\n }\n }\n\n return new Response(\"Not found\", { status: 404 });\n}\n\nfunction getHTML() {\n const html = String.raw`\n\n\n\n\n\n\n\n\n\n\nRMT Dispatch Board\n\n\n`;\n return html\n .replace(\"SCRIPTCLOSE\", \"\");\n}","import { blob } from \"https://esm.town/v/std/blob\";\n\n// เพิ่มไว้เหนือ syncToDispatchBoard (ใช้ list เดียวกับที่ฝังในตัว Dispatch Board)\nconst FIXED_DRIVERS_LIST = [\n { name: \"Kittipong\", plate: \"Camry 7ขจ5110\" },\n { name: \"Kaiyawich\", plate: \"Innova 4ขต520\" },\n { name: \"Natee\", plate: \"Majesty 1นช3827\" },\n { name: \"Yutthana\", plate: \"BR-V 4ขห2052\" },\n { name: \"Jaturong\", plate: \"Cross 4ขธ5094\" },\n { name: \"Chanat\", plate: \"Cross 4ขว5036\" },\n { name: \"Manop\", plate: \"Cross 6ขท1593\" },\n { name: \"KongKamchai\", plate: \"Cross 5ขข4188\" },\n { name: \"Chanachai\", plate: \"Cross 6ขท1603\" },\n { name: \"Wanchot\", plate: \"Cross 5ขก4327\" },\n { name: \"Tanoangsak\", plate: \"Cross 7ขฐ7010\" },\n { name: \"Paphonthanai\", plate: \"Cross 5ขก4318\" },\n { name: \"Sakchai\", plate: \"5ขก1307\" },\n { name: \"Pichet\", plate: \"5ขข210\" },\n { name: \"Pakorn\", plate: \"6ขถ4665\" },\n { name: \"Thawanchai\", plate: \"6ขถ6725\" },\n { name: \"Kwanchai APB\", plate: \"Innova 6ขภ1045\" },\n { name: \"Monchai APB\", plate: \"Innova 6ขภ1067\" },\n];\n\nfunction matchFixedDriver(rawName) {\n if (!rawName) return null;\n const lower = rawName.toLowerCase().trim();\n const firstWord = lower.split(\" \")[0];\n return FIXED_DRIVERS_LIST.find((d) => {\n const dl = d.name.toLowerCase();\n return lower.includes(dl) || dl.includes(firstWord);\n }) || null;\n}\n\nasync function syncToDispatchBoard(rows) {\n const boardUrl = localStorage.getItem(\"rmt_boardurl\");\n if (!boardUrl) return;\n\n const boardData = {};\n const dateSet = new Set();\n const unmatched = new Set();\n\n rows.forEach((r) => {\n if ((r[\"Status\"] || \"\").trim() !== \"Car Complete\") return;\n const raw = r[\"Date\"] || \"\";\n if (!raw) return;\n const s = raw.trim().split(\" \")[0];\n const parts = s.split(\"/\");\n let date = s;\n if (parts.length === 3 && parts[0].length !== 4) {\n date = parts[2] + \"/\" + parts[0].padStart(2, \"0\") + \"/\" +\n parts[1].padStart(2, \"0\");\n }\n\n // ✅ ใช้ parseDrivers() ตัวเต็ม รองรับทุก format + คนขับหลายคน\n const drivers = parseDrivers(r);\n if (!drivers.length) return;\n\n dateSet.add(date);\n const passengers = (r[\"Passenger\"] || \"\").split(\"\\n\").map((p) => {\n return p.split(\"\\n\")[0].trim().replace(/（[^）]*）.*/, \"\").replace(\n /\$[^)]*\$.*/,\n \"\",\n ).trim();\n }).filter(Boolean);\n const dests = getDestinations(r); // แนบจุดแวะ D1-D3 ไปด้วย\n\n drivers.forEach((drv) => {\n if (!drv.name) return;\n const matched = matchFixedDriver(drv.name);\n const finalName = matched ? matched.name : drv.name;\n const finalPlate = matched ? matched.plate : (drv.plate || \"\");\n if (!matched) unmatched.add(drv.name);\n\n if (!boardData[date]) boardData[date] = {};\n if (!boardData[date][finalName]) {\n boardData[date][finalName] = { jobs: [], specials: [] };\n }\n\n const key = (r[\"Start time\"] || \"\") + (r[\"End time\"] || \"\") +\n (passengers[0] || \"\");\n const exists = boardData[date][finalName].jobs.find((j) => j.key === key);\n if (!exists) {\n boardData[date][finalName].jobs.push({\n key,\n manual: false,\n time: `${r[\"Start time\"] || \"?\"}-${r[\"End time\"] || \"?\"}`,\n passenger: passengers[0] || \"-\",\n start: r[\"Start place\"] || \"-\",\n end: r[\"End place\"] || \"-\",\n plate: finalPlate,\n phone: (r[\"Phone number\"] || \"\").replace(/[\"\\[\\]]/g, \"\").trim(),\n detail: (r[\"Detail \"] || r[\"Detail\"] || \"\").replace(\n /https?:\\/\\/rfg1\\.eim\\.ricoh\\.com[^\\s]*/g,\n \"\",\n ).trim(),\n dests,\n });\n }\n });\n });\n\n try {\n await fetch(`${boardUrl}/save`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ boardData, dates: [...dateSet].sort() }),\n });\n if (unmatched.size) {\n showToast(\n `📊 Sync แล้ว แต่มีชื่อจับคู่ไม่ได้: ${\n [...unmatched].join(\", \")\n } — เช็คสะกดใน FIXED_DRIVERS_LIST`,\n \"error\",\n );\n } else {\n showToast(\"📊 Sync ไป Dispatch Board แล้วครับ (ครบทุกคน)\", \"success\");\n }\n } catch (e) {\n showToast(\"❌ Sync ไป Dispatch Board ไม่สำเร็จ\", \"error\");\n }\n}\n\nconst CORS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n};\n\nfunction jsonRes(data: any, status = 200) {\n return new Response(JSON.stringify(data), {\n status,\n headers: { \"Content-Type\": \"application/json\", ...CORS },\n });\n}\n\nasync function getBoard() {\n try {\n return await blob.getJSON(\"dispatch_board\") || { boardData: {}, dates: [] };\n } catch {\n return { boardData: {}, dates: [] };\n }\n}\nasync function getPhotos() {\n try {\n return await blob.getJSON(\"driver_photos\") || {};\n } catch {\n return {};\n }\n}\nasync function getWarnings(): Promise {\n try {\n return await blob.getJSON(\"warnings\") || [];\n } catch {\n return [];\n }\n}\nasync function saveWarnings(list: any[]) {\n await blob.setJSON(\"warnings\", list);\n}\nasync function getTasks(): Promise {\n try {\n return await blob.getJSON(\"my_tasks\") || [];\n } catch {\n return [];\n }\n}\nasync function saveTasks(list: any[]) {\n await blob.setJSON(\"my_tasks\", list);\n}\nasync function getFurniture(): Promise {\n try {\n return await blob.getJSON(\"furniture\") || [];\n } catch {\n return [];\n }\n}\nasync function saveFurniture(list: any[]) {\n await blob.setJSON(\"furniture\", list);\n}\n\n// ── PROJECT WORKS ──\nasync function getProjects(): Promise {\n try {\n return await blob.getJSON(\"my_projects\") || [];\n } catch {\n return [];\n }\n}\nasync function saveProjects(list: any[]) {\n await blob.setJSON(\"my_projects\", list);\n}\n\nexport default async function (req: Request) {\n if (req.method === \"OPTIONS\") return new Response(\"ok\", { headers: CORS });\n const url = new URL(req.url);\n\n // ── WARNING LOG ──\n if (req.method === \"GET\" && url.pathname === \"/warnings\") {\n const warnings = await getWarnings();\n const driver = url.searchParams.get(\"driver\");\n const list = driver\n ? warnings.filter((w) =>\n w.driverName.toLowerCase().includes(driver.toLowerCase())\n )\n : warnings;\n list.sort((a: any, b: any) =>\n new Date(b.createdAt).getTime() - new Date(a.createdAt).getTime()\n );\n return jsonRes({ warnings: list, total: list.length });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/warnings\") {\n const body = await req.json();\n const warnings = await getWarnings();\n\n if (body.action === \"add\") {\n const w = {\n id: `w_${Date.now()}_${Math.random().toString(36).slice(2, 7)}`,\n driverName: body.driverName || \"\",\n date: body.date || new Date().toISOString().split(\"T\")[0],\n topic: body.topic || \"\",\n severity: body.severity || \"verbal\",\n note: body.note || \"\",\n recordedBy: body.recordedBy || \"\",\n acknowledged: false,\n createdAt: new Date().toISOString(),\n };\n warnings.push(w);\n await saveWarnings(warnings);\n return jsonRes({ ok: true, warning: w });\n }\n if (body.action === \"delete\") {\n const idx = warnings.findIndex((w: any) => w.id === body.id);\n if (idx === -1) return jsonRes({ ok: false }, 404);\n warnings.splice(idx, 1);\n await saveWarnings(warnings);\n return jsonRes({ ok: true });\n }\n if (body.action === \"acknowledge\") {\n const w = warnings.find((w: any) => w.id === body.id);\n if (!w) return jsonRes({ ok: false }, 404);\n w.acknowledged = true;\n w.acknowledgedAt = new Date().toISOString();\n await saveWarnings(warnings);\n return jsonRes({ ok: true, warning: w });\n }\n if (body.action === \"edit\") {\n const w = warnings.find((w: any) => w.id === body.id);\n if (!w) return jsonRes({ ok: false }, 404);\n [\"topic\", \"severity\", \"note\", \"date\", \"recordedBy\", \"driverName\"].forEach(\n (k) => {\n if (body[k] !== undefined) w[k] = body[k];\n },\n );\n w.updatedAt = new Date().toISOString();\n await saveWarnings(warnings);\n return jsonRes({ ok: true, warning: w });\n }\n return jsonRes({ ok: false, error: \"Unknown action\" }, 400);\n }\n\n // ── MY TASKS (Tim's personal schedule) ──\n if (req.method === \"GET\" && url.pathname === \"/mytasks\") {\n const tasks = await getTasks();\n tasks.sort((a: any, b: any) => {\n const da = a.date + (a.startTime || \"00:00\");\n const db = b.date + (b.startTime || \"00:00\");\n return da.localeCompare(db);\n });\n return jsonRes({ tasks, total: tasks.length });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/mytasks\") {\n const body = await req.json();\n const tasks = await getTasks();\n\n if (body.action === \"add\") {\n const t = {\n id: `t_${Date.now()}_${Math.random().toString(36).slice(2, 7)}`,\n title: body.title || \"\",\n type: body.type || \"task\",\n date: body.date || new Date().toISOString().split(\"T\")[0],\n startTime: body.startTime || \"\",\n endTime: body.endTime || \"\",\n priority: body.priority || \"normal\",\n note: body.note || \"\",\n status: \"pending\",\n createdAt: new Date().toISOString(),\n };\n tasks.push(t);\n await saveTasks(tasks);\n return jsonRes({ ok: true, task: t });\n }\n if (body.action === \"delete\") {\n const idx = tasks.findIndex((t: any) => t.id === body.id);\n if (idx === -1) return jsonRes({ ok: false }, 404);\n tasks.splice(idx, 1);\n await saveTasks(tasks);\n return jsonRes({ ok: true });\n }\n if (body.action === \"toggle\") {\n const t = tasks.find((t: any) => t.id === body.id);\n if (!t) return jsonRes({ ok: false }, 404);\n t.status = t.status === \"done\" ? \"pending\" : \"done\";\n t.completedAt = t.status === \"done\" ? new Date().toISOString() : null;\n await saveTasks(tasks);\n return jsonRes({ ok: true, task: t });\n }\n if (body.action === \"edit\") {\n const t = tasks.find((t: any) => t.id === body.id);\n if (!t) return jsonRes({ ok: false }, 404);\n [\"title\", \"type\", \"date\", \"startTime\", \"endTime\", \"priority\", \"note\"]\n .forEach((k) => {\n if (body[k] !== undefined) t[k] = body[k];\n });\n t.updatedAt = new Date().toISOString();\n await saveTasks(tasks);\n return jsonRes({ ok: true, task: t });\n }\n return jsonRes({ ok: false, error: \"Unknown action\" }, 400);\n }\n\n // ── OFFICE FURNITURE REGISTRY ──\n if (req.method === \"GET\" && url.pathname === \"/furniture\") {\n const items = await getFurniture();\n items.sort((a: any, b: any) =>\n (a.location || \"\").localeCompare(b.location || \"\") ||\n (a.name || \"\").localeCompare(b.name || \"\")\n );\n return jsonRes({ items, total: items.length });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/furniture\") {\n const body = await req.json();\n const items = await getFurniture();\n\n if (body.action === \"add\") {\n const f = {\n id: `f_${Date.now()}_${Math.random().toString(36).slice(2, 7)}`,\n category: body.category || \"\",\n name: body.name || \"\",\n assetCode: body.assetCode || \"\",\n location: body.location || \"\",\n condition: body.condition || \"good\", // good | damaged | repair | disposed\n quantity: body.quantity ? Number(body.quantity) : 1,\n photo: body.photo || \"\",\n note: body.note || \"\",\n createdAt: new Date().toISOString(),\n };\n items.push(f);\n await saveFurniture(items);\n return jsonRes({ ok: true, item: f });\n }\n if (body.action === \"edit\") {\n const f = items.find((x: any) => x.id === body.id);\n if (!f) return jsonRes({ ok: false }, 404);\n [\n \"category\",\n \"name\",\n \"assetCode\",\n \"location\",\n \"condition\",\n \"quantity\",\n \"photo\",\n \"note\",\n ]\n .forEach((k) => {\n if (body[k] !== undefined) {\n f[k] = k === \"quantity\" ? Number(body[k]) : body[k];\n }\n });\n f.updatedAt = new Date().toISOString();\n await saveFurniture(items);\n return jsonRes({ ok: true, item: f });\n }\n if (body.action === \"delete\") {\n const idx = items.findIndex((x: any) => x.id === body.id);\n if (idx === -1) return jsonRes({ ok: false }, 404);\n items.splice(idx, 1);\n await saveFurniture(items);\n return jsonRes({ ok: true });\n }\n return jsonRes({ ok: false, error: \"Unknown action\" }, 400);\n }\n\n if (req.method === \"GET\" && url.pathname === \"/sw.js\") {\n const sw = `\nself.addEventListener('install', e => self.skipWaiting());\nself.addEventListener('activate', e => clients.claim());\nself.addEventListener('fetch', function(e) {\n if (e.request.url.includes('/data') || e.request.url.includes('/warnings') || e.request.url.includes('/mytasks')) return;\n e.respondWith(fetch(e.request).then(function(response) {\n var clone = response.clone();\n caches.open('rmt-v1').then(function(cache) { cache.put(e.request, clone); });\n return response;\n }).catch(function() { return caches.match(e.request); }));\n});`;\n return new Response(sw, {\n headers: { \"Content-Type\": \"application/javascript\", ...CORS },\n });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/manifest.json\") {\n const manifest = {\n name: \"RMT Dispatch Board\",\n short_name: \"RMT Board\",\n start_url: \"/\",\n display: \"standalone\",\n background_color: \"#0f1117\",\n theme_color: \"#0f1117\",\n orientation: \"landscape\",\n icons: [{\n src:\n \"data:image/svg+xml,\",\n sizes: \"512x512\",\n type: \"image/svg+xml\",\n }],\n };\n return new Response(JSON.stringify(manifest), {\n headers: { \"Content-Type\": \"application/manifest+json\", ...CORS },\n });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/\") {\n return new Response(getHTML(), {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/data\") {\n const board = await getBoard();\n const photos = await getPhotos();\n return jsonRes({ ...board, photos, fixedDrivers: FIXED_DRIVERS });\n }\n\n // ── BOARD MUTATIONS ──\n if (req.method === \"POST\") {\n const body = await req.json();\n\n if (url.pathname === \"/save\") {\n const existing = await getBoard();\n const newBoardData = body.boardData || {};\n const merged = { ...existing.boardData };\n Object.keys(newBoardData).forEach((date) => {\n if (!merged[date]) merged[date] = {};\n Object.keys(newBoardData[date]).forEach((drv) => {\n if (!merged[date][drv]) merged[date][drv] = newBoardData[date][drv];\n else {\n const existingKeys = new Set(\n merged[date][drv].jobs.map((j: any) => j.key),\n );\n const newJobs = newBoardData[date][drv].jobs.filter((j: any) =>\n !existingKeys.has(j.key)\n );\n merged[date][drv].jobs = [...merged[date][drv].jobs, ...newJobs];\n }\n });\n });\n const allDates = [\n ...new Set([...(existing.dates || []), ...(body.dates || [])]),\n ].sort(\n (a: string, b: string) =>\n new Date(a.replace(/\\//g, \"-\")).getTime() -\n new Date(b.replace(/\\//g, \"-\")).getTime(),\n );\n await blob.setJSON(\"dispatch_board\", {\n boardData: merged,\n dates: allDates,\n });\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/photo\") {\n const photos = await getPhotos();\n photos[body.name] = body.photo;\n await blob.setJSON(\"driver_photos\", photos);\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/special\") {\n const board = await getBoard();\n if (!board.boardData[body.date]) board.boardData[body.date] = {};\n if (!board.boardData[body.date][body.driver]) {\n board.boardData[body.date][body.driver] = { jobs: [], specials: [] };\n }\n if (!board.boardData[body.date][body.driver].specials) {\n board.boardData[body.date][body.driver].specials = [];\n }\n if (body.action === \"add\") {\n board.boardData[body.date][body.driver].specials.push({\n type: body.type,\n label: body.label,\n });\n } else if (body.action === \"remove\") {\n board.boardData[body.date][body.driver].specials.splice(body.idx, 1);\n }\n await blob.setJSON(\"dispatch_board\", board);\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/removedate\") {\n const board = await getBoard();\n board.dates = board.dates.filter((d: string) => d !== body.date);\n delete board.boardData[body.date];\n await blob.setJSON(\"dispatch_board\", board);\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/newmonth\") {\n await blob.setJSON(\"dispatch_board\", { boardData: {}, dates: [] });\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/addjob\") {\n const board = await getBoard();\n const { date, driver, job } = body;\n if (!board.boardData[date]) board.boardData[date] = {};\n if (!board.boardData[date][driver]) {\n board.boardData[date][driver] = { jobs: [], specials: [] };\n }\n board.boardData[date][driver].jobs.push(job);\n if (!board.dates.includes(date)) board.dates.push(date);\n board.dates.sort((a: string, b: string) =>\n new Date(a.replace(/\\//g, \"-\")).getTime() -\n new Date(b.replace(/\\//g, \"-\")).getTime()\n );\n await blob.setJSON(\"dispatch_board\", board);\n return jsonRes({ ok: true });\n }\n if (url.pathname === \"/removejob\") {\n const board = await getBoard();\n const { date, driver, key } = body;\n if (board.boardData[date]?.[driver]) {\n board.boardData[date][driver].jobs = board.boardData[date][driver].jobs\n .filter((j: any) => j.key !== key);\n }\n await blob.setJSON(\"dispatch_board\", board);\n return jsonRes({ ok: true });\n }\n }\n\n return new Response(\"Not found\", { status: 404 });\n}\n\nfunction getHTML() {\n const html = String.raw`\n\n\n\n\n\n\n\n\n\n\nRMT Dispatch Board\n\n\n`;\n return html\n .replace(\"SCRIPTCLOSE\", \"\");\n}","createdAt",["D",1784518028443],"branchVersion","branchId","7090a44e-5b40-11f1-9a74-ee650bb23af1","id","708fdb5e-5b40-11f1-9a74-ee650bb23af1","Rmtboardmain",["D",1780046774969],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","1ae8fa8e-86eb-4124-a225-373da2f0a58c","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e1b75-460a-702e-b4f6-69e2c7b4d474","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_102":98},"org",{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",42,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","ZGAME","handle","displayName","Patompong Hansanam","avatar","https://lh3.googleusercontent.com/a/ACg8ocK7lDRBggdBFsMZnWHExBRJ9NSiCKtEM_AqotaSiAjM2JlSwnY=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":150,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":151,"_78":152,"_80":153,"_82":25},"tree",[145],"files",[145],"counts",{"_134":60,"_135":136,"_137":60,"_138":139,"_140":141},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"a72ee5b1-dbfa-44be-9d26-de7d8da93ae8","parentId","latest",["D",1784518028443],32,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":60,"_144":60},"connections",{"_142":60,"_143":60},"count","unfilledCount","emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":146,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_147":148,"_27":149},["D",1784518028443],"children",[],[28],["D",1780046774969],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_123":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":121,"_196":-5,"_197":-7,"_198":-7,"_199":60,"_200":25,"_201":25,"_202":-5,"_203":25,"_204":25,"_205":25,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":84,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"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 · v33