silvrgit/lib/train.js

// train.js
const http = require('http');
const logger = require('log4js').getLogger('train');
let trainCache = {
  last: {},
  data: {}
};

module.exports = {
  dbe_glq: function (req, res) {

    logger.info('DBE:GLQ request');

    const now = new Date();
    const nowSeconds = (now.getHours() * (60 * 60)) + (now.getMinutes() * 60);

    if (trainCache.last.dbeglq === null || nowSeconds !== trainCache.last.dbeglq) 
      Query(function (a, b) {

        const ts = a.departures[0].service;
        let output = {};
        logger.debug(ts);

        logger.debug(ts.sta);
        output.sta = ts.sta;
        output.eta = ts.eta;
        trainCache.data.dbeglq = output;

        res.setHeader('Content-Type', 'application/json');
        res.end(JSON.stringify(trainCache.data.dbeglq));
      }, res, 'huxley.apphb.com', '/next/dbe/to/glq/1?accessToken=215b99fe-b237-4a01-aadc-cf315d6756d8');

        
  },
  glq_dbe: function (req, res) {

    logger.info('GLQ:DBE request');

    const now = new Date();
    const nowSeconds = (now.getHours() * (60 * 60)) + (now.getMinutes() * 60);

    if (trainCache.last.glqdbe === null || nowSeconds !== trainCache.last.dbeglq) 
      Query(function (a, b) {

        const ts = a.departures[0].service;
        const output = {};
        logger.debug(ts);
                //GLOBAL.lastcheck = now;
        logger.debug(ts.sta);
                // logger.debug(toSeconds(ts.sta));

        output.sta = ts.sta;
        output.eta = ts.eta;
        trainCache.data.glqdbe = output;
                //  trainCache.last.glqdbe = toSeconds(ts.sta);
                //  console.log(ts);
        res.setHeader('Content-Type', 'application/json');
        res.end(JSON.stringify(trainCache.data.glqdbe));
      }, res, 'huxley.apphb.com', '/next/glq/to/dbe/1?accessToken=215b99fe-b237-4a01-aadc-cf315d6756d8');

        
  },
  getTrainTimes: function (req, res) {
        // console.log(req);
    logger.info('getTrainTimes: ' + JSON.stringify(req.query));
    if (req.query.hasOwnProperty('from') && req.query.hasOwnProperty('from')) {

      const url = '/all/' + req.query.from + '/to/' + req.query.to + '/10?accessToken=215b99fe-b237-4a01-aadc-cf315d6756d8';

      Query(function (a, b) {
        res.setHeader('Content-Type', 'application/json');
        res.end(JSON.stringify(a));
      }, res, 'huxley.apphb.com', url);
    } else {
      res.setHeader('Content-Type', 'application/json');
      res.end(JSON.stringify({}));
    }

  },
  getNextTrainTimes: function (req, res) {
    logger.info('getNextTrainTimes: ' + JSON.stringify(req.query));
    let trainFrom, trainTo, trainToken, url;
    if (req.query.hasOwnProperty('from') && req.query.hasOwnProperty('from')) {
      trainFrom = req.query.from;
      trainTo = req.query.to;
      trainToken = trainFrom + trainTo;
      url = '/next/' + trainFrom + '/to/' + trainTo + '/1?accessToken=215b99fe-b237-4a01-aadc-cf315d6756d8';
      logger.info('Requesting latest time for : ' + trainToken);

      const now = new Date();
      const nowSeconds = (now.getHours() * (60 * 60)) + (now.getMinutes() * 60);
      logger.info('Now Seconds: ' + nowSeconds);
      if (trainCache.last[trainToken] === null || nowSeconds !== trainCache.last[trainToken]) 

        Query(function (a, b) {

          const output = {};
          const ts = a.departures[0].service;
          if (ts !== null) {
                        //  console.log(ts);
                        //GLOBAL.lastcheck = now;
            logger.debug(ts.sta, ts.std);
                        // logger.debug(toSeconds(ts.sta));

            output.sta = (ts.sta !== null) ? ts.sta : ts.std;
            output.eta = (ts.eta !== null ? ts.eta : ts.etd);

                        //  trainCache.last.glqdbe = toSeconds(ts.sta);
                        //  console.log(ts);
          } else {
            logger.warn('*** NO SERVICE');
            output.sta = 'No Service';
            output.eta = 'No Service';
          }

          trainCache.data[trainToken] = output;

          res.setHeader('Content-Type', 'application/json');
          res.end(JSON.stringify(trainCache.data[trainToken]));
        }, res, 'huxley.apphb.com', url);

    }

  }, getRoute: function (req, res) {
    logger.info('getRoute: ' + JSON.stringify(req.query));
    let routeID;
    let data = {};
    if (req.query.hasOwnProperty('route')) {

      routeID = req.query.route;
      Query(function (a, b) {

        if (a !== null && a.message === null) 
          data = a;
                
        res.setHeader('Content-Type', 'application/json');
        res.end(JSON.stringify(data));
      }, res, 'huxley.apphb.com', '/service/' + routeID + '?accessToken=215b99fe-b237-4a01-aadc-cf315d6756d8');
    }

  }
};

function toSeconds(inval) {
  console.log('inval', typeof inval);
  if (typeof inval === 'string') {
    const a = inval.split(':');
    return ((parseInt(a[0]) * (60 * 60)) + (parseInt(a[1]) * 60));
  }

  return '';

}

function Query(callback, r, host, path) {
  logger.debug(path);
  const req = r;
  const options = {
    host: host,
        //  port: 80,
    path: path,
        //method: 'GET',
    headers: {}
  };

  try {
    http.request(options).on('response', function (response) {
      let data = '';
      response.on('data', function (chunk) {
        data += chunk;
      });
      response.on('end', function () {
        callback(JSON.parse(data), r);
      });
      response.on('error', function (e) {
        console.error(e);
      });
    }).end();
  } catch (e) {
    console.log(e);
  }
}