script.js

var GtfsRealtimeBindings = require('gtfs-realtime-bindings'),
    request = require('request'),
    express = require('express'),
    cors = require('cors'),
    fs = require('fs');

var app = express();
app.use('/', express.static('public'));
app.use('/service_alerts.json',cors());
app.use('/trip_updates.json',cors());

var config = JSON.parse(fs.readFileSync('config.json', 'utf8'));

var requestSettingsTripUpdates = {
    method: 'GET',
    //url: 'http://localhost:8000/trip_updates.pb',
    url: config['gtfs-urls']['trip-updates'],
    encoding: null
};
var requestSettingsServiceAlerts = {
    method: 'GET',
    //url: 'http://localhost:8000/service_alerts.pb',
    url: config['gtfs-urls']['service-alerts'],
    encoding: null
};

request(requestSettingsServiceAlerts, function (error, response, body) {

    if (!error && response.statusCode == 200) {

        var feed = GtfsRealtimeBindings.FeedMessage.decode(body);

        fs.writeFile('public/service_alerts.json', JSON.stringify(feed), function (err) {
            if (err) return console.log(err);
        });
    }
});

request(requestSettingsTripUpdates, function (error, response, body) {
    if (!error && response.statusCode == 200) {
        var feed = GtfsRealtimeBindings.FeedMessage.decode(body);
        fs.writeFile('public/trip_updates.json', JSON.stringify(feed), function (err) {
            if (err) return console.log(err);
            //console.log('Hello World > helloworld.txt');
        });
        //console.log(feed.entity[0]);
    }
});

var minutes = 1, the_interval = minutes * 60 * 1000;
setInterval(function() {
    console.log("I am doing my minute check");

    request(requestSettingsTripUpdates, function (error, response, body) {

        if (!error && response.statusCode == 200) {

            var feed = GtfsRealtimeBindings.FeedMessage.decode(body);

            fs.writeFile('public/trip_updates.json', JSON.stringify(feed), function (err) {
                if (err) return console.log(err);
                //console.log('Hello World > helloworld.txt');
            });
            //console.log(feed.entity[0]);

        }else{console.log('Error trying to get tripupdates');}

    });


    request(requestSettingsServiceAlerts, function (error, response, body) {

        if (!error && response.statusCode == 200) {

            var feed = GtfsRealtimeBindings.FeedMessage.decode(body);

            fs.writeFile('public/service_alerts.json', JSON.stringify(feed), function (err) {
                if (err) return console.log(err);
                //console.log('Hello World > helloworld.txt');
            });
            //console.log(feed.entity[0]);
          
        }
    });
}, the_interval);

app.get('/servicesAlerts', function (req, res) {
    console.log("Got Service Alerts Request");

    request(requestSettingsServiceAlerts, function (error, response, body) {

        if (!error && response.statusCode == 200) {

            var feed = GtfsRealtimeBindings.FeedMessage.decode(body);
            res.write(JSON.stringify(feed));

            //console.log(feed.entity[0]);
            feed.entity.forEach(function(entity) {
               // res.write(JSON.stringify(entity));
              //  console.log(entity.alert.header_text.translation[0]);

            });
        }
    });
});

app.get('/tripUpdates', function (req, res) {
    console.log("Got Trip Updates Request");

    request(requestSettingsTripUpdates, function (error, response, body) {

        if (!error && response.statusCode == 200) {

            var feed = GtfsRealtimeBindings.FeedMessage.decode(body);

            feed.entity.forEach(function(entity) {
                res.write(JSON.stringify(entity));
                if (entity.trip_update) {
                    console.log(entity.trip_update);
                }
            });
        }
    });
});

var server = app.listen(config.port, function () {
    var host = server.address().address;
    var port = server.address().port;

    console.log('Example app listening at http://%s:%s', host, port);
});