[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_222":223,"_224":225},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_38":-7,"_128":-5,"_19":129,"_130":131,"_132":133,"_134":135,"_136":137,"_21":138,"_139":140,"_141":142,"_143":24,"_144":145,"_146":147,"_148":-5,"_149":-5,"_150":151},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","keisisqrl","name","amtrak-gtfs-rt-mcp","branchName","main","path","refresh-gtfs.ts","project",{"_32":71,"_13":14,"_36":72,"_73":-5,"_74":24,"_75":76,"_77":76,"_78":79,"_80":81,"_30":67,"_82":83,"_84":24,"_85":-5,"_86":-5,"_87":26,"_40":41,"_88":89,"_90":91,"_92":93,"_94":-5,"_95":96,"_97":96,"_98":99,"_100":99,"_101":99,"_102":96,"_103":96,"_52":104,"_105":106,"_107":108,"_109":24},"file",{"_62":63,"_13":18,"_64":65,"_66":24,"_70":-5},"isDirectory",false,"page",0,"history",[31],"hasNext","userId",{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":53,"_21":54,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":60},"id","24032343-da48-49d7-8d67-d3bf49369783","branchId","1825b209-ac72-41e6-a980-02e7cc391063","createdAt",["D",1787253254803],"version",15,"orgId","019adb55-d35c-728f-b295-f00e23c346f1","parentId","cdb0e0cc-f370-49a2-9248-2f332de0700f","incomingCommitId","aiChatMessageId","b814935d-6ff0-41d8-bf5c-5c0462ff3820","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_32":67,"_40":41,"_11":12,"_68":69},{"_62":63,"_13":18,"_64":65,"_66":24},"pull","merge","revert","multiple","commits",[61],{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":-5,"_49":-5,"_50":-5,"_51":-5,"_52":53,"_21":54,"_55":-5,"_56":-5,"_57":-5},"fileId","5546a9aa-9ccb-11f1-8c77-1607ee4eb77e","fileType","interval","deleted","019adb55-d35c-728f-b295-ec7539176851","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM2Rnkza0hHT2QwSXJDb0JIQTR0M21kc256UCJ9","deletedAtVersion","2cfb9927-155e-47cc-9f73-c923b21f7f89",["D",1787252879017],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Public read-only MCP server for Amtrak GTFS-RT realtime data","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/b311a2b1-bbdf-44a0-32bf-805991479f00/square512?exp=1789570799&sig=8774c2ce159458ccd598a9e6ba6085be27243f94361e9c052cf665df58a6da37","pinnedFileId","01a02092-b0af-72ec-bba6-7217fa87c97d","pinPreview","pinMigrated","screenshotVersion","likeCount","tursoName","2cfb9927155e47cc9f73c923b21f7f89","tursoHostname","2cfb9927155e47cc9f73c923b21f7f89-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789520505489],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_127":69},"org",{"_11":12,"_123":-5,"_68":69,"_30":67,"_124":125,"_126":24},"branch",{"_38":110,"_13":16,"_32":35,"_111":71,"_112":113,"_114":115,"_116":76,"_117":118,"_119":120,"_121":14,"_122":12},"isOwned",35,"projectId","forkedBranchId","4317995d-9bca-44ba-8f1c-e817322f354f","forkedBranchVersion",33,"forkedProjectPrivacy","forkedProjectId","c5a66f73-8318-4d99-b192-14a8e864ebc4","forkedProjectOrgId","019aa807-52c2-709c-928b-2029bae9a558","projectName","userHandle","displayName","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":71,"_13":14,"_36":217,"_73":-5,"_74":24,"_75":76,"_77":76,"_78":79,"_80":81,"_30":67,"_82":83,"_84":24,"_85":-5,"_86":-5,"_87":26,"_40":41,"_88":89,"_90":91,"_92":218,"_94":-5,"_95":96,"_97":96,"_98":99,"_100":99,"_101":99,"_102":96,"_103":96,"_52":219,"_105":220,"_107":221,"_109":24},"tree",[181,182,183,184],"files",[181,182,183,184],"counts",{"_170":26,"_171":172,"_173":26,"_174":175,"_176":177},"contents",[],{"_32":162,"_13":18,"_62":63,"_42":-5,"_34":35,"_163":39,"_164":147,"_36":165,"_38":26,"_64":65,"_166":167,"_66":24,"_168":-5,"_17":169},"upstreamProject",{"_32":118,"_13":158,"_78":159,"_80":81,"_75":76,"_52":160},"upstreamBranch",{"_32":113,"_36":152,"_153":154,"_13":16,"_111":118,"_38":110,"_112":-5,"_114":-5,"_155":156,"_73":-5,"_109":24,"_75":76,"_122":157,"_40":120,"_121":158},"emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},["D",1787154356274],"updatedAt",["D",1788980495343],"lockfileKey","1788980495999-esm.town_v_templates_mcp-server@35-main","templates","mcp-server","a simple mcp server",{"_11":157,"_127":161},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789570799&sig=257a5acfa0921f3bba1b6e04c40af81b331d69d65dd78c28728d8fa984364db5","4f89f110-1811-4e46-bb57-bb5ff66b6b5d","branchVersion","latest",["D",1787253254803],"content","import { ingestGtfs } from \"./ingest-gtfs.ts\";\n\n/** Refresh the static GTFS schedule data in SQLite from the Amtrak GTFS.zip. */\nexport default async function () {\n await ingestGtfs();\n}\n","label",[18],"pulls","branches",1,"forks","envVars",{"_178":26,"_180":26},"connections",{"_178":26,"_179":26},"count","unfilledCount","emptyCount",{"_32":209,"_13":210,"_62":211,"_42":-5,"_34":35,"_163":110,"_164":147,"_36":212,"_38":213,"_64":21,"_166":214,"_66":24,"_168":-5,"_186":215,"_17":216},{"_32":199,"_13":200,"_62":201,"_42":-5,"_34":35,"_163":202,"_164":147,"_36":203,"_38":204,"_64":205,"_166":206,"_66":24,"_168":-5,"_186":207,"_17":208},{"_32":189,"_13":190,"_62":83,"_42":-5,"_34":35,"_163":191,"_164":147,"_36":192,"_38":193,"_64":194,"_166":195,"_66":24,"_168":196,"_186":197,"_17":198},{"_32":162,"_13":18,"_62":63,"_42":-5,"_34":35,"_163":39,"_164":147,"_36":185,"_38":26,"_64":65,"_166":167,"_66":24,"_168":-5,"_186":187,"_17":188},["D",1787253254803],"children",[],[18],"48d178a2-95cd-4bf4-a2fb-f29e2cb3b55e","main.ts",34,["D",1787253783810],13,"http","import {\n createMcpHandler,\n McpServer,\n} from \"npm:@modelcontextprotocol/server@2\";\nimport * as z from \"npm:zod@4/v4\";\nimport GtfsRealtimeBindings from \"npm:gtfs-realtime-bindings\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst FEED_URL = \"https://asm-backend.transitdocs.com/gtfs/amtrak\";\nconst FEED_CACHE_KEY = \"gtfsrt_feed_v1\";\nconst FEED_CACHE_TTL_MS = 60 * 1000; // 60 seconds\nconst GTFS_DB_NOTE =\n \"Static GTFS table data is queried from this val's SQLite database, loaded from https://content.amtrak.com/content/gtfs/GTFS.zip by the ingest-gtfs.ts script.\";\n\n/** Run a SQL query against this val's GTFS database and return the rows. */\nasync function q(sql: string, args: (string | number | null)[] = []) {\n const res = await sqlite.execute({ sql, args });\n return res.rows as Record[];\n}\n\n/**\n * Convert a GTFS-RT epoch-seconds value to an ISO string.\n * Values may be a number, an int64 string, or a protobufjs Long instance\n * (which exposes a `.toNumber()` method).\n */\nfunction toIso(sec?: number | string | { toNumber(): number } | null): string | null {\n if (sec === undefined || sec === null || sec === \"\") return null;\n const n = typeof sec === \"object\" && typeof sec.toNumber === \"function\"\n ? sec.toNumber()\n : Number(sec);\n if (!Number.isFinite(n)) return null;\n return new Date(n * 1000).toISOString();\n}\n\n/** Ensures the GTFS-RT cache table exists (created once per instance). */\nlet cacheTableReady: Promise | null = null;\n\n/**\n * Fetch and decode the GTFS-RT feed into its protobuf message, serving the raw\n * feed body from a 60-second SQLite cache. All realtime tools share this cache,\n * so the upstream feed is fetched at most once per minute.\n */\nasync function getFeed() {\n if (!cacheTableReady) {\n cacheTableReady = sqlite.execute(\n `CREATE TABLE IF NOT EXISTS rtcache (\n key TEXT PRIMARY KEY,\n data TEXT,\n fetched_at INTEGER\n )`,\n ).then(() => {});\n }\n await cacheTableReady;\n\n const now = Date.now();\n const cached = await sqlite.execute(\n \"SELECT data, fetched_at FROM rtcache WHERE key = ?\",\n [FEED_CACHE_KEY],\n );\n const row = cached.rows[0];\n if (\n row &&\n typeof row.data === \"string\" &&\n typeof row.fetched_at === \"number\" &&\n now - row.fetched_at < FEED_CACHE_TTL_MS\n ) {\n const bytes = Uint8Array.from(atob(row.data), (c) => c.charCodeAt(0));\n return GtfsRealtimeBindings.transit_realtime.FeedMessage.decode(bytes);\n }\n\n const res = await fetch(FEED_URL, {\n headers: { Accept: \"application/x-protobuf, application/octet-stream\" },\n });\n if (!res.ok) {\n throw new Error(`GTFS-RT feed request failed: ${res.status} ${res.statusText}`);\n }\n const bytes = new Uint8Array(await res.arrayBuffer());\n\n let binary = \"\";\n for (let i = 0; i < bytes.length; i++) binary += String.fromCharCode(bytes[i]);\n await sqlite.execute(\n \"INSERT OR REPLACE INTO rtcache (key, data, fetched_at) VALUES (?,?,?)\",\n [FEED_CACHE_KEY, btoa(binary), now],\n );\n\n return GtfsRealtimeBindings.transit_realtime.FeedMessage.decode(bytes);\n}\n\nfunction mapTrip(trip: any) {\n return {\n tripId: trip?.tripId ?? null,\n routeId: trip?.routeId ?? null,\n startDate: trip?.startDate ?? null,\n startTime: trip?.startTime ?? null,\n directionId: trip?.directionId ?? null,\n scheduleRelationship: trip?.scheduleRelationship ?? null,\n };\n}\n\nfunction mapTripUpdate(tu: any) {\n return {\n trip: mapTrip(tu?.trip),\n timestamp: toIso(tu?.timestamp),\n delay: tu?.delay ?? null,\n vehicleId: tu?.vehicle?.id ?? null,\n stopTimeUpdates: (tu?.stopTimeUpdate ?? []).map((stu: any) => ({\n stopSequence: stu?.stopSequence ?? null,\n stopId: stu?.stopId ?? null,\n arrivalTime: toIso(stu?.arrival?.time),\n arrivalDelay: stu?.arrival?.delay ?? null,\n departureTime: toIso(stu?.departure?.time),\n departureDelay: stu?.departure?.delay ?? null,\n scheduleRelationship: stu?.scheduleRelationship ?? null,\n })),\n };\n}\n\nfunction mapVehicle(v: any) {\n return {\n trip: mapTrip(v?.trip),\n vehicleId: v?.vehicle?.id ?? null,\n label: v?.vehicle?.label ?? null,\n latitude: v?.position?.latitude ?? null,\n longitude: v?.position?.longitude ?? null,\n bearing: v?.position?.bearing ?? null,\n speed: v?.position?.speed ?? null,\n currentStopSequence: v?.currentStopSequence ?? null,\n stopId: v?.stopId ?? null,\n currentStatus: v?.currentStatus ?? null,\n timestamp: toIso(v?.timestamp),\n };\n}\n\nfunction mapAlert(a: any) {\n return {\n headerText: a?.headerText?.translation?.[0]?.text ?? null,\n descriptionText: a?.descriptionText?.translation?.[0]?.text ?? null,\n cause: a?.cause ?? null,\n effect: a?.effect ?? null,\n url: a?.url?.translation?.[0]?.text ?? null,\n informedEntities: (a?.informedEntity ?? []).map((ie: any) => ({\n routeId: ie?.routeId ?? null,\n stopId: ie?.stopId ?? null,\n tripId: ie?.trip?.tripId ?? null,\n })),\n activePeriods: (a?.activePeriod ?? []).map((p: any) => ({\n start: toIso(p?.start),\n end: toIso(p?.end),\n })),\n };\n}\n\nconst handler = createMcpHandler(() => {\n const server = new McpServer({\n name: \"amtrak-gtfs-rt\",\n version: \"1.0.0\",\n });\n\n server.registerTool(\"get_feed_header\", {\n description:\n \"Get metadata about the Amtrak GTFS-RT feed: the GTFS-RT version, the feed timestamp, and counts of trip updates, vehicle positions, and service alerts currently in the feed.\",\n inputSchema: z.object({}),\n }, async () => {\n const feed = await getFeed();\n const entities = feed.entity ?? [];\n const counts = { tripUpdates: 0, vehicles: 0, alerts: 0 };\n for (const e of entities) {\n if (e.tripUpdate) counts.tripUpdates++;\n if (e.vehicle) counts.vehicles++;\n if (e.alert) counts.alerts++;\n }\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({\n gtfsRealtimeVersion: feed.header?.gtfsRealtimeVersion ?? null,\n timestamp: toIso(feed.header?.timestamp),\n entityCount: entities.length,\n ...counts,\n }, null, 2),\n }],\n };\n });\n\n server.registerTool(\"get_trip_updates\", {\n description:\n \"Get real-time arrival/departure predictions (TripUpdates) for Amtrak trains. Optionally filter by routeId (e.g. '79', '950', '880') and/or tripId (the train number). Returns each trip's stops with predicted arrival/departure times and delays.\",\n inputSchema: z.object({\n routeId: z.string().optional().describe(\"Optional Amtrak route id to filter by, e.g. '79'\"),\n tripId: z.string().optional().describe(\"Optional trip id (train number) to filter by, e.g. '287743'\"),\n }),\n }, async ({ routeId, tripId }) => {\n const feed = await getFeed();\n const updates = (feed.entity ?? [])\n .filter((e) => e.tripUpdate)\n .map((e) => mapTripUpdate(e.tripUpdate))\n .filter((u) => (!routeId || u.trip.routeId === routeId) && (!tripId || u.trip.tripId === tripId));\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ count: updates.length, tripUpdates: updates }, null, 2),\n }],\n };\n });\n\n server.registerTool(\"get_vehicle_positions\", {\n description:\n \"Get live positions of Amtrak trains (VehiclePositions). Optionally filter by routeId, tripId, or vehicleId. Returns each vehicle's lat/long, bearing, speed, current stop, and status.\",\n inputSchema: z.object({\n routeId: z.string().optional().describe(\"Optional Amtrak route id to filter by, e.g. '79'\"),\n tripId: z.string().optional().describe(\"Optional trip id (train number) to filter by\"),\n vehicleId: z.string().optional().describe(\"Optional vehicle id to filter by\"),\n }),\n }, async ({ routeId, tripId, vehicleId }) => {\n const feed = await getFeed();\n const vehicles = (feed.entity ?? [])\n .filter((e) => e.vehicle)\n .map((e) => mapVehicle(e.vehicle))\n .filter((v) =>\n (!routeId || v.trip.routeId === routeId) &&\n (!tripId || v.trip.tripId === tripId) &&\n (!vehicleId || v.vehicleId === vehicleId));\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ count: vehicles.length, vehicles }, null, 2),\n }],\n };\n });\n\n server.registerTool(\"get_service_alerts\", {\n description:\n \"Get active service alerts (disruptions, advisories) for Amtrak. Optionally filter by routeId. Returns each alert's header, description, cause, effect, and affected routes/stops.\",\n inputSchema: z.object({\n routeId: z.string().optional().describe(\"Optional Amtrak route id to filter by\"),\n }),\n }, async ({ routeId }) => {\n const feed = await getFeed();\n const alerts = (feed.entity ?? [])\n .filter((e) => e.alert)\n .map((e) => mapAlert(e.alert))\n .filter((a) => !routeId || a.informedEntities.some((ie: any) => ie.routeId === routeId));\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ count: alerts.length, alerts }, null, 2),\n }],\n };\n });\n\n // ---- Static GTFS tools (queried from SQLite) ----\n // These are read-only queries of the val's GTFS database.\n\n server.registerTool(\"get_routes\", {\n description:\n \"List Amtrak routes from the static GTFS schedule. Optionally filter by a route id (e.g. '79') or a free-text query matched against the route name. Returns route id, short name, long name, type, and url.\",\n inputSchema: z.object({\n routeId: z.string().optional().describe(\"Optional route id to look up, e.g. '79'\"),\n query: z.string().optional().describe(\"Optional text to search in route long/short names, e.g. 'Crescent'\"),\n }),\n }, async ({ routeId, query }) => {\n const rows = await q(\"SELECT * FROM routes\");\n const filtered = rows.filter((r) => {\n if (routeId && r.route_id !== routeId) return false;\n if (query) {\n const haystack = `${r.route_long_name ?? \"\"} ${r.route_short_name ?? \"\"}`.toLowerCase();\n if (!haystack.includes(query.toLowerCase())) return false;\n }\n return true;\n });\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ count: filtered.length, note: GTFS_DB_NOTE, routes: filtered }, null, 2),\n }],\n };\n });\n\n server.registerTool(\"get_stops\", {\n description:\n \"List Amtrak stations/stops from the static GTFS schedule. Filter by stop id (e.g. 'SAL'), a text query matched against the stop name, or a lat/lon location with radiusKm for stops within a radius. Returns stop id, name, timezone, and coordinates.\",\n inputSchema: z.object({\n stopId: z.string().optional().describe(\"Optional stop id to look up, e.g. 'NYP'\"),\n query: z.string().optional().describe(\"Optional text to search in stop names, e.g. 'Union'\"),\n lat: z.number().optional().describe(\"Latitude for a nearby-stops search\"),\n lon: z.number().optional().describe(\"Longitude for a nearby-stops search\"),\n radiusKm: z.number().optional().describe(\"Search radius in km when lat/lon given (default 25)\"),\n }),\n }, async ({ stopId, query, lat, lon, radiusKm }) => {\n let rows: Record[];\n if (lat != null && lon != null) {\n const rad = radiusKm ?? 25;\n const kmPerDegLat = 111.32;\n const dLat = rad / kmPerDegLat;\n const dLon = rad / (kmPerDegLat * Math.cos(lat * Math.PI / 180));\n rows = await q(\n `SELECT * FROM stops\n WHERE stop_lat IS NOT NULL\n AND stop_lat BETWEEN ? AND ?\n AND stop_lon BETWEEN ? AND ?\n ORDER BY ( (stop_lat - ?)*(stop_lat - ?) + (stop_lon - ?)*(stop_lon - ?)*(?*?) ) LIMIT 50`,\n [\n lat - dLat, lat + dLat,\n lon - dLon, lon + dLon,\n lat, lat, lon, lon, Math.cos(lat * Math.PI / 180),\n ],\n );\n rows = rows.filter((s) =>\n haversineKm(lat, lon, Number(s.stop_lat), Number(s.stop_lon)) <= rad);\n } else {\n rows = await q(\"SELECT * FROM stops\");\n rows = rows.filter((s) => {\n if (stopId && s.stop_id !== stopId) return false;\n if (query && !String(s.stop_name ?? \"\").toLowerCase().includes(query.toLowerCase())) return false;\n return true;\n });\n rows = rows.slice(0, 200);\n }\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ count: rows.length, note: GTFS_DB_NOTE, stops: rows }, null, 2),\n }],\n };\n });\n\n server.registerTool(\"get_agency\", {\n description:\n \"List the transit agencies from the static GTFS feed (names, urls, timezones). Optional filter by agencyId.\",\n inputSchema: z.object({\n agencyId: z.string().optional().describe(\"Optional agency id to filter by\"),\n }),\n }, async ({ agencyId }) => {\n const rows = (await q(\"SELECT * FROM agency\"))\n .filter((a) => !agencyId || a.agency_id === agencyId);\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ count: rows.length, note: GTFS_DB_NOTE, agency: rows }, null, 2),\n }],\n };\n });\n\n server.registerTool(\"get_trips\", {\n description:\n \"List scheduled trips from the static GTFS. Filter by route, trip, or a headsign search. Returns trip id (train number), route id, headsign, direction, and service id.\",\n inputSchema: z.object({\n routeId: z.string().optional().describe(\"Optional route id to filter by, e.g. '79'\"),\n tripId: z.string().optional().describe(\"Optional trip id to look up\"),\n headsign: z.string().optional().describe(\"Optional text to search in trip headsigns, e.g. 'New York'\"),\n limit: z.number().min(1).max(500).optional().describe(\"Max results (default 100)\"),\n }),\n }, async ({ routeId, tripId, headsign, limit }) => {\n const lim = limit ?? 100;\n const rows = await q(\n `SELECT t.route_id, t.service_id, t.trip_id, t.trip_short_name, t.direction_id,\n t.trip_headsign, r.route_long_name\n FROM trips t LEFT JOIN routes r ON r.route_id = t.route_id\n WHERE (? = '' OR t.route_id = ?)\n AND (? = '' OR t.trip_id = ?)\n AND (? = '' OR lower(t.trip_headsign) LIKE '%' || lower(?) || '%')\n LIMIT ?`,\n [routeId ?? \"\", routeId ?? \"\", tripId ?? \"\", tripId ?? \"\", headsign ?? \"\", headsign ?? \"\", lim],\n );\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ count: rows.length, note: GTFS_DB_NOTE, trips: rows }, null, 2),\n }],\n };\n });\n\n server.registerTool(\"get_trip_schedule\", {\n description:\n \"Get the full scheduled itinerary of a trip from the static GTFS: each stop in order with scheduled arrival and departure times and the stop name. Provide a tripId (train number) or look up trips with get_trips first.\",\n inputSchema: z.object({\n tripId: z.string().describe(\"The trip id (train number) to get the schedule for, e.g. '287743'\"),\n }),\n }, async ({ tripId }) => {\n const trip = (await q(\n `SELECT t.trip_id, t.trip_headsign, t.route_id, t.direction_id, t.service_id,\n r.route_long_name\n FROM trips t LEFT JOIN routes r ON r.route_id = t.route_id WHERE t.trip_id = ?`,\n [tripId],\n ))[0] ?? null;\n const stops = await q(\n `SELECT st.stop_sequence, st.arrival_time, st.departure_time, st.pickup_type, st.drop_off_type,\n s.stop_id, s.stop_name\n FROM stop_times st JOIN stops s ON s.stop_id = st.stop_id\n WHERE st.trip_id = ? ORDER BY st.stop_sequence`,\n [tripId],\n );\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ trip, count: stops.length, note: GTFS_DB_NOTE, stops }, null, 2),\n }],\n };\n });\n\n server.registerTool(\"get_stop_departures\", {\n description:\n \"List scheduled departures/arrivals at a station from the static GTFS. Provide a stop id (e.g. 'SAL') and optionally a route id. Returns each trip's scheduled arrival/departure time, headsign, and route.\",\n inputSchema: z.object({\n stopId: z.string().describe(\"The stop id (station code), e.g. 'SAL' or 'NYP'\"),\n routeId: z.string().optional().describe(\"Optional route id to filter to, e.g. '79'\"),\n limit: z.number().min(1).max(500).optional().describe(\"Max results (default 100)\"),\n }),\n }, async ({ stopId, routeId, limit }) => {\n const lim = limit ?? 100;\n const rows = await q(\n `SELECT st.trip_id, st.arrival_time, st.departure_time,\n t.route_id, t.trip_headsign, r.route_long_name\n FROM stop_times st\n JOIN trips t ON t.trip_id = st.trip_id\n JOIN routes r ON r.route_id = t.route_id\n WHERE st.stop_id = ? AND (? = '' OR t.route_id = ?)\n ORDER BY st.departure_time\n LIMIT ?`,\n [stopId, routeId ?? \"\", routeId ?? \"\", lim],\n );\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ count: rows.length, note: GTFS_DB_NOTE, stopId, departures: rows }, null, 2),\n }],\n };\n });\n\n server.registerTool(\"get_calendar\", {\n description:\n \"Get the service calendar (which days of the week a service runs, and its date range) from the static GTFS. Provide a tripId to look up its service days, or a serviceId directly.\",\n inputSchema: z.object({\n tripId: z.string().optional().describe(\"Optional trip id to look up its service\"),\n serviceId: z.string().optional().describe(\"Optional service id directly\"),\n }),\n }, async ({ tripId, serviceId }) => {\n let sid = serviceId;\n if (!sid && tripId) {\n const t = (await q(\"SELECT service_id FROM trips WHERE trip_id = ?\", [tripId]))[0];\n sid = (t?.service_id as string) ?? \"\";\n }\n const days = sid\n ? await q(\"SELECT * FROM calendar WHERE service_id = ?\", [sid])\n : await q(\"SELECT * FROM calendar LIMIT 500\");\n const tripsForService = sid.length\n ? await q(\"SELECT trip_id, route_id, trip_headsign FROM trips WHERE service_id = ? LIMIT 50\", [sid])\n : [];\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ serviceId: sid || null, count: days.length, note: GTFS_DB_NOTE, calendar: days, tripsForService }, null, 2),\n }],\n };\n });\n\n return server;\n});\n\n/** Great-circle distance in km between two lat/lon points (for nearby-stops search). */\nfunction haversineKm(lat1: number, lon1: number, lat2: number, lon2: number): number {\n const R = 6371;\n const toRad = (d: number) => (d * Math.PI) / 180;\n const dLat = toRad(lat2 - lat1);\n const dLon = toRad(lon2 - lon1);\n const a = Math.sin(dLat / 2) ** 2 +\n Math.cos(toRad(lat1)) * Math.cos(toRad(lat2)) * Math.sin(dLon / 2) ** 2;\n return 2 * R * Math.asin(Math.sqrt(a));\n}\n\nexport default handler.fetch;\n","amtrak-status-mcp",[],[190],"878c59fa-5e4e-4551-9649-74363160f768","ingest-gtfs.ts","133759e2-9ccb-11f1-8c77-1607ee4eb77e",20,["D",1787253400383],8,"script","import { unzipSync, strFromU8 } from \"npm:fflate\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst GTFS_URL = \"https://content.amtrak.com/content/gtfs/GTFS.zip\";\n\n/** Minimal RFC-4180 CSV parser that handles quoted fields. */\nfunction parseCSV(text: string): string[][] {\n const rows: string[][] = [];\n let row: string[] = [];\n let field = \"\";\n let inQuotes = false;\n for (let i = 0; i < text.length; i++) {\n const c = text[i];\n if (inQuotes) {\n if (c === '\"') {\n if (text[i + 1] === '\"') {\n field += '\"';\n i++;\n } else {\n inQuotes = false;\n }\n } else {\n field += c;\n }\n } else {\n if (c === '\"') inQuotes = true;\n else if (c === \",\") {\n row.push(field);\n field = \"\";\n } else if (c === \"\\n\") {\n row.push(field);\n rows.push(row);\n row = [];\n field = \"\";\n } else if (c === \"\\r\") {\n // ignore\n } else {\n field += c;\n }\n }\n }\n if (field !== \"\" || row.length > 0) {\n row.push(field);\n rows.push(row);\n }\n return rows;\n}\n\n/** Parse CSV text into an array of row objects keyed by the header row. */\nfunction toObjects(text: string): Record[] {\n const rows = parseCSV(text);\n if (rows.length === 0) return [];\n const headers = rows[0];\n return rows.slice(1).map((r) => {\n const obj: Record = {};\n headers.forEach((h, i) => {\n obj[h] = r[i] ?? \"\";\n });\n return obj;\n });\n}\n\nfunction num(v: string | undefined): number | null {\n if (v === undefined || v === \"\") return null;\n const n = Number(v);\n return Number.isFinite(n) ? n : null;\n}\n\nexport async function ingestGtfs() {\n console.log(\"Downloading GTFS.zip...\");\n const res = await fetch(GTFS_URL);\n if (!res.ok) throw new Error(`Download failed: ${res.status} ${res.statusText}`);\n const bytes = new Uint8Array(await res.arrayBuffer());\n console.log(\"Downloaded\", (bytes.byteLength / 1024 / 1024).toFixed(1), \"MB\");\n\n const unzipped = unzipSync(bytes);\n const text = (name: string) => strFromU8(unzipped[name] ?? new Uint8Array());\n\n // --- Schema (drop + recreate so constraints apply cleanly) ---\n await sqlite.execute(\"DROP TABLE IF EXISTS stop_times\");\n await sqlite.execute(\"DROP TABLE IF EXISTS trips\");\n await sqlite.execute(\"DROP TABLE IF EXISTS calendar\");\n await sqlite.execute(\"DROP TABLE IF EXISTS agency\");\n await sqlite.execute(\"DROP TABLE IF EXISTS stops\");\n await sqlite.execute(\"DROP TABLE IF EXISTS routes\");\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS routes (\n route_id TEXT PRIMARY KEY,\n agency_id TEXT,\n route_short_name TEXT,\n route_long_name TEXT,\n route_type TEXT,\n route_url TEXT,\n route_color TEXT,\n route_text_color TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS stops (\n stop_id TEXT PRIMARY KEY,\n stop_code TEXT,\n stop_name TEXT,\n stop_url TEXT,\n stop_timezone TEXT,\n stop_lat REAL,\n stop_lon REAL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS trips (\n route_id TEXT,\n service_id TEXT,\n trip_id TEXT PRIMARY KEY,\n trip_short_name TEXT,\n direction_id TEXT,\n shape_id TEXT,\n trip_headsign TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS stop_times (\n trip_id TEXT,\n arrival_time TEXT,\n departure_time TEXT,\n stop_id TEXT,\n stop_sequence INTEGER NOT NULL DEFAULT 0,\n pickup_type TEXT,\n drop_off_type TEXT,\n PRIMARY KEY (trip_id, stop_sequence)\n )`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_stop_times_trip ON stop_times (trip_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_stop_times_stop ON stop_times (stop_id)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS calendar (\n service_id TEXT PRIMARY KEY,\n monday INTEGER, tuesday INTEGER, wednesday INTEGER, thursday INTEGER,\n friday INTEGER, saturday INTEGER, sunday INTEGER,\n start_date TEXT, end_date TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS agency (\n agency_id TEXT PRIMARY KEY,\n agency_name TEXT,\n agency_url TEXT,\n agency_timezone TEXT,\n agency_lang TEXT,\n agency_phone TEXT\n )`);\n\n // --- Routes ---\n const routes = toObjects(text(\"routes.txt\"));\n for (let i = 0; i < routes.length; i += 500) {\n const chunk = routes.slice(i, i + 500);\n const stmts = chunk.map((r) => ({\n sql: `INSERT OR REPLACE INTO routes (route_id, agency_id, route_short_name, route_long_name, route_type, route_url, route_color, route_text_color)\n VALUES (?,?,?,?,?,?,?,?)`,\n args: [r.route_id, r.agency_id, r.route_short_name, r.route_long_name, r.route_type, r.route_url, r.route_color, r.route_text_color],\n }));\n if (i === 0) stmts.unshift({ sql: \"DELETE FROM routes\" });\n await sqlite.batch(stmts);\n }\n console.log(\"routes:\", routes.length);\n\n // --- Stops ---\n const stops = toObjects(text(\"stops.txt\"));\n for (let i = 0; i < stops.length; i += 500) {\n const chunk = stops.slice(i, i + 500);\n const stmts = chunk.map((s) => ({\n sql: `INSERT OR REPLACE INTO stops (stop_id, stop_code, stop_name, stop_url, stop_timezone, stop_lat, stop_lon)\n VALUES (?,?,?,?,?,?,?)`,\n args: [s.stop_id, s.stop_code, s.stop_name, s.stop_url, s.stop_timezone, num(s.stop_lat), num(s.stop_lon)],\n }));\n if (i === 0) stmts.unshift({ sql: \"DELETE FROM stops\" });\n await sqlite.batch(stmts);\n }\n console.log(\"stops:\", stops.length);\n\n // --- Trips ---\n const trips = toObjects(text(\"trips.txt\"));\n for (let i = 0; i < trips.length; i += 500) {\n const chunk = trips.slice(i, i + 500);\n const stmts = chunk.map((t) => ({\n sql: `INSERT OR REPLACE INTO trips (route_id, service_id, trip_id, trip_short_name, direction_id, shape_id, trip_headsign)\n VALUES (?,?,?,?,?,?,?)`,\n args: [t.route_id, t.service_id, t.trip_id, t.trip_short_name, t.direction_id, t.shape_id, t.trip_headsign],\n }));\n if (i === 0) stmts.unshift({ sql: \"DELETE FROM trips\" });\n await sqlite.batch(stmts);\n }\n console.log(\"trips:\", trips.length);\n\n // --- Stop times ---\n const stopTimes = toObjects(text(\"stop_times.txt\"));\n for (let i = 0; i < stopTimes.length; i += 500) {\n const chunk = stopTimes.slice(i, i + 500);\n const stmts = chunk.map((st) => ({\n sql: `INSERT OR REPLACE INTO stop_times (trip_id, arrival_time, departure_time, stop_id, stop_sequence, pickup_type, drop_off_type)\n VALUES (?,?,?,?,?,?,?)`,\n args: [st.trip_id, st.arrival_time, st.departure_time, st.stop_id, num(st.stop_sequence) ?? 0, st.pickup_type, st.drop_off_type],\n }));\n if (i === 0) stmts.unshift({ sql: \"DELETE FROM stop_times\" });\n await sqlite.batch(stmts);\n }\n console.log(\"stop_times:\", stopTimes.length);\n\n // --- Calendar ---\n const calendar = toObjects(text(\"calendar.txt\"));\n for (let i = 0; i < calendar.length; i += 500) {\n const chunk = calendar.slice(i, i + 500);\n const stmts = chunk.map((c) => ({\n sql: `INSERT OR REPLACE INTO calendar (service_id, monday, tuesday, wednesday, thursday, friday, saturday, sunday, start_date, end_date)\n VALUES (?,?,?,?,?,?,?,?,?,?)`,\n args: [c.service_id, num(c.monday), num(c.tuesday), num(c.wednesday), num(c.thursday), num(c.friday), num(c.saturday), num(c.sunday), c.start_date, c.end_date],\n }));\n if (i === 0) stmts.unshift({ sql: \"DELETE FROM calendar\" });\n await sqlite.batch(stmts);\n }\n console.log(\"calendar:\", calendar.length);\n\n // --- Agency ---\n const agency = toObjects(text(\"agency.txt\"));\n for (let i = 0; i < agency.length; i += 500) {\n const chunk = agency.slice(i, i + 500);\n const stmts = chunk.map((a) => ({\n sql: `INSERT OR REPLACE INTO agency (agency_id, agency_name, agency_url, agency_timezone, agency_lang, agency_phone)\n VALUES (?,?,?,?,?,?)`,\n args: [a.agency_id ?? \"\", a.agency_name ?? \"\", a.agency_url ?? \"\", a.agency_timezone ?? \"\", a.agency_lang ?? \"\", a.agency_phone ?? \"\"],\n }));\n if (i === 0) stmts.unshift({ sql: \"DELETE FROM agency\" });\n await sqlite.batch(stmts);\n }\n console.log(\"agency:\", agency.length);\n\n console.log(\"Ingest complete.\");\n}\n",[],[200],"020fd710-2a49-4132-835a-38390eff0ee5","README.md","01a02092-b0af-72ec-bba6-6fef447fd351",["D",1787253821007],4,"# Amtrak GTFS + GTFS-RT MCP server\n\nA **public, read-only** [Model Context Protocol](https://modelcontextprotocol.io) server\nthat lets AI agents query both live and scheduled Amtrak transit data:\n\n- **Realtime (GTFS-RT)** — live predictions, train positions, and alerts, fetched on\n every call from the [transitdocs](https://asm-backend.transitdocs.com/gtfs/amtrak) feed.\n- **Static (GTFS)** — routes, stops, trips, schedules, and service calendars, loaded\n into this val's SQLite database from [Amtrak's GTFS.zip](https://content.amtrak.com/content/gtfs/GTFS.zip).\n\n## Realtime tools\n\n| Tool | Description |\n| --- | --- |\n| `get_feed_header` | Feed metadata: version, timestamp, and counts of trip updates / vehicles / alerts. |\n| `get_trip_updates` | Real-time arrival/departure predictions. Filters: `routeId`, `tripId`. |\n| `get_vehicle_positions` | Live train positions (lat/long, bearing, speed, current stop). Filters: `routeId`, `tripId`, `vehicleId`. |\n| `get_service_alerts` | Active service alerts / advisories. Filter: `routeId`. |\n\n## Static GTFS tools (SQLite)\n\n| Tool | Description |\n| --- | --- |\n| `get_routes` | List routes. Filters: `routeId`, `query` (name search). |\n| `get_stops` | List stations. Filters: `stopId`, `query` (name search), or `lat`/`lon`/`radiusKm` (nearby). |\n| `get_trips` | List scheduled trips. Filters: `routeId`, `tripId`, `headsign`, `limit`. |\n| `get_trip_schedule` | Full itinerary of a trip: stops in order with scheduled times. Requires `tripId`. |\n| `get_stop_departures` | Scheduled departures/arrivals at a station. Requires `stopId`, optional `routeId`. |\n| `get_calendar` | Service days/date range for a `tripId` or `serviceId`. |\n| `get_agency` | Transit agency info. Filter: `agencyId`. |\n\nRealtime times are ISO-8601; static schedule times are `HH:MM:SS`; delays are in seconds.\n\n## Data freshness\n\n- **All realtime tools** (`get_feed_header`, `get_trip_updates`,\n `get_vehicle_positions`, `get_service_alerts`) share a single **60-second cache**\n of the raw GTFS-RT feed, stored in SQLite. The upstream feed is fetched at most\n once per minute; every tool reads from the same cached copy.\n- Static GTFS is stored in SQLite and refreshed **daily at 4:00 UTC** by the\n `refresh-gtfs.ts` interval, which re-downloads the GTFS.zip and re-ingests via\n `ingest-gtfs.ts`. You can also run `ingest-gtfs.ts` manually at any time.\n\n## Connect an MCP client\n\nPoint your MCP client at the server's URL (streamable HTTP transport). For example,\nin a Claude Code / MCP config:\n\n```json\n{\n \"mcpServers\": {\n \"amtrak-gtfs\": {\n \"type\": \"http\",\n \"url\": \"https://.val.run\"\n }\n }\n}\n```\n\nYou can also test it quickly in the [Cloudflare MCP playground](https://playground.ai.cloudflare.com).\n\n## Example\n\nAsk your agent: *\"Where is Amtrak train 287743 right now, and what are its upcoming stops?\"*\nIt will call `get_vehicle_positions` and `get_trip_updates` (live) and\n`get_trip_schedule` (scheduled) to answer.\n\n## Notes\n\n- Read-only: realtime tools only fetch the upstream feed; static tools only read SQLite.\n- Built on the v2 TypeScript SDK (`@modelcontextprotocol/server`), compatible with\n MCP 2.0 (2026-07-28 spec) and the legacy spec.\n",[],[210],["D",1787252879017],["D",1789520505489],{"_11":12,"_127":69},{"_11":12,"_123":-5,"_68":69,"_30":67,"_124":125,"_126":24},{"_38":110,"_13":16,"_32":35,"_111":71,"_112":113,"_114":115,"_116":76,"_117":118,"_119":120,"_121":14,"_122":12},"ctx",{"_52":-5,"_149":255,"_256":257,"_258":259,"_260":24,"_261":24,"_262":24,"_263":147,"_264":-5,"_265":-7,"_266":-7,"_267":26,"_268":24,"_269":24,"_270":-5,"_271":24,"_272":24,"_273":24,"_274":-5},"ENV",{"_226":227,"_228":229,"_230":16,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254},"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"]

History · refresh-gtfs.ts