2f:T5db,

Inbound from Quincy Center

${tripsInbound.map(trip => { const schedule = trip.scheduleQuincyCenter const scheduleArrival = trip.scheduleSouthStation const minutes = d3.timeMinute.count(Date.now(), schedule.arrivalTime) const hours = Math.floor(minutes / 60) const delay = Math.round((schedule["arrivalTime"] - schedule["scheduleArrivalTime"])/ (1000 * 60)) let color = "#000000" if (schedule["predictionArrivalTime"]) { if (delay > 0) { color = 'red' } else { color = 'green' } } const {vehicle} = trip let vehicleStatus = '' if (vehicle) { vehicleStatus = `${vehicle.current_status} ${vehicle.stop.name}` } let vehicleSpeed = '' if (vehicle) { vehicleSpeed = `${Math.round(vehicle.speed)} mph` } return htl.html``})}

Prediction	Schedule	Arrival	Route
${hours > 0 ? hours : ''}${hours > 0 ? 'h' : ''} ${minutes % 60}m ${delay < 0 ? '(' + Math.abs(delay) + 'm early)' : ''} ${delay > 0 ? '(' + Math.abs(delay) + 'm late)' : ''}	${d3.timeFormat('%-I:%M %p')(schedule["arrivalTime"])}	${d3.timeFormat('%-I:%M %p')(scheduleArrival["arrivalTime"])}	${schedule["route_long_name"]}	${vehicleStatus}	${vehicleSpeed}

30:T565,

Outbound from South Station

${tripsOutbound.map(trip => { const schedule = trip.scheduleSouthStation const scheduleArrival = trip.scheduleQuincyCenter const minutes = d3.timeMinute.count(Date.now(), schedule["departureTime"]) const hours = Math.floor(minutes / 60) const delay = Math.round((schedule["departureTime"] - schedule["scheduleDepartureTime"])/ (1000 * 60)) let color = "#000000" if (schedule["predictionDepartureTime"]) { if (delay > 0) { color = 'red' } else { color = 'green' } } const {vehicle} = trip let vehicleStatus = '' if (vehicle) { vehicleStatus = `${vehicle.current_status} ${vehicle.stop.name}` } return htl.html``})}

Prediction	Schedule	Arrival	Route
${hours > 0 ? hours : ''}${hours > 0 ? 'h' : ''} ${minutes % 60}m ${delay < 0 ? '(' + Math.abs(delay) + 'm early)' : ''} ${delay > 0 ? '(' + Math.abs(delay) + 'm late)' : ''}	${d3.timeFormat('%-I:%M %p')(schedule["departureTime"])}	${d3.timeFormat('%-I:%M %p')(scheduleArrival["departureTime"])}	${schedule["route_long_name"]}	${vehicleStatus}

31:T5a7,

Next at Quincy Center

${tripsClean.filter(d => d.scheduleQuincyCenter && !d.scheduleQuincyCenter.isArrived).sort((a, b) => d3.ascending(a.scheduleQuincyCenter.arrivalTime, b.scheduleQuincyCenter.arrivalTime)).map(trip => { const schedule = trip.scheduleQuincyCenter const scheduleArrival = trip.scheduleSouthStation const minutes = d3.timeMinute.count(Date.now(), schedule["departureTime"]) const hours = Math.floor(minutes / 60) const delay = Math.round((schedule["departureTime"] - schedule["scheduleDepartureTime"])/ (1000 * 60)) let color = "#000000" if (schedule["predictionDepartureTime"]) { if (delay > 0) { color = 'red' } else { color = 'green' } } const {vehicle} = trip let vehicleStatus = '' if (vehicle) { vehicleStatus = `${vehicle.current_status} ${vehicle.stop.name}` } return htl.html``})}

Prediction	Schedule	Destination	Status
${hours > 0 ? hours : ''}${hours > 0 ? 'h' : ''} ${minutes % 60}m ${delay < 0 ? '(' + Math.abs(delay) + 'm early)' : ''} ${delay > 0 ? '(' + Math.abs(delay) + 'm late)' : ''}	${d3.timeFormat('%-I:%M %p')(schedule["departureTime"])}	${trip.tripDetails.headsign}	${vehicleStatus}

32:T9a2,schedulesClean = schedules.data.map(schedule => { const {arrival_time: schedule_arrival_time, departure_time: schedule_departure_time, direction_id, stop_headsign, stop_sequence} = schedule.attributes const scheduleDepartureTime = schedule_departure_time ? new Date(schedule_departure_time) : null const scheduleArrivalTime = schedule_arrival_time ? new Date(schedule_arrival_time) : null const {color: route_color, description: route_description, long_name: route_long_name, direction_destinations: route_direction_destinations, direction_names: route_direction_names} = routes.get(schedule.relationships.route.data.id) const direction_destination = route_direction_destinations[direction_id] const direction_name = route_direction_names[direction_id] const tripId = schedule.relationships.trip.data.id const {headsign: trip_headsign} = trips.get(tripId) const {name: stop_name} = stops.get(schedule.relationships.stop.data.id) const {arrival_time: prediction_arrival_time, departure_time: prediction_departure_time} = schedule.relationships.prediction.data ? predictions.get(schedule.relationships.prediction.data.id) : {arrival_time: null} const predictionArrivalTime = prediction_arrival_time ? new Date(prediction_arrival_time) : null const predictionDepartureTime = prediction_departure_time ? new Date(prediction_departure_time) : null const arrivalTime = predictionArrivalTime ? predictionArrivalTime : scheduleArrivalTime const arrivalTimeType = predictionArrivalTime ? 'prediction' : 'schedule' const departureTime = predictionDepartureTime ? predictionDepartureTime : scheduleDepartureTime const departureTimeType = predictionDepartureTime ? 'prediction' : 'schedule' const time = departureTime ? departureTime : arrivalTime const timeType = departureTime ? departureTimeType : arrivalTimeType const delay = predictionArrivalTime - scheduleArrivalTime const now = new Date() const isArrived = arrivalTime < now const isDeparted = departureTime < now return { arrivalTime, arrivalTimeType, scheduleArrivalTime, predictionArrivalTime, departureTime, departureTimeType, scheduleDepartureTime, predictionDepartureTime, time, timeType, delay, tripId, direction_id, direction_destination, direction_name, stop_name, stop_sequence, route_description, route_long_name, route_color: `#${route_color}`, isArrived, isDeparted } })33:[{"id":"db03aacc7d9c203d15e7a48bc39260c1279d03aa8cc399604132a5dfc6509b74a4ca5597001330b136a3c55d316fd73b1f268082d026e991a743b254b069704c","href":"https://static.observableusercontent.com/files/db03aacc7d9c203d15e7a48bc39260c1279d03aa8cc399604132a5dfc6509b74a4ca5597001330b136a3c55d316fd73b1f268082d026e991a743b254b069704c","name":"greenbush.geojson","type":"application/geo+json","lastModified":1688343729487.895,"size":60635}] 2d:{"title":"MBTA Commuter Rail","cells":[{"id":0,"value":"# MBTA Commuter Rail\n\nhttps://www.mbta.com/developers/v3-api","pinned":false,"hidden":false,"mode":"md"},{"id":413,"value":"viewof updatedAtPointer = Plot.plot({\n marginLeft: 85,\n width: 1180,\n height: 350,\n grid: true,\n facet: {\n data: oldColonyRouteProgress.filter(d => d.dist < 0.15),\n y: \"direction_id\"\n },\n y: {\n ticks: greenbushStations.filter(d => d.location > 18.5 && d.location < 27.8 ).map(d => d.location),\n tickFormat: (d, i) => greenbushStations.filter(d => d.location > 18.5 && d.location < 27.8 )[i].name,\n domain: [18.5, 27.74735673881346]\n },\n x: {\n type: \"time\"\n },\n color: oldColonyColor,\n marks: [\n Plot.line(oldColonyRouteProgress.filter(d => d.dist < 0.15), {x: \"updatedAt\", y: \"location\", fy: \"direction_id\", z: \"tripId\", stroke: \"routeId\", clip: \"frame\"}),\n Plot.ruleX(oldColonyRouteProgress.filter(d => d.dist < 0.15), Plot.pointerX({x: \"updatedAt\", stroke: \"red\"})),\n \n ]\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":465,"value":"Plot.plot({\n projection: {\n type: \"mercator\",\n domain: greenbush,\n inset: 50\n },\n color: oldColonyColor,\n marks: [\n Plot.geo(greenbush),\n Plot.geo(greenbushStationsGeo, {stroke: \"black\", r: 4}),\n Plot.text(greenbushStationsGeo, Plot.centroid({\n text: (d) => d.name,\n textAnchor: \"start\",\n dy: -5,\n dx: 5,\n stroke: \"white\",\n fill: \"black\"\n })),\n Plot.geo(oldColonyVehicleLocationHistory.filter(d => !updatedAtPointer || (updatedAtPointer.updatedAt - d.updatedAt)/1000 < 60 && (updatedAtPointer.updatedAt - d.updatedAt)/1000 >= 0).map(d => { \n return {\n type: \"Feature\",\n geometry: {\n type: \"Point\",\n coordinates: [d.longitude, d.latitude]\n },\n ...d\n }\n }), { fill: \"routeId\", stroke: \"white\" }),\n \n ]\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":83,"value":"$2f","pinned":false,"hidden":false,"mode":"html"},{"id":143,"value":"$30","pinned":false,"hidden":false,"mode":"html"},{"id":272,"value":"$31","pinned":false,"hidden":false,"mode":"html"},{"id":346,"value":"vehicleLocationHistory = fetch(\"https://mbta-tracker.jmuyskens.workers.dev/?getHours=6\").then(d => d.json())","pinned":true,"hidden":false,"mode":"ojs"},{"id":4,"value":"schedules = fetch(\"https://api-v3.mbta.com/schedules?include=stop%2Ctrip%2Cprediction%2Croute&filter%5Broute_type%5D=2&filter%5Broute%5D=CR-Greenbush%2CCR-Kingston%2CCR-Middleborough\").then(res => res.json())","pinned":false,"hidden":false,"mode":"ojs"},{"id":286,"value":"alertsAPIResponse = fetch(\"https://api-v3.mbta.com/alerts?include=stops%2Croutes%2Ctrips%2Cfacilities&filter%5Bactivity%5D=BOARD%2CEXIT%2CRIDE\").then(res => res.json())","pinned":false,"hidden":false,"mode":"ojs"},{"id":154,"value":"vehicles = fetch(\"https://api-v3.mbta.com/vehicles?include=trip%2Cstop%2Croute&filter%5Broute_type%5D=1,2\").then(res => res.json())","pinned":false,"hidden":false,"mode":"ojs"},{"id":293,"value":"routeAlerts = new Map(alertsAPIResponse.data.reduce((prev, curr) => {\n \n const {routes} = curr.relationships\n if (routes) {\n for (const route of routes.data) {\n prev.push([route.id, curr])\n }\n }\n return prev\n}, []))","pinned":false,"hidden":false,"mode":"ojs"},{"id":308,"value":"tripAlerts = new Map(alertsAPIResponse.data.reduce((prev, curr) => {\n \n const {trips} = curr.relationships\n if (trips) {\n for (const trip of trips.data) {\n prev.push([trip.id, curr])\n }\n }\n return prev\n}, []))","pinned":false,"hidden":false,"mode":"ojs"},{"id":22,"value":"routes = new Map(schedules.included.filter(d => d.type === \"route\").map(d => [d.id, d.attributes]))","pinned":false,"hidden":false,"mode":"ojs"},{"id":25,"value":"predictions = new Map(schedules.included.filter(d => d.type === \"prediction\").map(d => [d.id, d.attributes]))","pinned":false,"hidden":false,"mode":"ojs"},{"id":29,"value":"stops = new Map(schedules.included.filter(d => d.type === \"stop\").map(d => [d.id, d.attributes]))","pinned":false,"hidden":false,"mode":"ojs"},{"id":135,"value":"viewof table = Inputs.table([...stops.entries()].map(d => { return {id: d[0], ...d[1]}}))","pinned":false,"hidden":false,"mode":"ojs"},{"id":33,"value":"trips = new Map(schedules.included.filter(d => d.type === \"trip\").map(d => [d.id, d.attributes]))","pinned":false,"hidden":false,"mode":"ojs"},{"id":220,"value":"schedulesByTrip = d3.group(schedulesClean, d => d.tripId)","pinned":false,"hidden":false,"mode":"ojs"},{"id":251,"value":"tripsOutbound = tripsClean.filter(trip => trip.tripDetails.direction_id === 0 && trip.scheduleQuincyCenter && !trip.scheduleQuincyCenter.isDeparted && trip.scheduleSouthStation && !trip.scheduleSouthStation.isDeparted).sort((a, b) => d3.ascending(a.scheduleSouthStation.departureTime, b.scheduleSouthStation.departureTime))","pinned":false,"hidden":false,"mode":"ojs"},{"id":246,"value":"tripsInbound = tripsClean.filter(trip => trip.tripDetails.direction_id === 1 && trip.scheduleQuincyCenter && !trip.scheduleQuincyCenter.isDeparted && trip.scheduleSouthStation).sort((a, b) => d3.ascending(a.scheduleQuincyCenter.arrivalTime, b.scheduleQuincyCenter.arrivalTime))","pinned":false,"hidden":false,"mode":"ojs"},{"id":230,"value":"tripsClean = [...trips.keys()].map(tripId => {\n const schedules = schedulesByTrip.get(tripId)\n const schedulesMap = new Map(schedules.map(schedule => [schedule.stop_name, schedule]))\n const scheduleQuincyCenter = schedulesMap.get('Quincy Center')\n const scheduleSouthStation = schedulesMap.get('South Station')\n const tripDetails = trips.get(tripId)\n const vehicle = tripVehicle.get(tripId)\n const tripAlert = tripAlerts.get(tripId)\n \n return {\n tripId,\n tripDetails,\n schedules,\n schedulesMap,\n scheduleQuincyCenter,\n scheduleSouthStation,\n vehicle,\n tripAlert\n }\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":8,"value":"schedulesIncludeMap = new Map(schedules.included.map(d => [d.id, d]))","pinned":false,"hidden":false,"mode":"ojs"},{"id":15,"value":"schedules.data[0]","pinned":false,"hidden":false,"mode":"ojs"},{"id":13,"value":"$32","pinned":false,"hidden":false,"mode":"ojs"},{"id":19,"value":"schedulesClean","pinned":true,"hidden":false,"mode":"ojs"},{"id":62,"value":"inboundSchedules = schedulesClean.filter(d => d.direction_name === \"Inbound\")","pinned":true,"hidden":false,"mode":"ojs"},{"id":64,"value":"outboundSchedules = schedulesClean.filter(d => d.direction_name === \"Outbound\")","pinned":true,"hidden":false,"mode":"ojs"},{"id":50,"value":"Plot.plot({\n x: {\n type: \"time\"\n },\n marks: [\n Plot.line(inboundSchedules, {x: \"arrivalTime\", y: \"stop_sequence\", z: \"tripId\", stroke: \"delay\"}),\n Plot.dot(inboundSchedules, {x: \"predictionArrivalTime\", y: \"stop_sequence\", z: \"tripId\", color: \"red\"})\n ]\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":69,"value":"Plot.plot({\n x: {\n type: \"time\"\n },\n marks: [\n Plot.line(outboundSchedules, {x: \"arrivalTime\", y: \"stop_sequence\", z: \"tripId\"}),\n Plot.dot(outboundSchedules, {x: \"predictionArrivalTime\", y: \"stop_sequence\", z: \"tripId\"})\n ]\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":78,"value":"nextInboundQuincyCenter = inboundSchedules.filter(d => d.arrivalTime >= Date.now() && d.stop_name === \"Quincy Center\").sort((a, b) => d3.ascending(a.arrivalTime, b.arrivalTime))","pinned":true,"hidden":false,"mode":"ojs"},{"id":81,"value":"nextOutboundSouthStation = outboundSchedules.filter(d => d.stop_name === \"South Station\").sort((a, b) => d3.ascending(a.departureTime, b.departureTime))","pinned":false,"hidden":false,"mode":"ojs"},{"id":192,"value":"mapIncluded = function(apiData) {\n const {included} = apiData\n const route = new Map(included.filter(d => d.type === \"route\").map(d => [d.id, d.attributes]))\n const stop = new Map(included.filter(d => d.type === \"stop\").map(d => [d.id, d.attributes]))\n const trip = new Map(included.filter(d => d.type === \"trip\").map(d => [d.id, d.attributes]))\n const prediction = new Map(included.filter(d => d.type === \"prediction\").map(d => [d.id, d.attributes]))\n return {\n route,\n stop,\n trip,\n prediction\n }\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":196,"value":"vehiclesIncluded = mapIncluded(vehicles)","pinned":false,"hidden":false,"mode":"ojs"},{"id":198,"value":"vehiclesClean = vehicles.data.map(vehicle => {\n const {attributes, relationships} = vehicle\n const route = vehiclesIncluded.route.get(relationships.route.data.id)\n const stop = vehiclesIncluded.stop.get(relationships.stop.data ? relationships.stop.data.id : null)\n const trip = vehiclesIncluded.trip.get(relationships.trip.data.id)\n \n return {\n ...attributes,\n route,\n stop,\n trip\n }\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":262,"value":"tripVehicle = new Map(vehicles.data.map(vehicle => {\n const {attributes, relationships} = vehicle\n const tripId = relationships.trip.data.id\n const stop = vehiclesIncluded.stop.get(relationships.stop.data ? relationships.stop.data.id : null)\n const point = turf.nearestPointOnLine(greenbush.features[0].geometry, [attributes.longitude, attributes.latitude], {units: 'miles'})\n return [\n tripId,\n {\n ...attributes,\n stop,\n point\n }\n ]\n}))","pinned":false,"hidden":false,"mode":"ojs"},{"id":207,"value":"vehiclesGeoJSON = {\n return {\n type: 'FeatureCollection',\n features: vehiclesClean.map(vehicle => {\n return {\n type: 'Feature',\n geometry: {\n type: 'Point',\n coordinates: [vehicle.longitude, vehicle.latitude],\n },\n properties: {\n ...vehicle\n }\n\n }\n })\n}}","pinned":false,"hidden":false,"mode":"ojs"},{"id":324,"value":"greenbush = FileAttachment(\"greenbush.geojson\").json()","pinned":true,"hidden":false,"mode":"ojs"},{"id":325,"value":"turf = require(\"@turf/turf@6\")","pinned":true,"hidden":false,"mode":"ojs"},{"id":488,"value":"greenbushStationsGeo = greenbushStations.map(d => {\n return {\n type: \"Feature\",\n geometry: {\n type: \"Point\",\n coordinates: [d.longitude, d.latitude]\n },\n ...d\n }\n})","pinned":false,"hidden":false,"mode":"ojs"},{"id":327,"value":"vehiclesClean.map(vehicle => {\n const point = turf.nearestPointOnLine(greenbush.features[0].geometry, [vehicle.longitude, vehicle.latitude], {units: 'miles'})\n return point\n})","pinned":true,"hidden":false,"mode":"ojs"},{"id":348,"value":"oldColonyVehicleLocationHistory = vehicleLocationHistory.filter(vehicle => vehicle.routeId === 'CR-Kingston' || vehicle.routeId === 'CR-Middleborough' || vehicle.routeId === 'CR-Greenbush' || vehicle.routeId === 'Red').map(d => { return {...d, updatedAt: new Date(d.updated_at) }})","pinned":false,"hidden":false,"mode":"ojs"},{"id":351,"value":"oldColonyRouteProgress = {\n let t = []\n let i = 0;\n for (const vehicle of oldColonyVehicleLocationHistory) {\n const {tripId, stopId, longitude, latitude, updated_at} = vehicle\n const stop = vehiclesIncluded.stop.get(stopId)\n const point = turf.nearestPointOnLine(greenbush.features[0].geometry, [longitude, latitude], {units: 'miles'})\n const {dist, location} = point.properties\n \n if (dist < 0.25) {\n t.push({\n ...vehicle,\n \n stop,\n point,\n dist,\n location\n })\n if (++i % 10 === 0) yield t;\n }\n }\n yield t;\n}\n","pinned":false,"hidden":false,"mode":"ojs"},{"id":364,"value":"greenbushStations = schedules.included.filter(d => d.type === \"stop\").map(stop => {\n const {attributes} = stop\n const {latitude, longitude} = attributes\n const point = turf.nearestPointOnLine(greenbush.features[0].geometry, [longitude, latitude], {units: 'miles'})\n const {dist, location} = point.properties\n return {\n ...attributes,\n dist,\n location\n }\n}).filter(d => d.dist < 0.1)","pinned":false,"hidden":false,"mode":"ojs"},{"id":483,"value":"oldColonyColor = ({\n domain: ['CR-Greenbush', 'CR-Kingston', 'CR-Middleborough', 'Red'],\n range: [\"#80276C\", \"#80276C\", \"#80276C\", \"#CD313350\"]\n })","pinned":false,"hidden":false,"mode":"ojs"},{"id":446,"value":"oldColonyRouteProgress","pinned":true,"hidden":false,"mode":"ojs"},{"id":469,"value":"import {geoMassachusettsMainland} from \"@washpostgraphics/state-plane-selector\"","pinned":true,"hidden":false,"mode":"ojs"}],"files":"$W33","stdlib":"1","titling":"auto"}