files moved
This commit is contained in:
Dobromir Popov
347
_archive/dht.js
Normal file
347
_archive/dht.js
Normal file
@@ -0,0 +1,347 @@
|
||||
// ./src/index.js
|
||||
|
||||
const env = process.env.NODE_ENV || 'development';
|
||||
console.log("ENV: %s", env);
|
||||
const config = require(__dirname + '/config/config.json')[env];
|
||||
|
||||
(function () {
|
||||
var exLog = console.log;
|
||||
console.log = function (msg) {
|
||||
exLog.apply(this, arguments);
|
||||
fs.appendFileSync(config.logFile, msg + "\r\n");
|
||||
}
|
||||
})();
|
||||
|
||||
|
||||
// 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 CERT_ROOT = "/etc/letsencrypt/live/iot.d-popov.com-0003";
|
||||
var SECURE_KEY = CERT_ROOT + "/privkey.pem"; //__dirname + '/../../test/secure/tls-key.pem';
|
||||
var SECURE_CERT = CERT_ROOT + "/cert.pem";
|
||||
var _privateKey = fs.readFileSync(SECURE_KEY, 'utf8');
|
||||
var _certificate = fs.readFileSync(SECURE_CERT, 'utf8');
|
||||
var _ca = fs.readFileSync(CERT_ROOT + "/chain.pem", 'utf8');
|
||||
var credentials = {
|
||||
key: _privateKey,
|
||||
cert: _certificate,
|
||||
ca: _ca
|
||||
};
|
||||
} 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 mqtt = require('../src/mqtt.js');
|
||||
var ir = require('../src/devices/ir');
|
||||
var u = require('../src/utils');
|
||||
|
||||
|
||||
app.use(auth.init());
|
||||
app.get('/', function (req, res) {
|
||||
res.redirect('/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://" + config.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/:days?', function (req, res) {
|
||||
res.render('chartGarden', {
|
||||
model: req.params
|
||||
});
|
||||
});
|
||||
|
||||
//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);
|
||||
});
|
||||
|
||||
config.gardenIP = process.env.GARDEN_IP || config.gardenIP || "";
|
||||
|
||||
app.use('/water', function (req, res) {
|
||||
var time = req.query.t;
|
||||
console.log("Watering cmd for: " + time);
|
||||
if (config.gardenIP != "" && config.gardenIP != "0.0.0.0") {
|
||||
console.log("DHT> sending cmd over HTTP");
|
||||
request('http://' + config.gardenIP + '/tools?cmd=event,manualwatering=' + time, {
|
||||
json: true
|
||||
}, (err, res, body) => {
|
||||
if (err) {
|
||||
return console.log("Problem watering: " + err);
|
||||
}
|
||||
console.log("Watering cmd successfully sent over HTTP!");
|
||||
});
|
||||
}
|
||||
mqtt.SendCmd("event,manualwatering=" + time);
|
||||
});
|
||||
app.use('/waterStop', function (req, res) {
|
||||
if (config.gardenIP != "" && config.gardenIP != "0.0.0.0") {
|
||||
console.log("DHT> sending cmd over HTTP");
|
||||
request('http://' + config.gardenIP + '/tools?cmd=event,stopwatering', {
|
||||
json: true
|
||||
}, (err, res, body) => {
|
||||
if (err) {
|
||||
return console.log("Problem watering: " + err);
|
||||
}
|
||||
console.log("STOP watering cmd sent!");
|
||||
});
|
||||
}
|
||||
mqtt.SendCmd("event,stopwatering");
|
||||
});
|
||||
|
||||
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(2443, () => {
|
||||
console.log('\r\n\r\nHTTPS server listening on port 2443');
|
||||
});
|
||||
wss = new WebSocket.Server({
|
||||
server: httpsServer
|
||||
});
|
||||
} else {
|
||||
var httpServer = http.createServer(app);
|
||||
httpServer.listen(2080, () => {
|
||||
console.log('HTTP server listening on port 2080');
|
||||
});
|
||||
wss = new WebSocket.Server({
|
||||
port: 2081
|
||||
}); //not secure
|
||||
console.log('WebSocket server listening on port 2081');
|
||||
}
|
||||
|
||||
// // # ┌────────────── 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', wss => {
|
||||
wss.on('message', message => {
|
||||
console.log('Received message => ${message}');
|
||||
});
|
||||
wss.send('ho!');
|
||||
});
|
||||
|
||||
|
||||
// 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: '/var/www/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";
|
||||
// console.log("Some debug messages");
|
||||
// //console.log = (msg) => console.log("C>" + msg);
|
||||
// console.log("Console MSG");
|
||||
|
||||
|
||||
function formatDate(date) {
|
||||
var hour = date.getHours();
|
||||
var minutes = date.getMinutes();
|
||||
var seconds = date.getSeconds();
|
||||
var milliseconds = date.getMilliseconds();
|
||||
|
||||
return '[' +
|
||||
((hour < 10) ? '0' + hour : hour) +
|
||||
':' +
|
||||
((minutes < 10) ? '0' + minutes : minutes) +
|
||||
':' +
|
||||
((seconds < 10) ? '0' + seconds : seconds) +
|
||||
'.' +
|
||||
('00' + milliseconds).slice(-3) +
|
||||
'] ';
|
||||
}
|
||||
30
_archive/ecosystem.config.js
Normal file
30
_archive/ecosystem.config.js
Normal file
@@ -0,0 +1,30 @@
|
||||
module.exports = {
|
||||
apps : [{
|
||||
script: 'dht.js',
|
||||
watch: ['.'],
|
||||
ignore_watch : ["dht.log"],
|
||||
env: {
|
||||
NODE_ENV: "development"
|
||||
},
|
||||
env_test: {
|
||||
NODE_ENV: "test",
|
||||
},
|
||||
env_production: {
|
||||
NODE_ENV: "production",
|
||||
}
|
||||
}
|
||||
],
|
||||
|
||||
deploy : {
|
||||
production : {
|
||||
user : 'SSH_USERNAME',
|
||||
host : 'SSH_HOSTMACHINE',
|
||||
ref : 'origin/master',
|
||||
repo : 'GIT_REPOSITORY',
|
||||
path : 'DESTINATION_PATH',
|
||||
'pre-deploy-local': '',
|
||||
'post-deploy' : 'npm install && pm2 reload ecosystem.config.js --env production',
|
||||
'pre-setup': ''
|
||||
}
|
||||
}
|
||||
};
|
||||
Reference in New Issue
Block a user