MTRNord/nordlab-hackerspace-door

/**
 * Main-functionality for handling the Modules :)
 *
 * @main Main
 * @module Main
 * @author Marcel Radzio
 */
//Load needed Features
var request = require('request');
var git = require('simple-git');
var schedule = require('node-schedule');
var argv = require('yargs').argv;
var params_config = require("./configs/ircServer.json");
var autoupdate = params_config["autoupdate"];
var async = require("async");
var _ = require("lodash");
var child = require('child_process')

//LOAD MODULES DOWN HERE
require('./helper/heroku.js');
var pushbullet = require('./handlers/pushbullet.js');
var irc = require('./handlers/irc.js');
//var slack = require('./handlers/slack.js');
var getNodes = require('./handlers/parseNodes.js');
var telegram = require('./handlers/telegram.js');

//Constants
var SIGINT = "SIGINT";
var door_status2 = "1";


/**
 * Get door-status from the Web
 *
 * @class GetData
 * @return {String} Door Status
 */
function GetData(){
  /**
   * Actual pulled Door Status
   *
   * @property door_status
   * @type String
   */
    request.get('http://www.nordlab-ev.de/doorstate/status.txt', function (error, response, body) {
        if (!error && response.statusCode === 200) {
            /**
         * Content of status_page
         *
         * @property body
         * @type String
         */
          door_status = body;
        }else{
        /**
         * Fired when an error occurs...
         *
         * @property error
         * @type String
         */
            //TODO Add real Error Handler
              door_status = error;
          throw new Error(err)
           }
           //If no error -> go on
        if (!error && response.statusCode === 200) {
              if (door_status2 !== door_status){
                  //Handle first run
                if (door_status2 !== "1") {
              /**
               * Save Old Door Status
               *
               * @property door_status2
               * @type String
               */
                      door_status2 = door_status;
                      //Translate var's
                     if (door_status === "geschlossen"){
                    door_status = "closed";
                     }else{
                    door_status = "open";
                  }

                  //ADD MODULES DOWN HERE
                  //Call Module send/main Functions
                  pushbullet.pushbulletSend(door_status);
                  //irc.ircSend(door_status);
              return door_status;

                }else{
                    //Save Last Status
                      door_status2 = door_status;
                return door_status;
                }
              }
        }
    }).setMaxListeners(0);
    //Rerun Function after 10 seconds
    setTimeout(function() {}, 10000);
}
//Handle "[CTRL]+[C]"
if (process.platform === "win32") {
    var rl = require("readline").createInterface({
        input: process.stdin,
        output: process.stdout
    }).setMaxListeners(0);
    rl.on(SIGINT, function () {
        process.emit(SIGINT);
    }).setMaxListeners(0);
}
process.on(SIGINT, function () {
    irc.ircStopp();
    process.exit();
}).setMaxListeners(0);

/**
 * Update - Pull last master from Github
 *
 * @method update
 */
function update(){
  git.pull("origin", "master", function(err, update) {
    if (err) {throw new Error(err)}
    if(update && update.summary.changes) {
      console.log('Start Update!');
      restart();
    }
  });
}

/**
 * Restart - Restart the Bot completly
 *
 * @method restart
 */
function restart(){
  console.log('Daily restart!');
  irc.ircEndCustom('Restart! Coming back in a few Seconds!');
  child.exec('npm restart');
}

// var j = schedule.scheduleJob('59 3 * * *', function(){
//   if (!argv.noupdate && autoupdate == 1) {
//     //Run update at 3am and 59min
//     update();
//   }else{
//     restart();
//   }
// });

//Startup
async.auto({
    ircPreload: function (callback) {
      // callback has to be called by `uploadImage` when it's done
      irc.ircPreload(callback)
    },
    ircBotCommands: function (callback) {
      //Activate IRC-Bot Command Handler
      irc.ircBotCommands(callback)
    },
    saveNodes: function (callback) {
      getNodes.saveNodes(callback)
    },
    telegramStart: function (callback) {
      telegram.start(callback)
    },
    GetData: function (callback) {
      async.forever(
        function(next) {
          GetData()
          callback(next)
        },
        function(err) {
          // if next is called with a value in its first parameter, it will appear
          // in here as 'err', and execution will stop.
          callback(err)
        }
      );
    }
  },
  function(err, result) {
    if (err) {
      console.log(err)
    }
  }
);