// ./src/index.js
var GardenIP = '192.168.1.133';
var AcIP = '192.168.1.143';
var HouseDhtIP = '192.168.1.126';

// importing the dependencies
const util = require('util');
const express = require('express');
const bodyParser = require('body-parser');

const request = require('request');

const WebSocket = require('ws');

const cors = require('cors');
const helmet = require('helmet');
const morgan = require('morgan');
const cron = require('node-cron');

//!https endpoint
var fs = require("fs");
var http = require('http');
var https = require('https');
try{
  var SECURE_KEY = "/etc/letsencrypt/live/iot.d-popov.com/privkey.pem"; //__dirname + '/../../test/secure/tls-key.pem';
  var SECURE_CERT = "/etc/letsencrypt/live/iot.d-popov.com/cert.pem";
  var _privateKey  = fs.readFileSync(SECURE_KEY, 'utf8');
  var _certificate = fs.readFileSync(SECURE_CERT, 'utf8');
  var credentials = {key: _privateKey, cert: _certificate};
}catch(ex){console.log("can't load certificates.");}


// defining the Express app
const app = express();
app.use(helmet());
app.use(bodyParser.urlencoded({ extended: true }));
app.use(bodyParser.json());
app.use(express.static('public'));
app.use(cors());
app.set('view engine', 'ejs');
app.use(require('express-ejs-layouts'));//https://www.npmjs.com/package/express-ejs-layouts
// adding morgan to log HTTP requests
app.use(morgan('combined'));

//defining endpoints
//!UI 
var auth = require('./src/auth.js');
var ac = require('./ac.js');
var db = require('./src/db');
var ir = require('./src/devices/ir');
var u = require('./src/utils');


app.use(auth.init());
app.get('/', function(req, res){ res.redirect('/n/login');});

app.get('/accontrol', auth.ensureLoggedIn_Orig,
 function(req, res){
  res.render('accontrol',{model:{data:req.body, user:req.user, command:"", info:""}});
});


app.post('/accontrol', 
//ensureLoggedIn,
function(req, res){
  console.log("POST accontrol");
  var sess=req.session;
  var model = { model: {user: req.user, data: req.body} };
  console.log("power:" + req.body.power);  console.log("heat:"  + req.body.heat);  console.log("temp:"  + req.body.temp);
  if(!req.body.temp){req.body.temp = 23;}
  console.log("temp:"  + req.body.temp);  console.log("econo:" + req.body.econo);  console.log("swing:" + req.body.swing);
  ac.Tlc112.Init();
  ac.Tlc112.SetPower(req.body.power);
  ac.Tlc112.SetMode(req.body.heat? ac.Mode.Heat:ac.Mode.Cool);
  ac.Tlc112.SetTemp(req.body.temp);
  ac.Tlc112.SetSwingVertical( req.body.swing);
  ac.Tlc112.SetFan(ac.FanSpeed.Med);
  
  var code = ac.Tlc112.GetCommand();
  
  mqtt_client.publish('cmnd/', 'controller')
  //break it
  //code = code.substring(150);
  //console.log("RAW: " + code);
  if(ir.SendCmd("http://"+AcIP, code))
  {
    console.log("OK. Temp: " + req.body.temp);
    BroadcastWS(ac.Tlc112.GetState());
  } else {
    model.info = "Error executing command. Server resturned:" + req.statusCode;
    BroadcastWS("Error sending IR command");
  }
  //console.log("req.user:" + util.inspect( req.user));
  res.render('accontrol', model);
  // res.render('accontrol',{model: {data: req.body, user: req.user, command: "", info: model.info}});
  });

  app.get('/chart', auth.ensureLoggedIn_Orig,
  function(req, res){
    res.render('chart', { user: req.user });
  });
  app.get('/garden', function(req, res){ res.render('chartGarden');  });

//Authentication --

//! ESP HANDLERS


const { parse } = require('querystring');
var moment = require('moment');
// var Sync = require('sync');

app.use('/dht', ir.html_handle_dht);

app.use('/waterTest',function(req, res){

  console.log("Watering TEST for: " + req.params);
});
app.use('/water',function(req, res){
  var time = req.query.t;
  console.log("Watering cmd for: " + time);
  request('http://'+GardenIP+'/control?cmd=event,manualwatering='+ time, { json: true }, (err, res, body) => {
    if (err) { return console.log("Problem watering: " + err);  }
  console.log("Watering cmd successfully sent!");
  });
});
app.use('/waterStop',function(req, res){
  request('http://'+GardenIP+'/control?cmd=event,stopwatering', { json: true }, (err, res, body) => {
    if (err) { return console.log("Problem watering: " + err);  }
  console.log("STOP watering cmd  sent!");
  });
});

function BroadcastWS(msg){
  wss.clients.forEach(function each(client) {
    if (client.readyState === WebSocket.OPEN) {
      client.send(moment().format() +" : "+ msg);
    }
  });
}


app.get("/device/:field_name/:days?", function (req, res) {
  db.devicemessages.findByName(req.params.field_name, req.params.days, function (err, data) {
    if (!err) { res.send(data); }
    else { console.log("error: ", err); }
  });
});

app.put('/device/:device_id/:field_name/:field_value', (req, res) => {
  db.devicemessages.insert( req.params.device_id, req.params.field_name, req.params.field_value,
    function (err, data) {
      if (!err) { res.send(data); }
      else { console.log("error: ", err); }
    });
});

//!Startup

var wws;
if(credentials){
  var httpsServer = https.createServer(credentials, app);
  httpsServer.listen(8443, () => {
    console.log('HTTPS server listening on port 8443');
  });
 wss = new WebSocket.Server({ server: httpsServer });
}
else
{
  var httpServer = http.createServer(app);
  httpServer.listen(82, () => {
    console.log('HTTP server listening on port 82');
  });
  wss = new WebSocket.Server({ port: 8080 });//not secure
}



//             // # ┌────────────── second (optional)
//             // # │ ┌──────────── minute
//             // # │ │ ┌────────── hour
//             // # │ │ │ ┌──────── day of month
//             // # │ │ │ │ ┌────── month
//             // # │ │ │ │ │ ┌──── day of week
//             // # │ │ │ │ │ │
//             // # │ │ │ │ │ │
//             // # * * * * * *
// cron.schedule('    */30 * * * *', () => {//cron.schedule('*/5 * * * * *', () => {
//   console.log(new Date().toISOString() + ' running a task every 30 minutes');
//   //StoreSensorReadings();
//   db.devicemessages.getFromDht('http://192.168.1.126/json');
// }).start();

//db.devicemessages.getFromDht('http://192.168.1.126/json');

wss.on('connection', ws => {
  ws.on('message', message => {
    console.log('Received message => ${message}');
  });
  ws.send('ho!');
});


var mosca = require('mosca');
var mqtt_settings = {
  port:1884,
  secure : {
    port: 8444,
    keyPath: SECURE_KEY,
    certPath: SECURE_CERT,
  }
}
var mqtt =  new mosca.Server(mqtt_settings);
mqtt.on('ready', function(){
  console.log("MQTT ready on port " + mqtt_settings.port);
})
mqtt.on('clientConnected', function(){
  console.log("MQTT client connected !");
});

var mqtt = require('mqtt')
var mqtt_client  = mqtt.connect('mqtt://192.168.1.131')
mqtt_client.on('connect', function () {
  console.log("MQTT connected. subscribing to topics");
  mqtt_client.subscribe('tele/tasmota/STATE');
  mqtt_client.subscribe('tele/tasmota/RESULT');//IR
  mqtt_client.subscribe('tele/tasmota/INFO2');
  // mqtt_client.subscribe('tele/tasmota/SENSOR');//DHT
  mqtt_client.subscribe('tele/+/SENSOR');//DHT
  mqtt_client.subscribe('tasmota_3FD92D');
  // mqtt_client.subscribe('tele');
  // mqtt_client.subscribe('dht');
  // mqtt_client.subscribe('ir');
  
  mqtt_client.subscribe('ESP_Easy/+');
  mqtt_client.subscribe('ESP_Easy/+/+');
  mqtt_client.publish('tasmota', 'controller connected')
});

var dht = {};
// https://github.com/pauloromeira/Sonoff-Tasmota/wiki/Commands
//https://stevessmarthomeguide.com/setting-up-the-sonoff-tasmota-mqtt-switch/
mqtt_client.on('message', function (topic, message) {
  var context = message.toString();
  console.log("MMQT> " + topic + " : " +  context);
  var handled = false;
  if(topic === "tele/tasmota/SENSOR")
  {
    var j = JSON.parse(message);
    //console.log("JSON> " + util.inspect(j));
    if(j.DHT11 && j.DHT11.Humidity !== null)
    {
      var msg = {
        dht:{
          hum: j.DHT11.Humidity,
          temp:  j.DHT11.Temperature,
          dew: j.DHT11.DewPoint
        }
      };

      db.devicemessages.insert( 0, "A23_DHT", JSON.stringify(msg), function (err, data) {
          if (!err) { console.log("success: "+ data);}
          else { console.log("error: " + err); }
        });
    }else {
      console.log("Got wrong DHT data: " + message );
    }
    handled = true;
  }
  if(topic === "ESP_Easy/status/LWT")
  {
    console.log("ESP_Easy >'" + message + "'");
    var stat = {};
    var pairs = message.toString().split(';');
    stat.event = pairs[0];
    for (var i = 0; i < pairs.length; i++)
    {
      var pair = pairs[i].split(':');
      if(pair.length == 2){
        stat[pair[0].trim()] = pair[1].trim() || '';
        //console.log( "'"+pair[0] +"' >'" + pair[1]  + "'");
      }
    }
    dht.ssid=stat["SSID"];
    dht.rssi=stat["RSSI"];
    if(stat.event ==='ON'){console.log("Device is ONLINE! <" + dht.ssid + "> " + dht.rssi + "dB" );}
    if(stat.event ==='OFF'){console.log("Device went ofline!");}
    handled = true;
  }
  if(topic === "ESP_Easy/Soil/RH")
  {
    console.log("Garden > soil " + message + "% moisture");
    dht.Soil = message.toString();
    if(dht.Soil > 10){
      SaveDhtIf();
    } else {
      console.log("Got suspicious soil RH value:" + dht.Soil);
      dht.Soil = null;
    }
    // db.devicemessages.insert(1, "A23_Garden_Humidity", message, function (err, data) {
    //   if (!err) { console.log("success: "+ data);}
    //   else { console.log("error: " + err); }
    // });
    handled = true;
  }
  if(topic === "ESP_Easy/bmp/Temperature")
  {
    console.log("Garden > air " + message + "C");
    dht.Temp = message.toString();
    SaveDhtIf();
    handled = true;
  }
  if(topic === "ESP_Easy/bmp/Humidity")
  {
    console.log("Garden > air " + message + "% RH");
    dht.Hum = message.toString();
    SaveDhtIf();
    handled = true;
  }
  if(topic === "ESP_Easy/bmp/Pressure")
  {
    console.log("Garden > air " + message + " hPa");
    dht.Pres = message.toString();
    SaveDhtIf();
    handled = true;
  }
  if(topic === "ESP_Easy/Water/start")
  {
    var j = JSON.parse(message);
    dht.Soil = j.soil;
    SaveDhtIf();
    handled = true;
    console.log("Garden > Started watering with " + j.soil + "% soil RH");
  }
  if(topic === "ESP_Easy/Water/stop")
  {
    var j = JSON.parse(message);
    dht.Soil = j.soil;
    SaveDhtIf();
    handled = true;
    console.log("Garden > Finished watering with " + j.soil + "% soil RH");
  }
  
  if(!handled){
    console.log(topic + " > " + message );
  }
});
function SaveDhtIf(){
  if(dht.Temp && dht.Hum && dht.Pres)// && dht.Soil
  {
    if(dht.Soil < 5)
    {
      console.log("Soil reported below 5%! Probable loose sensor wire. Record discarded" );
      dht = {};
      return;
    }
    console.log("Writing to DB > " + JSON.stringify(dht)+"; SSID: '"+dht.ssid+"' RSSI:"+ dht.rssi + "dB");
    db.devicemessages.insert(1, "A23_Garden_dht", JSON.stringify(dht), function (err, data) {
      if (!err) { console.log("success: "+ data);}
      else { console.log("error: " + err); }
    });
    dht = {};
  }else{
    if(dht.Temp ){console.log("have Temp");}
    if(dht.Hum ){console.log("have Hum");}
    if(dht.Pres ){console.log("have Pres");}
   console.log("Missing all data to write to DB !");
  }
}

//(function() {
  // var exLog = console.log;
  // console.log = function(msg) {
  //     exLog.apply(this, arguments);
  //     fs.writeFileSync('./log.txt', msg);
  // }
//})();

const {keys} = Object;
const {Console} = console;

/**
 * Redirect console to a file.  Call without path or with false-y
 * value to restore original behavior.
 * @param {string} [path]
 */
function file(path) {
    const con = path ? new Console(fs.createWriteStream(path)) : null;

    keys(Console.prototype).forEach(key => {
        if (path) {
            this[key] = (...args) => con[key](...args);
        } else {
            delete this[key];
        }
    });
};

// ///---patch global console object and export
module.exports = console.file = file;

console.file(__dirname + '/../log.txt');//__dirname + '/debug.log' log.txt




var log4js = require("log4js");
log4js.configure({
  appenders: {
    file: {
      type: 'file',
      filename: '/../log4.txt',
      maxLogSize: 10 * 1024 * 1024, // = 10Mb
      backups: 5, // keep five backup files
      compress: true, // compress the backups
      encoding: 'utf-8',
      mode: 0o0640,
      flags: 'w+'
    },
    console: { type: 'console' }
  },categories: {
      default: { appenders: ['console','file'], level: 'trace' }
    }
});

var logger = log4js.getLogger();
logger.level = "debug";
logger.debug("Some debug messages");
console.log = (msg) => logger.trace(msg);
console.log("Console MSG");