[{"_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",{"_109":108,"_38":51,"_117":95,"_33":118,"_13":14,"_119":-5,"_11":120,"_121":122,"_123":124,"_125":126,"_127":128,"_26":-5,"_129":130,"_131":132,"_133":31,"_134":135,"_136":137,"_138":-5,"_139":-5,"_140":141},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":61,"_19":62,"_63":37,"_64":31,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":31},"version",31,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","a6e29c38-224e-4944-b846-caaa7f17622e","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","01a02092-b0af-72ec-bba6-7217fa87c97d","name","fileType","http","content","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\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst FEED_URL = \"https://asm-backend.transitdocs.com/gtfs/amtrak\";\nconst VEHICLE_CACHE_KEY = \"vehicle_positions_v1\";\nconst VEHICLE_CACHE_TTL_MS = 5 * 60 * 1000; // 5 minutes\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/** 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\n/**\n * Get the full list of vehicle positions, served from a 5-minute cache to\n * reduce upstream feed requests. On a cache miss it fetches + decodes the feed,\n * maps the vehicles, and stores them in blob storage.\n */\nasync function getCachedVehicles(): Promise[]> {\n const cached = await blob.getJSON(VEHICLE_CACHE_KEY);\n if (\n cached &&\n Array.isArray(cached.vehicles) &&\n typeof cached.fetchedAt === \"number\" &&\n Date.now() - cached.fetchedAt < VEHICLE_CACHE_TTL_MS\n ) {\n return cached.vehicles;\n }\n const feed = await getFeed();\n const vehicles = (feed.entity ?? [])\n .filter((e) => e.vehicle)\n .map((e) => mapVehicle(e.vehicle));\n await blob.setJSON(VEHICLE_CACHE_KEY, { fetchedAt: Date.now(), vehicles });\n return vehicles;\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 allVehicles = await getCachedVehicles();\n const vehicles = allVehicles.filter((v: any) =>\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({\n count: vehicles.length,\n cached: true,\n cacheTtlSeconds: VEHICLE_CACHE_TTL_MS / 1000,\n vehicles,\n }, 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","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/** 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\n/**\n * Get the full list of vehicle positions, served from a 5-minute cache to\n * reduce upstream feed requests. On a cache miss it fetches + decodes the feed,\n * maps the vehicles, and stores them in blob storage.\n */\nasync function getCachedVehicles(): Promise[]> {\n const cached = await blob.getJSON(VEHICLE_CACHE_KEY);\n if (\n cached &&\n Array.isArray(cached.vehicles) &&\n typeof cached.fetchedAt === \"number\" &&\n Date.now() - cached.fetchedAt < VEHICLE_CACHE_TTL_MS\n ) {\n return cached.vehicles;\n }\n const feed = await getFeed();\n const vehicles = (feed.entity ?? [])\n .filter((e) => e.vehicle)\n .map((e) => mapVehicle(e.vehicle));\n await blob.setJSON(VEHICLE_CACHE_KEY, { fetchedAt: Date.now(), vehicles });\n return vehicles;\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 allVehicles = await getCachedVehicles();\n const vehicles = allVehicles.filter((v: any) =>\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({\n count: vehicles.length,\n cached: true,\n cacheTtlSeconds: VEHICLE_CACHE_TTL_MS / 1000,\n vehicles,\n }, 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","createdAt",["D",1787253763529],"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=1789581599&sig=48b6ed5fac0f7d8efc451b92ed7273cca140e0919dd5dbc530e7e899e56a2272","019adb55-d35c-728f-b295-ec7539176851","pinnedFileId","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",{"_109":108,"_116":112},"org",{"_109":108,"_110":-5,"_111":112,"_19":62,"_113":114,"_115":31},"branch",{"_13":94,"_38":95,"_49":48,"_96":50,"_97":98,"_99":100,"_101":56,"_102":103,"_104":105,"_106":51,"_107":108},"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",{"_49":50,"_38":51,"_44":217,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":61,"_19":62,"_63":37,"_64":31,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":218,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":219,"_89":220,"_91":221,"_93":31},"tree",[200,201,202,203],"files",[200,201,202,203],"counts",{"_189":68,"_190":191,"_192":68,"_193":194,"_195":196},"contents",[152,153,154,155],"upstreamProject",{"_49":103,"_38":148,"_58":149,"_60":61,"_55":56,"_87":150},"upstreamBranch",{"_49":98,"_44":142,"_143":144,"_38":95,"_96":103,"_13":94,"_97":-5,"_99":-5,"_145":146,"_53":-5,"_93":31,"_55":56,"_107":147,"_69":105,"_106":148},"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",{"_109":147,"_116":151},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789581599&sig=bed85510764f48a9de82762af4b4ce99c525d0ab75e5b57f327c71a53e183d4a",{"_49":181,"_38":182,"_36":183,"_159":-5,"_47":48,"_46":184,"_161":31,"_44":185,"_13":186,"_39":26,"_41":187,"_30":31,"_165":-5,"_33":188},{"_49":172,"_38":173,"_36":174,"_159":-5,"_47":48,"_46":175,"_161":137,"_44":176,"_13":177,"_39":178,"_41":179,"_30":31,"_165":-5,"_33":180},{"_49":167,"_38":34,"_36":37,"_159":-5,"_47":48,"_46":14,"_161":31,"_44":168,"_13":169,"_39":40,"_41":43,"_30":31,"_165":170,"_33":171},{"_49":156,"_38":157,"_36":158,"_159":-5,"_47":48,"_46":160,"_161":137,"_44":162,"_13":68,"_39":163,"_41":164,"_30":31,"_165":-5,"_33":166},"4f89f110-1811-4e46-bb57-bb5ff66b6b5d","refresh-gtfs.ts","5546a9aa-9ccb-11f1-8c77-1607ee4eb77e","parentId",15,"latest",["D",1787253254803],"interval","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",[157],"0608f74a-6e7f-4b1e-bcdd-fb7df772a725",["D",1787253763529],10,"amtrak-status-mcp",[34],"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",[173],"9f90a088-be5c-4967-b247-995ca03498d7","README.md","01a02092-b0af-72ec-bba6-6fef447fd351",28,["D",1787253557400],3,"# 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- **`get_vehicle_positions`** is served from a **5-minute cache** (stored in blob\n storage) to cut upstream feed requests; the upstream feed is only fetched when\n the cache expires. Responses include `cached: true` and `cacheTtlSeconds`.\n- The other realtime tools (`get_trip_updates`, `get_service_alerts`,\n `get_feed_header`) fetch the feed live on every call.\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",[182],"pulls","branches",1,"forks","envVars",{"_197":68,"_199":68},"connections",{"_197":68,"_198":68},"count","unfilledCount","emptyCount",{"_49":181,"_38":182,"_36":183,"_159":-5,"_47":48,"_46":184,"_161":31,"_44":214,"_13":186,"_39":26,"_41":187,"_30":31,"_165":-5,"_205":215,"_33":216},{"_49":172,"_38":173,"_36":174,"_159":-5,"_47":48,"_46":175,"_161":137,"_44":211,"_13":177,"_39":178,"_41":179,"_30":31,"_165":-5,"_205":212,"_33":213},{"_49":167,"_38":34,"_36":37,"_159":-5,"_47":48,"_46":14,"_161":31,"_44":208,"_13":169,"_39":40,"_41":43,"_30":31,"_165":170,"_205":209,"_33":210},{"_49":156,"_38":157,"_36":158,"_159":-5,"_47":48,"_46":160,"_161":137,"_44":204,"_13":68,"_39":163,"_41":164,"_30":31,"_165":-5,"_205":206,"_33":207},["D",1787253254803],"children",[],[157],["D",1787253763529],[],[34],["D",1787253400383],[],[173],["D",1787253557400],[],[182],["D",1787252879017],["D",1789520505489],{"_109":108,"_116":112},{"_109":108,"_110":-5,"_111":112,"_19":62,"_113":114,"_115":31},{"_13":94,"_38":95,"_49":48,"_96":50,"_97":98,"_99":100,"_101":56,"_102":103,"_104":105,"_106":51,"_107":108},"ctx",{"_87":-5,"_139":255,"_256":257,"_258":259,"_260":31,"_261":31,"_262":31,"_263":137,"_264":-5,"_265":-7,"_266":-7,"_267":68,"_268":31,"_269":31,"_270":-5,"_271":31,"_272":31,"_273":31,"_274":-5},"ENV",{"_226":227,"_228":229,"_230":95,"_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"]

Diff · v31