NYC Subway Times

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_273":274,"_275":276},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"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":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":63,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",94,"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","feed-fetcher.ts","latestPath","fileId","e0f56ed4-77b7-11f1-be6a-1607ee4eb77e","name","fileType","interval","content","import { fetch } from \"https://esm.town/v/std/fetch\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport protobuf from \"npm:protobufjs@8.0.0\";\nimport { FeedMessage } from \"./types.ts\";\nimport { STATIONS } from \"./stops.ts\";\n\nconst MTA_FEED_BASE = \"https://api-endpoint.mta.info/Dataservice/mtagtfsfeeds/nyct%2F\";\n\n// Number of consecutive failed runs (15 min apart) before a feed is\n// considered a sustained failure worth emailing about, rather than a\n// one-off blip in an otherwise-flaky upstream API.\nconst FAILURE_STREAK_THRESHOLD = 3;\n\nexport const FEED_IDS = [...new Set(Object.values(STATIONS).flatMap((s) => s.feeds))];\n\n// Parsed once per cold start, reused across all fetches.\nconst feedTypePromise: Promise = (async () => {\n const gtfsProto = await readFile(\"/gtfs-realtime.proto\");\n const parsed = protobuf.parse(gtfsProto);\n return parsed.root.lookupType(\"transit_realtime.FeedMessage\");\n})();\n\ntype FeedResult =\n | { feedId: string; status: \"ok\"; durationMs: number }\n | { feedId: string; status: \"error\"; durationMs: number; error: string };\n\ntype FeedErrorResult = Extract;\n\nasync function fetchAndStoreFeed(feedId: string, feedType: protobuf.Type): Promise {\n const start = Date.now();\n try {\n const res = await fetch(`${MTA_FEED_BASE}${feedId}`);\n if (!res.ok) {\n throw new Error(`HTTP ${res.status} ${res.statusText}`);\n }\n const bytes = await res.bytes();\n const feed = FeedMessage.parse(feedType.decode(bytes).toJSON());\n const fetchedAt = new Date().toISOString();\n // Leave any previously stored blob untouched on failure — only a\n // successful parse ever overwrites it, so stale-but-good data survives\n // a flaky MTA response instead of being replaced with nothing.\n await blob.setJSON(`feed:${feedId}`, { feed, fetchedAt });\n return { feedId, status: \"ok\", durationMs: Date.now() - start };\n } catch (err) {\n return {\n feedId,\n status: \"error\",\n durationMs: Date.now() - start,\n error: err instanceof Error ? err.message : String(err),\n };\n }\n}\n\ntype FailStreaks = Record;\n\n/**\n * Updates each feed's consecutive-failure count and returns which feeds\n * just crossed into (or recovered from) a sustained failure, so the caller\n * can decide whether to alert. Crossing is re-checked every\n * FAILURE_STREAK_THRESHOLD failures (not just the first) so a prolonged\n * outage still produces periodic reminders instead of a single email.\n */\nfunction updateFailStreaks(\n streaks: FailStreaks,\n results: FeedResult[],\n): { streaks: FailStreaks; newlyFailing: FeedResult[]; recovered: string[] } {\n const nextStreaks: FailStreaks = { ...streaks };\n const newlyFailing: FeedResult[] = [];\n const recovered: string[] = [];\n\n for (const result of results) {\n const priorStreak = streaks[result.feedId] ?? 0;\n if (result.status === \"error\") {\n const streak = priorStreak + 1;\n nextStreaks[result.feedId] = streak;\n if (streak >= FAILURE_STREAK_THRESHOLD && streak % FAILURE_STREAK_THRESHOLD === 0) {\n newlyFailing.push(result);\n }\n } else {\n nextStreaks[result.feedId] = 0;\n if (priorStreak >= FAILURE_STREAK_THRESHOLD) {\n recovered.push(result.feedId);\n }\n }\n }\n\n return { streaks: nextStreaks, newlyFailing, recovered };\n}\n\nexport default async function (interval: Interval) {\n const runStart = new Date().toISOString();\n const feedType = await feedTypePromise;\n\n const results = await Promise.all(\n FEED_IDS.map((feedId) => fetchAndStoreFeed(feedId, feedType)),\n );\n\n for (const result of results) {\n if (result.status === \"ok\") {\n console.log(JSON.stringify({\n event: \"feed_fetch_ok\",\n feedId: result.feedId,\n durationMs: result.durationMs,\n }));\n } else {\n console.error(JSON.stringify({\n event: \"feed_fetch_error\",\n feedId: result.feedId,\n durationMs: result.durationMs,\n error: result.error,\n }));\n }\n }\n\n const failedFeedIds = results.filter((r) => r.status === \"error\").map((r) => r.feedId);\n const succeededFeedIds = results.filter((r) => r.status === \"ok\").map((r) => r.feedId);\n\n const summary = {\n event: \"feed_fetch_run_summary\",\n runStart,\n runEnd: new Date().toISOString(),\n lastRunAt: interval.lastRunAt?.toISOString() ?? null,\n total: FEED_IDS.length,\n succeeded: succeededFeedIds.length,\n failed: failedFeedIds.length,\n failedFeedIds,\n };\n\n // Log at a level matching the outcome, so a log viewer filtered to\n // \"errors only\" surfaces incomplete runs without needing to parse JSON.\n if (failedFeedIds.length > 0) {\n console.error(JSON.stringify(summary));\n } else {\n console.log(JSON.stringify(summary));\n }\n\n // Also persist the summary as a blob (not just logs) so the last run's\n // health can be inspected directly via blob tools, independent of log\n // retention.\n await blob.setJSON(\"feed:_meta\", summary);\n\n const priorStreaks = (await blob.getJSON(\"feed:_failstreaks\")) as FailStreaks | undefined ?? {};\n const { streaks, newlyFailing, recovered } = updateFailStreaks(priorStreaks, results);\n await blob.setJSON(\"feed:_failstreaks\", streaks);\n\n if (newlyFailing.length > 0) {\n const lines = newlyFailing.map((r) =>\n `- ${r.feedId}: failing for ${streaks[r.feedId]} consecutive runs (~${\n streaks[r.feedId] * 15\n } min). Last error: ${r.error}`\n );\n console.error(JSON.stringify({\n event: \"feed_alert_sent\",\n kind: \"sustained_failure\",\n feedIds: newlyFailing.map((r) => r.feedId),\n }));\n await email({\n subject: `MTA feed fetcher: ${newlyFailing.length} feed(s) failing`,\n text: `The following feeds have been failing for ${FAILURE_STREAK_THRESHOLD}+ consecutive 15-minute runs:\\n\\n${\n lines.join(\"\\n\")\n }\\n\\nCheck feed:_meta and feed:_failstreaks blobs, or the feed-fetcher.ts logs, for details.`,\n });\n }\n\n if (recovered.length > 0) {\n console.log(JSON.stringify({\n event: \"feed_alert_sent\",\n kind: \"recovered\",\n feedIds: recovered,\n }));\n await email({\n subject: `MTA feed fetcher: ${recovered.length} feed(s) recovered`,\n text: `The following feeds are fetching successfully again after a sustained failure:\\n\\n${\n recovered.map((id) => `- ${id}`).join(\"\\n\")\n }`,\n });\n }\n}\n","import { fetch } from \"https://esm.town/v/std/fetch\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport protobuf from \"npm:protobufjs@8.0.0\";\nimport { FeedMessage } from \"./types.ts\";\nimport { STATIONS } from \"./stops.ts\";\n\nconst MTA_FEED_BASE = \"https://api-endpoint.mta.info/Dataservice/mtagtfsfeeds/nyct%2F\";\n\n// Number of consecutive failed runs (15 min apart) before a feed is\n// considered a sustained failure worth emailing about, rather than a\n// one-off blip in an otherwise-flaky upstream API.\nconst FAILURE_STREAK_THRESHOLD = 3;\n\nexport const FEED_IDS = [...new Set(Object.values(STATIONS).flatMap((s) => s.feeds))];\n\n// Parsed once per cold start, reused across all fetches.\nconst feedTypePromise: Promise = (async () => {\n const gtfsProto = await readFile(\"/gtfs-realtime.proto\");\n const parsed = protobuf.parse(gtfsProto);\n return parsed.root.lookupType(\"transit_realtime.FeedMessage\");\n})();\n\ntype FeedResult =\n | { feedId: string; status: \"ok\"; durationMs: number }\n | { feedId: string; status: \"error\"; durationMs: number; error: string };\n\ntype FeedErrorResult = Extract;\n\nasync function fetchAndStoreFeed(feedId: string, feedType: protobuf.Type): Promise {\n const start = Date.now();\n try {\n const res = await fetch(`${MTA_FEED_BASE}${feedId}`);\n if (!res.ok) {\n throw new Error(`HTTP ${res.status} ${res.statusText}`);\n }\n const bytes = await res.bytes();\n const feed = FeedMessage.parse(feedType.decode(bytes).toJSON());\n const fetchedAt = new Date().toISOString();\n // Leave any previously stored blob untouched on failure — only a\n // successful parse ever overwrites it, so stale-but-good data survives\n // a flaky MTA response instead of being replaced with nothing.\n await blob.setJSON(`feed:${feedId}`, { feed, fetchedAt });\n return { feedId, status: \"ok\", durationMs: Date.now() - start };\n } catch (err) {\n return {\n feedId,\n status: \"error\",\n durationMs: Date.now() - start,\n error: err instanceof Error ? err.message : String(err),\n };\n }\n}\n\ntype FailStreaks = Record;\n\n/**\n * Updates each feed's consecutive-failure count and returns which feeds\n * just crossed into (or recovered from) a sustained failure, so the caller\n * can decide whether to alert. Crossing is re-checked every\n * FAILURE_STREAK_THRESHOLD failures (not just the first) so a prolonged\n * outage still produces periodic reminders instead of a single email.\n */\nfunction updateFailStreaks(\n streaks: FailStreaks,\n results: FeedResult[],\n): { streaks: FailStreaks; newlyFailing: FeedErrorResult[]; recovered: string[] } {\n const nextStreaks: FailStreaks = { ...streaks };\n const newlyFailing: FeedErrorResult[] = [];\n const recovered: string[] = [];\n\n for (const result of results) {\n const priorStreak = streaks[result.feedId] ?? 0;\n if (result.status === \"error\") {\n const streak = priorStreak + 1;\n nextStreaks[result.feedId] = streak;\n if (streak >= FAILURE_STREAK_THRESHOLD && streak % FAILURE_STREAK_THRESHOLD === 0) {\n newlyFailing.push(result);\n }\n } else {\n nextStreaks[result.feedId] = 0;\n if (priorStreak >= FAILURE_STREAK_THRESHOLD) {\n recovered.push(result.feedId);\n }\n }\n }\n\n return { streaks: nextStreaks, newlyFailing, recovered };\n}\n\nexport default async function (interval: Interval) {\n const runStart = new Date().toISOString();\n const feedType = await feedTypePromise;\n\n const results = await Promise.all(\n FEED_IDS.map((feedId) => fetchAndStoreFeed(feedId, feedType)),\n );\n\n for (const result of results) {\n if (result.status === \"ok\") {\n console.log(JSON.stringify({\n event: \"feed_fetch_ok\",\n feedId: result.feedId,\n durationMs: result.durationMs,\n }));\n } else {\n console.error(JSON.stringify({\n event: \"feed_fetch_error\",\n feedId: result.feedId,\n durationMs: result.durationMs,\n error: result.error,\n }));\n }\n }\n\n const failedFeedIds = results.filter((r) => r.status === \"error\").map((r) => r.feedId);\n const succeededFeedIds = results.filter((r) => r.status === \"ok\").map((r) => r.feedId);\n\n const summary = {\n event: \"feed_fetch_run_summary\",\n runStart,\n runEnd: new Date().toISOString(),\n lastRunAt: interval.lastRunAt?.toISOString() ?? null,\n total: FEED_IDS.length,\n succeeded: succeededFeedIds.length,\n failed: failedFeedIds.length,\n failedFeedIds,\n };\n\n // Log at a level matching the outcome, so a log viewer filtered to\n // \"errors only\" surfaces incomplete runs without needing to parse JSON.\n if (failedFeedIds.length > 0) {\n console.error(JSON.stringify(summary));\n } else {\n console.log(JSON.stringify(summary));\n }\n\n // Also persist the summary as a blob (not just logs) so the last run's\n // health can be inspected directly via blob tools, independent of log\n // retention.\n await blob.setJSON(\"feed:_meta\", summary);\n\n const priorStreaks = (await blob.getJSON(\"feed:_failstreaks\")) as FailStreaks | undefined ?? {};\n const { streaks, newlyFailing, recovered } = updateFailStreaks(priorStreaks, results);\n await blob.setJSON(\"feed:_failstreaks\", streaks);\n\n if (newlyFailing.length > 0) {\n const lines = newlyFailing.map((r) =>\n `- ${r.feedId}: failing for ${streaks[r.feedId]} consecutive runs (~${\n streaks[r.feedId] * 15\n } min). Last error: ${r.error}`\n );\n console.error(JSON.stringify({\n event: \"feed_alert_sent\",\n kind: \"sustained_failure\",\n feedIds: newlyFailing.map((r) => r.feedId),\n }));\n await email({\n subject: `MTA feed fetcher: ${newlyFailing.length} feed(s) failing`,\n text: `The following feeds have been failing for ${FAILURE_STREAK_THRESHOLD}+ consecutive 15-minute runs:\\n\\n${\n lines.join(\"\\n\")\n }\\n\\nCheck feed:_meta and feed:_failstreaks blobs, or the feed-fetcher.ts logs, for details.`,\n });\n }\n\n if (recovered.length > 0) {\n console.log(JSON.stringify({\n event: \"feed_alert_sent\",\n kind: \"recovered\",\n feedIds: recovered,\n }));\n await email({\n subject: `MTA feed fetcher: ${recovered.length} feed(s) recovered`,\n text: `The following feeds are fetching successfully again after a sustained failure:\\n\\n${\n recovered.map((id) => `- ${id}`).join(\"\\n\")\n }`,\n });\n }\n}\n","createdAt",["D",1783177329050],"branchVersion","branchId","54b45800-12cb-11f1-bbe4-42dde27851f2","id","54b3e6fe-12cb-11f1-bbe4-42dde27851f2","mta-train-times",["D",1772079993386],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Query for the next available trains at a given station","imageUrl","019c9832-2a8e-755d-9ca7-7b048a8a0db2","pinnedFileId","12dc447c-3433-11f1-88d9-42b51c65c3df","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019c9832-2a8e-755d-9ca7-7efeceaebf7a","tursoName","54b3e6fe12cb11f1bbe442dde27851f2","tursoHostname","54b3e6fe12cb11f1bbe442dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789524636084],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",101,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","danelliottpalmer","handle","displayName","Dan Palmer","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/9456439f-dfec-4246-aa22-52d6a763fa00/square512?exp=1789549199&sig=add69814face3e14131d1baf9c9f850d52b29e7f539613753327bda5176387d3","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":268,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":269,"_72":63,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":270,"_84":271,"_86":272,"_88":25},"tree",[227,228,229,230,231,232,233,234,235,236],"files",[227,228,229,230,231,232,233,234,235,236],"counts",{"_217":63,"_218":197,"_219":63,"_220":221,"_222":223},"contents",[131,132,133,134,135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":210,"_32":211,"_30":57,"_144":-5,"_41":42,"_40":212,"_146":59,"_38":213,"_13":214,"_33":182,"_35":215,"_24":25,"_150":-5,"_27":216},{"_43":203,"_32":204,"_30":205,"_144":-5,"_41":42,"_40":206,"_146":25,"_38":207,"_13":165,"_33":166,"_35":208,"_24":25,"_150":-5,"_27":209},{"_43":200,"_32":28,"_30":31,"_144":-5,"_41":42,"_40":14,"_146":25,"_38":201,"_13":148,"_33":34,"_35":37,"_24":25,"_150":-5,"_27":202},{"_43":192,"_32":193,"_30":194,"_144":-5,"_41":42,"_40":195,"_146":59,"_38":196,"_13":197,"_33":166,"_35":198,"_24":25,"_150":-5,"_27":199},{"_43":185,"_32":186,"_30":187,"_144":-5,"_41":42,"_40":188,"_146":59,"_38":189,"_13":148,"_33":20,"_35":190,"_24":25,"_150":-5,"_27":191},{"_43":176,"_32":177,"_30":178,"_144":-5,"_41":42,"_40":179,"_146":25,"_38":180,"_13":181,"_33":182,"_35":183,"_24":25,"_150":-5,"_27":184},{"_43":169,"_32":170,"_30":171,"_144":-5,"_41":42,"_40":172,"_146":59,"_38":173,"_13":165,"_33":20,"_35":174,"_24":25,"_150":-5,"_27":175},{"_43":160,"_32":161,"_30":162,"_144":-5,"_41":42,"_40":163,"_146":25,"_38":164,"_13":165,"_33":166,"_35":167,"_24":25,"_150":-5,"_27":168},{"_43":152,"_32":153,"_30":154,"_144":-5,"_41":42,"_40":155,"_146":25,"_38":156,"_13":157,"_33":20,"_35":158,"_24":25,"_150":-5,"_27":159},{"_43":141,"_32":142,"_30":143,"_144":-5,"_41":42,"_40":145,"_146":59,"_38":147,"_13":148,"_33":20,"_35":149,"_24":25,"_150":-5,"_27":151},"b7e0b75a-5c29-11f1-95d8-ee650bb23af1","utils.ts","dd775ac0-3427-11f1-9a20-42b51c65c3df","parentId",73,"latest",["D",1780146967344],4,"import { loadFeeds } from \"./feed-loader.ts\";\nimport { aggregateFeeds } from \"./feed-aggregator.ts\";\nimport { summariseTrains } from \"./train-summariser.ts\";\nimport { STATIONS } from \"./stops.ts\";\n\nexport function getFeedsForStation(stationId: string): string[] {\n return STATIONS[stationId]?.feeds ?? [];\n}\n\nexport async function getArrivals(stationId: string) {\n const station = STATIONS[stationId];\n if (!station) return null;\n\n const { feeds, feedErrors } = await loadFeeds(station.feeds);\n const { northbound, southbound } = aggregateFeeds(feeds, stationId);\n\n return {\n fetchedAt: new Date().toISOString(),\n stationId,\n stationName: station.name,\n stopIds: { northbound: `${stationId}N`, southbound: `${stationId}S` },\n ...(feedErrors.length > 0 && { feedErrors }),\n northbound: { trains: summariseTrains(northbound) },\n southbound: { trains: summariseTrains(southbound) },\n };\n}\n","label",[142],"8c299dc6-1985-4fb6-946a-425ef529bf77","types.ts","243386f8-33b2-11f1-b731-42b51c65c3df",85,["D",1783088586616],5,"import { z } from \"npm:zod\";\n\nconst NyctTripDescriptor = z.object({\n trainId: z.string().optional(),\n isAssigned: z.boolean().optional(),\n direction: z.enum([\"NORTH\", \"SOUTH\"]).optional(),\n});\n\nconst TripDescriptor = z.object({\n tripId: z.string().optional(),\n startTime: z.string().optional(),\n startDate: z.string().optional(),\n routeId: z.string().optional(),\n \".transit_realtime.nyctTripDescriptor\": NyctTripDescriptor.optional(),\n});\n\nconst StopTimeEvent = z.object({\n time: z.string(),\n delay: z.number().optional(),\n});\n\nconst NyctStopTimeUpdate = z.object({\n scheduledTrack: z.string().optional(),\n actualTrack: z.string().optional(),\n});\n\nconst StopTimeUpdate = z.object({\n stopId: z.string().optional(),\n arrival: StopTimeEvent.optional(),\n departure: StopTimeEvent.optional(),\n /** One of: EMPTY, MANY_SEATS_AVAILABLE, FEW_SEATS_AVAILABLE, STANDING_ROOM_ONLY, CRUSHED_STANDING_ROOM_ONLY, FULL, NOT_ACCEPTING_PASSENGERS, NO_DATA_AVAILABLE */\n departureOccupancyStatus: z.string().optional(),\n \".transit_realtime.nyctStopTimeUpdate\": NyctStopTimeUpdate.optional(),\n});\n\nconst TripUpdate = z.object({\n trip: TripDescriptor,\n stopTimeUpdate: z.array(StopTimeUpdate).optional(),\n});\n\nconst VehiclePosition = z.object({\n trip: TripDescriptor.optional(),\n currentStopSequence: z.number().optional(),\n /** One of: STOPPED_AT, IN_TRANSIT_TO, INCOMING_AT */\n currentStatus: z.enum([\"STOPPED_AT\", \"IN_TRANSIT_TO\", \"INCOMING_AT\"]).optional(),\n timestamp: z.string().optional(),\n stopId: z.string().optional(),\n});\n\nconst FeedEntity = z.object({\n id: z.string(),\n tripUpdate: TripUpdate.optional(),\n vehicle: VehiclePosition.optional(),\n});\n\nexport const FeedMessage = z.object({\n header: z.object({\n gtfsRealtimeVersion: z.string(),\n timestamp: z.string().optional(),\n \".transit_realtime.nyctFeedHeader\": z.any().optional(),\n }),\n entity: z.array(FeedEntity),\n});\n\nexport const ArrivalsRequest = z.object({\n stationId: z.string().min(1),\n});\n\nexport type FeedMessageType = z.infer;\nexport type FeedEntityType = z.infer;\nexport type StopTimeUpdateType = z.infer;\nexport type ArrivalsRequestType = z.infer;\n",[153],"7561aeca-5c38-11f1-91cc-ee650bb23af1","train-summariser.ts","b3721c68-5c29-11f1-a9ad-ee650bb23af1",81,["D",1780153298230],3,"script","import type { RawTrain } from \"./feed-aggregator.ts\";\nimport { DESTINATION_NAMES } from \"./stops.ts\";\n\nfunction parseDestinationCode(trainId: string): string | undefined {\n return trainId.split(\"/\")[1]?.trim();\n}\n\nfunction toTrainSummary(raw: RawTrain, now: number) {\n const trip = raw.entity.tripUpdate!.trip;\n const nyct = trip[\".transit_realtime.nyctTripDescriptor\"];\n const trainId = nyct?.trainId ?? trip.tripId;\n const nyctStop = raw.stop[\".transit_realtime.nyctStopTimeUpdate\"];\n\n const destinationCode = parseDestinationCode(trainId);\n const destination = destinationCode ? (DESTINATION_NAMES[destinationCode] ?? destinationCode) : null;\n\n const arrivalUnix = Number(raw.stop.arrival?.time ?? raw.stop.departure?.time);\n const minutesAway = Math.floor((arrivalUnix * 1000 - now) / 60000);\n\n return {\n trainId,\n route: trip.routeId,\n destination,\n minutesAway,\n timing: {\n arrivalTime: arrivalUnix\n ? new Date(arrivalUnix * 1000).toISOString()\n : null,\n departureTime: raw.stop.departure?.time\n ? new Date(Number(raw.stop.departure.time) * 1000).toISOString()\n : null,\n delaySeconds: raw.stop.arrival?.delay ?? raw.stop.departure?.delay ?? null,\n },\n status: {\n vehicleStatus: raw.vehicleStatus,\n atStation: raw.atStation,\n occupancyStatus: raw.stop.departureOccupancyStatus ?? null,\n },\n track: {\n scheduled: nyctStop?.scheduledTrack ?? null,\n actual: nyctStop?.actualTrack ?? null,\n },\n };\n}\n\nfunction byArrival(a: RawTrain, b: RawTrain): number {\n return (\n Number(a.stop.arrival?.time ?? a.stop.departure?.time) -\n Number(b.stop.arrival?.time ?? b.stop.departure?.time)\n );\n}\n\nfunction isFuture(train: RawTrain): boolean {\n const time = Number(train.stop.arrival?.time ?? train.stop.departure?.time);\n return time * 1000 > Date.now();\n}\n\nexport function summariseTrains(trains: RawTrain[], limit = 10) {\n const now = Date.now();\n return trains.sort(byArrival).filter(isFuture).slice(0, limit).map((t) => toTrainSummary(t, now));\n}\n",[161],"a05cdab4-5c29-11f1-b96a-ee650bb23af1","stops.ts","ceb5a618-3427-11f1-bae7-42b51c65c3df",69,["D",1780146927644],"export type Station = { name: string; feeds: string[] };\n\n// Single source of truth for all 497 active stops. A stop either has a name and feeds, or it doesn't exist.\nexport const STATIONS: Record = {\n \"103\": { name: \"238 St\", feeds: [\"gtfs\"] },\n \"104\": { name: \"231 St\", feeds: [\"gtfs\"] },\n \"106\": { name: \"Marble Hill-225 St\", feeds: [\"gtfs\"] },\n \"107\": { name: \"215 St\", feeds: [\"gtfs\"] },\n \"108\": { name: \"207 St\", feeds: [\"gtfs\"] },\n \"109\": { name: \"Dyckman St\", feeds: [\"gtfs\"] },\n \"110\": { name: \"191 St\", feeds: [\"gtfs\"] },\n \"111\": { name: \"181 St\", feeds: [\"gtfs\"] },\n \"112\": { name: \"168 St-Washington Hts\", feeds: [\"gtfs\"] },\n \"113\": { name: \"157 St\", feeds: [\"gtfs\"] },\n \"114\": { name: \"145 St\", feeds: [\"gtfs\"] },\n \"115\": { name: \"137 St-City College\", feeds: [\"gtfs\"] },\n \"116\": { name: \"125 St\", feeds: [\"gtfs\"] },\n \"117\": { name: \"116 St-Columbia University\", feeds: [\"gtfs\"] },\n \"118\": { name: \"Cathedral Pkwy (110 St)\", feeds: [\"gtfs\"] },\n \"119\": { name: \"103 St\", feeds: [\"gtfs\"] },\n \"120\": { name: \"96 St\", feeds: [\"gtfs\"] },\n \"121\": { name: \"86 St\", feeds: [\"gtfs\"] },\n \"122\": { name: \"79 St\", feeds: [\"gtfs\"] },\n \"123\": { name: \"72 St\", feeds: [\"gtfs\"] },\n \"124\": { name: \"66 St-Lincoln Center\", feeds: [\"gtfs\"] },\n \"125\": { name: \"59 St-Columbus Circle\", feeds: [\"gtfs\"] },\n \"126\": { name: \"50 St\", feeds: [\"gtfs\"] },\n \"127\": { name: \"Times Sq-42 St\", feeds: [\"gtfs\"] },\n \"128\": { name: \"34 St-Penn Station\", feeds: [\"gtfs\"] },\n \"129\": { name: \"28 St\", feeds: [\"gtfs\"] },\n \"130\": { name: \"23 St\", feeds: [\"gtfs\"] },\n \"131\": { name: \"18 St\", feeds: [\"gtfs\"] },\n \"132\": { name: \"14 St\", feeds: [\"gtfs\"] },\n \"133\": { name: \"Christopher St-Stonewall\", feeds: [\"gtfs\"] },\n \"134\": { name: \"Houston St\", feeds: [\"gtfs\"] },\n \"135\": { name: \"Canal St\", feeds: [\"gtfs\"] },\n \"136\": { name: \"Franklin St\", feeds: [\"gtfs\"] },\n \"137\": { name: \"Chambers St\", feeds: [\"gtfs\"] },\n \"138\": { name: \"WTC Cortlandt\", feeds: [\"gtfs\"] },\n \"139\": { name: \"Rector St\", feeds: [\"gtfs\"] },\n \"142\": { name: \"South Ferry\", feeds: [\"gtfs\"] },\n \"201\": { name: \"Wakefield-241 St\", feeds: [\"gtfs\"] },\n \"204\": { name: \"Nereid Av\", feeds: [\"gtfs\"] },\n \"205\": { name: \"233 St\", feeds: [\"gtfs\"] },\n \"206\": { name: \"225 St\", feeds: [\"gtfs\"] },\n \"207\": { name: \"219 St\", feeds: [\"gtfs\"] },\n \"208\": { name: \"Gun Hill Rd\", feeds: [\"gtfs\"] },\n \"209\": { name: \"Burke Av\", feeds: [\"gtfs\"] },\n \"210\": { name: \"Allerton Av\", feeds: [\"gtfs\"] },\n \"211\": { name: \"Pelham Pkwy\", feeds: [\"gtfs\"] },\n \"212\": { name: \"Bronx Park East\", feeds: [\"gtfs\"] },\n \"213\": { name: \"E 180 St\", feeds: [\"gtfs\"] },\n \"214\": { name: \"West Farms Sq-E Tremont Av\", feeds: [\"gtfs\"] },\n \"215\": { name: \"174 St\", feeds: [\"gtfs\"] },\n \"216\": { name: \"Freeman St\", feeds: [\"gtfs\"] },\n \"217\": { name: \"Simpson St\", feeds: [\"gtfs\"] },\n \"218\": { name: \"Intervale Av\", feeds: [\"gtfs\"] },\n \"219\": { name: \"Prospect Av\", feeds: [\"gtfs\"] },\n \"220\": { name: \"Jackson Av\", feeds: [\"gtfs\"] },\n \"221\": { name: \"3 Av-149 St\", feeds: [\"gtfs\"] },\n \"222\": { name: \"149 St-Grand Concourse\", feeds: [\"gtfs\"] },\n \"224\": { name: \"135 St\", feeds: [\"gtfs\"] },\n \"225\": { name: \"125 St\", feeds: [\"gtfs\"] },\n \"226\": { name: \"116 St\", feeds: [\"gtfs\"] },\n \"227\": { name: \"110 St-Malcolm X Plaza\", feeds: [\"gtfs\"] },\n \"228\": { name: \"Park Place\", feeds: [\"gtfs\"] },\n \"229\": { name: \"Fulton St\", feeds: [\"gtfs\"] },\n \"230\": { name: \"Wall St\", feeds: [\"gtfs\"] },\n \"231\": { name: \"Clark St\", feeds: [\"gtfs\"] },\n \"232\": { name: \"Borough Hall\", feeds: [\"gtfs\"] },\n \"233\": { name: \"Hoyt St\", feeds: [\"gtfs\"] },\n \"234\": { name: \"Nevins St\", feeds: [\"gtfs\"] },\n \"235\": { name: \"Atlantic Av-Barclays Ctr\", feeds: [\"gtfs\"] },\n \"236\": { name: \"Bergen St\", feeds: [\"gtfs\"] },\n \"237\": { name: \"Grand Army Plaza\", feeds: [\"gtfs\"] },\n \"238\": { name: \"Eastern Pkwy-Brooklyn Museum\", feeds: [\"gtfs\"] },\n \"239\": { name: \"Franklin Av-Medgar Evers College\", feeds: [\"gtfs\"] },\n \"241\": { name: \"President St-Medgar Evers College\", feeds: [\"gtfs\"] },\n \"242\": { name: \"Sterling St\", feeds: [\"gtfs\"] },\n \"243\": { name: \"Winthrop St\", feeds: [\"gtfs\"] },\n \"244\": { name: \"Church Av\", feeds: [\"gtfs\"] },\n \"245\": { name: \"Beverly Rd\", feeds: [\"gtfs\"] },\n \"246\": { name: \"Newkirk Av-Little Haiti\", feeds: [\"gtfs\"] },\n \"247\": { name: \"Flatbush Av-Brooklyn College\", feeds: [\"gtfs\"] },\n \"248\": { name: \"Nostrand Av\", feeds: [\"gtfs\"] },\n \"249\": { name: \"Kingston Av\", feeds: [\"gtfs\"] },\n \"250\": { name: \"Crown Hts-Utica Av\", feeds: [\"gtfs\"] },\n \"251\": { name: \"Sutter Av-Rutland Rd\", feeds: [\"gtfs\"] },\n \"252\": { name: \"Saratoga Av\", feeds: [\"gtfs\"] },\n \"253\": { name: \"Rockaway Av\", feeds: [\"gtfs\"] },\n \"254\": { name: \"Junius St\", feeds: [\"gtfs\"] },\n \"255\": { name: \"Pennsylvania Av\", feeds: [\"gtfs\"] },\n \"256\": { name: \"Van Siclen Av\", feeds: [\"gtfs\"] },\n \"257\": { name: \"New Lots Av\", feeds: [\"gtfs\"] },\n \"301\": { name: \"Harlem-148 St\", feeds: [\"gtfs\"] },\n \"302\": { name: \"145 St\", feeds: [\"gtfs\"] },\n \"401\": { name: \"Woodlawn\", feeds: [\"gtfs\"] },\n \"402\": { name: \"Mosholu Pkwy\", feeds: [\"gtfs\"] },\n \"405\": { name: \"Bedford Park Blvd-Lehman College\", feeds: [\"gtfs\"] },\n \"406\": { name: \"Kingsbridge Rd\", feeds: [\"gtfs\"] },\n \"407\": { name: \"Fordham Rd\", feeds: [\"gtfs\"] },\n \"408\": { name: \"183 St\", feeds: [\"gtfs\"] },\n \"409\": { name: \"Burnside Av\", feeds: [\"gtfs\"] },\n \"410\": { name: \"176 St\", feeds: [\"gtfs\"] },\n \"411\": { name: \"Mt Eden Av\", feeds: [\"gtfs\"] },\n \"412\": { name: \"170 St\", feeds: [\"gtfs\"] },\n \"413\": { name: \"167 St\", feeds: [\"gtfs\"] },\n \"414\": { name: \"161 St-Yankee Stadium\", feeds: [\"gtfs\"] },\n \"415\": { name: \"149 St-Grand Concourse\", feeds: [\"gtfs\"] },\n \"416\": { name: \"138 St-Grand Concourse\", feeds: [\"gtfs\"] },\n \"418\": { name: \"Fulton St\", feeds: [\"gtfs\"] },\n \"419\": { name: \"Wall St\", feeds: [\"gtfs\"] },\n \"420\": { name: \"Bowling Green\", feeds: [\"gtfs\"] },\n \"423\": { name: \"Borough Hall\", feeds: [\"gtfs\"] },\n \"501\": { name: \"Eastchester-Dyre Av\", feeds: [\"gtfs\"] },\n \"502\": { name: \"Baychester Av\", feeds: [\"gtfs\"] },\n \"503\": { name: \"Gun Hill Rd\", feeds: [\"gtfs\"] },\n \"504\": { name: \"Pelham Pkwy\", feeds: [\"gtfs\"] },\n \"505\": { name: \"Morris Park\", feeds: [\"gtfs\"] },\n \"601\": { name: \"Pelham Bay Park\", feeds: [\"gtfs\"] },\n \"602\": { name: \"Buhre Av\", feeds: [\"gtfs\"] },\n \"603\": { name: \"Middletown Rd\", feeds: [\"gtfs\"] },\n \"604\": { name: \"Westchester Sq-E Tremont Av\", feeds: [\"gtfs\"] },\n \"606\": { name: \"Zerega Av\", feeds: [\"gtfs\"] },\n \"607\": { name: \"Castle Hill Av\", feeds: [\"gtfs\"] },\n \"608\": { name: \"Parkchester\", feeds: [\"gtfs\"] },\n \"609\": { name: \"St Lawrence Av\", feeds: [\"gtfs\"] },\n \"610\": { name: \"Morrison Av-Soundview\", feeds: [\"gtfs\"] },\n \"611\": { name: \"Elder Av\", feeds: [\"gtfs\"] },\n \"612\": { name: \"Whitlock Av\", feeds: [\"gtfs\"] },\n \"613\": { name: \"Hunts Point Av\", feeds: [\"gtfs\"] },\n \"614\": { name: \"Longwood Av\", feeds: [\"gtfs\"] },\n \"615\": { name: \"E 149 St\", feeds: [\"gtfs\"] },\n \"616\": { name: \"E 143 St-St Mary's St\", feeds: [\"gtfs\"] },\n \"617\": { name: \"Cypress Av\", feeds: [\"gtfs\"] },\n \"618\": { name: \"Brook Av\", feeds: [\"gtfs\"] },\n \"619\": { name: \"3 Av-138 St\", feeds: [\"gtfs\"] },\n \"621\": { name: \"125 St\", feeds: [\"gtfs\"] },\n \"622\": { name: \"116 St\", feeds: [\"gtfs\"] },\n \"623\": { name: \"110 St\", feeds: [\"gtfs\"] },\n \"624\": { name: \"103 St\", feeds: [\"gtfs\"] },\n \"625\": { name: \"96 St\", feeds: [\"gtfs\"] },\n \"626\": { name: \"86 St\", feeds: [\"gtfs\"] },\n \"627\": { name: \"77 St\", feeds: [\"gtfs\"] },\n \"628\": { name: \"68 St-Hunter College\", feeds: [\"gtfs\"] },\n \"629\": { name: \"59 St\", feeds: [\"gtfs\"] },\n \"630\": { name: \"51 St\", feeds: [\"gtfs\"] },\n \"631\": { name: \"Grand Central-42 St\", feeds: [\"gtfs\"] },\n \"632\": { name: \"33 St\", feeds: [\"gtfs\"] },\n \"633\": { name: \"28 St\", feeds: [\"gtfs\"] },\n \"634\": { name: \"23 St-Baruch College\", feeds: [\"gtfs\"] },\n \"635\": { name: \"14 St-Union Sq\", feeds: [\"gtfs\"] },\n \"636\": { name: \"Astor Pl\", feeds: [\"gtfs\"] },\n \"637\": { name: \"Bleecker St\", feeds: [\"gtfs\"] },\n \"638\": { name: \"Spring St\", feeds: [\"gtfs\"] },\n \"639\": { name: \"Canal St\", feeds: [\"gtfs\"] },\n \"640\": { name: \"Brooklyn Bridge-City Hall\", feeds: [\"gtfs\"] },\n \"701\": { name: \"Flushing-Main St\", feeds: [\"gtfs\"] },\n \"702\": { name: \"Mets-Willets Point\", feeds: [\"gtfs\"] },\n \"705\": { name: \"111 St\", feeds: [\"gtfs\"] },\n \"706\": { name: \"103 St-Corona Plaza\", feeds: [\"gtfs\"] },\n \"707\": { name: \"Junction Blvd\", feeds: [\"gtfs\"] },\n \"708\": { name: \"90 St-Elmhurst Av\", feeds: [\"gtfs\"] },\n \"709\": { name: \"82 St-Jackson Hts\", feeds: [\"gtfs\"] },\n \"710\": { name: \"74 St-Broadway\", feeds: [\"gtfs\"] },\n \"711\": { name: \"69 St\", feeds: [\"gtfs\"] },\n \"712\": { name: \"61 St-Woodside\", feeds: [\"gtfs\"] },\n \"713\": { name: \"52 St\", feeds: [\"gtfs\"] },\n \"714\": { name: \"46 St-Bliss St\", feeds: [\"gtfs\"] },\n \"715\": { name: \"40 St-Lowery St\", feeds: [\"gtfs\"] },\n \"716\": { name: \"33 St-Rawson St\", feeds: [\"gtfs\"] },\n \"718\": { name: \"Queensboro Plaza\", feeds: [\"gtfs\"] },\n \"719\": { name: \"Court Sq\", feeds: [\"gtfs\"] },\n \"720\": { name: \"Hunters Point Av\", feeds: [\"gtfs\"] },\n \"721\": { name: \"Vernon Blvd-Jackson Av\", feeds: [\"gtfs\"] },\n \"723\": { name: \"Grand Central-42 St\", feeds: [\"gtfs\"] },\n \"724\": { name: \"5 Av\", feeds: [\"gtfs\"] },\n \"725\": { name: \"Times Sq-42 St\", feeds: [\"gtfs\"] },\n \"726\": { name: \"34 St-Hudson Yards\", feeds: [\"gtfs\"] },\n \"901\": { name: \"Grand Central-42 St\", feeds: [\"gtfs\"] },\n \"902\": { name: \"Times Sq-42 St\", feeds: [\"gtfs\"] },\n \"A02\": { name: \"Inwood-207 St\", feeds: [\"gtfs-ace\"] },\n \"A03\": { name: \"Dyckman St\", feeds: [\"gtfs-ace\"] },\n \"A05\": { name: \"190 St\", feeds: [\"gtfs-ace\"] },\n \"A06\": { name: \"181 St\", feeds: [\"gtfs-ace\"] },\n \"A07\": { name: \"175 St\", feeds: [\"gtfs-ace\"] },\n \"A09\": { name: \"168 St\", feeds: [\"gtfs-ace\"] },\n \"A10\": { name: \"163 St-Amsterdam Av\", feeds: [\"gtfs-ace\"] },\n \"A11\": { name: \"155 St\", feeds: [\"gtfs-ace\"] },\n \"A12\": { name: \"145 St\", feeds: [\"gtfs-ace\"] },\n \"A14\": { name: \"135 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A15\": { name: \"125 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A16\": { name: \"116 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A17\": { name: \"Cathedral Pkwy (110 St)\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A18\": { name: \"103 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A19\": { name: \"96 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A20\": { name: \"86 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A21\": { name: \"81 St-Museum of Natural History\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A22\": { name: \"72 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A24\": { name: \"59 St-Columbus Circle\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A25\": { name: \"50 St\", feeds: [\"gtfs-ace\"] },\n \"A27\": { name: \"42 St-Port Authority Bus Terminal\", feeds: [\"gtfs-ace\"] },\n \"A28\": { name: \"34 St-Penn Station\", feeds: [\"gtfs-ace\"] },\n \"A30\": { name: \"23 St\", feeds: [\"gtfs-ace\"] },\n \"A31\": { name: \"14 St\", feeds: [\"gtfs-ace\"] },\n \"A32\": { name: \"W 4 St-Wash Sq\", feeds: [\"gtfs-ace\"] },\n \"A33\": { name: \"Spring St\", feeds: [\"gtfs-ace\"] },\n \"A34\": { name: \"Canal St\", feeds: [\"gtfs-ace\"] },\n \"A36\": { name: \"Chambers St\", feeds: [\"gtfs-ace\"] },\n \"A38\": { name: \"Fulton St\", feeds: [\"gtfs-ace\"] },\n \"A40\": { name: \"High St\", feeds: [\"gtfs-ace\"] },\n \"A41\": { name: \"Jay St-MetroTech\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"A42\": { name: \"Hoyt-Schermerhorn Sts\", feeds: [\"gtfs-g\", \"gtfs-ace\"] },\n \"A43\": { name: \"Lafayette Av\", feeds: [\"gtfs-ace\"] },\n \"A44\": { name: \"Clinton-Washington Avs\", feeds: [\"gtfs-ace\"] },\n \"A45\": { name: \"Franklin Av\", feeds: [\"gtfs-ace\"] },\n \"A46\": { name: \"Nostrand Av\", feeds: [\"gtfs-ace\"] },\n \"A47\": { name: \"Kingston-Throop Avs\", feeds: [\"gtfs-ace\"] },\n \"A48\": { name: \"Utica Av\", feeds: [\"gtfs-ace\"] },\n \"A49\": { name: \"Ralph Av\", feeds: [\"gtfs-ace\"] },\n \"A50\": { name: \"Rockaway Av\", feeds: [\"gtfs-ace\"] },\n \"A51\": { name: \"Broadway Junction\", feeds: [\"gtfs-ace\"] },\n \"A52\": { name: \"Liberty Av\", feeds: [\"gtfs-ace\"] },\n \"A53\": { name: \"Van Siclen Av\", feeds: [\"gtfs-ace\"] },\n \"A54\": { name: \"Shepherd Av\", feeds: [\"gtfs-ace\"] },\n \"A55\": { name: \"Euclid Av\", feeds: [\"gtfs-ace\"] },\n \"A57\": { name: \"Grant Av\", feeds: [\"gtfs-ace\"] },\n \"A59\": { name: \"80 St\", feeds: [\"gtfs-ace\"] },\n \"A60\": { name: \"88 St\", feeds: [\"gtfs-ace\"] },\n \"A61\": { name: \"Rockaway Blvd\", feeds: [\"gtfs-ace\"] },\n \"A63\": { name: \"104 St\", feeds: [\"gtfs-ace\"] },\n \"A64\": { name: \"111 St\", feeds: [\"gtfs-ace\"] },\n \"A65\": { name: \"Ozone Park-Lefferts Blvd\", feeds: [\"gtfs-ace\"] },\n \"B04\": { name: \"21 St-Queensbridge\", feeds: [\"gtfs-bdfm\"] },\n \"B05\": { name: \"B05\", feeds: [\"gtfs-bdfm\"] },\n \"B06\": { name: \"Roosevelt Island\", feeds: [\"gtfs-bdfm\"] },\n \"B08\": { name: \"Lexington Av/63 St\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"B10\": { name: \"57 St\", feeds: [\"gtfs-bdfm\"] },\n \"B12\": { name: \"9 Av\", feeds: [\"gtfs-bdfm\"] },\n \"B13\": { name: \"Fort Hamilton Pkwy\", feeds: [\"gtfs-bdfm\"] },\n \"B14\": { name: \"50 St\", feeds: [\"gtfs-bdfm\"] },\n \"B15\": { name: \"55 St\", feeds: [\"gtfs-bdfm\"] },\n \"B16\": { name: \"62 St\", feeds: [\"gtfs-bdfm\"] },\n \"B17\": { name: \"71 St\", feeds: [\"gtfs-bdfm\"] },\n \"B18\": { name: \"79 St\", feeds: [\"gtfs-bdfm\"] },\n \"B19\": { name: \"18 Av\", feeds: [\"gtfs-bdfm\"] },\n \"B20\": { name: \"20 Av\", feeds: [\"gtfs-bdfm\"] },\n \"B21\": { name: \"Bay Pkwy\", feeds: [\"gtfs-bdfm\"] },\n \"B22\": { name: \"25 Av\", feeds: [\"gtfs-bdfm\"] },\n \"B23\": { name: \"Bay 50 St\", feeds: [\"gtfs-bdfm\"] },\n \"D01\": { name: \"Norwood-205 St\", feeds: [\"gtfs-bdfm\"] },\n \"D03\": { name: \"Bedford Park Blvd\", feeds: [\"gtfs-bdfm\"] },\n \"D04\": { name: \"Kingsbridge Rd\", feeds: [\"gtfs-bdfm\"] },\n \"D05\": { name: \"Fordham Rd\", feeds: [\"gtfs-bdfm\"] },\n \"D06\": { name: \"182-183 Sts\", feeds: [\"gtfs-bdfm\"] },\n \"D07\": { name: \"Tremont Av\", feeds: [\"gtfs-bdfm\"] },\n \"D08\": { name: \"174-175 Sts\", feeds: [\"gtfs-bdfm\"] },\n \"D09\": { name: \"170 St\", feeds: [\"gtfs-bdfm\"] },\n \"D10\": { name: \"167 St\", feeds: [\"gtfs-bdfm\"] },\n \"D11\": { name: \"161 St-Yankee Stadium\", feeds: [\"gtfs-bdfm\"] },\n \"D12\": { name: \"155 St\", feeds: [\"gtfs-bdfm\"] },\n \"D13\": { name: \"145 St\", feeds: [\"gtfs-bdfm\"] },\n \"D14\": { name: \"7 Av\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"D15\": { name: \"47-50 Sts-Rockefeller Ctr\", feeds: [\"gtfs-bdfm\"] },\n \"D16\": { name: \"42 St-Bryant Pk\", feeds: [\"gtfs-bdfm\"] },\n \"D17\": { name: \"34 St-Herald Sq\", feeds: [\"gtfs-bdfm\"] },\n \"D18\": { name: \"23 St\", feeds: [\"gtfs-bdfm\"] },\n \"D19\": { name: \"14 St\", feeds: [\"gtfs-bdfm\"] },\n \"D20\": { name: \"W 4 St-Wash Sq\", feeds: [\"gtfs-bdfm\"] },\n \"D21\": { name: \"Broadway-Lafayette St\", feeds: [\"gtfs-bdfm\"] },\n \"D22\": { name: \"Grand St\", feeds: [\"gtfs-bdfm\"] },\n \"D23\": { name: \"D23\", feeds: [\"gtfs-nqrw\"] },\n \"D24\": { name: \"Atlantic Av-Barclays Ctr\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"D25\": { name: \"7 Av\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"D26\": { name: \"Prospect Park\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"D27\": { name: \"Parkside Av\", feeds: [\"gtfs-nqrw\"] },\n \"D28\": { name: \"Church Av\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"D29\": { name: \"Beverley Rd\", feeds: [\"gtfs-nqrw\"] },\n \"D30\": { name: \"Cortelyou Rd\", feeds: [\"gtfs-nqrw\"] },\n \"D31\": { name: \"Newkirk Plaza\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"D32\": { name: \"Avenue H\", feeds: [\"gtfs-nqrw\"] },\n \"D33\": { name: \"Avenue J\", feeds: [\"gtfs-nqrw\"] },\n \"D34\": { name: \"Avenue M\", feeds: [\"gtfs-nqrw\"] },\n \"D35\": { name: \"Kings Hwy\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"D37\": { name: \"Avenue U\", feeds: [\"gtfs-nqrw\"] },\n \"D38\": { name: \"Neck Rd\", feeds: [\"gtfs-nqrw\"] },\n \"D39\": { name: \"Sheepshead Bay\", feeds: [\"gtfs-nqrw\"] },\n \"D40\": { name: \"Brighton Beach\", feeds: [\"gtfs-nqrw\"] },\n \"D42\": { name: \"W 8 St-NY Aquarium\", feeds: [\"gtfs-bdfm\"] },\n \"D43\": { name: \"Coney Island-Stillwell Av\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"E01\": { name: \"World Trade Center\", feeds: [\"gtfs-ace\"] },\n \"F01\": { name: \"Jamaica-179 St\", feeds: [\"gtfs-bdfm\"] },\n \"F02\": { name: \"169 St\", feeds: [\"gtfs-bdfm\"] },\n \"F03\": { name: \"Parsons Blvd\", feeds: [\"gtfs-bdfm\"] },\n \"F04\": { name: \"Sutphin Blvd\", feeds: [\"gtfs-bdfm\"] },\n \"F05\": { name: \"Briarwood\", feeds: [\"gtfs-bdfm\"] },\n \"F06\": { name: \"Kew Gardens-Union Tpke\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"F07\": { name: \"75 Av\", feeds: [\"gtfs-bdfm\"] },\n \"F09\": { name: \"Court Sq-23 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"F11\": { name: \"Lexington Av/53 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"F12\": { name: \"5 Av/53 St\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\"] },\n \"F14\": { name: \"2 Av\", feeds: [\"gtfs-bdfm\"] },\n \"F15\": { name: \"Delancey St-Essex St\", feeds: [\"gtfs-bdfm\"] },\n \"F16\": { name: \"East Broadway\", feeds: [\"gtfs-bdfm\"] },\n \"F18\": { name: \"York St\", feeds: [\"gtfs-bdfm\"] },\n \"F20\": { name: \"Bergen St\", feeds: [\"gtfs-g\", \"gtfs-bdfm\"] },\n \"F21\": { name: \"Carroll St\", feeds: [\"gtfs-g\", \"gtfs-bdfm\"] },\n \"F22\": { name: \"Smith-9 Sts\", feeds: [\"gtfs-g\", \"gtfs-bdfm\"] },\n \"F23\": { name: \"4 Av-9 St\", feeds: [\"gtfs-g\", \"gtfs-bdfm\"] },\n \"F24\": { name: \"7 Av\", feeds: [\"gtfs-g\", \"gtfs-bdfm\"] },\n \"F25\": { name: \"15 St-Prospect Park\", feeds: [\"gtfs-g\", \"gtfs-bdfm\"] },\n \"F26\": { name: \"Fort Hamilton Pkwy\", feeds: [\"gtfs-g\", \"gtfs-bdfm\"] },\n \"F27\": { name: \"Church Av\", feeds: [\"gtfs-g\", \"gtfs-bdfm\"] },\n \"F29\": { name: \"Ditmas Av\", feeds: [\"gtfs-bdfm\"] },\n \"F30\": { name: \"18 Av\", feeds: [\"gtfs-bdfm\"] },\n \"F31\": { name: \"Avenue I\", feeds: [\"gtfs-bdfm\"] },\n \"F32\": { name: \"Bay Pkwy\", feeds: [\"gtfs-bdfm\"] },\n \"F33\": { name: \"Avenue N\", feeds: [\"gtfs-bdfm\"] },\n \"F34\": { name: \"Avenue P\", feeds: [\"gtfs-bdfm\"] },\n \"F35\": { name: \"Kings Hwy\", feeds: [\"gtfs-bdfm\"] },\n \"F36\": { name: \"Avenue U\", feeds: [\"gtfs-bdfm\"] },\n \"F38\": { name: \"Avenue X\", feeds: [\"gtfs-bdfm\"] },\n \"F39\": { name: \"Neptune Av\", feeds: [\"gtfs-bdfm\"] },\n \"G05\": { name: \"Jamaica Center-Parsons/Archer\", feeds: [\"gtfs-jz\", \"gtfs-ace\"] },\n \"G06\": { name: \"Sutphin Blvd-Archer Av-JFK Airport\", feeds: [\"gtfs-jz\", \"gtfs-ace\"] },\n \"G07\": { name: \"Jamaica-Van Wyck\", feeds: [\"gtfs-ace\"] },\n \"G08\": { name: \"Forest Hills-71 Av\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G09\": { name: \"67 Av\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G10\": { name: \"63 Dr-Rego Park\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G11\": { name: \"Woodhaven Blvd\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G12\": { name: \"Grand Av-Newtown\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G13\": { name: \"Elmhurst Av\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G14\": { name: \"Jackson Hts-Roosevelt Av\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G15\": { name: \"65 St\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G16\": { name: \"Northern Blvd\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G18\": { name: \"46 St\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G19\": { name: \"Steinway St\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G20\": { name: \"36 St\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G21\": { name: \"Queens Plaza\", feeds: [\"gtfs-ace\", \"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"G22\": { name: \"Court Sq\", feeds: [\"gtfs-g\"] },\n \"G24\": { name: \"21 St\", feeds: [\"gtfs-g\"] },\n \"G26\": { name: \"Greenpoint Av\", feeds: [\"gtfs-g\"] },\n \"G28\": { name: \"Nassau Av\", feeds: [\"gtfs-g\"] },\n \"G29\": { name: \"Metropolitan Av\", feeds: [\"gtfs-g\"] },\n \"G30\": { name: \"Broadway\", feeds: [\"gtfs-g\"] },\n \"G31\": { name: \"Flushing Av\", feeds: [\"gtfs-g\"] },\n \"G32\": { name: \"Myrtle-Willoughby Avs\", feeds: [\"gtfs-g\"] },\n \"G33\": { name: \"Bedford-Nostrand Avs\", feeds: [\"gtfs-g\"] },\n \"G34\": { name: \"Classon Av\", feeds: [\"gtfs-g\"] },\n \"G35\": { name: \"Clinton-Washington Avs\", feeds: [\"gtfs-g\"] },\n \"G36\": { name: \"Fulton St\", feeds: [\"gtfs-g\"] },\n \"H01\": { name: \"Aqueduct Racetrack\", feeds: [\"gtfs-ace\"] },\n \"H02\": { name: \"Aqueduct-N Conduit Av\", feeds: [\"gtfs-ace\"] },\n \"H03\": { name: \"Howard Beach-JFK Airport\", feeds: [\"gtfs-ace\"] },\n \"H04\": { name: \"Broad Channel\", feeds: [\"gtfs-ace\"] },\n \"H06\": { name: \"Beach 67 St\", feeds: [\"gtfs-ace\"] },\n \"H07\": { name: \"Beach 60 St\", feeds: [\"gtfs-ace\"] },\n \"H08\": { name: \"Beach 44 St\", feeds: [\"gtfs-ace\"] },\n \"H09\": { name: \"Beach 36 St\", feeds: [\"gtfs-ace\"] },\n \"H10\": { name: \"Beach 25 St\", feeds: [\"gtfs-ace\"] },\n \"H11\": { name: \"Far Rockaway-Mott Av\", feeds: [\"gtfs-ace\"] },\n \"H12\": { name: \"Beach 90 St\", feeds: [\"gtfs-ace\"] },\n \"H13\": { name: \"Beach 98 St\", feeds: [\"gtfs-ace\"] },\n \"H14\": { name: \"Beach 105 St\", feeds: [\"gtfs-ace\"] },\n \"H15\": { name: \"Rockaway Park-Beach 116 St\", feeds: [\"gtfs-ace\"] },\n \"H19\": { name: \"H19\", feeds: [\"gtfs-ace\"] },\n \"J12\": { name: \"121 St\", feeds: [\"gtfs-jz\"] },\n \"J13\": { name: \"111 St\", feeds: [\"gtfs-jz\"] },\n \"J14\": { name: \"104 St\", feeds: [\"gtfs-jz\"] },\n \"J15\": { name: \"Woodhaven Blvd\", feeds: [\"gtfs-jz\"] },\n \"J16\": { name: \"85 St-Forest Pkwy\", feeds: [\"gtfs-jz\"] },\n \"J17\": { name: \"75 St-Elderts Ln\", feeds: [\"gtfs-jz\"] },\n \"J19\": { name: \"Cypress Hills\", feeds: [\"gtfs-jz\"] },\n \"J20\": { name: \"Crescent St\", feeds: [\"gtfs-jz\"] },\n \"J21\": { name: \"Norwood Av\", feeds: [\"gtfs-jz\"] },\n \"J22\": { name: \"Cleveland St\", feeds: [\"gtfs-jz\"] },\n \"J23\": { name: \"Van Siclen Av\", feeds: [\"gtfs-jz\"] },\n \"J24\": { name: \"Alabama Av\", feeds: [\"gtfs-jz\"] },\n \"J27\": { name: \"Broadway Junction\", feeds: [\"gtfs-jz\"] },\n \"J28\": { name: \"Chauncey St\", feeds: [\"gtfs-jz\"] },\n \"J29\": { name: \"Halsey St\", feeds: [\"gtfs-jz\"] },\n \"J30\": { name: \"Gates Av\", feeds: [\"gtfs-jz\"] },\n \"J31\": { name: \"Kosciuszko St\", feeds: [\"gtfs-jz\"] },\n \"L01\": { name: \"8 Av\", feeds: [\"gtfs-l\"] },\n \"L02\": { name: \"6 Av\", feeds: [\"gtfs-l\"] },\n \"L03\": { name: \"14 St-Union Sq\", feeds: [\"gtfs-l\"] },\n \"L05\": { name: \"3 Av\", feeds: [\"gtfs-l\"] },\n \"L06\": { name: \"1 Av\", feeds: [\"gtfs-l\"] },\n \"L08\": { name: \"Bedford Av\", feeds: [\"gtfs-l\"] },\n \"L10\": { name: \"Lorimer St\", feeds: [\"gtfs-l\"] },\n \"L11\": { name: \"Graham Av\", feeds: [\"gtfs-l\"] },\n \"L12\": { name: \"Grand St\", feeds: [\"gtfs-l\"] },\n \"L13\": { name: \"Montrose Av\", feeds: [\"gtfs-l\"] },\n \"L14\": { name: \"Morgan Av\", feeds: [\"gtfs-l\"] },\n \"L15\": { name: \"Jefferson St\", feeds: [\"gtfs-l\"] },\n \"L16\": { name: \"DeKalb Av\", feeds: [\"gtfs-l\"] },\n \"L17\": { name: \"Myrtle-Wyckoff Avs\", feeds: [\"gtfs-l\"] },\n \"L24\": { name: \"Atlantic Av\", feeds: [\"gtfs-l\"] },\n \"L25\": { name: \"Sutter Av\", feeds: [\"gtfs-l\"] },\n \"L26\": { name: \"Livonia Av\", feeds: [\"gtfs-l\"] },\n \"L27\": { name: \"New Lots Av\", feeds: [\"gtfs-l\"] },\n \"L28\": { name: \"East 105 St\", feeds: [\"gtfs-l\"] },\n \"L29\": { name: \"Canarsie-Rockaway Pkwy\", feeds: [\"gtfs-l\"] },\n \"M01\": { name: \"Middle Village-Metropolitan Av\", feeds: [\"gtfs-bdfm\"] },\n \"M04\": { name: \"Fresh Pond Rd\", feeds: [\"gtfs-bdfm\"] },\n \"M05\": { name: \"Forest Av\", feeds: [\"gtfs-bdfm\"] },\n \"M06\": { name: \"Seneca Av\", feeds: [\"gtfs-bdfm\"] },\n \"M08\": { name: \"Myrtle-Wyckoff Avs\", feeds: [\"gtfs-bdfm\"] },\n \"M09\": { name: \"Knickerbocker Av\", feeds: [\"gtfs-bdfm\"] },\n \"M10\": { name: \"Central Av\", feeds: [\"gtfs-bdfm\"] },\n \"M11\": { name: \"Myrtle Av\", feeds: [\"gtfs-jz\", \"gtfs-bdfm\"] },\n \"M12\": { name: \"Flushing Av\", feeds: [\"gtfs-jz\", \"gtfs-bdfm\"] },\n \"M13\": { name: \"Lorimer St\", feeds: [\"gtfs-jz\", \"gtfs-bdfm\"] },\n \"M14\": { name: \"Hewes St\", feeds: [\"gtfs-jz\", \"gtfs-bdfm\"] },\n \"M16\": { name: \"Marcy Av\", feeds: [\"gtfs-jz\", \"gtfs-bdfm\"] },\n \"M18\": { name: \"Delancey St-Essex St\", feeds: [\"gtfs-jz\", \"gtfs-bdfm\"] },\n \"M19\": { name: \"Bowery\", feeds: [\"gtfs-jz\"] },\n \"M20\": { name: \"Canal St\", feeds: [\"gtfs-jz\"] },\n \"M21\": { name: \"Chambers St\", feeds: [\"gtfs-jz\"] },\n \"M22\": { name: \"Fulton St\", feeds: [\"gtfs-jz\"] },\n \"M23\": { name: \"Broad St\", feeds: [\"gtfs-jz\"] },\n \"N02\": { name: \"8 Av\", feeds: [\"gtfs-nqrw\"] },\n \"N03\": { name: \"Fort Hamilton Pkwy\", feeds: [\"gtfs-nqrw\"] },\n \"N04\": { name: \"New Utrecht Av\", feeds: [\"gtfs-nqrw\"] },\n \"N05\": { name: \"18 Av\", feeds: [\"gtfs-nqrw\"] },\n \"N06\": { name: \"20 Av\", feeds: [\"gtfs-nqrw\"] },\n \"N07\": { name: \"Bay Pkwy\", feeds: [\"gtfs-nqrw\"] },\n \"N08\": { name: \"Kings Hwy\", feeds: [\"gtfs-nqrw\"] },\n \"N09\": { name: \"Avenue U\", feeds: [\"gtfs-nqrw\"] },\n \"N10\": { name: \"86 St\", feeds: [\"gtfs-nqrw\"] },\n \"N12\": { name: \"N12\", feeds: [\"gtfs-nqrw\"] },\n \"Q01\": { name: \"Canal St\", feeds: [\"gtfs-nqrw\"] },\n \"Q03\": { name: \"72 St\", feeds: [\"gtfs-nqrw\"] },\n \"Q04\": { name: \"86 St\", feeds: [\"gtfs-nqrw\"] },\n \"Q05\": { name: \"96 St\", feeds: [\"gtfs-nqrw\"] },\n \"R01\": { name: \"Astoria-Ditmars Blvd\", feeds: [\"gtfs-nqrw\"] },\n \"R03\": { name: \"Astoria Blvd\", feeds: [\"gtfs-nqrw\"] },\n \"R04\": { name: \"30 Av\", feeds: [\"gtfs-nqrw\"] },\n \"R05\": { name: \"Broadway\", feeds: [\"gtfs-nqrw\"] },\n \"R06\": { name: \"36 Av\", feeds: [\"gtfs-nqrw\"] },\n \"R08\": { name: \"39 Av-Dutch Kills\", feeds: [\"gtfs-nqrw\"] },\n \"R09\": { name: \"Queensboro Plaza\", feeds: [\"gtfs-nqrw\"] },\n \"R11\": { name: \"Lexington Av/59 St\", feeds: [\"gtfs-nqrw\"] },\n \"R13\": { name: \"5 Av/59 St\", feeds: [\"gtfs-nqrw\"] },\n \"R14\": { name: \"57 St-7 Av\", feeds: [\"gtfs-nqrw\"] },\n \"R15\": { name: \"49 St\", feeds: [\"gtfs-nqrw\"] },\n \"R16\": { name: \"Times Sq-42 St\", feeds: [\"gtfs-nqrw\"] },\n \"R17\": { name: \"34 St-Herald Sq\", feeds: [\"gtfs-nqrw\"] },\n \"R18\": { name: \"28 St\", feeds: [\"gtfs-nqrw\"] },\n \"R19\": { name: \"23 St\", feeds: [\"gtfs-nqrw\"] },\n \"R20\": { name: \"14 St-Union Sq\", feeds: [\"gtfs-nqrw\"] },\n \"R21\": { name: \"8 St-NYU\", feeds: [\"gtfs-nqrw\"] },\n \"R22\": { name: \"Prince St\", feeds: [\"gtfs-nqrw\"] },\n \"R23\": { name: \"Canal St\", feeds: [\"gtfs-nqrw\"] },\n \"R24\": { name: \"City Hall\", feeds: [\"gtfs-nqrw\"] },\n \"R25\": { name: \"Cortlandt St\", feeds: [\"gtfs-nqrw\"] },\n \"R26\": { name: \"Rector St\", feeds: [\"gtfs-nqrw\"] },\n \"R27\": { name: \"Whitehall St-South Ferry\", feeds: [\"gtfs-nqrw\"] },\n \"R28\": { name: \"Court St\", feeds: [\"gtfs-nqrw\"] },\n \"R29\": { name: \"Jay St-MetroTech\", feeds: [\"gtfs-nqrw\"] },\n \"R30\": { name: \"DeKalb Av\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"R31\": { name: \"Atlantic Av-Barclays Ctr\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"R32\": { name: \"Union St\", feeds: [\"gtfs-nqrw\"] },\n \"R33\": { name: \"4 Av-9 St\", feeds: [\"gtfs-nqrw\"] },\n \"R34\": { name: \"Prospect Av\", feeds: [\"gtfs-nqrw\"] },\n \"R35\": { name: \"25 St\", feeds: [\"gtfs-nqrw\"] },\n \"R36\": { name: \"36 St\", feeds: [\"gtfs-bdfm\", \"gtfs-nqrw\"] },\n \"R39\": { name: \"45 St\", feeds: [\"gtfs-nqrw\"] },\n \"R40\": { name: \"53 St\", feeds: [\"gtfs-nqrw\"] },\n \"R41\": { name: \"59 St\", feeds: [\"gtfs-nqrw\"] },\n \"R42\": { name: \"Bay Ridge Av\", feeds: [\"gtfs-nqrw\"] },\n \"R43\": { name: \"77 St\", feeds: [\"gtfs-nqrw\"] },\n \"R44\": { name: \"86 St\", feeds: [\"gtfs-nqrw\"] },\n \"R45\": { name: \"Bay Ridge-95 St\", feeds: [\"gtfs-nqrw\"] },\n \"R60\": { name: \"R60\", feeds: [\"gtfs-nqrw\"] },\n \"R65\": { name: \"R65\", feeds: [\"gtfs-nqrw\"] },\n \"S01\": { name: \"Franklin Av\", feeds: [\"gtfs-bdfm\"] },\n \"S03\": { name: \"Park Pl\", feeds: [\"gtfs-bdfm\"] },\n \"S04\": { name: \"Botanic Garden\", feeds: [\"gtfs-bdfm\"] },\n \"S09\": { name: \"Tottenville\", feeds: [\"gtfs-si\"] },\n \"S11\": { name: \"Arthur Kill\", feeds: [\"gtfs-si\"] },\n \"S13\": { name: \"Richmond Valley\", feeds: [\"gtfs-si\"] },\n \"S14\": { name: \"Pleasant Plains\", feeds: [\"gtfs-si\"] },\n \"S15\": { name: \"Prince's Bay\", feeds: [\"gtfs-si\"] },\n \"S16\": { name: \"Huguenot\", feeds: [\"gtfs-si\"] },\n \"S17\": { name: \"Annadale\", feeds: [\"gtfs-si\"] },\n \"S18\": { name: \"Eltingville\", feeds: [\"gtfs-si\"] },\n \"S19\": { name: \"Great Kills\", feeds: [\"gtfs-si\"] },\n \"S20\": { name: \"Bay Terrace\", feeds: [\"gtfs-si\"] },\n \"S21\": { name: \"Oakwood Heights\", feeds: [\"gtfs-si\"] },\n \"S22\": { name: \"New Dorp\", feeds: [\"gtfs-si\"] },\n \"S23\": { name: \"Grant City\", feeds: [\"gtfs-si\"] },\n \"S24\": { name: \"Jefferson Av\", feeds: [\"gtfs-si\"] },\n \"S25\": { name: \"Dongan Hills\", feeds: [\"gtfs-si\"] },\n \"S26\": { name: \"Old Town\", feeds: [\"gtfs-si\"] },\n \"S27\": { name: \"Grasmere\", feeds: [\"gtfs-si\"] },\n \"S28\": { name: \"Clifton\", feeds: [\"gtfs-si\"] },\n \"S29\": { name: \"Stapleton\", feeds: [\"gtfs-si\"] },\n \"S30\": { name: \"Tompkinsville\", feeds: [\"gtfs-si\"] },\n \"S31\": { name: \"St George\", feeds: [\"gtfs-si\"] },\n \"X22\": { name: \"X22\", feeds: [\"gtfs-bdfm\"] },\n};\n\n// Human-readable names for trainId destination codes (the part after / in e.g. \"1R 2058 95S/CTL\")\nexport const DESTINATION_NAMES: Record = {\n // NQRW\n \"95S\": \"Bay Ridge–95 St\",\n \"CTL\": \"WTC Cortlandt\",\n \"QPL\": \"Queens Plaza\",\n \"DIT\": \"Astoria–Ditmars Blvd\",\n \"STL\": \"Coney Island–Stillwell Av\",\n \"962\": \"96 St\",\n \"BBC\": \"Brighton Beach\",\n \"WHL\": \"Whitehall St\",\n // 1/2/3/4/5/6/7/S\n \"241\": \"Wakefield–241 St\",\n \"DYR\": \"Eastchester–Dyre Av\",\n \"PEL\": \"Pelham Bay Park\",\n \"WDL\": \"Woodlawn\",\n \"FLA\": \"Flatbush Av–Brooklyn College\",\n \"NLT\": \"New Lots Av\",\n \"UTI\": \"Crown Heights–Utica Av\",\n \"SFT\": \"South Ferry\",\n \"TSS\": \"Times Sq–42 St\",\n \"GCS\": \"Grand Central–42 St\",\n \"34H\": \"34 St–Hudson Yards\",\n \"MST\": \"Flushing–Main St\",\n // ACE\n \"P-A\": \"34 St–Penn Station\",\n \"168\": \"168 St\",\n \"207\": \"Inwood–207 St\",\n \"EUC\": \"Euclid Av\",\n \"FAR\": \"Far Rockaway–Mott Av\",\n \"LEF\": \"Lefferts Blvd\",\n \"RPK\": \"Rockaway Park–Beach 116 St\",\n \"WTC\": \"World Trade Center\",\n // BDFM\n \"179\": \"Jamaica–179 St\",\n \"205\": \"Norwood–205 St\",\n \"MET\": \"Metropolitan Av\",\n // G\n \"CHU\": \"Church Av\",\n \"CRS\": \"Court Sq\",\n // JZ\n \"BRD\": \"Broad St\",\n // L\n \"8AV\": \"8 Av\",\n \"RPY\": \"Canarsie–Rockaway Pkwy\",\n // Staten Island Railway\n \"STG\": \"St. George\",\n \"TNV\": \"Tottenville\",\n};\n",[170],"3f55d404-81ab-4623-a1e9-cc2871578e2a","main.ts","54b76e8c-12cb-11f1-bbe4-42dde27851f2",83,["D",1783087579696],38,"http","import { z } from \"npm:zod\";\nimport { ArrivalsRequest } from \"./types.ts\";\nimport { getArrivals } from \"./utils.ts\";\n\nexport async function handleWebRequest(req: Request) {\n if (req.method !== \"GET\") {\n return new Response(\n JSON.stringify({ error: \"Method not allowed\" }),\n {\n status: 405,\n headers: { \"Content-Type\": \"application/json\", \"Allow\": \"GET\" },\n },\n );\n }\n\n const url = new URL(req.url);\n const stationId = url.searchParams.get(\"stationId\");\n const result = ArrivalsRequest.safeParse({ stationId });\n\n if (!result.success) {\n return new Response(\n JSON.stringify({\n error: \"Invalid request\",\n details: z.treeifyError(result.error),\n }),\n { status: 400, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n try {\n const data = await getArrivals(result.data.stationId);\n if (data === null) {\n return new Response(\n JSON.stringify({\n error: `Unknown stationId: ${result.data.stationId}`,\n }),\n { status: 404, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n return new Response(JSON.stringify(data, null, 2), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n console.error(\"Failed to fetch arrival data:\", err);\n return new Response(\n JSON.stringify({\n error: \"Failed to fetch arrival data. Please try again later.\",\n }),\n { status: 503, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n}",[177],"12103dc6-1392-11f1-903f-42dde27851f2","gtfs-realtime.proto","163c96fc-138c-11f1-b999-42dde27851f2",17,["D",1772165351414],"// Copyright 2015 The GTFS Specifications Authors.\n//\n// Licensed under the Apache License, Version 2.0 (the \"License\");\n// you may not use this file except in compliance with the License.\n// You may obtain a copy of the License at\n//\n// http://www.apache.org/licenses/LICENSE-2.0\n//\n// Unless required by applicable law or agreed to in writing, software\n// distributed under the License is distributed on an \"AS IS\" BASIS,\n// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\n// See the License for the specific language governing permissions and\n// limitations under the License.\n\n// Protocol definition file for GTFS Realtime.\n//\n// GTFS Realtime lets transit agencies provide consumers with realtime\n// information about disruptions to their service (stations closed, lines not\n// operating, important delays etc), location of their vehicles and expected\n// arrival times.\n//\n// This protocol is published at:\n// https://github.com/google/transit/tree/master/gtfs-realtime\n\nsyntax = \"proto2\";\noption java_package = \"com.google.transit.realtime\";\npackage transit_realtime;\n\n// The contents of a feed message.\n// A feed is a continuous stream of feed messages. Each message in the stream is\n// obtained as a response to an appropriate HTTP GET request.\n// A realtime feed is always defined with relation to an existing GTFS feed.\n// All the entity ids are resolved with respect to the GTFS feed.\n// Note that \"required\" and \"optional\" as stated in this file refer to Protocol\n// Buffer cardinality, not semantic cardinality. See reference.md at\n// https://github.com/google/transit/tree/master/gtfs-realtime for field\n// semantic cardinality.\nmessage FeedMessage {\n // Metadata about this feed and feed message.\n required FeedHeader header = 1;\n\n // Contents of the feed.\n repeated FeedEntity entity = 2;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// Metadata about a feed, included in feed messages.\nmessage FeedHeader {\n // Version of the feed specification.\n // The current version is 2.0. Valid versions are \"2.0\", \"1.0\".\n required string gtfs_realtime_version = 1;\n\n // Determines whether the current fetch is incremental. Currently,\n // DIFFERENTIAL mode is unsupported and behavior is unspecified for feeds\n // that use this mode. There are discussions on the GTFS Realtime mailing\n // list around fully specifying the behavior of DIFFERENTIAL mode and the\n // documentation will be updated when those discussions are finalized.\n enum Incrementality {\n FULL_DATASET = 0;\n DIFFERENTIAL = 1;\n }\n optional Incrementality incrementality = 2 [default = FULL_DATASET];\n\n // This timestamp identifies the moment when the content of this feed has been\n // created (in server time). In POSIX time (i.e., number of seconds since\n // January 1st 1970 00:00:00 UTC).\n optional uint64 timestamp = 3;\n\n // String that matches the feed_info.feed_version from the GTFS feed that the real\n // time data is based on. Consumers can use this to identify which GTFS feed is\n // currently active or when a new one is available to download.\n optional string feed_version = 4;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// A definition (or update) of an entity in the transit feed.\nmessage FeedEntity {\n // The ids are used only to provide incrementality support. The id should be\n // unique within a FeedMessage. Consequent FeedMessages may contain\n // FeedEntities with the same id. In case of a DIFFERENTIAL update the new\n // FeedEntity with some id will replace the old FeedEntity with the same id\n // (or delete it - see is_deleted below).\n // The actual GTFS entities (e.g. stations, routes, trips) referenced by the\n // feed must be specified by explicit selectors (see EntitySelector below for\n // more info).\n required string id = 1;\n\n // Whether this entity is to be deleted. Relevant only for incremental\n // fetches.\n optional bool is_deleted = 2 [default = false];\n\n // Data about the entity itself. Exactly one of the following fields must be\n // present (unless the entity is being deleted).\n optional TripUpdate trip_update = 3;\n optional VehiclePosition vehicle = 4;\n optional Alert alert = 5;\n\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional Shape shape = 6;\n optional Stop stop = 7;\n optional TripModifications trip_modifications = 8;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n//\n// Entities used in the feed.\n//\n\n// Realtime update of the progress of a vehicle along a trip.\n// Depending on the value of ScheduleRelationship, a TripUpdate can specify:\n// - A trip that proceeds along the schedule.\n// - A trip that proceeds along a route but has no fixed schedule.\n// - A trip that have been added or removed with regard to schedule.\n//\n// The updates can be for future, predicted arrival/departure events, or for\n// past events that already occurred.\n// Normally, updates should get more precise and more certain (see\n// uncertainty below) as the events gets closer to current time.\n// Even if that is not possible, the information for past events should be\n// precise and certain. In particular, if an update points to time in the past\n// but its update's uncertainty is not 0, the client should conclude that the\n// update is a (wrong) prediction and that the trip has not completed yet.\n//\n// Note that the update can describe a trip that is already completed.\n// To this end, it is enough to provide an update for the last stop of the trip.\n// If the time of that is in the past, the client will conclude from that that\n// the whole trip is in the past (it is possible, although inconsequential, to\n// also provide updates for preceding stops).\n// This option is most relevant for a trip that has completed ahead of schedule,\n// but according to the schedule, the trip is still proceeding at the current\n// time. Removing the updates for this trip could make the client assume\n// that the trip is still proceeding.\n// Note that the feed provider is allowed, but not required, to purge past\n// updates - this is one case where this would be practically useful.\nmessage TripUpdate {\n // The Trip that this message applies to. There can be at most one\n // TripUpdate entity for each actual trip instance.\n // If there is none, that means there is no prediction information available.\n // It does *not* mean that the trip is progressing according to schedule.\n required TripDescriptor trip = 1;\n\n // Additional information on the vehicle that is serving this trip.\n optional VehicleDescriptor vehicle = 3;\n\n // Timing information for a single predicted event (either arrival or\n // departure).\n // Timing consists of delay and/or estimated time, and uncertainty.\n // - delay should be used when the prediction is given relative to some\n // existing schedule in GTFS.\n // - time should be given whether there is a predicted schedule or not. If\n // both time and delay are specified, time will take precedence\n // (although normally, time, if given for a scheduled trip, should be\n // equal to scheduled time in GTFS + delay).\n //\n // Uncertainty applies equally to both time and delay.\n // The uncertainty roughly specifies the expected error in true delay (but\n // note, we don't yet define its precise statistical meaning). It's possible\n // for the uncertainty to be 0, for example for trains that are driven under\n // computer timing control.\n message StopTimeEvent {\n // Delay (in seconds) can be positive (meaning that the vehicle is late) or\n // negative (meaning that the vehicle is ahead of schedule). Delay of 0\n // means that the vehicle is exactly on time.\n optional int32 delay = 1;\n\n // Event as absolute time.\n // In Unix time (i.e., number of seconds since January 1st 1970 00:00:00\n // UTC).\n optional int64 time = 2;\n\n // If uncertainty is omitted, it is interpreted as unknown.\n // If the prediction is unknown or too uncertain, the delay (or time) field\n // should be empty. In such case, the uncertainty field is ignored.\n // To specify a completely certain prediction, set its uncertainty to 0.\n optional int32 uncertainty = 3;\n\n // Scheduled time for a NEW, REPLACEMENT, or DUPLICATED trip.\n // In Unix time (i.e., number of seconds since January 1st 1970 00:00:00\n // UTC).\n // Optional if TripUpdate.schedule_relationship is NEW, REPLACEMENT or DUPLICATED, forbidden otherwise.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional int64 scheduled_time = 4;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features\n // and modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n\n // Realtime update for arrival and/or departure events for a given stop on a\n // trip. Updates can be supplied for both past and future events.\n // The producer is allowed, although not required, to drop past events.\n message StopTimeUpdate {\n // The update is linked to a specific stop either through stop_sequence or\n // stop_id, so one of the fields below must necessarily be set.\n // See the documentation in TripDescriptor for more information.\n\n // Must be the same as in stop_times.txt in the corresponding GTFS feed.\n optional uint32 stop_sequence = 1;\n // Must be the same as in stops.txt in the corresponding GTFS feed.\n optional string stop_id = 4;\n\n optional StopTimeEvent arrival = 2;\n optional StopTimeEvent departure = 3;\n\n // Expected occupancy after departure from the given stop.\n // Should be provided only for future stops.\n // In order to provide departure_occupancy_status without either arrival or\n // departure StopTimeEvents, ScheduleRelationship should be set to NO_DATA. \n optional VehiclePosition.OccupancyStatus departure_occupancy_status = 7;\n\n // The relation between the StopTimeEvents and the static schedule.\n enum ScheduleRelationship {\n // The vehicle is proceeding in accordance with its static schedule of\n // stops, although not necessarily according to the times of the schedule.\n // At least one of arrival and departure must be provided. If the schedule\n // for this stop contains both arrival and departure times then so must\n // this update. Frequency-based trips (GTFS frequencies.txt with exact_times = 0)\n // should not have a SCHEDULED value and should use UNSCHEDULED instead.\n SCHEDULED = 0;\n\n // The stop is skipped, i.e., the vehicle will not stop at this stop.\n // Arrival and departure are optional.\n SKIPPED = 1;\n\n // No StopTimeEvents are given for this stop.\n // The main intention for this value is to give time predictions only for\n // part of a trip, i.e., if the last update for a trip has a NO_DATA\n // specifier, then StopTimeEvents for the rest of the stops in the trip\n // are considered to be unspecified as well.\n // Neither arrival nor departure should be supplied.\n NO_DATA = 2;\n\n // The vehicle is operating a trip defined in GTFS frequencies.txt with exact_times = 0.\n // This value should not be used for trips that are not defined in GTFS frequencies.txt,\n // or trips in GTFS frequencies.txt with exact_times = 1. Trips containing StopTimeUpdates\n // with ScheduleRelationship=UNSCHEDULED must also set TripDescriptor.ScheduleRelationship=UNSCHEDULED.\n // NOTE: This field is still experimental, and subject to change. It may be\n // formally adopted in the future.\n UNSCHEDULED = 3;\n }\n optional ScheduleRelationship schedule_relationship = 5\n [default = SCHEDULED];\n\n // Provides the updated values for the stop time.\n // NOTE: This message is still experimental, and subject to change. It may be formally adopted in the future.\n message StopTimeProperties {\n // Supports real-time stop assignments. Refers to a stop_id defined in the GTFS stops.txt.\n // The new assigned_stop_id should not result in a significantly different trip experience for the end user than\n // the stop_id defined in GTFS stop_times.txt. In other words, the end user should not view this new stop_id as an\n // \"unusual change\" if the new stop was presented within an app without any additional context.\n // For example, this field is intended to be used for platform assignments by using a stop_id that belongs to the\n // same station as the stop originally defined in GTFS stop_times.txt.\n // To assign a stop without providing any real-time arrival or departure predictions, populate this field and set\n // StopTimeUpdate.schedule_relationship = NO_DATA.\n // If this field is populated, it is preferred to omit `StopTimeUpdate.stop_id` and use only `StopTimeUpdate.stop_sequence`. If\n // `StopTimeProperties.assigned_stop_id` and `StopTimeUpdate.stop_id` are populated, `StopTimeUpdate.stop_id` must match `assigned_stop_id`.\n // Platform assignments should be reflected in other GTFS-realtime fields as well\n // (e.g., `VehiclePosition.stop_id`).\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string assigned_stop_id = 1;\n\n // The updated headsign of the vehicle at the stop.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string stop_headsign = 2;\n\n enum DropOffPickupType {\n // Regularly scheduled pickup/dropoff.\n REGULAR = 0;\n\n // No pickup/dropoff available\n NONE = 1;\n\n // Must phone agency to arrange pickup/dropoff.\n PHONE_AGENCY = 2;\n\n // Must coordinate with driver to arrange pickup/dropoff.\n COORDINATE_WITH_DRIVER = 3;\n }\n\n // The updated pickup of the vehicle at the stop.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional DropOffPickupType pickup_type = 3;\n\n // The updated drop off of the vehicle at the stop.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional DropOffPickupType drop_off_type = 4;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features\n // and modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n\n // Realtime updates for certain properties defined within GTFS stop_times.txt\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional StopTimeProperties stop_time_properties = 6;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features\n // and modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n\n // Updates to StopTimes for the trip (both future, i.e., predictions, and in\n // some cases, past ones, i.e., those that already happened).\n // The updates must be sorted by stop_sequence, and apply for all the\n // following stops of the trip up to the next specified one.\n //\n // Example 1:\n // For a trip with 20 stops, a StopTimeUpdate with arrival delay and departure\n // delay of 0 for stop_sequence of the current stop means that the trip is\n // exactly on time.\n //\n // Example 2:\n // For the same trip instance, 3 StopTimeUpdates are provided:\n // - delay of 5 min for stop_sequence 3\n // - delay of 1 min for stop_sequence 8\n // - delay of unspecified duration for stop_sequence 10\n // This will be interpreted as:\n // - stop_sequences 3,4,5,6,7 have delay of 5 min.\n // - stop_sequences 8,9 have delay of 1 min.\n // - stop_sequences 10,... have unknown delay.\n repeated StopTimeUpdate stop_time_update = 2;\n\n // The most recent moment at which the vehicle's real-time progress was measured\n // to estimate StopTimes in the future. When StopTimes in the past are provided,\n // arrival/departure times may be earlier than this value. In POSIX\n // time (i.e., the number of seconds since January 1st 1970 00:00:00 UTC).\n optional uint64 timestamp = 4;\n\n // The current schedule deviation for the trip. Delay should only be\n // specified when the prediction is given relative to some existing schedule\n // in GTFS.\n //\n // Delay (in seconds) can be positive (meaning that the vehicle is late) or\n // negative (meaning that the vehicle is ahead of schedule). Delay of 0\n // means that the vehicle is exactly on time.\n //\n // Delay information in StopTimeUpdates take precedent of trip-level delay\n // information, such that trip-level delay is only propagated until the next\n // stop along the trip with a StopTimeUpdate delay value specified.\n //\n // Feed providers are strongly encouraged to provide a TripUpdate.timestamp\n // value indicating when the delay value was last updated, in order to\n // evaluate the freshness of the data.\n //\n // NOTE: This field is still experimental, and subject to change. It may be\n // formally adopted in the future.\n optional int32 delay = 5;\n\n // Defines updated properties of the trip, such as a new shape_id when there is a detour. Or defines the\n // trip_id, start_date, and start_time of a DUPLICATED trip. \n // NOTE: This message is still experimental, and subject to change. It may be formally adopted in the future.\n message TripProperties {\n // Defines the identifier of a new trip that is a duplicate of an existing trip defined in (CSV) GTFS trips.txt\n // but will start at a different service date and/or time (defined using the TripProperties.start_date and\n // TripProperties.start_time fields). See definition of trips.trip_id in (CSV) GTFS. Its value must be different\n // than the ones used in the (CSV) GTFS. Required if schedule_relationship=DUPLICATED, otherwise this field must not\n // be populated and will be ignored by consumers.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string trip_id = 1;\n // Service date on which the DUPLICATED trip will be run, in YYYYMMDD format. Required if\n // schedule_relationship=DUPLICATED, otherwise this field must not be populated and will be ignored by consumers.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string start_date = 2;\n // Defines the departure start time of the trip when it’s duplicated. See definition of stop_times.departure_time\n // in (CSV) GTFS. Scheduled arrival and departure times for the duplicated trip are calculated based on the offset\n // between the original trip departure_time and this field. For example, if a GTFS trip has stop A with a\n // departure_time of 10:00:00 and stop B with departure_time of 10:01:00, and this field is populated with the value\n // of 10:30:00, stop B on the duplicated trip will have a scheduled departure_time of 10:31:00. Real-time prediction\n // delay values are applied to this calculated schedule time to determine the predicted time. For example, if a\n // departure delay of 30 is provided for stop B, then the predicted departure time is 10:31:30. Real-time\n // prediction time values do not have any offset applied to them and indicate the predicted time as provided.\n // For example, if a departure time representing 10:31:30 is provided for stop B, then the predicted departure time\n // is 10:31:30. This field is required if schedule_relationship is DUPLICATED, otherwise this field must not be\n // populated and will be ignored by consumers.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string start_time = 3;\n // Specifies the identifier of the shape of the vehicle travel path when the trip shape differs from the shape specified in (CSV) GTFS\n // or to specify it in real-time when it's not provided by (CSV) GTFS, such as a vehicle that takes differing paths based on rider demand. See definition of trips.shape_id in (CSV) GTFS.\n // If a shape is neither defined in (CSV) GTFS nor in real-time, the shape is considered unknown. This field can refer to a shape defined in the (CSV) GTFS in shapes.txt or a `Shape` in the same (protobuf) real-time feed. \n // The order of stops (stop sequences) for this trip must remain the same as (CSV) GTFS. \n // If it refers to a `Shape` entity in the same real-time feed, the value of this field should be the one of the `shape_id` inside the entity, and _not_ the `id` of `FeedEntity`.\n // Stops that are a part of the original trip but will no longer be made, such as when a detour occurs, should be marked as schedule_relationship=SKIPPED or more details can be provided via a `TripModifications` message.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future. \n optional string shape_id = 4;\n\n // Specifies the headsign for this trip when it differs from the original.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string trip_headsign = 5;\n\n // Specifies the name for this trip when it differs from the original.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string trip_short_name = 6;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features\n // and modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n optional TripProperties trip_properties = 6;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// Realtime positioning information for a given vehicle.\nmessage VehiclePosition {\n // The Trip that this vehicle is serving.\n // Can be empty or partial if the vehicle can not be identified with a given\n // trip instance.\n optional TripDescriptor trip = 1;\n\n // Additional information on the vehicle that is serving this trip.\n optional VehicleDescriptor vehicle = 8;\n\n // Current position of this vehicle.\n optional Position position = 2;\n\n // The stop sequence index of the current stop. The meaning of\n // current_stop_sequence (i.e., the stop that it refers to) is determined by\n // current_status.\n // If current_status is missing IN_TRANSIT_TO is assumed.\n optional uint32 current_stop_sequence = 3;\n // Identifies the current stop. The value must be the same as in stops.txt in\n // the corresponding GTFS feed.\n optional string stop_id = 7;\n\n enum VehicleStopStatus {\n // The vehicle is just about to arrive at the stop (on a stop\n // display, the vehicle symbol typically flashes).\n INCOMING_AT = 0;\n\n // The vehicle is standing at the stop.\n STOPPED_AT = 1;\n\n // The vehicle has departed and is in transit to the next stop.\n IN_TRANSIT_TO = 2;\n }\n // The exact status of the vehicle with respect to the current stop.\n // Ignored if current_stop_sequence is missing.\n optional VehicleStopStatus current_status = 4 [default = IN_TRANSIT_TO];\n\n // Moment at which the vehicle's position was measured. In POSIX time\n // (i.e., number of seconds since January 1st 1970 00:00:00 UTC).\n optional uint64 timestamp = 5;\n\n // Congestion level that is affecting this vehicle.\n enum CongestionLevel {\n UNKNOWN_CONGESTION_LEVEL = 0;\n RUNNING_SMOOTHLY = 1;\n STOP_AND_GO = 2;\n CONGESTION = 3;\n SEVERE_CONGESTION = 4; // People leaving their cars.\n }\n optional CongestionLevel congestion_level = 6;\n\n // The state of passenger occupancy for the vehicle or carriage.\n // Individual producers may not publish all OccupancyStatus values. Therefore, consumers\n // must not assume that the OccupancyStatus values follow a linear scale.\n // Consumers should represent OccupancyStatus values as the state indicated \n // and intended by the producer. Likewise, producers must use OccupancyStatus values that\n // correspond to actual vehicle occupancy states.\n // For describing passenger occupancy levels on a linear scale, see `occupancy_percentage`.\n // This field is still experimental, and subject to change. It may be formally adopted in the future.\n enum OccupancyStatus {\n // The vehicle or carriage is considered empty by most measures, and has few or no\n // passengers onboard, but is still accepting passengers.\n EMPTY = 0;\n\n // The vehicle or carriage has a large number of seats available.\n // The amount of free seats out of the total seats available to be\n // considered large enough to fall into this category is determined at the\n // discretion of the producer.\n MANY_SEATS_AVAILABLE = 1;\n\n // The vehicle or carriage has a relatively small number of seats available.\n // The amount of free seats out of the total seats available to be\n // considered small enough to fall into this category is determined at the\n // discretion of the feed producer.\n FEW_SEATS_AVAILABLE = 2;\n\n // The vehicle or carriage can currently accommodate only standing passengers.\n STANDING_ROOM_ONLY = 3;\n\n // The vehicle or carriage can currently accommodate only standing passengers\n // and has limited space for them.\n CRUSHED_STANDING_ROOM_ONLY = 4;\n\n // The vehicle or carriage is considered full by most measures, but may still be\n // allowing passengers to board.\n FULL = 5;\n\n // The vehicle or carriage is not accepting passengers, but usually accepts passengers for boarding.\n NOT_ACCEPTING_PASSENGERS = 6;\n\n // The vehicle or carriage doesn't have any occupancy data available at that time.\n NO_DATA_AVAILABLE = 7;\n\n // The vehicle or carriage is not boardable and never accepts passengers.\n // Useful for special vehicles or carriages (engine, maintenance carriage, etc…).\n NOT_BOARDABLE = 8;\n\n }\n // If multi_carriage_status is populated with per-carriage OccupancyStatus,\n // then this field should describe the entire vehicle with all carriages accepting passengers considered.\n optional OccupancyStatus occupancy_status = 9;\n\n // A percentage value indicating the degree of passenger occupancy in the vehicle.\n // The values are represented as an integer without decimals. 0 means 0% and 100 means 100%.\n // The value 100 should represent the total maximum occupancy the vehicle was designed for,\n // including both seated and standing capacity, and current operating regulations allow.\n // The value may exceed 100 if there are more passengers than the maximum designed capacity.\n // The precision of occupancy_percentage should be low enough that individual passengers cannot be tracked boarding or alighting the vehicle.\n // If multi_carriage_status is populated with per-carriage occupancy_percentage, \n // then this field should describe the entire vehicle with all carriages accepting passengers considered.\n // This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional uint32 occupancy_percentage = 10;\n\n // Carriage specific details, used for vehicles composed of several carriages\n // This message/field is still experimental, and subject to change. It may be formally adopted in the future.\n message CarriageDetails {\n\n // Identification of the carriage. Should be unique per vehicle.\n optional string id = 1;\n\n // User visible label that may be shown to the passenger to help identify\n // the carriage. Example: \"7712\", \"Car ABC-32\", etc...\n // This message/field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string label = 2;\n\n // Occupancy status for this given carriage, in this vehicle\n // This message/field is still experimental, and subject to change. It may be formally adopted in the future.\n optional OccupancyStatus occupancy_status = 3 [default = NO_DATA_AVAILABLE];\n\n // Occupancy percentage for this given carriage, in this vehicle.\n // Follows the same rules as \"VehiclePosition.occupancy_percentage\"\n // -1 in case data is not available for this given carriage (as protobuf defaults to 0 otherwise)\n // This message/field is still experimental, and subject to change. It may be formally adopted in the future.\n optional int32 occupancy_percentage = 4 [default = -1];\n\n // Identifies the order of this carriage with respect to the other\n // carriages in the vehicle's list of CarriageDetails.\n // The first carriage in the direction of travel must have a value of 1.\n // The second value corresponds to the second carriage in the direction\n // of travel and must have a value of 2, and so forth.\n // For example, the first carriage in the direction of travel has a value of 1.\n // If the second carriage in the direction of travel has a value of 3,\n // consumers will discard data for all carriages (i.e., the multi_carriage_details field).\n // Carriages without data must be represented with a valid carriage_sequence number and the fields \n // without data should be omitted (alternately, those fields could also be included and set to the \"no data\" values).\n // This message/field is still experimental, and subject to change. It may be formally adopted in the future.\n optional uint32 carriage_sequence = 5;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n\n // Details of the multiple carriages of this given vehicle.\n // The first occurrence represents the first carriage of the vehicle, \n // given the current direction of travel. \n // The number of occurrences of the multi_carriage_details \n // field represents the number of carriages of the vehicle.\n // It also includes non boardable carriages, \n // like engines, maintenance carriages, etc… as they provide valuable \n // information to passengers about where to stand on a platform.\n // This message/field is still experimental, and subject to change. It may be formally adopted in the future.\n repeated CarriageDetails multi_carriage_details = 11;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// An alert, indicating some sort of incident in the public transit network.\nmessage Alert {\n // Time when the alert should be shown to the user. If missing, the\n // alert will be shown as long as it appears in the feed.\n // If multiple ranges are given, the alert will be shown during all of them.\n repeated TimeRange active_period = 1;\n\n // Entities whose users we should notify of this alert.\n repeated EntitySelector informed_entity = 5;\n\n // Cause of this alert. If cause_detail is included, then Cause must also be included.\n enum Cause {\n UNKNOWN_CAUSE = 1;\n OTHER_CAUSE = 2; // Not machine-representable.\n TECHNICAL_PROBLEM = 3;\n STRIKE = 4; // Public transit agency employees stopped working.\n DEMONSTRATION = 5; // People are blocking the streets.\n ACCIDENT = 6;\n HOLIDAY = 7;\n WEATHER = 8;\n MAINTENANCE = 9;\n CONSTRUCTION = 10;\n POLICE_ACTIVITY = 11;\n MEDICAL_EMERGENCY = 12;\n }\n optional Cause cause = 6 [default = UNKNOWN_CAUSE];\n\n // What is the effect of this problem on the affected entity. If effect_detail is included, then Effect must also be included.\n enum Effect {\n NO_SERVICE = 1;\n REDUCED_SERVICE = 2;\n\n // We don't care about INsignificant delays: they are hard to detect, have\n // little impact on the user, and would clutter the results as they are too\n // frequent.\n SIGNIFICANT_DELAYS = 3;\n\n DETOUR = 4;\n ADDITIONAL_SERVICE = 5;\n MODIFIED_SERVICE = 6;\n OTHER_EFFECT = 7;\n UNKNOWN_EFFECT = 8;\n STOP_MOVED = 9;\n NO_EFFECT = 10;\n ACCESSIBILITY_ISSUE = 11;\n }\n optional Effect effect = 7 [default = UNKNOWN_EFFECT];\n\n // The URL which provides additional information about the alert.\n optional TranslatedString url = 8;\n\n // Alert header. Contains a short summary of the alert text as plain-text.\n optional TranslatedString header_text = 10;\n\n // Full description for the alert as plain-text. The information in the\n // description should add to the information of the header.\n optional TranslatedString description_text = 11;\n\n // Text for alert header to be used in text-to-speech implementations. This field is the text-to-speech version of header_text.\n optional TranslatedString tts_header_text = 12;\n\n // Text for full description for the alert to be used in text-to-speech implementations. This field is the text-to-speech version of description_text.\n optional TranslatedString tts_description_text = 13;\n\n // Severity of this alert.\n enum SeverityLevel {\n UNKNOWN_SEVERITY = 1;\n INFO = 2;\n WARNING = 3;\n SEVERE = 4;\n }\n\n optional SeverityLevel severity_level = 14 [default = UNKNOWN_SEVERITY];\n\n // TranslatedImage to be displayed along the alert text. Used to explain visually the alert effect of a detour, station closure, etc. The image must enhance the understanding of the alert. Any essential information communicated within the image must also be contained in the alert text.\n // The following types of images are discouraged : image containing mainly text, marketing or branded images that add no additional information. \n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional TranslatedImage image = 15;\n\n // Text describing the appearance of the linked image in the `image` field (e.g., in case the image can't be displayed\n // or the user can't see the image for accessibility reasons). See the HTML spec for alt image text - https://html.spec.whatwg.org/#alt.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional TranslatedString image_alternative_text = 16;\n\n\n // Description of the cause of the alert that allows for agency-specific language; more specific than the Cause. If cause_detail is included, then Cause must also be included.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional TranslatedString cause_detail = 17;\n\n // Description of the effect of the alert that allows for agency-specific language; more specific than the Effect. If effect_detail is included, then Effect must also be included.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional TranslatedString effect_detail = 18;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features\n // and modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n//\n// Low level data structures used above.\n//\n\n// A time interval. The interval is considered active at time 't' if 't' is\n// greater than or equal to the start time and less than the end time.\nmessage TimeRange {\n // Start time, in POSIX time (i.e., number of seconds since January 1st 1970\n // 00:00:00 UTC).\n // If missing, the interval starts at minus infinity.\n optional uint64 start = 1;\n\n // End time, in POSIX time (i.e., number of seconds since January 1st 1970\n // 00:00:00 UTC).\n // If missing, the interval ends at plus infinity.\n optional uint64 end = 2;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// A position.\nmessage Position {\n // Degrees North, in the WGS-84 coordinate system.\n required float latitude = 1;\n\n // Degrees East, in the WGS-84 coordinate system.\n required float longitude = 2;\n\n // Bearing, in degrees, clockwise from North, i.e., 0 is North and 90 is East.\n // This can be the compass bearing, or the direction towards the next stop\n // or intermediate location.\n // This should not be direction deduced from the sequence of previous\n // positions, which can be computed from previous data.\n optional float bearing = 3;\n\n // Odometer value, in meters.\n optional double odometer = 4;\n // Momentary speed measured by the vehicle, in meters per second.\n optional float speed = 5;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// A descriptor that identifies an instance of a GTFS trip, or all instances of\n// a trip along a route.\n// - To specify a single trip instance, the trip_id (and if necessary,\n// start_time) is set. If route_id is also set, then it should be same as one\n// that the given trip corresponds to.\n// - To specify all the trips along a given route, only the route_id should be\n// set. Note that if the trip_id is not known, then stop sequence ids in\n// TripUpdate are not sufficient, and stop_ids must be provided as well. In\n// addition, absolute arrival/departure times must be provided.\nmessage TripDescriptor {\n // The trip_id from the GTFS feed that this selector refers to.\n // For non frequency-based trips, this field is enough to uniquely identify\n // the trip. For frequency-based trip, start_time and start_date might also be\n // necessary. When schedule_relationship is DUPLICATED within a TripUpdate, the trip_id identifies the trip from\n // static GTFS to be duplicated. When schedule_relationship is DUPLICATED within a VehiclePosition, the trip_id\n // identifies the new duplicate trip and must contain the value for the corresponding TripUpdate.TripProperties.trip_id.\n optional string trip_id = 1;\n\n // The route_id from the GTFS that this selector refers to.\n optional string route_id = 5;\n\n // The direction_id from the GTFS feed trips.txt file, indicating the\n // direction of travel for trips this selector refers to.\n optional uint32 direction_id = 6;\n\n // The initially scheduled start time of this trip instance.\n // When the trip_id corresponds to a non-frequency-based trip, this field\n // should either be omitted or be equal to the value in the GTFS feed. When\n // the trip_id correponds to a frequency-based trip, the start_time must be\n // specified for trip updates and vehicle positions. If the trip corresponds\n // to exact_times=1 GTFS record, then start_time must be some multiple\n // (including zero) of headway_secs later than frequencies.txt start_time for\n // the corresponding time period. If the trip corresponds to exact_times=0,\n // then its start_time may be arbitrary, and is initially expected to be the\n // first departure of the trip. Once established, the start_time of this\n // frequency-based trip should be considered immutable, even if the first\n // departure time changes -- that time change may instead be reflected in a\n // StopTimeUpdate.\n // Format and semantics of the field is same as that of\n // GTFS/frequencies.txt/start_time, e.g., 11:15:35 or 25:15:35.\n optional string start_time = 2;\n // The scheduled start date of this trip instance.\n // Must be provided to disambiguate trips that are so late as to collide with\n // a scheduled trip on a next day. For example, for a train that departs 8:00\n // and 20:00 every day, and is 12 hours late, there would be two distinct\n // trips on the same time.\n // This field can be provided but is not mandatory for schedules in which such\n // collisions are impossible - for example, a service running on hourly\n // schedule where a vehicle that is one hour late is not considered to be\n // related to schedule anymore.\n // In YYYYMMDD format.\n optional string start_date = 3;\n\n // The relation between this trip and the static schedule. If a trip is done\n // in accordance with temporary schedule, not reflected in GTFS, then it\n // shouldn't be marked as SCHEDULED, but likely as ADDED.\n enum ScheduleRelationship {\n // Trip that is running in accordance with its GTFS schedule, or is close\n // enough to the scheduled trip to be associated with it.\n SCHEDULED = 0;\n\n // This value has been deprecated as the behavior was unspecified. \n // Use DUPLICATED for an extra trip that is the same as a scheduled trip except the start date or time, \n // or NEW for an extra trip that is unrelated to an existing trip.\n ADDED = 1 [deprecated = true];\n\n // A trip that is running with no schedule associated to it (GTFS frequencies.txt exact_times=0).\n // Trips with ScheduleRelationship=UNSCHEDULED must also set all StopTimeUpdates.ScheduleRelationship=UNSCHEDULED.\n UNSCHEDULED = 2;\n\n // A trip that existed in the schedule but was removed.\n CANCELED = 3;\n\n // A trip that replaces an existing trip in the schedule.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n REPLACEMENT = 5;\n\n // An extra trip that was added in addition to a running schedule, for example, to replace a broken vehicle or to\n // respond to sudden passenger load. Used with TripUpdate.TripProperties.trip_id, TripUpdate.TripProperties.start_date,\n // and TripUpdate.TripProperties.start_time to copy an existing trip from static GTFS but start at a different service\n // date and/or time. Duplicating a trip is allowed if the service related to the original trip in (CSV) GTFS\n // (in calendar.txt or calendar_dates.txt) is operating within the next 30 days. The trip to be duplicated is\n // identified via TripUpdate.TripDescriptor.trip_id. This enumeration does not modify the existing trip referenced by\n // TripUpdate.TripDescriptor.trip_id - if a producer wants to cancel the original trip, it must publish a separate\n // TripUpdate with the value of CANCELED or DELETED. If a producer wants to replace the original trip, a value of \n // `REPLACEMENT` should be used instead.\n //\n // Trips defined in GTFS frequencies.txt with exact_times that is\n // empty or equal to 0 cannot be duplicated. The VehiclePosition.TripDescriptor.trip_id for the new trip must contain\n // the matching value from TripUpdate.TripProperties.trip_id and VehiclePosition.TripDescriptor.ScheduleRelationship\n // must also be set to DUPLICATED.\n // Existing producers and consumers that were using the ADDED enumeration to represent duplicated trips must follow\n // the migration guide (https://github.com/google/transit/tree/master/gtfs-realtime/spec/en/examples/migration-duplicated.md)\n // to transition to the DUPLICATED enumeration.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n DUPLICATED = 6;\n\n\n // A trip that existed in the schedule but was removed and must not be shown to users.\n // DELETED should be used instead of CANCELED to indicate that a transit provider would like to entirely remove\n // information about the corresponding trip from consuming applications, so the trip is not shown as cancelled to\n // riders, e.g. a trip that is entirely being replaced by another trip.\n // This designation becomes particularly important if several trips are cancelled and replaced with substitute service.\n // If consumers were to show explicit information about the cancellations it would distract from the more important\n // real-time predictions.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n DELETED = 7;\n\n // An extra trip unrelated to any existing trips, for example, to respond to sudden passenger load.\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n NEW = 8;\n }\n optional ScheduleRelationship schedule_relationship = 4;\n\n message ModifiedTripSelector {\n // The 'id' from the FeedEntity in which the contained TripModifications object affects this trip.\n optional string modifications_id = 1;\n\n // The trip_id from the GTFS feed that is modified by the modifications_id\n optional string affected_trip_id = 2;\n\n // The initially scheduled start time of this trip instance, applied to the frequency based modified trip. Same definition as start_time in TripDescriptor.\n optional string start_time = 3;\n\n // The start date of this trip instance in YYYYMMDD format, applied to the modified trip. Same definition as start_date in TripDescriptor.\n optional string start_date = 4;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n\n // Linkage to any modifications done to this trip (shape changes, removal or addition of stops).\n // If this field is provided, the `trip_id`, `route_id`, `direction_id`, `start_time`, `start_date` fields of the `TripDescriptor` MUST be left empty, to avoid confusion by consumers that aren't looking for the `ModifiedTripSelector` value.\n optional ModifiedTripSelector modified_trip = 7;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// Identification information for the vehicle performing the trip.\nmessage VehicleDescriptor {\n // Internal system identification of the vehicle. Should be unique per\n // vehicle, and can be used for tracking the vehicle as it proceeds through\n // the system.\n optional string id = 1;\n\n // User visible label, i.e., something that must be shown to the passenger to\n // help identify the correct vehicle.\n optional string label = 2;\n\n // The license plate of the vehicle.\n optional string license_plate = 3;\n\n enum WheelchairAccessible {\n // The trip doesn't have information about wheelchair accessibility.\n // This is the **default** behavior. If the static GTFS contains a\n // _wheelchair_accessible_ value, it won't be overwritten.\n NO_VALUE = 0;\n\n // The trip has no accessibility value present.\n // This value will overwrite the value from the GTFS.\n UNKNOWN = 1;\n\n // The trip is wheelchair accessible.\n // This value will overwrite the value from the GTFS.\n WHEELCHAIR_ACCESSIBLE = 2;\n\n // The trip is **not** wheelchair accessible.\n // This value will overwrite the value from the GTFS.\n WHEELCHAIR_INACCESSIBLE = 3;\n }\n optional WheelchairAccessible wheelchair_accessible = 4 [default = NO_VALUE];\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// A selector for an entity in a GTFS feed.\nmessage EntitySelector {\n // The values of the fields should correspond to the appropriate fields in the\n // GTFS feed.\n // At least one specifier must be given. If several are given, then the\n // matching has to apply to all the given specifiers.\n optional string agency_id = 1;\n optional string route_id = 2;\n // corresponds to route_type in GTFS.\n optional int32 route_type = 3;\n optional TripDescriptor trip = 4;\n optional string stop_id = 5;\n // Corresponds to trip direction_id in GTFS trips.txt. If provided the\n // route_id must also be provided.\n optional uint32 direction_id = 6;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// An internationalized message containing per-language versions of a snippet of\n// text or a URL.\n// One of the strings from a message will be picked up. The resolution proceeds\n// as follows:\n// 1. If the UI language matches the language code of a translation,\n// the first matching translation is picked.\n// 2. If a default UI language (e.g., English) matches the language code of a\n// translation, the first matching translation is picked.\n// 3. If some translation has an unspecified language code, that translation is\n// picked.\nmessage TranslatedString {\n message Translation {\n // A UTF-8 string containing the message.\n required string text = 1;\n // BCP-47 language code. Can be omitted if the language is unknown or if\n // no i18n is done at all for the feed. At most one translation is\n // allowed to have an unspecified language tag.\n optional string language = 2;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n // At least one translation must be provided.\n repeated Translation translation = 1;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// An internationalized image containing per-language versions of a URL linking to an image\n// along with meta information\n// Only one of the images from a message will be retained by consumers. The resolution proceeds\n// as follows:\n// 1. If the UI language matches the language code of a translation,\n// the first matching translation is picked.\n// 2. If a default UI language (e.g., English) matches the language code of a\n// translation, the first matching translation is picked.\n// 3. If some translation has an unspecified language code, that translation is\n// picked.\n// NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\nmessage TranslatedImage {\n message LocalizedImage {\n // String containing an URL linking to an image\n // The image linked must be less than 2MB. \n // If an image changes in a significant enough way that an update is required on the consumer side, the producer must update the URL to a new one.\n // The URL should be a fully qualified URL that includes http:// or https://, and any special characters in the URL must be correctly escaped. See the following http://www.w3.org/Addressing/URL/4_URI_Recommentations.html for a description of how to create fully qualified URL values.\n required string url = 1;\n\n // IANA media type as to specify the type of image to be displayed. \n // The type must start with \"image/\"\n required string media_type = 2;\n\n // BCP-47 language code. Can be omitted if the language is unknown or if\n // no i18n is done at all for the feed. At most one translation is\n // allowed to have an unspecified language tag.\n optional string language = 3;\n\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n // At least one localized image must be provided.\n repeated LocalizedImage localized_image = 1;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// Describes the physical path that a vehicle takes when it's not part of the (CSV) GTFS,\n// such as for a detour. Shapes belong to Trips, and consist of a sequence of shape points.\n// Tracing the points in order provides the path of the vehicle. Shapes do not need to intercept\n// the location of Stops exactly, but all Stops on a trip should lie within a small distance of\n// the shape for that trip, i.e. close to straight line segments connecting the shape points\n// NOTE: This message is still experimental, and subject to change. It may be formally adopted in the future.\nmessage Shape {\n // Identifier of the shape. Must be different than any shape_id defined in the (CSV) GTFS.\n // This field is required as per reference.md, but needs to be specified here optional because \"Required is Forever\"\n // See https://developers.google.com/protocol-buffers/docs/proto#specifying_field_rules\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string shape_id = 1;\n\n // Encoded polyline representation of the shape. This polyline must contain at least two points and represent the full shape of the trip where it's used. \n // For more information about encoded polylines, see https://developers.google.com/maps/documentation/utilities/polylinealgorithm\n // This field is required as per reference.md, but needs to be specified here optional because \"Required is Forever\"\n // See https://developers.google.com/protocol-buffers/docs/proto#specifying_field_rules\n // NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n optional string encoded_polyline = 2;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// Describes a stop which is served by trips. All fields are as described in the GTFS-Static specification.\n// NOTE: This message is still experimental, and subject to change. It may be formally adopted in the future.\nmessage Stop {\n enum WheelchairBoarding {\n UNKNOWN = 0;\n AVAILABLE = 1;\n NOT_AVAILABLE = 2;\n }\n\n optional string stop_id = 1;\n optional TranslatedString stop_code = 2;\n optional TranslatedString stop_name = 3;\n optional TranslatedString tts_stop_name = 4;\n optional TranslatedString stop_desc = 5;\n optional float stop_lat = 6;\n optional float stop_lon = 7;\n optional string zone_id = 8;\n optional TranslatedString stop_url = 9;\n optional string parent_station = 11;\n optional string stop_timezone = 12;\n optional WheelchairBoarding wheelchair_boarding = 13 [default = UNKNOWN];\n optional string level_id = 14;\n optional TranslatedString platform_code = 15;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\nmessage TripModifications {\n // A `Modification` message replaces a span of n stop times from each affected trip starting at `start_stop_selector`.\n message Modification {\n // The stop selector of the first stop_time of the original trip that is to be affected by this modification.\n // Used in conjuction with `end_stop_selector`. \n // `start_stop_selector` is required and is used to define the reference stop used with `travel_time_to_stop`.\n optional StopSelector start_stop_selector = 1;\n\n // The stop selector of the last stop of the original trip that is to be affected by this modification. \n // The selection is inclusive, so if only one stop_time is replaced by that modification, `start_stop_selector` and `end_stop_selector` must be equivalent.\n // If no stop_time is replaced, `end_stop_selector` must not be provided. It's otherwise required.\n optional StopSelector end_stop_selector = 2;\n\n // The number of seconds of delay to add to all departure and arrival times following the end of this modification. \n // If multiple modifications apply to the same trip, the delays accumulate as the trip advances. \n optional int32 propagated_modification_delay = 3 [default = 0];\n\n // A list of replacement stops, replacing those of the original trip. \n // The length of the new stop times may be less, the same, or greater than the number of replaced stop times. \n repeated ReplacementStop replacement_stops = 4;\n\n // An `id` value from the `FeedEntity` message that contains the `Alert` describing this Modification for user-facing communication.\n optional string service_alert_id = 5;\n\n // This timestamp identifies the moment when the modification has last been changed.\n // In POSIX time (i.e., number of seconds since January 1st 1970 00:00:00 UTC).\n optional uint64 last_modified_time = 6;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n\n message SelectedTrips {\n // A list of trips affected with this replacement that all have the same new `shape_id`. A `TripUpdate` with `schedule_relationship=REPLACEMENT` must not already exist for the trip.\n repeated string trip_ids = 1;\n // The ID of the new shape for the modified trips in this SelectedTrips. \n // May refer to a new shape added using a `Shape` message in the same GTFS-RT feed, or to an existing shape defined in the GTFS-Static feed’s shapes.txt. \n // If it refers to a `Shape` entity in the real-time feed, the value of this field should be the one of the `shape_id` inside the entity, and _not_ the `id` of `FeedEntity`.\n optional string shape_id = 2;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n }\n\n // A list of selected trips affected by this TripModifications.\n repeated SelectedTrips selected_trips = 1;\n\n // A list of start times in the real-time trip descriptor for the trip_id defined in trip_ids. \n // Useful to target multiple departures of a trip_id in a frequency-based trip.\n repeated string start_times = 2;\n\n // Dates on which the modifications occurs, in the YYYYMMDD format. Producers SHOULD only transmit detours occurring within the next week.\n // The dates provided should not be used as user-facing information, if a user-facing start and end date needs to be provided, they can be provided in the linked service alert with `service_alert_id`\n repeated string service_dates = 3;\n\n // A list of modifications to apply to the affected trips. \n repeated Modification modifications = 4;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\n// Select a stop by stop sequence or by stop_id. At least one of the two values must be provided.\nmessage StopSelector {\n // Must be the same as in stop_times.txt in the corresponding GTFS feed.\n optional uint32 stop_sequence = 1;\n // Must be the same as in stops.txt in the corresponding GTFS feed.\n optional string stop_id = 2;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// NOTE: This field is still experimental, and subject to change. It may be formally adopted in the future.\nmessage ReplacementStop {\n // The difference in seconds between the arrival time at this stop and the arrival time at the reference stop. The reference stop is the stop prior to start_stop_selector. If the modification begins at the first stop of the trip, then the first stop of the trip is the reference stop.\n // This value MUST be monotonically increasing and may only be a negative number if the first stop of the original trip is the reference stop.\n optional int32 travel_time_to_stop = 1;\n\n // The replacement stop ID which will now be visited by the trip. May refer to a new stop added using a GTFS-RT `Stop` message in the same GTFS-RT feed, or to an existing stop defined in the (CSV) GTFS feed’s `stops.txt`.\n // If it refers to a `Shape` entity in the real-time feed, the value of this field should be the one of the `stop_id` inside the entity, and _not_ the `id` of `FeedEntity`. The replacement stop MUST have `location_type=0` (routable stops).\n optional string stop_id = 2;\n\n // The extensions namespace allows 3rd-party developers to extend the\n // GTFS Realtime Specification in order to add and evaluate new features and\n // modifications to the spec.\n extensions 1000 to 1999;\n\n // The following extension IDs are reserved for private use by any organization.\n extensions 9000 to 9999;\n}\n\n// Copyright 2012 Metropolitan Transportation Authority\n//\n// Protocol definition NYCT-specific extensions to GTFS-realtime.\n//\n// As originally posted at:\n//\n// https://groups.google.com/d/msg/gtfs-realtime/KWJhkXH0kBg/8rlRMxiL-ysJ\n\n// syntax = \"proto2\";\n\n// import \"com/google/transit/realtime/gtfs-realtime.proto\";\n\n// option java_package = \"com.google.transit.realtime\";\n// package transit_realtime;\n\nmessage TripReplacementPeriod {\n // The replacement period is for this route\n optional string route_id = 1;\n // The start time is omitted, the end time is currently now + 30 minutes for\n // all routes of the A division\n optional transit_realtime.TimeRange replacement_period = 2;\n}\n\n// NYCT Subway extensions for the feed header\nmessage NyctFeedHeader {\n // Version of the NYCT Subway extensions\n // The current version is 1.0\n required string nyct_subway_version = 1;\n // For the NYCT Subway, the GTFS-realtime feed replaces any scheduled\n // trip within the trip_replacement_period. \n // This feed is a full dataset, it contains all trips starting \n // in the trip_replacement_period. If a trip from the static GTFS is not\n // found in the GTFS-realtime feed, it should be considered as cancelled.\n // The replacement period can be different for each route, so here is \n // a list of the routes where the trips in the feed replace all \n // scheduled trips within the replacement period.\n repeated TripReplacementPeriod trip_replacement_period = 2;\n}\n\nextend FeedHeader {\n optional NyctFeedHeader nyct_feed_header = 1001;\n}\n\n// NYCT Subway extensions for the trip descriptor\nmessage NyctTripDescriptor {\n // The nyct_train_id is meant for internal use only. It provides an\n // easy way to associated GTFS-realtime trip identifiers with NYCT rail\n // operations identifier \n // \n // The ATS office system assigns unique train identification (Train ID) to\n // each train operating within or ready to enter the mainline of the\n // monitored territory. An example of this is 06 0123+ PEL/BBR and is decoded\n // as follows: \n // \n // The first character represents the trip type designator. 0 identifies a\n // scheduled revenue trip. Other revenue trip values that are a result of a\n // change to the base schedule include; [= reroute], [/ skip stop], [$ turn\n // train] also known as shortly lined service. \n // \n // The second character 6 represents the trip line i.e. number 6 train The\n // third set of characters identify the decoded origin time. The last\n // character may be blank \"on the whole minute\" or + \"30 seconds\" \n // \n // Note: Origin times will not change when there is a trip type change. This\n // is followed by a three character \"Origin Location\" / \"Destination\n // Location\"\n optional string train_id = 1;\n\n // This trip has been assigned to a physical train. If true, this trip is\n // already underway or most likely will depart shortly. \n //\n // Train Assignment is a function of the Automatic Train Supervision (ATS)\n // office system used by NYCT Rail Operations to monitor and track train\n // movements. ATS provides the ability to \"assign\" the nyct_train_id\n // attribute when a physical train is at its origin terminal. These assigned\n // trips have the is_assigned field set in the TripDescriptor.\n //\n // When a train is at a terminal but has not been given a work program it is\n // declared unassigned and is tagged as such. Unassigned trains can be moved\n // to a storage location or assigned a nyct_train_id when a determination for\n // service is made.\n optional bool is_assigned = 2; \n\n // The direction the train is moving. \n enum Direction {\n NORTH = 1;\n EAST = 2;\n SOUTH = 3;\n WEST = 4; \n }\n // Uptown and Bronx-bound trains are moving NORTH.\n // Times Square Shuttle to Grand Central is also northbound.\n //\n // Downtown and Brooklyn-bound trains are moving SOUTH.\n // Times Square Shuttle to Times Square is also southbound.\n // \n // EAST and WEST are not used currently.\n optional Direction direction = 3;\n}\n\nextend transit_realtime.TripDescriptor {\n optional NyctTripDescriptor nyct_trip_descriptor = 1001;\n}\n\n// NYCT Subway extensions for the stop time update\nmessage NyctStopTimeUpdate {\n // Provides the planned station arrival track. The following is the Manhattan\n // track configurations:\n // 1: southbound local\n // 2: southbound express\n // 3: northbound express\n // 4: northbound local\n //\n // In the Bronx (except Dyre Ave line)\n // M: bi-directional express (in the AM express to Manhattan, in the PM\n // express away).\n //\n // The Dyre Ave line is configured:\n // 1: southbound\n // 2: northbound\n // 3: bi-directional\n optional string scheduled_track = 1;\n\n // This is the actual track that the train is operating on and can be used to\n // determine if a train is operating according to its current schedule\n // (plan).\n // \n // The actual track is known only shortly before the train reaches a station,\n // typically not before it leaves the previous station. Therefore, the NYCT\n // feed sets this field only for the first station of the remaining trip.\n // \n // Different actual and scheduled track is the result of manually rerouting a\n // train off it scheduled path. When this occurs, prediction data may become\n // unreliable since the train is no longer operating in accordance to its\n // schedule. The rules engine for the 'countdown' clocks will remove this\n // train from all schedule stations.\n optional string actual_track = 2;\n}\n\nextend transit_realtime.TripUpdate.StopTimeUpdate {\n optional NyctStopTimeUpdate nyct_stop_time_update = 1001;\n}",[186],"e6b2d193-5c59-4b2e-ae90-7408212e22ed","feed-loader.ts","a6fe2a12-5c29-11f1-bb46-ee650bb23af1",91,["D",1783176917820],1,"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { FeedMessage } from \"./types.ts\";\n\nexport type ParsedFeed = ReturnType;\n\n// Feeds are refreshed on a 15-minute cron (see feed-fetcher.ts). If a blob\n// is older than this, the cron has stalled and the data is unreliable\n// enough to treat as unavailable rather than serve silently.\nconst STALE_THRESHOLD_MS = 30 * 60 * 1000;\n\ntype StoredFeed = { feed: ParsedFeed; fetchedAt: string };\n\ntype LoadResult =\n | { feedId: string; status: \"ok\"; feed: ParsedFeed }\n | { feedId: string; status: \"missing\" }\n | { feedId: string; status: \"stale\"; ageMs: number; fetchedAt: string };\n\nasync function loadFeed(feedId: string): Promise {\n const stored = await blob.getJSON(`feed:${feedId}`) as StoredFeed | undefined;\n if (!stored) {\n return { feedId, status: \"missing\" };\n }\n const ageMs = Date.now() - new Date(stored.fetchedAt).getTime();\n if (ageMs > STALE_THRESHOLD_MS) {\n return { feedId, status: \"stale\", ageMs, fetchedAt: stored.fetchedAt };\n }\n return { feedId, status: \"ok\", feed: stored.feed };\n}\n\nexport async function loadFeeds(\n feedIds: string[],\n): Promise<{ feeds: ParsedFeed[]; feedErrors: string[] }> {\n const results = await Promise.all(feedIds.map(loadFeed));\n\n const feeds: ParsedFeed[] = [];\n const feedErrors: string[] = [];\n for (const result of results) {\n if (result.status === \"ok\") {\n feeds.push(result.feed);\n continue;\n }\n feedErrors.push(result.feedId);\n console.error(JSON.stringify({\n event: \"feed_load_error\",\n feedId: result.feedId,\n reason: result.status,\n ...(result.status === \"stale\" && { ageMs: result.ageMs, fetchedAt: result.fetchedAt }),\n }));\n }\n return { feeds, feedErrors };\n}\n",[193],"9cfa333c-4b64-4546-8cb6-f702cb4804b5",["D",1783177329050],[28],"068e977a-efbe-417d-b83f-bd755e8dd128","feed-aggregator.ts","ad4d74ea-5c29-11f1-a149-ee650bb23af1",86,["D",1783088596008],"import { type FeedEntityType, type StopTimeUpdateType } from \"./types.ts\";\nimport type { ParsedFeed } from \"./feed-loader.ts\";\n\ntype VehicleStatus = \"STOPPED_AT\" | \"IN_TRANSIT_TO\" | \"INCOMING_AT\";\n\nexport type RawTrain = {\n entity: FeedEntityType;\n stop: StopTimeUpdateType;\n vehicleStatus: VehicleStatus | null;\n atStation: boolean;\n};\n\nexport function aggregateFeeds(\n feeds: ParsedFeed[],\n stationId: string,\n): { northbound: RawTrain[]; southbound: RawTrain[] } {\n const northStopId = `${stationId}N`;\n const southStopId = `${stationId}S`;\n\n const vehicleStatusMap = new Map();\n const northbound: { entity: FeedEntityType; stop: StopTimeUpdateType }[] = [];\n const southbound: { entity: FeedEntityType; stop: StopTimeUpdateType }[] = [];\n\n for (const feed of feeds) {\n for (const entity of feed.entity) {\n if (entity.vehicle?.currentStatus && entity.vehicle.trip?.tripId) {\n vehicleStatusMap.set(entity.vehicle.trip.tripId, {\n status: entity.vehicle.currentStatus as VehicleStatus,\n stopId: entity.vehicle.stopId ?? null,\n });\n }\n if (entity.tripUpdate) {\n const northStop = entity.tripUpdate.stopTimeUpdate?.find((s) => s.stopId === northStopId);\n const southStop = entity.tripUpdate.stopTimeUpdate?.find((s) => s.stopId === southStopId);\n if (northStop) northbound.push({ entity, stop: northStop });\n if (southStop) southbound.push({ entity, stop: southStop });\n }\n }\n }\n\n const resolve = (entity: FeedEntityType, stopId: string): { vehicleStatus: VehicleStatus | null; atStation: boolean } => {\n const vs = vehicleStatusMap.get(entity.tripUpdate!.trip.tripId);\n if (!vs) return { vehicleStatus: null, atStation: false };\n const atStation = vs.status === \"STOPPED_AT\" && vs.stopId === stopId;\n const arrivingAtStation = vs.status === \"INCOMING_AT\" && vs.stopId === stopId;\n return {\n vehicleStatus: (atStation || arrivingAtStation) ? vs.status : null,\n atStation,\n };\n };\n\n return {\n northbound: northbound.map(({ entity, stop }) => ({ entity, stop, ...resolve(entity, northStopId) })),\n southbound: southbound.map(({ entity, stop }) => ({ entity, stop, ...resolve(entity, southStopId) })),\n };\n}\n",[204],"7b4e018e-5c2a-11f1-859f-ee650bb23af1","example.ts",76,["D",1780147295220],12,"import { getArrivals } from \"./utils.ts\";\nimport { STATIONS } from \"./stops.ts\";\n\nconst ROUTE_COLORS: Record = {\n \"1\": \"#EE352E\", \"2\": \"#EE352E\", \"3\": \"#EE352E\",\n \"4\": \"#00933C\", \"5\": \"#00933C\", \"6\": \"#00933C\",\n \"7\": \"#B933AD\",\n \"A\": \"#0039A6\", \"C\": \"#0039A6\", \"E\": \"#0039A6\",\n \"B\": \"#FF6319\", \"D\": \"#FF6319\", \"F\": \"#FF6319\", \"M\": \"#FF6319\",\n \"G\": \"#6CBE45\",\n \"J\": \"#996633\", \"Z\": \"#996633\",\n \"L\": \"#A7A9AC\",\n \"N\": \"#FCCC0A\", \"Q\": \"#FCCC0A\", \"R\": \"#FCCC0A\", \"W\": \"#FCCC0A\",\n \"S\": \"#808183\", \"FS\": \"#808183\", \"GS\": \"#808183\", \"H\": \"#808183\",\n \"SIR\": \"#0039A6\",\n};\n\nconst VEHICLE_BADGES: Record = {\n \"STOPPED_AT\": `AT STOP`,\n \"INCOMING_AT\": `ARRIVING`,\n \"IN_TRANSIT_TO\": `EN ROUTE`,\n};\n\nfunction minutesAway(fetchedAt: string, arrivalTime: string | null): string {\n if (!arrivalTime) return \"—\";\n const diff = Math.round((new Date(arrivalTime).getTime() - new Date(fetchedAt).getTime()) / 60000);\n if (diff <= 0) return \"Now\";\n return `${diff} min`;\n}\n\nfunction bullet(route: string): string {\n const color = ROUTE_COLORS[route] ?? \"#555\";\n const textColor = route === \"N\" || route === \"Q\" || route === \"R\" || route === \"W\" ? \"#000\" : \"#fff\";\n return `${route}`;\n}\n\nfunction trainRow(train: ReturnType, fetchedAt: string): string {\n const mins = minutesAway(fetchedAt, train.arrivalTime);\n const delayed = train.delaySeconds && train.delaySeconds > 60\n ? `+${Math.round(train.delaySeconds / 60)}m late`\n : \"\";\n const statusIcon = train.vehicleStatus ? (VEHICLE_BADGES[train.vehicleStatus] ?? \"\") : \"\";\n const track = train.scheduledTrack\n ? `Track ${train.actual !== train.scheduled ? `~~${train.scheduled}~~ ${train.actual}` : train.scheduled}`\n : \"\";\n return `\n

\n ${bullet(train.route)}\n

${train.destination ?? train.trainId}

${statusIcon}${track}

${mins}

${delayed}

`;\n}\n\nfunction flattenTrain(t: NonNullable>>[\"northbound\"][\"trains\"][number]) {\n return {\n trainId: t.trainId,\n route: t.route,\n destination: t.destination,\n arrivalTime: t.timing.arrivalTime,\n delaySeconds: t.timing.delaySeconds,\n vehicleStatus: t.status.vehicleStatus,\n scheduled: t.track.scheduled,\n actual: t.track.actual,\n };\n}\n\nfunction directionPanel(label: string, trains: NonNullable>>[\"northbound\"][\"trains\"], fetchedAt: string): string {\n const rows = trains.length\n ? trains.map((t) => trainRow(flattenTrain(t), fetchedAt)).join(\"\")\n : `

No trains scheduled

`;\n return `\n

${label}

\n ${rows}\n

`;\n}\n\nfunction stationOptions(selected: string): string {\n return Object.entries(STATIONS)\n .sort((a, b) => a[1].name.localeCompare(b[1].name))\n .map(([id, s]) => ``)\n .join(\"\");\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const stationId = url.searchParams.get(\"stationId\") ?? \"A44\";\n\n let bodyHtml: string;\n\n try {\n const data = await getArrivals(stationId);\n if (!data) {\n bodyHtml = `

Unknown station: ${stationId}

`;\n } else {\n const feedErrorBanner = data.feedErrors?.length\n ? `

⚠ Partial data — feed error: ${data.feedErrors.join(\", \")}

`\n : \"\";\n bodyHtml = `\n

${data.stationName}

Updated ${new Date(data.fetchedAt).toLocaleTimeString()}

\n ${feedErrorBanner}\n

\n ${directionPanel(\"Northbound\", data.northbound.trains, data.fetchedAt)}\n ${directionPanel(\"Southbound\", data.southbound.trains, data.fetchedAt)}\n

`;\n }\n } catch (_err) {\n bodyHtml = `

Failed to fetch arrival data. Please try again.

`;\n }\n\n const html = `\n\n\n \n \n NYC Subway Times\n \n \n\n\n

\n \n

${bodyHtml}

\n\n`;\n\n return new Response(html, { headers: { \"Content-Type\": \"text/html;charset=UTF-8\" } });\n}\n",[211],"pulls","branches","forks","envVars",{"_224":63,"_226":63},"connections",{"_224":63,"_225":63},"count","unfilledCount","emptyCount",{"_43":210,"_32":211,"_30":57,"_144":-5,"_41":42,"_40":212,"_146":59,"_38":265,"_13":214,"_33":182,"_35":215,"_24":25,"_150":-5,"_238":266,"_27":267},{"_43":203,"_32":204,"_30":205,"_144":-5,"_41":42,"_40":206,"_146":25,"_38":262,"_13":165,"_33":166,"_35":208,"_24":25,"_150":-5,"_238":263,"_27":264},{"_43":200,"_32":28,"_30":31,"_144":-5,"_41":42,"_40":14,"_146":25,"_38":259,"_13":148,"_33":34,"_35":37,"_24":25,"_150":-5,"_238":260,"_27":261},{"_43":192,"_32":193,"_30":194,"_144":-5,"_41":42,"_40":195,"_146":59,"_38":256,"_13":197,"_33":166,"_35":198,"_24":25,"_150":-5,"_238":257,"_27":258},{"_43":185,"_32":186,"_30":187,"_144":-5,"_41":42,"_40":188,"_146":59,"_38":253,"_13":148,"_33":20,"_35":190,"_24":25,"_150":-5,"_238":254,"_27":255},{"_43":176,"_32":177,"_30":178,"_144":-5,"_41":42,"_40":179,"_146":25,"_38":250,"_13":181,"_33":182,"_35":183,"_24":25,"_150":-5,"_238":251,"_27":252},{"_43":169,"_32":170,"_30":171,"_144":-5,"_41":42,"_40":172,"_146":59,"_38":247,"_13":165,"_33":20,"_35":174,"_24":25,"_150":-5,"_238":248,"_27":249},{"_43":160,"_32":161,"_30":162,"_144":-5,"_41":42,"_40":163,"_146":25,"_38":244,"_13":165,"_33":166,"_35":167,"_24":25,"_150":-5,"_238":245,"_27":246},{"_43":152,"_32":153,"_30":154,"_144":-5,"_41":42,"_40":155,"_146":25,"_38":241,"_13":157,"_33":20,"_35":158,"_24":25,"_150":-5,"_238":242,"_27":243},{"_43":141,"_32":142,"_30":143,"_144":-5,"_41":42,"_40":145,"_146":59,"_38":237,"_13":148,"_33":20,"_35":149,"_24":25,"_150":-5,"_238":239,"_27":240},["D",1780146967344],"children",[],[142],["D",1783088586616],[],[153],["D",1780153298230],[],[161],["D",1780146927644],[],[170],["D",1783087579696],[],[177],["D",1772165351414],[],[186],["D",1783176917820],[],[193],["D",1783177329050],[],[28],["D",1783088596008],[],[204],["D",1780147295220],[],[211],["D",1772079993386],["D",1789524636084],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":306,"_307":308,"_309":310,"_311":25,"_312":25,"_313":25,"_314":59,"_315":-5,"_316":-7,"_317":-7,"_318":63,"_319":25,"_320":25,"_321":-5,"_322":25,"_323":25,"_324":25,"_325":-5},"ENV",{"_277":278,"_279":280,"_281":90,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305},"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 · v94