[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_333":334,"_335":336},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_51":-7,"_240":-5,"_19":241,"_242":243,"_244":245,"_246":247,"_248":249,"_21":250,"_251":252,"_253":254,"_255":24,"_256":257,"_258":259,"_260":-5,"_261":-5,"_262":263},"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","main.ts","project",{"_45":188,"_13":14,"_49":189,"_77":-5,"_190":24,"_191":192,"_193":192,"_194":195,"_196":197,"_30":83,"_198":79,"_199":24,"_200":-5,"_201":-5,"_202":26,"_53":54,"_203":204,"_205":206,"_207":208,"_209":-5,"_210":211,"_212":211,"_213":214,"_215":214,"_216":214,"_217":211,"_218":211,"_64":219,"_220":221,"_222":223,"_224":24},"file",{"_78":79,"_13":18,"_80":81,"_82":24,"_187":-5},"isDirectory",false,"page",0,"history",[31,32,33,34,35,36,37,38,39,40,41,42,43,44],"hasNext","userId",{"_45":180,"_47":48,"_49":181,"_51":182,"_53":54,"_55":173,"_56":-5,"_58":161,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":183,"_21":184,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":185},{"_45":173,"_47":48,"_49":174,"_51":175,"_53":54,"_55":166,"_56":-5,"_58":161,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":176,"_21":177,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":178},{"_45":166,"_47":48,"_49":167,"_51":168,"_53":54,"_55":157,"_56":-5,"_58":161,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":169,"_21":170,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":171},{"_45":157,"_47":48,"_49":158,"_51":159,"_53":54,"_55":160,"_56":-5,"_58":161,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":162,"_21":163,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":164},{"_45":150,"_47":48,"_49":151,"_51":152,"_53":54,"_55":143,"_56":-5,"_58":138,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":153,"_21":154,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":155},{"_45":143,"_47":48,"_49":144,"_51":145,"_53":54,"_55":134,"_56":-5,"_58":138,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":146,"_21":147,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":148},{"_45":134,"_47":48,"_49":135,"_51":136,"_53":54,"_55":137,"_56":-5,"_58":138,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":139,"_21":140,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":141},{"_45":127,"_47":48,"_49":128,"_51":129,"_53":54,"_55":118,"_56":-5,"_58":122,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":130,"_21":131,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":132},{"_45":118,"_47":48,"_49":119,"_51":120,"_53":54,"_55":121,"_56":-5,"_58":122,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":123,"_21":124,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":125},{"_45":111,"_47":48,"_49":112,"_51":113,"_53":54,"_55":102,"_56":-5,"_58":106,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":114,"_21":115,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":116},{"_45":102,"_47":48,"_49":103,"_51":104,"_53":54,"_55":105,"_56":-5,"_58":106,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":107,"_21":108,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":109},{"_45":95,"_47":48,"_49":96,"_51":97,"_53":54,"_55":86,"_56":-5,"_58":90,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":98,"_21":99,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":100},{"_45":86,"_47":48,"_49":87,"_51":88,"_53":54,"_55":89,"_56":-5,"_58":90,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":91,"_21":92,"_67":-5,"_68":-5,"_70":-5,"_71":-5,"_72":93},{"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_56":57,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":65,"_21":66,"_67":-5,"_68":69,"_70":-5,"_71":-5,"_72":73},"id","d0390016-5bf0-4b61-b19a-edab128ef121","branchId","1825b209-ac72-41e6-a980-02e7cc391063","createdAt",["D",1787252879017],"version",1,"orgId","019adb55-d35c-728f-b295-f00e23c346f1","parentId","incomingCommitId","c0026277-f5e7-47bd-a55e-9d050953919e","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},"pull","merge",{"_47":75,"_13":16,"_51":76,"_77":-5},"revert","multiple","commits",[74],{"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_56":57,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":65,"_21":66,"_67":-5,"_68":69,"_70":-5},"4317995d-9bca-44ba-8f1c-e817322f354f",35,"deletedAt","fileId","01a02092-b0af-72ec-bba6-7217fa87c97d","fileType","http","deleted","019adb55-d35c-728f-b295-ec7539176851","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM2Rnkza0hHT2QwSXJDb0JIQTR0M21kc256UCJ9","3703997b-550b-4d31-a1b9-d8992364946e",["D",1787252939601],4,"1a521dca-f815-4e86-8c0c-94b4f764a799","77bf9c02-fda8-476f-ae92-d8c7adfa69de",{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[94],{"_45":86,"_47":48,"_49":87,"_51":88,"_53":54,"_55":89,"_56":-5,"_58":90,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":91,"_21":92,"_67":-5,"_68":-5,"_70":-5},"0b7421bc-70f2-4813-af6f-360e2e167992",["D",1787252978791],5,{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[101],{"_45":95,"_47":48,"_49":96,"_51":97,"_53":54,"_55":86,"_56":-5,"_58":90,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":98,"_21":99,"_67":-5,"_68":-5,"_70":-5},"3c8c85b2-848d-46ac-b118-1abcae268f6b",["D",1787253213199],11,"69878717-cf0f-44de-9def-b1951be2af41","b814935d-6ff0-41d8-bf5c-5c0462ff3820",{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[110],{"_45":102,"_47":48,"_49":103,"_51":104,"_53":54,"_55":105,"_56":-5,"_58":106,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":107,"_21":108,"_67":-5,"_68":-5,"_70":-5},"006c8eed-0385-47c7-acff-f9807eeb50c8",["D",1787253232795],12,{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[117],{"_45":111,"_47":48,"_49":112,"_51":113,"_53":54,"_55":102,"_56":-5,"_58":106,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":114,"_21":115,"_67":-5,"_68":-5,"_70":-5},"40f6788b-3a4f-4c99-91b2-6710c06d1db9",["D",1787253436384],22,"b96b55fb-cc0e-4f3f-a5a6-76182a5e0689","60ffd694-83f0-4d4d-8cdb-ac0bbf461cdc",{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[126],{"_45":118,"_47":48,"_49":119,"_51":120,"_53":54,"_55":121,"_56":-5,"_58":122,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":123,"_21":124,"_67":-5,"_68":-5,"_70":-5},"bd230a2c-b842-4f47-9d8c-8a8cac2f51c6",["D",1787253438707],23,{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[133],{"_45":127,"_47":48,"_49":128,"_51":129,"_53":54,"_55":118,"_56":-5,"_58":122,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":130,"_21":131,"_67":-5,"_68":-5,"_70":-5},"43990b90-b431-4115-9c7f-12ca685d4349",["D",1787253525983],25,"7f2a4cca-3275-48b3-8fe2-4b370fec6f94","f3c265d7-4203-48d8-8b0a-16413d338404",{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[142],{"_45":134,"_47":48,"_49":135,"_51":136,"_53":54,"_55":137,"_56":-5,"_58":138,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":139,"_21":140,"_67":-5,"_68":-5,"_70":-5},"9278b890-f53b-4f45-900a-24537c6a2547",["D",1787253536610],26,{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[149],{"_45":143,"_47":48,"_49":144,"_51":145,"_53":54,"_55":134,"_56":-5,"_58":138,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":146,"_21":147,"_67":-5,"_68":-5,"_70":-5},"c8941d5b-9674-4281-9ade-7c0f289f8f03",["D",1787253540161],27,{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[156],{"_45":150,"_47":48,"_49":151,"_51":152,"_53":54,"_55":143,"_56":-5,"_58":138,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":153,"_21":154,"_67":-5,"_68":-5,"_70":-5},"4cbc66d4-50d4-4284-8e61-4ae4212b6ffb",["D",1787253763529],31,"3f56d68d-528b-4be3-b7ae-8b272becea39","a6e29c38-224e-4944-b846-caaa7f17622e",{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[165],{"_45":157,"_47":48,"_49":158,"_51":159,"_53":54,"_55":160,"_56":-5,"_58":161,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":162,"_21":163,"_67":-5,"_68":-5,"_70":-5},"35332fb8-b673-4115-b5d5-1c77496fbd0e",["D",1787253770607],32,{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[172],{"_45":166,"_47":48,"_49":167,"_51":168,"_53":54,"_55":157,"_56":-5,"_58":161,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":169,"_21":170,"_67":-5,"_68":-5,"_70":-5},"1b1aed95-fc38-4708-9ca1-16efe4ea0552",["D",1787253778658],33,{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[179],{"_45":173,"_47":48,"_49":174,"_51":175,"_53":54,"_55":166,"_56":-5,"_58":161,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":176,"_21":177,"_67":-5,"_68":-5,"_70":-5},"1cebfcec-28bf-4645-9767-5d7b723ee969",["D",1787253783810],34,{"_45":83,"_53":54,"_11":12,"_84":85},{"_78":79,"_13":18,"_80":81,"_82":24},[186],{"_45":180,"_47":48,"_49":181,"_51":182,"_53":54,"_55":173,"_56":-5,"_58":161,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":183,"_21":184,"_67":-5,"_68":-5,"_70":-5},"deletedAtVersion","2cfb9927-155e-47cc-9f73-c923b21f7f89",["D",1787252879017],"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=1789574399&sig=cc85601be98c236cb528f298013a11bef65438acbffa6d48fe8697dce2856585","pinnedFileId","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,"_239":85},"org",{"_11":12,"_235":-5,"_84":85,"_30":83,"_236":237,"_238":24},"branch",{"_51":76,"_13":16,"_45":48,"_225":188,"_226":75,"_227":175,"_228":192,"_229":230,"_231":232,"_233":14,"_234":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","c5a66f73-8318-4d99-b192-14a8e864ebc4","forkedProjectOrgId","019aa807-52c2-709c-928b-2029bae9a558","projectName","userHandle","displayName","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_45":188,"_13":14,"_49":328,"_77":-5,"_190":24,"_191":192,"_193":192,"_194":195,"_196":197,"_30":83,"_198":79,"_199":24,"_200":-5,"_201":-5,"_202":26,"_53":54,"_203":204,"_205":206,"_207":329,"_209":-5,"_210":211,"_212":211,"_213":214,"_215":214,"_216":214,"_217":211,"_218":211,"_64":330,"_220":331,"_222":332,"_224":24},"tree",[293,294,295,296],"files",[293,294,295,296],"counts",{"_283":26,"_284":52,"_285":26,"_286":287,"_288":289},"contents",[],{"_45":274,"_47":48,"_78":79,"_13":18,"_275":276,"_80":81,"_51":277,"_55":-5,"_49":278,"_279":182,"_280":281,"_17":282},"upstreamProject",{"_45":230,"_13":270,"_194":271,"_196":197,"_191":192,"_64":272},"upstreamBranch",{"_45":75,"_49":264,"_265":266,"_13":16,"_225":230,"_51":76,"_226":-5,"_227":-5,"_267":268,"_77":-5,"_224":24,"_191":192,"_234":269,"_53":232,"_233":270},"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":269,"_239":273},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789574399&sig=3d6a0be010e77940e58f104bd06b986c1fe4f3a57bc9d85e134d5d62fe89a483","48d178a2-95cd-4bf4-a2fb-f29e2cb3b55e","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\";\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",13,["D",1787253783810],"branchVersion","label","amtrak-status-mcp",[18],"pulls","branches","forks","envVars",{"_290":26,"_292":26},"connections",{"_290":26,"_291":26},"count","unfilledCount","emptyCount",{"_45":321,"_13":322,"_78":323,"_55":-5,"_47":48,"_279":76,"_301":259,"_49":324,"_51":88,"_80":21,"_275":325,"_82":24,"_280":-5,"_305":326,"_17":327},{"_45":311,"_13":312,"_78":313,"_55":-5,"_47":48,"_279":314,"_301":259,"_49":315,"_51":316,"_80":317,"_275":318,"_82":24,"_280":-5,"_305":319,"_17":320},{"_45":274,"_13":18,"_78":79,"_55":-5,"_47":48,"_279":182,"_301":259,"_49":308,"_51":277,"_80":81,"_275":276,"_82":24,"_280":281,"_305":309,"_17":310},{"_45":297,"_13":298,"_78":299,"_55":-5,"_47":48,"_279":300,"_301":259,"_49":302,"_51":26,"_80":303,"_275":304,"_82":24,"_280":-5,"_305":306,"_17":307},"4f89f110-1811-4e46-bb57-bb5ff66b6b5d","refresh-gtfs.ts","5546a9aa-9ccb-11f1-8c77-1607ee4eb77e",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","children",[],[298],["D",1787253783810],[],[18],"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",[],[312],"020fd710-2a49-4132-835a-38390eff0ee5","README.md","01a02092-b0af-72ec-bba6-6fef447fd351",["D",1787253821007],"# 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",[],[322],["D",1787252879017],["D",1789520505489],{"_11":12,"_239":85},{"_11":12,"_235":-5,"_84":85,"_30":83,"_236":237,"_238":24},{"_51":76,"_13":16,"_45":48,"_225":188,"_226":75,"_227":175,"_228":192,"_229":230,"_231":232,"_233":14,"_234":12},"ctx",{"_64":-5,"_261":366,"_367":368,"_369":370,"_371":24,"_372":24,"_373":24,"_374":259,"_375":-5,"_376":-7,"_377":-7,"_378":26,"_379":24,"_380":24,"_381":-5,"_382":24,"_383":24,"_384":24,"_385":-5},"ENV",{"_337":338,"_339":340,"_341":16,"_342":343,"_344":345,"_346":347,"_348":349,"_350":351,"_352":353,"_354":355,"_356":357,"_358":359,"_360":361,"_362":363,"_364":365},"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 · main.ts