index.js

var SerialPort = require('serialport'); //serialport for connecting to Arduino
var express = require('express'); // webframework on node.js
var bodyParser = require('body-parser'); //using body parser to easy parsing
var app = express(); //run express on app;
//var php = require('php-node'); //using php on node.js
var path = require('path'); //path directory lib
var fs = require('fs'); //manage file.
var btoa = require('btoa'); //base64


var moment = require('moment-timezone'); //config timezone
moment().tz("Asia/Bangkok").format();

var waktu = require('moment');

process.env.TZ = 'Asia/Bangkok'; 

require('events').EventEmitter.defaultMaxListeners = Infinity; //socket.io infinity users
var server = require('http').createServer(app); //create server from express config
var io = require('socket.io').listen(server); //create io.socket to run in server

//config express for using json
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(express.static(path.join(__dirname, 'public')));
app.set('json spaces', 4); //tidy the json code

var portNumber = 3030;
server.listen(portNumber); //start http-server on port

var portName = process.argv[2]; // get port number on command
var portAntenna = process.argv[3]; // get port for antenna tracker

/* Coordinate Antenna Tracker */
// according to antenna GPS
var trackLatitude = -7.658567;
var trackLongitude = 107.689918;
var sudutAzimuth, sudutElevasi, prevSudutAzimuth, prevSudutElevasi;

//variable declare
var datahasil , 
  RAWData , 
  jumlahClient = 0 ,
  dcClient = 0 ,
  triggerTakePhoto = false ,
  temp ,
  save = false ,
  valid = false,
  stopped = false,
  lanjutkan = false,
  checkAntenna = false,
  nomorGambar = 0,
  gambar = '',
  count = 0,
  oneImagePath = '',
  listGambar = [];

var param = {
  nama : '621', //header team
  ketinggian : 0 ,
  temperature : 0, 
  kelembaban : 0,
  tekanan : 0,
  arahAngin : 0,
  kecAngin : 0,
  latitude : 0.0,
  longitude : 0.0,
  startLatitude : 0.0 ,
  startLongitude : 0.0 ,
  endLatitude : 0.0,
  endLongitude : 0.0,
  imgAltitude : 0.0 ,
  imgTime : 0,
  co2 :0,
  pitch : 0,
  roll : 0,
  yaw : 0,
  graph : {
        ketinggian : [],
        temperature : [],
        kelembaban : [],
        tekanan : [],
        arahAngin : [],
        kecAngin : [],
        co2 : []
  },
  data : function(){
    var getData = this.nama + "\t" 
                  + moment().format("HH:mm:ss") + "\t"
                  + this.ketinggian + "\t" 
                  + this.temperature + "\t" 
                  + this.kelembaban + "\t" 
                  + this.tekanan + "\t" 
                  + parseFloat(this.arahAngin).toFixed(2) + "\t" 
                  + parseFloat(this.kecAngin).toFixed(2) + "\t" 
                  + this.latitude + "\t"
                  + this.longitude + "\t"
                  + this.co2 ;
    return getData;
  } ,
  logFile : function() {
    if (this.ketinggian >= 50 && this.ketinggian < 9500) {
      if ((this.ketinggian % 50 == 0) && (save == false)) {
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      } else if ((this.ketinggian % 50 == 1) && (save == false)){
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      } else if ((this.ketinggian % 50 == 2) && (save == false)) {
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      }else if ((this.ketinggian % 50 == 3) && (save == false)) {
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      }
      else if ((this.ketinggian % 50 == 4) && (save == false)) {
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      }else if ((this.ketinggian % 50 == 5) && (save == false)) {
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      }else if ((this.ketinggian % 50 == 6) && (save == false)) {
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      }else if ((this.ketinggian % 50 == 7) && (save == false)) {
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      }else if ((this.ketinggian % 50 == 8) && (save == false)) {
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      }else if ((this.ketinggian % 50 == 9) && (save == false)) {
        this.dataAdd();
        logger.write(this.data() + '\r\n'); //save log
        console.log("Save data to log.txt on " + this.ketinggian + " meter" );
        save = true;
      }
    }
  } , 
  dataAdd : function(){
        this.graph.ketinggian.push(this.ketinggian);
        this.graph.temperature.push(this.temperature);
        this.graph.kelembaban.push(this.kelembaban);
        this.graph.tekanan.push(this.tekanan);
        this.graph.arahAngin.push(this.arahAngin);
        this.graph.kecAngin.push(this.kecAngin);
        this.graph.co2.push(this.co2);
  } 
};

/*----------  FIle Save  ----------*/
const testFolder = 'Public/fotoudara/';
app.get('/listGambar' , function(req , res) {
  var files = [];
  fs.readdirSync(testFolder).forEach(file => {
    files.push(file);
  })

  res.json({ data: files});

});

/*----------  JSON  ----------*/
app.get('/data' , function(req , res) {
  res.json({data : param.graph});
});

app.get('/listImage' , function(req , res) {
  res.json({data : listGambar});
});

/*----------  Serial COnnection  ----------*/
// configure Serial Port to connect to Payload
var zeroPort = new SerialPort(
  portName,
  {
    baudRate : 57600,
    databits : 8,
    parity : 'none',
    parser : SerialPort.parsers.readline('\r\n')
  });

/*----------  Serial COnnection  ----------*/
// configure Serial Port to connect to Antenna
if (portAntenna != null) {
  var antennaSerial = new SerialPort(
  portAntenna,
  {
    baudRate : 115200 ,
    databits : 8,
    parity : 'none',
    parser : SerialPort.parsers.readline('\r\n')
  });
  checkAntenna = true;
} else {
  console.log("antenna tracker port is not initialized");
}

/*===============================
=            Picture            =
===============================*/

function hexToBase64(str) {
    return btoa(String.fromCharCode.apply(null, str.replace(/\r|\n/g, "").replace(/([\da-fA-F]{2}) ?/g, "0x$1 ").replace(/ +$/, "").split(" ")));
}

function simpanGambar(data) {
  //console.log(data);
  //console.log('yang mau diconvert');
  var img = "data:image/png;base64," + hexToBase64(data);
  var data = img.replace(/^data:image\/\w+;base64,/, "");
  var buf = new Buffer(data, 'base64');
  nomorGambar++;
  listGambar.push(nomorGambar+'_'+param.imgAltitude+'_'+param.imgTime+'.jpeg'); //to savve the list
  fs.writeFile('Public/fotoudara/'+nomorGambar+'_'+param.imgAltitude+'_'+param.imgTime+'.jpeg', buf);
  oneImagePath = nomorGambar+'_'+param.imgAltitude+'_'+param.imgTime+'.jpeg';
}


/*=====  End of Picture  ======*/
    // save gambar with button
 


// log data to txt (good use)
var logger = fs.createWriteStream('log.txt' , {
  flags : 'a'
});
logger.write("ID \t Waktu \t Ketinggian   Suhu  Humid  Tekanan  Arah-Angin  Kec-Angin  Lintang \t Bujur     \t CO2" + "\r\n");
logger.write("[==========================================================================================================]" + "\r\n");


/*----------  Start Main  ----------*/
zeroPort.on('open', function() {

  console.log('KASUARI APTRG Started');
  console.log('======================');
  console.log('Port Open, Server on port ' + portNumber);

  var delayMillis = 3000; //3 second

  setTimeout(function() {
    // set first home to payload, for elevation parameter
    zeroPort.write("1 " + trackLatitude + "," + trackLongitude +'\n', function(err) {
    if (err) {
      return console.log('Error on write: ', err.message);
    }
    console.log('Send home, to tracker..');
    console.log('Start to receive Data..');
    });
  }, delayMillis);

 


  //get data from arduino
  zeroPort.on('data', function(data) {
    RAWData = data.toString();
    RAWData = RAWData.replace(/(\r\n|\n|\r)/gm,""); //word replacer to simply parsing
    datahasil = RAWData.split(','); //split the data with ,
    //console.log(RAWData);
    //console.log(datahasil.length);
    //send event in web server
    if (datahasil.length == 12) {
      if (datahasil[0] == "OK") { //header
      //socket.emit('kirim', {datahasil:datahasil});  //send to html with tag kirim
      valid = true;
      param.ketinggian  = datahasil[1];
      
      if (datahasil[2] != "0.00") {
        param.temperature = datahasil[2]; 
        param.kelembaban  = datahasil[3];
      }

      param.tekanan     = datahasil[4];
      // param.arahAngin   = datahasil[5];
      // param.kecAngin    = datahasil[6];

      if (datahasil[5] != "********** " || datahasil[6] != "0.000000 " || datahasil[6] != "0.000000" ) {
       if (!isNaN(datahasil[5]) && !isNaN(datahasil[6])) {


        param.latitude    = datahasil[5];
        param.longitude   = datahasil[6];

        // calculate azimuth and elevation
       /*=============================================================
        =            Antenna Tracker azimuth and elevation            =
        =============================================================*/
          sudutAzimuth = parseInt(getBearing(trackLatitude, trackLongitude, param.latitude, param.longitude));
          sudutElevasi = parseInt(getElevation(trackLatitude, trackLongitude, param.latitude, param.longitude , param.ketinggian));
        /*=====  End of Antenna Tracker azimuth and elevation  ======*/
        
        //console.log(sudutAzimuth);
        //console.log(sudutElevasi);
           if (checkAntenna) {
            // antennaSerial.on('open', function() {
            //   console.log("Antenna Tracker ready!");

            //   //send the sudut
               console.log(sudutAzimuth + " ---- "+ sudutElevasi);
               //console.log();
              //  console.log("RAW ori: " + sudutAzimuth + "---" + sudutElevasi);
               // console.log("RAW prev : " + prevSudutAzimuth + "---" + prevSudutElevasi);

            if (sudutAzimuth != null && sudutElevasi != null){

              if (prevSudutElevasi != sudutElevasi || prevSudutAzimuth != sudutAzimuth) {
                prevSudutElevasi = sudutElevasi;
                prevSudutAzimuth = sudutAzimuth;
                //console.log("RAW : " + sudutAzimuth + "---" + sudutElevasi);
                //  console.log(sudutElevasi);
                antennaSerial.write(" " + sudutAzimuth + "," + sudutElevasi +'#');
              }
            }
            //});
         
          }
        }
      } 

      // param.co2         = datahasil[7];
      param.co2         = co2Correction(datahasil[7],param.tekanan,param.temperature).toFixed(2);
      param.pitch       = datahasil[8];
      param.roll        = datahasil[9];
      param.yaw         = datahasil[10];
      
      
        if ((datahasil[11] != "IMG") && (datahasil[11] != "")){

          // check first img data contains FFD8? 
          if ((datahasil[11].indexOf("FFD8") >= 0) && (count == 0)) {
            lanjutkan = true;
            param.imgTime = moment().format("HHmmss");
            param.imgAltitude = param.ketinggian;
            console.log('Capturing...');
          }

          // first appear sesuai
          if (lanjutkan == true){
            // tampung gambar
            gambar = gambar + datahasil[11];
          }
          //console.log(count);
          count++;


          // check akhir string ada FFD9 (akhir dari JPEG)
          if (datahasil[11].slice(-4) == "FFD9") {
            console.log('Save image ...');
            simpanGambar(gambar);
            lanjutkan = false; //set ke false lanjutkan biar ngcek lagi paspertama
            count = 0;
            gambar = ''; //set ke kosong lagi
          }
          
        } 

        if (param.ketinggian % 50 > 10){
          save = false;
        }
        
        param.logFile(); // command to save the data in log file;
        stopped = false;

      } else if (datahasil[0] != "OK") {
        // do berhet\nti
        stopped = true;
      }
    } else {
      valid = false;
    }


  });

  // calculate kecepatan angin dan arah angin
  setInterval(
    function() {
      if ((valid == true) && (datahasil[5] != "********** ")) {
        
        setTimeout( function() {
          param.startLatitude = datahasil[5];
          param.startLongitude = datahasil[6];
          // console.log('start');
        } , 1000); //delay 1 secodns

        param.endLatitude = datahasil[5];
        param.endLongitude = datahasil[6];
        // console.log('end');

        if ((param.startLatitude != param.endLatitude) || (param.startLongitude != param.endLongitude)) {
          var bearing = getBearing(param.startLatitude , param.startLongitude , param.endLatitude , param.endLongitude);
          var dist = distance(param.startLatitude , param.startLongitude , param.endLatitude , param.endLongitude , 0 , 0);
         
          if (!isNaN(bearing)) {
            param.arahAngin = bearing;
          }

          if (!isNaN(dist)) {
            if (dist < 100)
              param.kecAngin = dist; 
          }
        }

        //console.log(param.arahAngin);
        //console.log(param.kecAngin);
      }
    }
  , 2000);

  //io.socket main communication
  io.on('connection' , function(socket){
      jumlahClient++;
      console.log('Number of Client : ' + jumlahClient);

      // get data from arduino
      // call again to get event send it to socket io
      zeroPort.on('data', function(data) {
          // send as a JSON
          socket.emit('kirim', { 
            datahasil : [
              param.ketinggian,
              param.temperature,
              param.kelembaban,
              param.tekanan,
              param.arahAngin,
              param.kecAngin,
              param.latitude,
              param.longitude,
              param.co2,
              param.pitch,
              param.roll,
              param.yaw,
              oneImagePath // path gambar in here for home
            ]
          });  

          socket.emit('dataGraph', {  
            data : [ 
              param.ketinggian,
              param.temperature,
              param.kelembaban,
              param.tekanan,
              param.arahAngin,
              param.kecAngin,
              param.co2
            ]
          });

          socket.emit('dataGauge', {  
            data : [ 
              param.ketinggian,
              param.temperature,
              param.kelembaban,
              param.tekanan,
              param.arahAngin,
              param.kecAngin,
              param.co2
            ]
          });

          socket.emit('dataCoordinate', {  
            data : [ 
              param.latitude,
              param.longitude
            ]
          });

          socket.emit('angin' , {
            data : [ 
              param.arahAngin , 
              param.kecAngin
            ]
          });
 
      });

  
      //handle disconnect users
      socket.on('disconnect' , function() {
          dcClient++;
          console.log('1 client disconnected , Total : ' + dcClient);
          jumlahClient--;
          console.log('Number of Client : ' + jumlahClient);
      });

      //receive socket emit from browser
      // socket.on('stop' , function(data) {
      //     zeroPort.write('0'); //send 0 to arduino
      // });

      // socket.on('startAgain', function(data){
      //   zeroPort.write('1');
      // });
    
      socket.on('takePict' , function(data){
        zeroPort.write('2');
      });

      socket.on('savingData' , function(data){
        console.log('Save data..')
        logger.write(param.data() + '\r\n'); //save log
      });
      
    });

   
});

// antennaSerial.on('data', function (data) {
//   console.log('Data:', data);
// });


function radians(n) {
  return n * (Math.PI / 180);
}

function degrees(n) {
  return n * (180 / Math.PI);
}

function getBearing(startLat,startLong,endLat,endLong){
  startLat = parseFloat(startLat);
  startLong = parseFloat(startLong);
  endLat = parseFloat(endLat);
  endLong = parseFloat(endLong);

  startLat = radians(startLat);
  startLong = radians(startLong);
  endLat = radians(endLat);
  endLong = radians(endLong);

  var dLong = endLong - startLong;

  var dPhi = Math.log(Math.tan(endLat/2.0+Math.PI/4.0)/Math.tan(startLat/2.0+Math.PI/4.0));
  if (Math.abs(dLong) > Math.PI){
    if (dLong > 0.0)
       dLong = -(2.0 * Math.PI - dLong);
    else
       dLong = (2.0 * Math.PI + dLong);
  }

  var bearingDegree = (degrees(Math.atan2(dLong, dPhi)) + 360.0) % 360.0; 
  
  if (!Number.isNaN(bearingDegree))
    return bearingDegree;
}

function getElevation(startLat, startLong, endLat, endLong , alt){
  startLat = parseFloat(startLat);
  startLong = parseFloat(startLong);
  endLat = parseFloat(endLat);
  endLong = parseFloat(endLong);

  startLat = radians(startLat);
  startLong = radians(startLong);
  endLat = radians(endLat);
  endLong = radians(endLong);

  var delLat = endLat - startLat;
  var delLon = endLong - startLong;

  var R = 6372795;
  var q = Math.sin(delLat/2)*Math.sin(delLat/2);
  var w = Math.cos(startLat)*Math.cos(endLat);
  var e = Math.sin(delLon/2)*Math.sin(delLon/2);
  var a = (q + w*e);
  var c = 2*Math.atan2(Math.sqrt(a) , Math.sqrt(1-a));
  var distance = c * R;

  var elev = degrees(Math.atan(alt/distance));
  
  if (!Number.isNaN(elev))
    return elev;
}

/**
 * Calculate distance between two points in latitude and longitude taking
 * into account height difference. If you are not interested in height
 * difference pass 0.0. Uses Haversine method as its base.
 * 
 * lat1, lon1 Start point lat2, lon2 End point el1 Start altitude in meters
 * el2 End altitude in meters
 * @returns Distance in Meters
 */
function distance(lat1,lon1,lat2,
        lon2, el1,  el2) {

    var R = 6371; // Radius of the earth
    el1 = 0;
    el2 = 0;

    var latDistance = radians(lat2 - lat1);
    var lonDistance = radians(lon2 - lon1);
    var a = Math.sin(latDistance / 2) * Math.sin(latDistance / 2)
            + Math.cos(radians(lat1)) * Math.cos(radians(lat2))
            * Math.sin(lonDistance / 2) * Math.sin(lonDistance / 2);
    var c = 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a));
    var distance = R * c * 1000; // convert to meters

    var height = el1 - el2;

    var distance = Math.pow(distance, 2) + Math.pow(height, 2);

    if (distance < 100)
      return Math.sqrt(distance).toFixed(2);

}

/**
 * Source :
 * http://www.vaisala.com/Vaisala%20Documents/Application%20notes/CEN-TIA-Parameter-How-to-measure-CO2-Application-note-B211228EN-A.pdf
 * where ppm is Co2 , hpa is pressure , and tmp is temperature
 */

function co2Correction(ppm , hpa , temp) {
  ppm = parseInt(ppm);
  hpa = parseInt(hpa);
  temp = parseInt(temp);

  return (ppm * (hpa / 1013) * (298/(273 + temp))) + 55;
}