[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_231":232,"_233":234},"routes/_app.x.$handle.$name",{"_108":107,"_37":49,"_116":94,"_32":117,"_13":14,"_118":-5,"_11":119,"_120":121,"_122":123,"_124":125,"_126":127,"_26":-5,"_128":129,"_130":131,"_132":30,"_133":134,"_135":136,"_137":-5,"_138":-5,"_139":140},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":59,"_19":60,"_61":62,"_63":30,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":30},"version",15,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","b814935d-6ff0-41d8-bf5c-5c0462ff3820","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","refresh-gtfs.ts","latestPath","fileId","5546a9aa-9ccb-11f1-8c77-1607ee4eb77e","name","fileType","interval","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","createdAt",["D",1787253254803],"branchVersion","branchId","1825b209-ac72-41e6-a980-02e7cc391063","id","2cfb9927-155e-47cc-9f73-c923b21f7f89","amtrak-gtfs-rt-mcp",["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=1789588799&sig=bb451bcdddf42876a0cdd1b7efe2ed19796d49b36cc887c4a50bffe5ae6dc077","019adb55-d35c-728f-b295-ec7539176851","pinnedFileId","01a02092-b0af-72ec-bba6-7217fa87c97d","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019adb55-d35c-728f-b295-f00e23c346f1","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","user",{"_108":107,"_115":111},"org",{"_108":107,"_109":-5,"_110":111,"_19":60,"_112":113,"_114":30},"branch",{"_13":93,"_37":94,"_47":46,"_95":48,"_96":97,"_98":99,"_100":54,"_101":102,"_103":104,"_105":49,"_106":107},"isOwned",35,"main","projectId","forkedBranchId","4317995d-9bca-44ba-8f1c-e817322f354f","forkedBranchVersion",33,"forkedProjectPrivacy","forkedProjectId","c5a66f73-8318-4d99-b192-14a8e864ebc4","forkedProjectOrgId","019aa807-52c2-709c-928b-2029bae9a558","projectName","userHandle","keisisqrl","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM2Rnkza0hHT2QwSXJDb0JIQTR0M21kc256UCJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_47":48,"_37":49,"_42":226,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":59,"_19":60,"_61":62,"_63":30,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":227,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":228,"_88":229,"_90":230,"_92":30},"tree",[205,206,207,208,209],"files",[205,206,207,208,209],"counts",{"_195":67,"_196":192,"_197":67,"_198":199,"_200":201},"contents",[151,152,153,154,155],"upstreamProject",{"_47":102,"_37":147,"_56":148,"_58":59,"_53":54,"_86":149},"upstreamBranch",{"_47":97,"_42":141,"_142":143,"_37":94,"_95":102,"_13":93,"_96":-5,"_98":-5,"_144":145,"_51":-5,"_92":30,"_53":54,"_106":146,"_68":104,"_105":147},"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",{"_108":146,"_115":150},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789588799&sig=6ce4a653b65ad390b6349a1b0a383cb839cc380a1beaf91551581c108538875d",{"_47":187,"_37":188,"_35":189,"_159":-5,"_45":46,"_44":190,"_161":30,"_42":191,"_13":192,"_38":26,"_40":193,"_29":30,"_165":-5,"_32":194},{"_47":179,"_37":180,"_35":181,"_159":-5,"_45":46,"_44":182,"_161":30,"_42":183,"_13":184,"_38":163,"_40":185,"_29":30,"_165":-5,"_32":186},{"_47":170,"_37":171,"_35":62,"_159":-5,"_45":46,"_44":172,"_161":30,"_42":173,"_13":174,"_38":175,"_40":176,"_29":30,"_165":177,"_32":178},{"_47":167,"_37":33,"_35":36,"_159":-5,"_45":46,"_44":14,"_161":136,"_42":168,"_13":67,"_38":39,"_40":41,"_29":30,"_165":-5,"_32":169},{"_47":156,"_37":157,"_35":158,"_159":-5,"_45":46,"_44":160,"_161":30,"_42":162,"_13":67,"_38":163,"_40":164,"_29":30,"_165":-5,"_32":166},"da1f10fe-50b2-44ce-959a-33188e604315","test-gtfs.ts","01b0b5b0-9ccb-11f1-8fd4-1607ee4eb77e","parentId",8,"latest",["D",1787253114565],"script","import { unzipSync, strFromU8 } from \"npm:fflate\";\n\nconst res = await fetch(\"https://content.amtrak.com/content/gtfs/GTFS.zip\");\nconsole.log(\"status\", res.status, \"size\", (await res.clone().arrayBuffer()).byteLength);\nconst bytes = new Uint8Array(await res.arrayBuffer());\nconsole.log(\"zip size KB\", (bytes.byteLength / 1024).toFixed(0));\nconst unzipped = unzipSync(bytes);\nconst files = Object.keys(unzipped).sort();\nfor (const f of files) {\n if (!f.endsWith(\"/\")) {\n console.log(f, (unzipped[f].length / 1024).toFixed(0) + \"KB\");\n }\n}\n// Peek at routes and stops headers\nconst stops = strFromU8(unzipped[\"stops.txt\"]);\nconsole.log(\"stops head lines:\", stops.split(\"\\n\").slice(0, 3).join(\"\\n\"));\nconst routes = strFromU8(unzipped[\"routes.txt\"]);\nconsole.log(\"routes head:\", routes.split(\"\\n\").slice(0, 3).join(\"\\n\"));\nconst trips = strFromU8(unzipped[\"trips.txt\"]);\nconsole.log(\"trips head:\", trips.split(\"\\n\").slice(0, 2).join(\"\\n\"));\n","label",[157],"4f89f110-1811-4e46-bb57-bb5ff66b6b5d",["D",1787253254803],[33],"e5479142-e83a-460c-843e-818043fa1440","main.ts",12,["D",1787253232795],4,"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 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 query(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/** Fetch and decode the GTFS-RT feed into its protobuf message. */\nasync function getFeed() {\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 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 query(\"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 query(\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 query(\"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 query(\"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 query(\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 query(\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 query(\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 query(\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 query(\"SELECT service_id FROM trips WHERE trip_id = ?\", [tripId]))[0];\n sid = (t?.service_id as string) ?? \"\";\n }\n const days = sid\n ? await query(\"SELECT * FROM calendar WHERE service_id = ?\", [sid])\n : await query(\"SELECT * FROM calendar LIMIT 500\");\n const tripsForService = sid.length\n ? await query(\"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",[171],"e05270e6-41c9-4bc4-9722-18d52c665e0b","ingest-gtfs.ts","133759e2-9ccb-11f1-8c77-1607ee4eb77e",14,["D",1787253252295],3,"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 (idempotent) ---\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,\n pickup_type TEXT,\n drop_off_type TEXT\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 // --- Clear existing rows ---\n await sqlite.execute(\"DELETE FROM routes\");\n await sqlite.execute(\"DELETE FROM stops\");\n await sqlite.execute(\"DELETE FROM trips\");\n await sqlite.execute(\"DELETE FROM stop_times\");\n await sqlite.execute(\"DELETE FROM calendar\");\n await sqlite.execute(\"DELETE FROM agency\");\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 await sqlite.batch(chunk.map((r) => ({\n sql: `INSERT 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 }\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 await sqlite.batch(chunk.map((s) => ({\n sql: `INSERT 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 }\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 await sqlite.batch(chunk.map((t) => ({\n sql: `INSERT 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 }\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 await sqlite.batch(chunk.map((st) => ({\n sql: `INSERT 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), st.pickup_type, st.drop_off_type],\n })));\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 await sqlite.batch(chunk.map((c) => ({\n sql: `INSERT 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 }\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 await sqlite.batch(chunk.map((a) => ({\n sql: `INSERT 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 }\n console.log(\"agency:\", agency.length);\n\n console.log(\"Ingest complete.\");\n}\n",[180],"9b5a3a09-3ef4-4196-994b-08434bb74d28","README.md","01a02092-b0af-72ec-bba6-6fef447fd351",7,["D",1787252999023],1,"# Amtrak GTFS-RT MCP server\n\nA **public, read-only** [Model Context Protocol](https://modelcontextprotocol.io) server\nthat lets AI agents query live Amtrak realtime transit data from the\n[transitdocs](https://asm-backend.transitdocs.com/gtfs/amtrak) GTFS-RT feed.\n\nIt fetches the feed on every call (no caching, no writes, no storage), decodes the\nProtocol Buffer with `gtfs-realtime-bindings`, and returns clean JSON.\n\n## Tools\n\n| Tool | Description |\n| --- | --- |\n| `get_feed_header` | Feed metadata: GTFS-RT version, feed timestamp, and counts of trip updates / vehicles / alerts. |\n| `get_trip_updates` | Real-time arrival/departure predictions. Optional filters: `routeId`, `tripId`. |\n| `get_vehicle_positions` | Live train positions (lat/long, bearing, speed, current stop). Optional filters: `routeId`, `tripId`, `vehicleId`. |\n| `get_service_alerts` | Active service alerts / advisories. Optional filter: `routeId`. |\n\nAll times are returned as ISO-8601 strings; delays are in seconds.\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-rt\": {\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` to answer.\n\n## Notes\n\n- Read-only: every tool only fetches the upstream feed and returns data.\n- Built on the v2 TypeScript SDK (`@modelcontextprotocol/server`), compatible with\n MCP 2.0 (2026-07-28 spec) and the legacy spec.\n",[188],"pulls","branches","forks","envVars",{"_202":67,"_204":67},"connections",{"_202":67,"_203":67},"count","unfilledCount","emptyCount",{"_47":187,"_37":188,"_35":189,"_159":-5,"_45":46,"_44":190,"_161":30,"_42":223,"_13":192,"_38":26,"_40":193,"_29":30,"_165":-5,"_211":224,"_32":225},{"_47":179,"_37":180,"_35":181,"_159":-5,"_45":46,"_44":182,"_161":30,"_42":220,"_13":184,"_38":163,"_40":185,"_29":30,"_165":-5,"_211":221,"_32":222},{"_47":170,"_37":171,"_35":62,"_159":-5,"_45":46,"_44":172,"_161":30,"_42":217,"_13":174,"_38":175,"_40":176,"_29":30,"_165":177,"_211":218,"_32":219},{"_47":167,"_37":33,"_35":36,"_159":-5,"_45":46,"_44":14,"_161":136,"_42":214,"_13":67,"_38":39,"_40":41,"_29":30,"_165":-5,"_211":215,"_32":216},{"_47":156,"_37":157,"_35":158,"_159":-5,"_45":46,"_44":160,"_161":30,"_42":210,"_13":67,"_38":163,"_40":164,"_29":30,"_165":-5,"_211":212,"_32":213},["D",1787253114565],"children",[],[157],["D",1787253254803],[],[33],["D",1787253232795],[],[171],["D",1787253252295],[],[180],["D",1787252999023],[],[188],["D",1787252879017],["D",1789520505489],{"_108":107,"_115":111},{"_108":107,"_109":-5,"_110":111,"_19":60,"_112":113,"_114":30},{"_13":93,"_37":94,"_47":46,"_95":48,"_96":97,"_98":99,"_100":54,"_101":102,"_103":104,"_105":49,"_106":107},"ctx",{"_86":-5,"_138":264,"_265":266,"_267":268,"_269":30,"_270":30,"_271":30,"_272":136,"_273":-5,"_274":-7,"_275":-7,"_276":67,"_277":30,"_278":30,"_279":-5,"_280":30,"_281":30,"_282":30,"_283":-5},"ENV",{"_235":236,"_237":238,"_239":94,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v15