node_helper.js

/* Magic Mirror
 * Module: mrx-work-traffic
 *
 * By Dominic Marx
 * MIT Licensed.
 */

var NodeHelper = require("node_helper");
var request = require('request');
var moment = require('moment');
 
module.exports = NodeHelper.create({

  start: function() {
    console.log("====================== Starting node_helper for module [" + this.name + "]");
  },
  
  
  // subclass socketNotificationReceived
  socketNotificationReceived: function(notification, payload){
    if (notification === 'GOOGLE_TRAFFIC_GET') {

      //first data opull after new config
      this.getPredictions(payload);

    }
  },


	
	getPredictions: function(payload) {
		var self = this;

    var returned = 0;
    var predictions = new Array();

		payload.destinations.forEach(function(dest, index) {
			request({url: dest.url, method: 'GET'}, function(error, response, body) {
				
        var prediction = new Object({
          config: dest.config
        });

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

          var data = JSON.parse(body);


          if (data.error_message) {
            console.log("MMM-MyCommute: " + data.error_message);
            prediction.error = true;
          } else {
  
            var routeList = new Array();
            for (var i = 0; i < data.routes.length; i++) {
              var r = data.routes[i];
              var routeObj = new Object({
                summary: r.summary,
                time: r.legs[0].duration.value
              });

              if (r.legs[0].duration_in_traffic) {
                routeObj.timeInTraffic = r.legs[0].duration_in_traffic.value;
              }
              if (dest.config.mode && dest.config.mode == 'transit') {
                var transitInfo = new Array();
                var gotFirstTransitLeg = false;
                for (var j = 0; j < r.legs[0].steps.length; j++) {
                  var s = r.legs[0].steps[j];

                  if (s.transit_details) {
                    var arrivalTime = '';
                    if (!gotFirstTransitLeg && dest.config.showNextVehicleDeparture) {
                      gotFirstTransitLeg = true;
                      // arrivalTime = ' <span class="transit-arrival-time">(next at ' + s.transit_details.departure_time.text + ')</span>';
                      arrivalTime = moment(s.transit_details.departure_time.value * 1000);
                    }
                    transitInfo.push({routeLabel: s.transit_details.line.short_name ? s.transit_details.line.short_name : s.transit_details.line.name, vehicle: s.transit_details.line.vehicle.type, arrivalTime: arrivalTime});
                  }
                  routeObj.transitInfo = transitInfo;
                }
              }
              routeList.push(routeObj);
            }
            prediction.routes = routeList;
            
          }

        } else {
          console.log( "Error getting traffic prediction: " + response.statusCode );
          prediction.error = true;

        }

        predictions[index] = prediction;
        returned++;

        if (returned == payload.destinations.length) {          
          self.sendSocketNotification('GOOGLE_TRAFFIC_RESPONSE' + payload.instanceId, predictions);
        };

      });
    });
	}
	
});