MTA GTFS Real Time Proto Decoder

mta.js

const Proto = require('protobufjs');
const Req = require('request');
var GtfsRealtimeBindings = require('gtfs-realtime-bindings');

const MTA_API_ENDPOINT = "http://datamine.mta.info/mta_esi.php?key=148133e77dd93f66b37d6c5054684401&feed_id=1"

Req({
	method: 'GET',
	url: MTA_API_ENDPOINT,
	encoding: null
}, (err, response, body) => {
	var feed = GtfsRealtimeBindings.FeedMessage.decode(body);
	feed.entity.forEach(function(entity) {
		if (entity.trip_update) {
			console.log(entity.trip_update);
		}
	});
});