[{"_1":2,"_180":-5,"_181":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","a31a1550ad486cf340b818a53bc6ddc8c7db0295","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_155":156,"_177":178,"_179":-5},"handle","wolf","name","cwruBuses","path","backend/refresh.ts","project",{"_101":102,"_95":103,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":114,"_115":116,"_117":-5,"_118":119,"_120":32,"_14":121,"_122":123,"_124":123,"_125":126,"_127":126,"_128":126,"_129":123,"_130":123,"_23":131,"_134":135,"_137":138,"_154":20},"id","94447f92-10f4-11f0-9a58-569c3dd06744","CWRUBuses","createdAt",["D",1743730309398],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","4555dd0e-707e-4444-acd3-049d206eb1db","pinnedFileId","1b081b7c-0bae-47aa-9c11-4fe47cd3a148","pinPreview",true,"pinMigrated","screenshotVersion",165,"likeCount","bced381e-9ab2-4b55-929d-e7c5064f7f38","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_132":133},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJvVXpPVUZRTjZGTGd2Q2t4c0RRdFpNZWJ5UCJ9","org",{"_93":94,"_136":133,"_12":112},"avatar","branch",{"_139":140,"_95":43,"_101":141,"_142":102,"_143":144,"_145":146,"_147":109,"_148":149,"_150":151,"_152":103,"_153":94},"version",168,"9446b4f6-10f4-11f0-9a58-569c3dd06744","projectId","forkedBranchId","961078ea-f528-11ef-aa68-569c3dd06744","forkedBranchVersion",38,"forkedProjectPrivacy","forkedProjectId","96102714-f528-11ef-aa68-569c3dd06744","forkedProjectOrgId","c606f87f-4d7e-48c8-9c39-ef5ab94aec49","projectName","userHandle","isOwned","file",{"_101":157,"_95":158,"_159":160,"_161":162,"_163":141,"_164":165,"_166":116,"_104":167,"_139":168,"_169":170,"_171":172,"_173":20,"_174":-5,"_97":175},"94278106-10fb-11f0-a54f-569c3dd06744","refresh.ts","fileId","6b6dbb8c-10fa-11f0-bbbe-569c3dd06744","parentId","f30bfb91-ea16-4b74-8a49-80696ee564be","branchId","branchVersion",132,"latest",["D",1743733315686],3,"fileType","script","content","import {\n getBusTracker,\n saveBreakHistory,\n saveBreaks,\n saveBusTracker,\n saveDetailedBreaks,\n savePositions,\n} from \"./storage.ts\";\n\n// Bus tracking config\nconst POLL_INTERVAL = 15 * 1000;\nconst POSITION_TOLERANCE = 0.0001;\nconst BUS_API_URL =\n \"https://cwruuh.transloc.com/Services/JSONPRelay.svc/GetMapVehiclePoints?method=jQuery1111026019195338200984_1742691992392&ApiKey=8882812681&isPublicMap=true&_=1742691993260\";\nconst STALE_THRESHOLD = 60 * 1000; // 60 seconds\n\nconst DEPOT_BOUNDS = {\n minLat: 41.5088,\n maxLat: 41.5107,\n minLng: -81.619,\n maxLng: -81.6154,\n};\n\nconst GAS_STATION_BOUNDS = {\n minLat: Math.min(41.5131, 41.5126),\n maxLat: Math.max(41.5131, 41.5126),\n minLng: Math.min(-81.6003, -81.5991),\n maxLng: Math.max(-81.6003, -81.5991),\n};\n\nconst ROUTE_NAMES = {\n 9: \"South Loop\",\n 1: \"BlueLink\",\n 33: \"NightLink\",\n 41: \"UCRC\",\n 14: \"KSL Express\",\n 34: \"HEC After Hours\",\n 6: \"Commuter PM\",\n 7: \"Commuter AM\",\n 19: \"A\",\n 20: \"B\",\n 21: \"C\",\n 22: \"Retail\",\n 24: \"West Campus\",\n 29: \"Charter\",\n 30: \"Out of Service\",\n 10: \"Greenlink\",\n 11: \"HEC Flyer\",\n 12: \"HEC Main\",\n 13: \"Heights AM\",\n 15: \"MPAC Express\",\n 18: \"Nursing 1\",\n 17: \"Nursing 2\",\n 38: \"Woodhill\",\n 40: \"Winter\",\n 42: \"Asiatown\",\n};\n\nfunction isInDepot(lat: number, lng: number) {\n return (\n lat >= DEPOT_BOUNDS.minLat &&\n lat <= DEPOT_BOUNDS.maxLat &&\n lng >= DEPOT_BOUNDS.minLng &&\n lng <= DEPOT_BOUNDS.maxLng\n );\n}\n\nfunction isInGasStation(lat: number, lng: number) {\n return (\n lat >= GAS_STATION_BOUNDS.minLat &&\n lat <= GAS_STATION_BOUNDS.maxLat &&\n lng >= GAS_STATION_BOUNDS.minLng &&\n lng <= GAS_STATION_BOUNDS.maxLng\n );\n}\n\nfunction isSamePosition(pos1: any, pos2: any) {\n return (\n Math.abs(pos1.Latitude - pos2.Latitude) < POSITION_TOLERANCE &&\n Math.abs(pos1.Longitude - pos2.Longitude) < POSITION_TOLERANCE\n );\n}\n\nasync function fetchBusData() {\n const res = await fetch(BUS_API_URL, {\n headers: {\n \"accept\":\n \"text/javascript, application/javascript, application/ecmascript, application/x-ecmascript, */*; q=0.01\",\n \"x-requested-with\": \"XMLHttpRequest\",\n \"referer\":\n \"https://cwruuh.transloc.com/iframe.aspx?showTwitter=false&showRouteMenu=false&showMainMenu=false\",\n },\n });\n\n const text = await res.text();\n const match = text.match(/^[^(]+\\((.*)\\);?$/);\n if (!match) throw new Error(\"Invalid JSONP response\");\n\n return JSON.parse(match[1]);\n}\n\n// Main cron function that runs every 15 seconds\nasync function monitorBuses() {\n try {\n // Get the current bus tracker state from blob storage\n let busTracker = await getBusTracker();\n\n // Fetch new data from the API\n const vehicles = await fetchBusData();\n const now = Date.now();\n\n // Debug logging\n console.log(`Fetched ${vehicles.length} buses from API`);\n\n // Reduce the break threshold to detect breaks more quickly (2 minutes instead of 3)\n const ADJUSTED_BREAK_THRESHOLD = 120; // 2 minutes in seconds\n\n vehicles.forEach((bus) => {\n const id = bus.VehicleID;\n const prev = busTracker[id];\n\n const isSame = prev && isSamePosition(prev.position, bus);\n const inDepot = isInDepot(bus.Latitude, bus.Longitude);\n const inGasStation = isInGasStation(bus.Latitude, bus.Longitude);\n const inExclusionZone = inDepot || inGasStation;\n\n if (!prev) {\n busTracker[id] = {\n position: { Latitude: bus.Latitude, Longitude: bus.Longitude },\n stationaryFor: 0,\n totalBreakTime: 0,\n onBreak: false,\n name: bus.Name,\n routeId: bus.RouteID,\n lastSeen: now,\n currentBreakStart: null,\n breaks: [],\n };\n return;\n }\n\n if (isSame) {\n // Increase the stationary time\n busTracker[id].stationaryFor += POLL_INTERVAL / 1000;\n\n // If a bus is stationary for a while, it might be on break\n if (\n !prev.onBreak &&\n busTracker[id].stationaryFor >= ADJUSTED_BREAK_THRESHOLD &&\n !inExclusionZone\n ) {\n busTracker[id].onBreak = true;\n busTracker[id].currentBreakStart = now -\n (busTracker[id].stationaryFor * 1000);\n console.log(\n `Bus ${bus.Name} (${id}) started break at ${\n new Date(busTracker[id].currentBreakStart).toISOString()\n }`,\n );\n }\n } else {\n // Bus has moved, if it was on break, record the break\n if (prev.onBreak) {\n const endTime = now;\n const duration = prev.stationaryFor;\n\n if (\n !isInDepot(prev.position.Latitude, prev.position.Longitude) &&\n !isInGasStation(prev.position.Latitude, prev.position.Longitude)\n ) {\n prev.totalBreakTime += duration;\n\n prev.breaks.push({\n startTime: prev.currentBreakStart,\n endTime,\n duration: Math.floor(duration),\n });\n\n console.log(\n `Bus ${bus.Name} (${id}) ended break, duration: ${\n Math.floor(duration)\n } seconds`,\n );\n }\n\n prev.onBreak = false;\n prev.currentBreakStart = null;\n }\n\n prev.position = { Latitude: bus.Latitude, Longitude: bus.Longitude };\n prev.stationaryFor = 0;\n }\n\n prev.lastSeen = now;\n prev.name = bus.Name;\n prev.routeId = bus.RouteID;\n });\n\n // Save the updated bus tracker state\n await saveBusTracker(busTracker);\n\n // Generate and save derived data for frontend\n\n // 1. Breaks - buses currently on break\n const onBreak = Object.entries(busTracker)\n .filter(([_, data]) =>\n data.onBreak &&\n data.lastSeen && (now - data.lastSeen) <= STALE_THRESHOLD\n )\n .map(([id, data]) => ({\n vehicleId: id,\n name: data.name,\n routeId: data.routeId,\n routeName: ROUTE_NAMES[data.routeId] || `Route ${data.routeId}`,\n lat: data.position.Latitude,\n lng: data.position.Longitude,\n currentBreak: Math.floor(data.stationaryFor),\n totalBreak: Math.floor(data.totalBreakTime + data.stationaryFor),\n }));\n\n await saveBreaks(onBreak);\n\n // 2. Positions - all buses and their current positions\n const positions = Object.entries(busTracker)\n .filter(([_, data]) =>\n data.lastSeen && (now - data.lastSeen) <= STALE_THRESHOLD\n )\n .map(([id, data]) => ({\n vehicleId: id,\n name: data.name,\n routeId: data.routeId,\n routeName: ROUTE_NAMES[data.routeId] || `Route ${data.routeId}`,\n lat: data.position.Latitude,\n lng: data.position.Longitude,\n onBreak: data.onBreak,\n }));\n\n await savePositions(positions);\n\n // 3. Break history\n const history = Object.entries(busTracker).map(([id, data]) => ({\n vehicleId: id,\n name: data.name,\n routeId: data.routeId,\n routeName: ROUTE_NAMES[data.routeId] || `Route ${data.routeId}`,\n breaks: data.breaks.map((b) => ({\n startTime: new Date(b.startTime).toISOString(),\n endTime: new Date(b.endTime).toISOString(),\n duration: b.duration,\n })),\n }));\n\n await saveBreakHistory(history);\n\n // 4. Detailed breaks\n const TWO_HOURS = 2 * 60 * 60 * 1000;\n const FOUR_HOURS = 4 * 60 * 60 * 1000;\n\n const summary = Object.entries(busTracker).map(([id, data]) => {\n // Calculate breaks in the last 2 and 4 hours\n let timeLast2h = 0;\n let timeLast4h = 0;\n\n // Add completed breaks within the time window\n if (data.breaks && data.breaks.length > 0) {\n // Filter breaks from the last 2 and 4 hours\n const breaksLast2h = data.breaks.filter((b) =>\n b.endTime && (now - b.endTime) <= TWO_HOURS\n );\n const breaksLast4h = data.breaks.filter((b) =>\n b.endTime && (now - b.endTime) <= FOUR_HOURS\n );\n\n // Sum up break durations\n timeLast2h = breaksLast2h.reduce((sum, b) => sum + b.duration, 0);\n timeLast4h = breaksLast4h.reduce((sum, b) => sum + b.duration, 0);\n\n console.log(\n `Bus ${data.name} (${id}) has ${breaksLast2h.length} breaks in last 2h, ${breaksLast4h.length} breaks in last 4h`,\n );\n }\n\n // If the bus is currently on break, add its live break time\n if (data.onBreak && data.currentBreakStart) {\n const currentBreakDuration = now - data.currentBreakStart;\n const elapsed = Math.floor(currentBreakDuration / 1000);\n\n console.log(\n `Bus ${data.name} (${id}) currently on break for ${elapsed} seconds`,\n );\n\n if (currentBreakDuration <= TWO_HOURS) {\n timeLast2h += elapsed;\n }\n if (currentBreakDuration <= FOUR_HOURS) {\n timeLast4h += elapsed;\n }\n }\n\n // Log stationary time for debugging\n console.log(\n `Bus ${data.name} (${id}) stationary for ${data.stationaryFor} seconds, onBreak: ${data.onBreak}`,\n );\n\n return {\n vehicleId: id,\n name: data.name,\n routeName: ROUTE_NAMES[data.routeId] || `Route ${data.routeId}`,\n routeId: data.routeId,\n onBreak: data.onBreak,\n stationaryFor: Math.floor(data.stationaryFor),\n breakTime2h: timeLast2h,\n breakTime4h: timeLast4h,\n };\n });\n\n await saveDetailedBreaks(summary);\n\n console.log(`Bus data refreshed at ${new Date().toISOString()}`);\n return { success: true, timestamp: now };\n } catch (err) {\n console.error(\"Error during monitoring:\", err);\n return { success: false, error: err.message };\n }\n}\n\n// This is the main export that will be called by the Val Town cron system\nexport default monitorBuses;","deleted","label",[176,158],"backend","permalink","https://www.val.town/x/wolf/cwruBuses/code/backend/refresh.ts","extension","actionData","errors"]