\n 🚌 CWRU Buses Monitoring\n

\n\n

\n \n\n

\n Buses Currently on Break\n

\n \n View Detailed Analysis\n \n \n \n \n

\n\n {loading\n ? (\n

Loading bus data...

\n )\n : }\n\n

\n Live Bus Map\n

\n \n\n {/* Loading notice for first load */}\n {!initialLoadDone.current && (\n

\n \n \n \n First load may take a moment as data is fetched from TransLoc\n API\n

\n )}\n

\n );\n}\n",[],[203,209,215],{"_105":222,"_98":223,"_156":224,"_158":210,"_159":139,"_160":225,"_162":119,"_107":226,"_102":227,"_164":188,"_166":228,"_167":25,"_168":-5,"_169":229,"_101":230},"852aa06e-10fd-11f0-8414-569c3dd06744","BusMap.tsx","ac06e33a-10f5-11f0-8ed4-569c3dd06744",162,["D",1743734149475],4,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useEffect, useRef, useState } from \"https://esm.sh/react@18.2.0\";\n\n// Import Leaflet types\ndeclare const L: any;\n\ninterface Bus {\n vehicleId: string;\n name: string;\n routeName: string;\n lat: number;\n lng: number;\n onBreak: boolean;\n}\n\ninterface BusMapProps {\n positions: Bus[];\n}\n\nexport function BusMap({ positions }: BusMapProps) {\n const mapRef = useRef(null);\n const markersRef = useRef>({});\n const [mapInitialized, setMapInitialized] = useState(false);\n\n // Keep track of last known positions to prevent buses from disappearing\n const [lastPositions, setLastPositions] = useState([]);\n\n // First, initialize the map - this runs only once\n useEffect(() => {\n if (typeof window !== \"undefined\" && !mapRef.current) {\n console.log(\"Initializing map...\");\n try {\n mapRef.current = L.map(\"mapContainer\").setView([41.509, -81.617], 15);\n\n L.tileLayer(\n \"https://{s}.basemaps.cartocdn.com/light_all/{z}/{x}/{y}{r}.png\",\n {\n attribution: \"© OpenStreetMap & Carto\",\n subdomains: \"abcd\",\n maxZoom: 19,\n },\n ).addTo(mapRef.current);\n\n setMapInitialized(true);\n console.log(\"Map initialized successfully\");\n } catch (error) {\n console.error(\"Error initializing map:\", error);\n }\n }\n\n return () => {\n if (mapRef.current) {\n mapRef.current.remove();\n mapRef.current = null;\n setMapInitialized(false);\n }\n };\n }, []);\n\n // Update markers whenever positions or map initialization status changes\n useEffect(() => {\n // Only continue if map is initialized\n if (!mapInitialized || !mapRef.current) {\n return;\n }\n\n console.log(`Updating markers with ${positions.length} positions...`);\n\n // Create icons for markers\n const activeBusIcon = L.icon({\n iconUrl: \"https://cdn-icons-png.flaticon.com/512/8/8110.png\",\n iconSize: [32, 32],\n iconAnchor: [16, 32],\n popupAnchor: [0, -32],\n });\n\n const breakBusIcon = L.icon({\n iconUrl: \"https://cdn-icons-png.flaticon.com/512/252/252025.png\",\n iconSize: [32, 32],\n iconAnchor: [16, 32],\n popupAnchor: [0, -32],\n });\n\n // Update last positions if we have new data\n if (positions.length > 0) {\n setLastPositions(positions);\n }\n\n // Determine which positions to use\n const displayPositions = positions.length > 0 ? positions : lastPositions;\n\n // Create a map for quick lookups\n const busMap = new Map();\n displayPositions.forEach((bus) => {\n busMap.set(bus.vehicleId, bus);\n });\n\n // Add or update markers for each bus\n displayPositions.forEach((bus) => {\n const icon = bus.onBreak ? breakBusIcon : activeBusIcon;\n\n if (markersRef.current[bus.vehicleId]) {\n // Update existing marker\n markersRef.current[bus.vehicleId]\n .setLatLng([bus.lat, bus.lng])\n .setIcon(icon);\n\n // Update popup content\n const popup = markersRef.current[bus.vehicleId].getPopup();\n if (popup) {\n popup.setContent(`\n

🚌 Bus ${bus.name}

${bus.routeName}

\n ${bus.onBreak ? \"🔴 On Break\" : \"🟢 Active\"}\n

\n `);\n }\n } else {\n // Create new marker\n try {\n markersRef.current[bus.vehicleId] = L.marker([bus.lat, bus.lng], {\n icon,\n })\n .addTo(mapRef.current)\n .bindPopup(\n `\n

🚌 Bus ${bus.name}

${bus.routeName}

\n ${bus.onBreak ? \"🔴 On Break\" : \"🟢 Active\"}\n

\n \n

\n\n {!mapInitialized && (\n

Loading map...

\n )}\n\n {mapInitialized && positions.length === 0 && lastPositions.length === 0\n && (\n

Waiting for bus data...

\n )}\n \n );\n}",[],[203,209,223],{"_105":232,"_98":233,"_156":234,"_158":210,"_159":139,"_160":174,"_162":119,"_107":235,"_102":161,"_164":188,"_166":236,"_167":25,"_168":-5,"_169":237,"_101":238},"edc8718c-10f8-11f0-88d9-569c3dd06744","BusTable.tsx","ac42ce68-10f5-11f0-a390-569c3dd06744",["D",1743732177563],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\ninterface Bus {\n vehicleId: string;\n name: string;\n routeName: string;\n currentBreak: number;\n totalBreak: number;\n}\n\ninterface BusTableProps {\n buses: Bus[];\n}\n\nexport function BusTable({ buses }: BusTableProps) {\n function formatTime(seconds: number) {\n const h = Math.floor(seconds / 3600);\n const m = Math.floor((seconds % 3600) / 60);\n const s = seconds % 60;\n\n const pad = (num: number) => String(num).padStart(2, \"0\");\n return `${pad(h)}:${pad(m)}:${pad(s)}`;\n }\n\n return (\n

\n \n \n \n \n Bus Number\n \n \n Route\n \n \n Break Duration\n \n \n Total Break Time\n \n \n \n \n {buses.length === 0\n ? (\n \n \n No buses currently on break\n \n \n )\n : (\n buses.map((bus) => (\n \n \n \n \n \n \n ))\n )}\n \n

\n {bus.name}\n	\n {bus.routeName}\n	\n {formatTime(bus.currentBreak)}\n	\n {formatTime(bus.totalBreak)}\n

\n );\n}\n",[],[203,209,233],{"_105":240,"_98":241,"_156":242,"_158":210,"_159":139,"_160":174,"_162":119,"_107":243,"_102":227,"_164":188,"_166":244,"_167":25,"_168":-5,"_169":245,"_101":246},"edc874ac-10f8-11f0-88d9-569c3dd06744","DetailedView.tsx","abe8d7d2-10f5-11f0-bdf0-569c3dd06744",["D",1743732177563],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { StatusIndicator } from \"./StatusIndicator.tsx\";\n\ninterface BusBreakSummary {\n vehicleId: string;\n name: string;\n routeName: string;\n routeId: number;\n onBreak: boolean;\n stationaryFor: number;\n breakTime2h: number;\n breakTime4h: number;\n}\n\nexport function DetailedView() {\n const [detailedData, setDetailedData] = useState([]);\n\n useEffect(() => {\n const fetchDetailedBreaks = async () => {\n try {\n const res = await fetch(\"/api/detailed-breaks\");\n const data = await res.json();\n\n // Sort by break time (last 2h) - highest first\n data.sort((a: BusBreakSummary, b: BusBreakSummary) =>\n b.breakTime2h - a.breakTime2h\n );\n setDetailedData(data);\n } catch (error) {\n console.error(\"Error fetching detailed break data:\", error);\n }\n };\n\n fetchDetailedBreaks();\n const interval = setInterval(fetchDetailedBreaks, 15000);\n\n return () => clearInterval(interval);\n }, []);\n\n function formatTime(seconds: number) {\n const h = Math.floor(seconds / 3600);\n const m = Math.floor((seconds % 3600) / 60);\n const s = seconds % 60;\n\n const pad = (num: number) => String(num).padStart(2, \"0\");\n return `${pad(h)}:${pad(m)}:${pad(s)}`;\n }\n\n return (\n

\n 🚌 Detailed Bus Break Analysis\n

\n\n

\n \n\n

\n \n \n \n \n Back to Dashboard\n \n\n

\n Showing detailed break times for all buses\n

\n\n

\n 🕒 Break Time Summary\n

\n\n

\n \n \n \n \n Bus Number\n \n \n Route\n \n \n Status\n \n \n Stationary For\n \n \n Break Time (Last 2h)\n \n \n Break Time (Last 4h)\n \n \n \n \n {detailedData.length === 0\n ? (\n \n \n Loading data...\n \n \n )\n : (\n detailedData.map((bus) => (\n 1800 ? \"bg-yellow-50\" : \"\"\n }`}\n >\n \n \n \n \n \n \n \n ))\n )}\n \n

\n {bus.name}\n	\n {bus.routeName}\n	\n {bus.onBreak\n ? (\n \n \n \n On Break\n \n )\n : (\n \n \n \n Active\n \n )}\n	\n {formatTime(bus.stationaryFor)}\n	\n {formatTime(bus.breakTime2h)}\n	\n {formatTime(bus.breakTime4h)}\n

\n\n

\n Note: Buses with more than 30 minutes of break time in the last 2\n hours are highlighted.\n

\n );\n}\n",[],[203,209,241],{"_105":248,"_98":249,"_156":250,"_158":210,"_159":139,"_160":174,"_162":119,"_107":251,"_102":161,"_164":188,"_166":252,"_167":25,"_168":-5,"_169":253,"_101":254},"edc87a60-10f8-11f0-88d9-569c3dd06744","StatusIndicator.tsx","1ef82020-10f6-11f0-83be-569c3dd06744",["D",1743732177563],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\n\ninterface StatusData {\n lastUpdate: string;\n status: \"fresh\" | \"stale\";\n age: number;\n}\n\nexport function StatusIndicator() {\n const [status, setStatus] = useState(null);\n\n useEffect(() => {\n const fetchStatus = async () => {\n try {\n const res = await fetch(\"/api/status\");\n const data = await res.json();\n setStatus(data);\n } catch (error) {\n console.error(\"Error fetching status:\", error);\n }\n };\n\n fetchStatus();\n const interval = setInterval(fetchStatus, 15000);\n\n return () => clearInterval(interval);\n }, []);\n\n if (!status) {\n return (\n

\n );\n }\n\n return (\n \n \n \n

\n \n Last update: {new Date(status.lastUpdate).toLocaleTimeString()}\n \n \n ({status.age} seconds ago)\n \n

\n \n {status.status === \"fresh\" ? \"Live\" : \"Stale\"}\n \n

\n \n );\n}\n",[],[203,209,249],[203,209],{"_105":257,"_98":258,"_156":259,"_158":204,"_159":139,"_160":174,"_162":119,"_107":260,"_102":261,"_164":262,"_166":263,"_167":25,"_168":-5,"_169":264,"_101":265},"edc87d6c-10f8-11f0-88d9-569c3dd06744","index.html","0e957203-73e5-4ab4-bcbc-07198da3d378",["D",1743732177563],5,"file","\n\n \n \n \n CWRU Bus Break Dashboard\n \n \n \n \n \n \n \n

\n \n \n \n\n",[],[203,258],{"_105":267,"_98":268,"_156":269,"_158":204,"_159":139,"_160":174,"_162":119,"_107":270,"_102":271,"_164":188,"_166":272,"_167":25,"_168":-5,"_169":273,"_101":274},"edc87f1a-10f8-11f0-88d9-569c3dd06744","index.tsx","845e0f61-c907-46a9-a86c-27b447f47242",["D",1743732177563],2,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"./components/App.tsx\";\nimport { DetailedView } from \"./components/DetailedView.tsx\";\n\nconst root = document.getElementById(\"root\");\nif (!root) {\n throw new Error(\"No root element found\");\n}\n\n// Simple router based on pathname\nconst currentPath = window.location.pathname;\nlet Component;\n\nif (currentPath === \"/detailed\") {\n Component = ;\n} else {\n Component = ;\n}\n\ncreateRoot(root).render(Component);\n",[],[203,268],[203],{"_105":277,"_98":278,"_156":279,"_158":-5,"_159":139,"_160":138,"_162":119,"_107":280,"_102":227,"_164":262,"_166":281,"_167":25,"_168":-5,"_169":282,"_101":283},"9089761e-119e-11f0-8f2e-569c3dd06744","README.md","cbcfa76b-334e-4dc5-a17d-d5dcb54986a4",["D",1743803317579],"(credit: Tobias Heller, ported to val town project)\n\n# React Hono Starter\n\nThis app is a starter template for client-side React and server-side Hono.\n\n- **Remix** this starter template on the top right to get started.\n\n- The **entrypoint** is `/backend/index.ts`. That's the backend HTTP server,\n which also serves the all the frontend assets.\n\n- The **client-side entrypoint** is `/frontend/index.html`, which in turn\n imports `/frontend/index.tsx`, which in turn imports the React app from\n `/frontend/components/App.tsx`.\n\n[React Hono Example](https://www.val.town/x/stevekrouse/reactHonoExample) is a\nfuller featured example project, with a SQLite database table, queries,\nclient-side CSS and a favicon, and some shared code that runs on both client and\nserver.",[],[278],{"_105":285,"_98":286,"_156":287,"_158":-5,"_159":139,"_160":288,"_162":119,"_107":289,"_102":161,"_164":290,"_166":291,"_167":25,"_168":-5,"_169":292,"_101":293},"4dcdcc36-10fd-11f0-ba73-569c3dd06744","kickstart.ts","49d9ad7a-10fd-11f0-958d-569c3dd06744",159,["D",1743734056651],"interval","export default async function (interval: Interval) {\n await fetch(\"https://wolf--14aa1afa10fc11f0bb2a569c3dd06744.web.val.run\")\n}",[],[286],{"_105":295,"_98":184,"_156":296,"_158":-5,"_159":139,"_160":121,"_162":119,"_107":297,"_102":298,"_164":177,"_166":299,"_167":25,"_168":300,"_169":301,"_101":302},"36b4f320-10fe-11f0-958d-569c3dd06744","14aa1afa-10fc-11f0-bb2a-569c3dd06744",["D",1743734447397],17,"import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const LAST_RUN_KEY = \"refresh_last_run\";\n const REFRESH_INTERVAL = 5000; // 5 seconds\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(LAST_RUN_KEY);\n const now = Date.now();\n\n // Only refresh if enough time has passed\n if (!lastRun || now - lastRun >= REFRESH_INTERVAL) {\n try {\n // Execute the refresh function\n await refresh();\n console.log(\"Refresh completed\");\n } catch (error) {\n console.error(\"Refresh failed:\", error);\n }\n\n // Update the last run timestamp\n await blob.setJSON(LAST_RUN_KEY, now);\n\n // Simple next run scheduling\n setTimeout(() => {\n fetch(\"https://wolf--14aa1afa10fc11f0bb2a569c3dd06744.web.val.run\");\n }, REFRESH_INTERVAL);\n\n await new Promise(() => {\n // This promise never resolves\n });\n\n return new Response(\"Refreshed and scheduled next run\");\n } else {\n return new Response(\"Too soon for refresh\");\n }\n}","cwru-busses-refresh",[],[184],"files",[153,171,182,192,201,207,213,221,231,239,247,256,266,276,284,294],"counts",{"_307":271,"_308":271,"_309":29,"_310":29},"pulls","branches","forks","envVars","contents",[313,316,319,322,325],{"_105":154,"_98":155,"_156":157,"_158":-5,"_159":139,"_160":161,"_162":119,"_107":314,"_102":29,"_164":165,"_166":-5,"_167":25,"_168":-5,"_101":315},["D",1743730309398],[155],{"_105":202,"_98":203,"_156":204,"_158":-5,"_159":139,"_160":161,"_162":119,"_107":317,"_102":29,"_164":165,"_166":-5,"_167":25,"_168":-5,"_101":318},["D",1743730309398],[203],{"_105":277,"_98":278,"_156":279,"_158":-5,"_159":139,"_160":138,"_162":119,"_107":320,"_102":227,"_164":262,"_166":281,"_167":25,"_168":-5,"_101":321},["D",1743803317579],[278],{"_105":285,"_98":286,"_156":287,"_158":-5,"_159":139,"_160":288,"_162":119,"_107":323,"_102":161,"_164":290,"_166":291,"_167":25,"_168":-5,"_101":324},["D",1743734056651],[286],{"_105":295,"_98":184,"_156":296,"_158":-5,"_159":139,"_160":121,"_162":119,"_107":326,"_102":298,"_164":177,"_166":299,"_167":25,"_168":300,"_101":327},["D",1743734447397],[184],"upstreamProject",{"_105":330,"_98":331,"_113":332,"_114":-5,"_111":112,"_19":333},"96102714-f528-11ef-aa68-569c3dd06744","reactHonoStarter","Starter template with client-side React & Hono server",{"_96":334,"_134":335},"std","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJVaVhpQ1BId3dscVpBbkdZVWlMNjJtcjkxWS5wbmcifQ","upstreamBranch",{"_105":142,"_107":338,"_339":340,"_98":40,"_140":330,"_102":341,"_141":-5,"_143":-5,"_342":343,"_109":-5,"_150":25,"_111":112,"_149":334,"_14":344,"_148":331},["D",1740674013689],"updatedAt",["D",1748439933668],67,"lockfileKey","1748439933889-esm.town_v_std_reactHonoStarter@67-main","c606f87f-4d7e-48c8-9c39-ef5ab94aec49","emptyEnvVars","isNew","routes/_app.x.$handle.$name.branch.$branch.history",{"_96":97,"_98":99,"_100":40,"_103":349,"_353":354,"_606":29,"_607":119},{"_105":106,"_98":99,"_107":350,"_109":-5,"_110":25,"_111":112,"_113":-5,"_114":-5,"_12":115,"_116":117,"_118":119,"_120":121,"_122":29,"_14":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_19":351,"_136":352,"_150":25},["D",1743730309398],{"_96":97,"_134":135},{"_102":138,"_98":40,"_105":139,"_140":106,"_141":142,"_143":144,"_145":112,"_146":147,"_148":99,"_149":97},"history",[355,360,368,376,381,390,399,404,412,419,424,432,441,450,459,468,476,485,494,503,512,520,527,535,543,551,559,568,575,582,590,598],{"_156":279,"_102":138,"_107":356,"_159":139,"_303":357},["D",1743803317579],[358],{"_105":277,"_159":139,"_156":279,"_98":278,"_166":281,"_164":262,"_102":227,"_158":-5,"_107":356,"_160":138,"_168":-5,"_162":119,"_167":25,"_101":359},[278],{"_156":279,"_102":361,"_107":362,"_159":139,"_303":363},167,["D",1743803311366],[364],{"_105":365,"_159":139,"_156":279,"_98":278,"_166":366,"_164":262,"_102":176,"_158":-5,"_107":362,"_160":361,"_168":-5,"_162":25,"_167":25,"_101":367},"8cd4f0e8-119e-11f0-a94b-569c3dd06744","(credit: Tobias Heller)\n\n# React Hono Starter\n\nThis app is a starter template for client-side React and server-side Hono.\n\n- **Remix** this starter template on the top right to get started.\n\n- The **entrypoint** is `/backend/index.ts`. That's the backend HTTP server,\n which also serves the all the frontend assets.\n\n- The **client-side entrypoint** is `/frontend/index.html`, which in turn\n imports `/frontend/index.tsx`, which in turn imports the React app from\n `/frontend/components/App.tsx`.\n\n[React Hono Example](https://www.val.town/x/stevekrouse/reactHonoExample) is a\nfuller featured example project, with a SQLite database table, queries,\nclient-side CSS and a favicon, and some shared code that runs on both client and\nserver.",[278],{"_156":279,"_102":369,"_107":370,"_159":139,"_303":371},166,["D",1743803308763],[372],{"_105":373,"_159":139,"_156":279,"_98":278,"_166":374,"_164":262,"_102":271,"_158":-5,"_107":370,"_160":369,"_168":-5,"_162":25,"_167":25,"_101":375},"8b48775e-119e-11f0-a258-569c3dd06744","(credit Tobias Heller)\n\n# React Hono Starter\n\nThis app is a starter template for client-side React and server-side Hono.\n\n- **Remix** this starter template on the top right to get started.\n\n- The **entrypoint** is `/backend/index.ts`. That's the backend HTTP server,\n which also serves the all the frontend assets.\n\n- The **client-side entrypoint** is `/frontend/index.html`, which in turn\n imports `/frontend/index.tsx`, which in turn imports the React app from\n `/frontend/components/App.tsx`.\n\n[React Hono Example](https://www.val.town/x/stevekrouse/reactHonoExample) is a\nfuller featured example project, with a SQLite database table, queries,\nclient-side CSS and a favicon, and some shared code that runs on both client and\nserver.",[278],{"_156":296,"_102":121,"_107":377,"_159":139,"_303":378},["D",1743734447397],[379],{"_105":295,"_159":139,"_156":296,"_98":184,"_166":299,"_164":177,"_102":298,"_158":-5,"_107":377,"_160":121,"_168":300,"_162":119,"_167":25,"_101":380},[184],{"_156":296,"_102":382,"_107":383,"_159":139,"_303":384},164,["D",1743734425829],[385],{"_105":386,"_159":139,"_156":296,"_98":184,"_166":387,"_164":177,"_102":388,"_158":-5,"_107":383,"_160":382,"_168":300,"_162":25,"_167":25,"_101":389},"29da201c-10fe-11f0-9a74-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const LAST_RUN_KEY = \"refresh_last_run\";\n const REFRESH_INTERVAL = 5000; // 5 seconds\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(LAST_RUN_KEY);\n const now = Date.now();\n\n // Only refresh if enough time has passed\n if (!lastRun || now - lastRun >= REFRESH_INTERVAL) {\n try {\n // Execute the refresh function\n await refresh();\n console.log(\"Refresh completed\");\n } catch (error) {\n console.error(\"Refresh failed:\", error);\n }\n\n // Update the last run timestamp\n await blob.setJSON(LAST_RUN_KEY, now);\n\n // Simple next run scheduling\n setTimeout(() => {\n fetch(\"https://wolf--14aa1afa10fc11f0bb2a569c3dd06744.web.val.run\");\n }, REFRESH_INTERVAL);\n\n return new Response(\"Refreshed and scheduled next run\");\n } else {\n return new Response(\"Too soon for refresh\");\n }\n}",16,[184],{"_156":296,"_102":391,"_107":392,"_159":139,"_303":393},163,["D",1743734289096],[394],{"_105":395,"_159":139,"_156":296,"_98":184,"_166":396,"_164":177,"_102":397,"_158":-5,"_107":392,"_160":391,"_168":300,"_162":25,"_167":25,"_101":398},"d85a172e-10fd-11f0-9086-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const LAST_RUN_KEY = \"refresh_last_run\";\n const HEALTH_CHECK_KEY = \"refresh_health_check\";\n const MAX_RETRIES = 3;\n const REFRESH_INTERVAL = 5000; // 5 seconds\n const HEALTH_CHECK_INTERVAL = 60000; // 1 minute\n\n // Get the last run timestamp and health check data\n const lastRun = await blob.getJSON(LAST_RUN_KEY);\n const healthCheck = await blob.getJSON(HEALTH_CHECK_KEY) || {\n lastSuccessfulRun: null,\n consecutiveFailures: 0,\n totalRuns: 0,\n totalFailures: 0,\n };\n\n const now = Date.now();\n let response = \"\";\n let shouldRefresh = false;\n\n // Check if this is a health check request\n const isHealthCheck = req.url.includes(\"?health=check\");\n\n // Perform health check recovery if needed\n if (isHealthCheck || !lastRun || (now - lastRun >= HEALTH_CHECK_INTERVAL)) {\n console.log(\"Performing health check\");\n\n // If no successful run in the last minute or too many consecutive failures, force a refresh\n if (\n !healthCheck.lastSuccessfulRun\n || (now - healthCheck.lastSuccessfulRun >= HEALTH_CHECK_INTERVAL)\n || healthCheck.consecutiveFailures > 3\n ) {\n console.log(\"Health check triggered refresh - system recovery\");\n shouldRefresh = true;\n response += \"Health recovery triggered. \";\n }\n\n // Update health check timestamp\n await blob.setJSON(HEALTH_CHECK_KEY, {\n ...healthCheck,\n lastChecked: now,\n });\n\n if (isHealthCheck) {\n return new Response(JSON.stringify({\n status: \"ok\",\n lastRun,\n healthCheck,\n now,\n }));\n }\n }\n\n // Normal refresh logic\n if (!lastRun || now - lastRun >= REFRESH_INTERVAL || shouldRefresh) {\n console.log(\"Starting refresh operation\");\n\n try {\n // Execute the refresh function\n await refresh();\n\n // Update health check on success\n await blob.setJSON(HEALTH_CHECK_KEY, {\n ...healthCheck,\n lastSuccessfulRun: now,\n consecutiveFailures: 0,\n totalRuns: (healthCheck.totalRuns || 0) + 1,\n });\n\n console.log(\"Refresh completed successfully\");\n response += \"Refreshed successfully. \";\n } catch (error) {\n console.error(\"Refresh operation failed:\", error);\n\n // Update health check on failure\n await blob.setJSON(HEALTH_CHECK_KEY, {\n ...healthCheck,\n consecutiveFailures: (healthCheck.consecutiveFailures || 0) + 1,\n totalRuns: (healthCheck.totalRuns || 0) + 1,\n totalFailures: (healthCheck.totalFailures || 0) + 1,\n lastError: error.message || String(error),\n lastErrorTime: now,\n });\n\n response += \"Refresh failed but continuing. \";\n }\n\n // Update the last run timestamp regardless of success/failure\n await blob.setJSON(LAST_RUN_KEY, now);\n\n // Schedule the next run with retry logic\n scheduleNextRun(0);\n\n return new Response(response + \"Scheduled next run\");\n } else {\n // Not enough time has passed, schedule the next run after waiting\n const timeToWait = REFRESH_INTERVAL - (now - lastRun);\n console.log(`Too soon for refresh. Waiting ${timeToWait}ms`);\n\n scheduleNextRun(timeToWait);\n\n return new Response(`${response}Too soon. Next refresh in ${timeToWait}ms`);\n }\n\n // Helper function to schedule the next run with retries\n function scheduleNextRun(delay: number) {\n (async () => {\n // Wait for the specified delay\n await new Promise(resolve => setTimeout(resolve, delay));\n\n let success = false;\n let attempts = 0;\n\n // Retry logic\n while (!success && attempts < MAX_RETRIES) {\n attempts++;\n try {\n console.log(`Triggering next run (attempt ${attempts}/${MAX_RETRIES})`);\n const response = await fetch(\"https://wolf--14aa1afa10fc11f0bb2a569c3dd06744.web.val.run\", {\n method: \"GET\",\n headers: { \"Cache-Control\": \"no-cache\" },\n });\n\n if (response.ok) {\n console.log(\"Successfully scheduled next run\");\n success = true;\n } else {\n console.warn(`Failed to trigger next run: HTTP ${response.status}`);\n // Exponential backoff between retries\n await new Promise(resolve => setTimeout(resolve, 1000 * Math.pow(2, attempts - 1)));\n }\n } catch (error) {\n console.error(`Failed to trigger next run (attempt ${attempts}/${MAX_RETRIES}):`, error);\n\n // Exponential backoff between retries\n await new Promise(resolve => setTimeout(resolve, 1000 * Math.pow(2, attempts - 1)));\n }\n }\n\n // If all retries failed, schedule a health check after a delay\n if (!success) {\n console.error(\"All retry attempts failed, scheduling health check\");\n setTimeout(async () => {\n try {\n await fetch(\"https://wolf--14aa1afa10fc11f0bb2a569c3dd06744.web.val.run?health=check\");\n } catch (e) {\n console.error(\"Even health check failed:\", e);\n }\n }, REFRESH_INTERVAL);\n }\n })();\n }\n}",15,[184],{"_156":224,"_102":225,"_107":400,"_159":139,"_303":401},["D",1743734149475],[402],{"_105":222,"_159":139,"_156":224,"_98":223,"_166":228,"_164":188,"_102":227,"_158":210,"_107":400,"_160":225,"_168":-5,"_162":119,"_167":25,"_101":403},[203,209,223],{"_156":224,"_102":405,"_107":406,"_159":139,"_303":407},161,["D",1743734117135],[408],{"_105":409,"_159":139,"_156":224,"_98":223,"_166":410,"_164":188,"_102":176,"_158":210,"_107":406,"_160":405,"_168":-5,"_162":25,"_167":25,"_101":411},"71dbb26e-10fd-11f0-8d6d-569c3dd06744","/** @jsxImportSource https://esm.sh/react@18.2.0 */ \n import { useEffect, useRef, useState } from \"https://esm.sh/react@18.2.0\"; \n import { debounce } from \"jsr:@std/async@1.0.12\"; \n \n // Import Leaflet types \n declare const L: any; \n \n interface Bus { \n vehicleId: string; \n name: string; \n routeName: string; \n lat: number; \n lng: number; \n onBreak: boolean; \n } \n \n interface BusMapProps { \n positions: Bus[]; \n } \n \n export function BusMap({ positions }: BusMapProps) { \n const mapRef = useRef(null); \n const markersRef = useRef>({}); \n const [mapInitialized, setMapInitialized] = useState(false); \n \n // Keep track of last known positions to prevent buses from disappearing \n const [lastPositions, setLastPositions] = useState([]); \n \n // First, initialize the map - this runs only once \n useEffect(() => { \n if (typeof window !== \"undefined\" && !mapRef.current) { \n console.log(\"Initializing map...\"); \n try { \n mapRef.current = L.map(\"mapContainer\").setView([41.509, -81.617], 15); \n \n L.tileLayer( \n \"https://{s}.basemaps.cartocdn.com/light_all/{z}/{x}/{y}{r}.png\", \n { \n attribution: \"© OpenStreetMap & Carto\", \n subdomains: \"abcd\", \n maxZoom: 19, \n // Add performance options \n updateWhenIdle: true, \n updateWhenZooming: false, \n keepBuffer: 2 \n }, \n ).addTo(mapRef.current); \n \n setMapInitialized(true); \n console.log(\"Map initialized successfully\"); \n } catch (error) { \n console.error(\"Error initializing map:\", error); \n } \n } \n \n return () => { \n if (mapRef.current) { \n mapRef.current.remove(); \n mapRef.current = null; \n setMapInitialized(false); \n } \n }; \n }, []); \n \n // Create debounced update function \n const updateMarkers = useRef( \n debounce((currentPositions: Bus[], currentMapInitialized: boolean, currentLastPositions: Bus[]) => { \n // Only continue if map is initialized \n if (!currentMapInitialized || !mapRef.current) { \n return; \n } \n \n console.log(`Updating markers with ${currentPositions.length} positions...`); \n \n // Create icons for markers \n const activeBusIcon = L.icon({ \n iconUrl: \"https://cdn-icons-png.flaticon.com/512/8/8110.png\", \n iconSize: [32, 32], \n iconAnchor: [16, 32], \n popupAnchor: [0, -32], \n }); \n \n const breakBusIcon = L.icon({ \n iconUrl: \"https://cdn-icons-png.flaticon.com/512/252/252025.png\", \n iconSize: [32, 32], \n iconAnchor: [16, 32], \n popupAnchor: [0, -32], \n }); \n \n // Determine which positions to use \n const displayPositions = currentPositions.length > 0 ? currentPositions : currentLastPositions; \n \n // Create a map for quick lookups \n const busMap = new Map(); \n displayPositions.forEach((bus) => { \n busMap.set(bus.vehicleId, bus); \n }); \n \n // Add or update markers for each bus \n displayPositions.forEach((bus) => { \n const icon = bus.onBreak ? breakBusIcon : activeBusIcon; \n \n if (markersRef.current[bus.vehicleId]) { \n // Update existing marker \n markersRef.current[bus.vehicleId] \n .setLatLng([bus.lat, bus.lng]) \n .setIcon(icon); \n \n // Update popup content \n const popup = markersRef.current[bus.vehicleId].getPopup(); \n if (popup) { \n popup.setContent(` \n

🚌 Bus ${bus.name}

${bus.routeName}

\n ${bus.onBreak ? \"🔴 On Break\" : \"🟢 Active\"} \n

\n `); \n } \n } else { \n // Create new marker \n try { \n markersRef.current[bus.vehicleId] = L.marker([bus.lat, bus.lng], { \n icon, \n }) \n .addTo(mapRef.current) \n .bindPopup( \n ` \n

🚌 Bus ${bus.name}

${bus.routeName}

\n ${bus.onBreak ? \"🔴 On Break\" : \"🟢 Active\"} \n

\n `, \n { \n closeButton: false, \n className: \"bus-popup\", \n autoPan: false, \n }, \n ); \n console.log(`Added marker for bus ${bus.name} (${bus.vehicleId})`); \n } catch (error) { \n console.error(`Error adding marker for bus ${bus.vehicleId}:`, error); \n } \n } \n }); \n \n // Remove markers for buses no longer in the data \n // Only do this if we have new data \n if (currentPositions.length > 0) { \n Object.keys(markersRef.current).forEach((id) => { \n if (!busMap.has(id)) { \n mapRef.current.removeLayer(markersRef.current[id]); \n delete markersRef.current[id]; \n console.log(`Removed marker for bus ${id}`); \n } \n }); \n } \n }, 300) // 300ms debounce time \n ).current; \n \n // Update last positions if we have new data \n useEffect(() => { \n if (positions.length > 0) { \n setLastPositions(positions); \n } \n }, [positions]); \n \n // Trigger the debounced update when positions or map status changes \n useEffect(() => { \n updateMarkers(positions, mapInitialized, lastPositions); \n }, [positions, mapInitialized, lastPositions]); \n \n return ( \n

\n \n {!mapInitialized && ( \n

Loading map...

\n )} \n \n {mapInitialized && positions.length === 0 && lastPositions.length === 0 && \n ( \n

Waiting for bus data...

\n )} \n

\n ); \n }",[203,209,223],{"_156":224,"_102":413,"_107":414,"_159":139,"_303":415},160,["D",1743734104139],[416],{"_105":417,"_159":139,"_156":224,"_98":223,"_166":410,"_164":188,"_102":271,"_158":210,"_107":414,"_160":413,"_168":-5,"_162":25,"_167":25,"_101":418},"6a1c62bc-10fd-11f0-af71-569c3dd06744",[203,209,223],{"_156":287,"_102":288,"_107":420,"_159":139,"_303":421},["D",1743734056651],[422],{"_105":285,"_159":139,"_156":287,"_98":286,"_166":291,"_164":290,"_102":161,"_158":-5,"_107":420,"_160":288,"_168":-5,"_162":119,"_167":25,"_101":423},[286],{"_156":287,"_102":425,"_107":426,"_159":139,"_303":427},158,["D",1743734050020],[428],{"_105":429,"_159":139,"_156":287,"_98":286,"_166":430,"_164":290,"_102":29,"_158":-5,"_107":426,"_160":425,"_168":-5,"_162":25,"_167":25,"_101":431},"49d9acee-10fd-11f0-958d-569c3dd06744","export default async function (interval: Interval) {\n \n}",[286],{"_156":296,"_102":433,"_107":434,"_159":139,"_303":435},157,["D",1743734038097],[436],{"_105":437,"_159":139,"_156":296,"_98":184,"_166":438,"_164":177,"_102":439,"_158":-5,"_107":434,"_160":433,"_168":300,"_162":25,"_167":25,"_101":440},"42bec52a-10fd-11f0-9c33-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const LAST_RUN_KEY = \"refresh_last_run\";\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(LAST_RUN_KEY);\n const now = Date.now();\n\n // Only perform the refresh if enough time has passed\n if (!lastRun || now - lastRun >= 5000) {\n // Execute the refresh function\n await refresh();\n\n // Update the last run timestamp\n await blob.setJSON(LAST_RUN_KEY, now);\n\n // Always schedule the next run\n // We do this in the background so the response can return immediately\n await (async () => {\n // Wait 5 seconds\n await new Promise(resolve => setTimeout(resolve, 5000));\n // Trigger the next run\n try {\n await fetch(\"https://wolf--14aa1afa10fc11f0bb2a569c3dd06744.web.val.run\");\n } catch (error) {\n console.error(\"Failed to trigger next run:\", error);\n }\n })();\n\n return new Response(\"refreshed and scheduled next run\");\n } else {\n // Not enough time has passed, but still schedule the next run\n const timeToWait = 5000 - (now - lastRun);\n\n // Schedule the next run after waiting for the remaining time\n (async () => {\n await new Promise(resolve => setTimeout(resolve, timeToWait));\n try {\n await fetch(\"https://wolf--14aa1afa10fc11f0bb2a569c3dd06744.web.val.run\");\n } catch (error) {\n console.error(\"Failed to trigger next run:\", error);\n }\n })();\n\n return new Response(`Too soon. Next refresh in ${timeToWait}ms`);\n }\n}",14,[184],{"_156":296,"_102":442,"_107":443,"_159":139,"_303":444},156,["D",1743733855373],[445],{"_105":446,"_159":139,"_156":296,"_98":184,"_166":447,"_164":177,"_102":448,"_158":-5,"_107":443,"_160":442,"_168":300,"_162":25,"_167":25,"_101":449},"d5d53d90-10fc-11f0-8951-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const LAST_RUN_KEY = \"refresh_last_run\";\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(LAST_RUN_KEY);\n const now = Date.now();\n\n // Only perform the refresh if enough time has passed\n if (!lastRun || now - lastRun >= 5000) {\n // Execute the refresh function\n await refresh();\n\n // Update the last run timestamp\n await blob.setJSON(LAST_RUN_KEY, now);\n\n // Always schedule the next run\n // We do this in the background so the response can return immediately\n (async () => {\n // Wait 5 seconds\n await new Promise(resolve => setTimeout(resolve, 5000));\n // Trigger the next run\n try {\n await fetch(\"https://wolf--14aa1afa10fc11f0bb2a569c3dd06744.web.val.run\");\n } catch (error) {\n console.error(\"Failed to trigger next run:\", error);\n }\n })();\n\n return new Response(\"refreshed and scheduled next run\");\n } else {\n // Not enough time has passed, but still schedule the next run\n const timeToWait = 5000 - (now - lastRun);\n\n // Schedule the next run after waiting for the remaining time\n (async () => {\n await new Promise(resolve => setTimeout(resolve, timeToWait));\n try {\n await fetch(\"https://wolf--14aa1afa10fc11f0bb2a569c3dd06744.web.val.run\");\n } catch (error) {\n console.error(\"Failed to trigger next run:\", error);\n }\n })();\n\n return new Response(`Too soon. Next refresh in ${timeToWait}ms`);\n }\n}",13,[184],{"_156":296,"_102":451,"_107":452,"_159":139,"_303":453},155,["D",1743733823728],[454],{"_105":455,"_159":139,"_156":296,"_98":184,"_166":456,"_164":177,"_102":457,"_158":-5,"_107":452,"_160":451,"_168":300,"_162":25,"_167":25,"_101":458},"c2f8b2ce-10fc-11f0-958d-569c3dd06744","import refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n // Execute the refresh function\n await refresh();\n\n // Trigger the next run in the background\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\")\n .catch(err => console.error(\"Error triggering next run:\", err));\n\n return new Response(\"refreshed and scheduled next run\");\n}",12,[184],{"_156":296,"_102":460,"_107":461,"_159":139,"_303":462},154,["D",1743733821746],[463],{"_105":464,"_159":139,"_156":296,"_98":184,"_166":465,"_164":177,"_102":466,"_158":-5,"_107":461,"_160":460,"_168":300,"_162":25,"_167":25,"_101":467},"c1ca32ba-10fc-11f0-ba73-569c3dd06744","import refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n // Execute the refresh function\n await refresh();\n\n // Wait 5 seconds\n await new Promise(resolve => {\n setTimeout(resolve, 5000);\n });\n\n // Trigger the next run in the background\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\")\n .catch(err => console.error(\"Error triggering next run:\", err));\n\n return new Response(\"refreshed and scheduled next run\");\n}",11,[184],{"_156":296,"_102":469,"_107":470,"_159":139,"_303":471},153,["D",1743733799348],[472],{"_105":473,"_159":139,"_156":296,"_98":184,"_166":465,"_164":177,"_102":474,"_158":-5,"_107":470,"_160":469,"_168":300,"_162":25,"_167":25,"_101":475},"b472b132-10fc-11f0-9f87-569c3dd06744",10,[184],{"_156":296,"_102":477,"_107":478,"_159":139,"_303":479},152,["D",1743733785792],[480],{"_105":481,"_159":139,"_156":296,"_98":184,"_166":482,"_164":177,"_102":483,"_158":-5,"_107":478,"_160":477,"_168":300,"_162":25,"_167":25,"_101":484},"ac5c35fe-10fc-11f0-a6d0-569c3dd06744","import refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n // Execute the refresh function\n await refresh();\n\n // Wait 5 seconds\n await new Promise(resolve => {\n setTimeout(resolve, 5000);\n });\n\n // Trigger the next run in the background\n fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\")\n .catch(err => console.error(\"Error triggering next run:\", err));\n\n return new Response(\"refreshed and scheduled next run\");\n}",9,[184],{"_156":296,"_102":486,"_107":487,"_159":139,"_303":488},151,["D",1743733748968],[489],{"_105":490,"_159":139,"_156":296,"_98":184,"_166":491,"_164":177,"_102":492,"_158":-5,"_107":487,"_160":486,"_168":300,"_162":25,"_167":25,"_101":493},"966aa622-10fc-11f0-8dcc-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const LAST_RUN_KEY = \"refresh_last_run\";\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(LAST_RUN_KEY);\n const now = Date.now();\n\n // Only perform the refresh if enough time has passed\n if (!lastRun || now - lastRun >= 5000) {\n // Execute the refresh function\n await refresh();\n\n // Update the last run timestamp\n await blob.setJSON(LAST_RUN_KEY, now);\n\n // Always schedule the next run\n // We do this in the background so the response can return immediately\n (async () => {\n // Wait 5 seconds\n await new Promise(resolve => setTimeout(resolve, 5000));\n // Trigger the next run\n try {\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n } catch (error) {\n console.error(\"Failed to trigger next run:\", error);\n }\n })();\n\n return new Response(\"refreshed and scheduled next run\");\n } else {\n // Not enough time has passed, but still schedule the next run\n const timeToWait = 5000 - (now - lastRun);\n\n // Schedule the next run after waiting for the remaining time\n await (async () => {\n await new Promise(resolve => setTimeout(resolve, timeToWait));\n try {\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n } catch (error) {\n console.error(\"Failed to trigger next run:\", error);\n }\n })();\n\n return new Response(`Too soon. Next refresh in ${timeToWait}ms`);\n }\n}",8,[184],{"_156":296,"_102":495,"_107":496,"_159":139,"_303":497},150,["D",1743733725027],[498],{"_105":499,"_159":139,"_156":296,"_98":184,"_166":500,"_164":177,"_102":501,"_158":-5,"_107":496,"_160":495,"_168":300,"_162":25,"_167":25,"_101":502},"882433da-10fc-11f0-a8fc-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const LAST_RUN_KEY = \"refresh_last_run\";\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(LAST_RUN_KEY);\n const now = Date.now();\n\n // Only perform the refresh if enough time has passed\n if (!lastRun || now - lastRun >= 5000) {\n // Execute the refresh function\n await refresh();\n\n // Update the last run timestamp\n await blob.setJSON(LAST_RUN_KEY, now);\n\n // Always schedule the next run\n // We do this in the background so the response can return immediately\n (async () => {\n // Wait 5 seconds\n await new Promise(resolve => setTimeout(resolve, 5000));\n // Trigger the next run\n try {\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n } catch (error) {\n console.error(\"Failed to trigger next run:\", error);\n }\n })();\n\n return new Response(\"refreshed and scheduled next run\");\n } else {\n // Not enough time has passed, but still schedule the next run\n const timeToWait = 5000 - (now - lastRun);\n\n // Schedule the next run after waiting for the remaining time\n (async () => {\n await new Promise(resolve => setTimeout(resolve, timeToWait));\n try {\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n } catch (error) {\n console.error(\"Failed to trigger next run:\", error);\n }\n })();\n\n return new Response(`Too soon. Next refresh in ${timeToWait}ms`);\n }\n}",7,[184],{"_156":296,"_102":504,"_107":505,"_159":139,"_303":506},149,["D",1743733677068],[507],{"_105":508,"_159":139,"_156":296,"_98":184,"_166":509,"_164":177,"_102":510,"_158":-5,"_107":505,"_160":504,"_168":300,"_162":25,"_167":25,"_101":511},"6b8e2dfc-10fc-11f0-aa0b-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const LAST_RUN_KEY = \"refresh_last_run\";\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(LAST_RUN_KEY);\n const now = Date.now();\n\n // Check if this is a fresh run (not triggered by our self-fetch)\n if (!lastRun || now - lastRun > 3000) { // 10 seconds buffer to avoid parallel runs\n // Execute the refresh function\n await refresh();\n\n // Update the last run timestamp\n await blob.setJSON(LAST_RUN_KEY, now);\n\n // Wait 5 seconds\n await new Promise(resolve => {\n setTimeout(resolve, 3000);\n });\n\n // Trigger the next run by fetching ourselves\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n\n return new Response(\"refreshed and scheduled next run\");\n } else {\n // This is a self-triggered run, so just return\n return new Response(\"already running\");\n }\n}",6,[184],{"_156":296,"_102":513,"_107":514,"_159":139,"_303":515},148,["D",1743733644888],[516],{"_105":517,"_159":139,"_156":296,"_98":184,"_166":518,"_164":177,"_102":261,"_158":-5,"_107":514,"_160":513,"_168":300,"_162":25,"_167":25,"_101":519},"585fd546-10fc-11f0-8d6f-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const LAST_RUN_KEY = \"refresh_last_run\";\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(LAST_RUN_KEY);\n const now = Date.now();\n\n // Check if this is a fresh run (not triggered by our self-fetch)\n if (!lastRun || now - lastRun > 10000) { // 10 seconds buffer to avoid parallel runs\n // Execute the refresh function\n await refresh();\n\n // Update the last run timestamp\n await blob.setJSON(LAST_RUN_KEY, now);\n\n // Wait 5 seconds\n await new Promise(resolve => {\n setTimeout(resolve, 5000);\n });\n\n // Trigger the next run by fetching ourselves\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n\n return new Response(\"refreshed and scheduled next run\");\n } else {\n // This is a self-triggered run, so just return\n return new Response(\"already running\");\n }\n}",[184],{"_156":296,"_102":521,"_107":522,"_159":139,"_303":523},147,["D",1743733619935],[524],{"_105":525,"_159":139,"_156":296,"_98":184,"_166":518,"_164":177,"_102":227,"_158":-5,"_107":522,"_160":521,"_168":300,"_162":25,"_167":25,"_101":526},"49808cf0-10fc-11f0-ba73-569c3dd06744",[184],{"_156":296,"_102":528,"_107":529,"_159":139,"_303":530},146,["D",1743733574839],[531],{"_105":532,"_159":139,"_156":296,"_98":184,"_166":533,"_164":177,"_102":176,"_158":-5,"_107":529,"_160":528,"_168":300,"_162":25,"_167":25,"_101":534},"2e9f2bc6-10fc-11f0-ba73-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const THROTTLE_KEY = \"refresh_last_run\";\n const THROTTLE_SECONDS = 5;\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(THROTTLE_KEY);\n const now = Date.now();\n\n // Check if we should run (if never run before or enough time has passed)\n if (!lastRun || now - lastRun > THROTTLE_SECONDS * 5000) {\n // Execute the main functionality\n await refresh();\n await new Promise(resolve => setTimeout(resolve, 5000));\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n\n // Update the last run timestamp\n await blob.setJSON(THROTTLE_KEY, now);\n return new Response(\"fetching...\");\n } else {\n // Not enough time has passed since last run\n const secondsSinceLastRun = Math.floor((now - lastRun) / 1000);\n const secondsRemaining = THROTTLE_SECONDS - secondsSinceLastRun;\n return new Response(`Throttled. Try again in ${secondsRemaining} seconds.`);\n }\n}",[184],{"_156":296,"_102":536,"_107":537,"_159":139,"_303":538},145,["D",1743733547223],[539],{"_105":540,"_159":139,"_156":296,"_98":184,"_166":541,"_164":177,"_102":271,"_158":-5,"_107":537,"_160":536,"_168":300,"_162":25,"_167":25,"_101":542},"1e2a7d18-10fc-11f0-8d6f-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const THROTTLE_KEY = \"refresh_last_run\";\n const THROTTLE_SECONDS = 5;\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(THROTTLE_KEY);\n const now = Date.now();\n\n // Check if we should run (if never run before or enough time has passed)\n if (!lastRun || now - lastRun > THROTTLE_SECONDS * 5000) {\n // Execute the main functionality\n await refresh();\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n\n // Update the last run timestamp\n await blob.setJSON(THROTTLE_KEY, now);\n return new Response(\"fetching...\");\n } else {\n // Not enough time has passed since last run\n const secondsSinceLastRun = Math.floor((now - lastRun) / 1000);\n const secondsRemaining = THROTTLE_SECONDS - secondsSinceLastRun;\n return new Response(`Throttled. Try again in ${secondsRemaining} seconds.`);\n }\n}",[184],{"_156":296,"_102":544,"_107":545,"_159":139,"_303":546},144,["D",1743733536246],[547],{"_105":548,"_159":139,"_156":296,"_98":184,"_166":549,"_164":177,"_102":161,"_158":-5,"_107":545,"_160":544,"_168":300,"_162":25,"_167":25,"_101":550},"179e6e82-10fc-11f0-be56-569c3dd06744","import { blob } from \"https://esm.town/v/std/blob\";\nimport refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n const THROTTLE_KEY = \"refresh_last_run\";\n const THROTTLE_SECONDS = 5;\n\n // Get the last run timestamp\n const lastRun = await blob.getJSON(THROTTLE_KEY);\n const now = Date.now();\n\n // Check if we should run (if never run before or enough time has passed)\n if (!lastRun || now - lastRun > THROTTLE_SECONDS * 1000) {\n // Execute the main functionality\n await refresh();\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n\n // Update the last run timestamp\n await blob.setJSON(THROTTLE_KEY, now);\n return new Response(\"fetching...\");\n } else {\n // Not enough time has passed since last run\n const secondsSinceLastRun = Math.floor((now - lastRun) / 1000);\n const secondsRemaining = THROTTLE_SECONDS - secondsSinceLastRun;\n return new Response(`Throttled. Try again in ${secondsRemaining} seconds.`);\n }\n}",[184],{"_156":296,"_102":552,"_107":553,"_159":139,"_303":554},143,["D",1743733531277],[555],{"_105":556,"_159":139,"_156":296,"_98":184,"_166":557,"_164":177,"_102":29,"_158":-5,"_107":553,"_160":552,"_168":300,"_162":25,"_167":25,"_101":558},"14aa1a5a-10fc-11f0-bb2a-569c3dd06744","export default async function (req: Request): Promise {\n return Response.json({ ok: true })\n}",[184],{"_156":560,"_102":561,"_107":562,"_159":139,"_303":563},"7e373ba2-10fb-11f0-a8f8-569c3dd06744",142,["D",1743733521525],[564],{"_105":565,"_159":139,"_156":560,"_98":566,"_166":549,"_164":177,"_102":457,"_158":-5,"_107":562,"_160":561,"_168":-5,"_162":119,"_167":119,"_101":567},"0ed8443a-10fc-11f0-bb64-569c3dd06744","frefresh.ts",[566],{"_156":560,"_102":569,"_107":570,"_159":139,"_303":571},141,["D",1743733511911],[572],{"_105":573,"_159":139,"_156":560,"_98":566,"_166":549,"_164":177,"_102":466,"_158":-5,"_107":570,"_160":569,"_168":-5,"_162":25,"_167":25,"_101":574},"091d1534-10fc-11f0-b000-569c3dd06744",[566],{"_156":560,"_102":576,"_107":577,"_159":139,"_303":578},140,["D",1743733508454],[579],{"_105":580,"_159":139,"_156":560,"_98":184,"_166":549,"_164":177,"_102":474,"_158":-5,"_107":577,"_160":576,"_168":-5,"_162":25,"_167":25,"_101":581},"070db096-10fc-11f0-ba73-569c3dd06744",[184],{"_156":560,"_102":583,"_107":584,"_159":139,"_303":585},139,["D",1743733448664],[586],{"_105":587,"_159":139,"_156":560,"_98":184,"_166":588,"_164":177,"_102":483,"_158":-5,"_107":584,"_160":583,"_168":-5,"_162":25,"_167":25,"_101":589},"e36a6850-10fb-11f0-af43-569c3dd06744","import refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n await refresh();\n await new Promise(resolve => {\n setTimeout(resolve, 5000);\n });\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n return new Response(\"fetching...\");\n}",[184],{"_156":560,"_102":591,"_107":592,"_159":139,"_303":593},138,["D",1743733409017],[594],{"_105":595,"_159":139,"_156":560,"_98":184,"_166":596,"_164":177,"_102":492,"_158":-5,"_107":592,"_160":591,"_168":-5,"_162":25,"_167":25,"_101":597},"cbc8e21c-10fb-11f0-af3e-569c3dd06744","import refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n await refresh();\n await new Promise(resolve => {\n setTimeout(resolve, 1000);\n });\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n return new Response(\"fetching...\")\n}",[184],{"_156":560,"_102":599,"_107":600,"_159":139,"_303":601},137,["D",1743733405107],[602],{"_105":603,"_159":139,"_156":560,"_98":184,"_166":604,"_164":177,"_102":501,"_158":-5,"_107":600,"_160":599,"_168":-5,"_162":25,"_167":25,"_101":605},"c9746d6a-10fb-11f0-8edf-569c3dd06744","import refresh from \"./backend/refresh.ts\";\n\nexport default async function(req: Request): Promise {\n await refresh();\n return new Promise(resolve => {\n setTimeout(resolve, 1000);\n });\n await fetch(\"https://wolf--7e373ba210fb11f0a8f8569c3dd06744.web.val.run\");\n return new Response(\"fetching...\")\n}",[184],"page","hasNext","routes/_app","actionData","errors"]

History