agent3TDAgent.js

/* Kyle Bowerman 1/9/2015
   the agent will post temp readings to Treasure Data.

   */


var request = require('request');
var moment = require('moment');
var moistureA1 = 0;
var lightA0 = 0;
var tdAgentURL = process.env.TD_AGENT_URL;



function postToTDAgent(payload) {
  //Make the post
  console.log(' called the post');
  request({
    method: 'POST',
    url: tdAgentURL,
    body: payload,
    json: true
  }, function(err, rsp,body){
    if (err || rsp.statusCode != 200) { console.log('HTTP error:', err, rsp.statusCode, body); }
    else {
      console.log('Got HTTP Response code %d', 200);
    }

  });

}


function getReading(url, msg, pin, device, err, rsp, callback) {
  //Make the request
  request(url, function (error, response, body) {
    if(msg) { console.log(msg); }
    if (!error && response.statusCode == 200) {
      console.log(body);
      var parsebody = body.split(" ");
      pinValue =  Number(parsebody[4]);
      console.log('The Value of ' + pin + ' pin is ', pinValue);

      //var d = new Date();

      var currentTime = moment();
      var epochtime = moment().valueOf();

      var payload = {
        msg: 'device',
        body: body,
        pin: pin,
        device:  device,
        version: 2,
        class: 'analog',
        value: pinValue,
        time: currentTime,
        devicetime: currentTime,
        epochtime: epochtime
      };

      postToTDAgent(payload);



    }
  });
}

function getTempReading(url, msg, pin, device, err, rsp, callback) {
  //Make the request
  request(url, function (error, response, body) {
    if(msg) { console.log(msg); }
    if (error ) { console.log('there is an error ' + error );}
    if (!error && response.statusCode == 200) {
      jsonBody = JSON.parse(body);
      //var d = new Date();
      var currentTime = moment();
      var epochtime = moment().valueOf();
      var payload = {
          msg: device,
          body: jsonBody,
          pin: pin,
          device:  jsonBody.device,
          version: 2,
          class: 'temp',
          value: jsonBody.temp,
          time: currentTime,
          devicetime: currentTime,
          epochtime: epochtime
      };

      postToTDAgent(payload);

    }
  });
}

// Make the call to get moisture
  getReading('http://localhost/arduino/analog/1/', '  getting the moisture reading from A1', 'A1', 'moisture');
// Make the call to get light
  getReading('http://localhost/arduino/analog/0/', '  getting the light reading from A0', 'A0', 'light');
// Make the call to get T1
  getTempReading('http://localhost/arduino/temp/1', 'getting the reading from T1', 'T1', 'temp at window');
// Make the call to get T1
  getTempReading('http://localhost/arduino/temp/2', 'getting the reading from T2', 'T2', 'temp inside');
//getReading('http://localhost/arduino/analog/2/');