tidy folder structure
This commit is contained in:
Dobromir Popov
266
_archive/ac.js
Normal file
266
_archive/ac.js
Normal file
@@ -0,0 +1,266 @@
|
||||
//#region Constants
|
||||
var kDefaultMessageGap = 100000;
|
||||
|
||||
var kNibbleSize = 4;
|
||||
var kLowNibble = 0;
|
||||
var kHighNibble = 4;
|
||||
var kModeBitsSize = 3;
|
||||
|
||||
var INT8_MIN = -128;
|
||||
var INT8_MAX = 127;
|
||||
var UINT8_MAX = 255;
|
||||
var UINT8_MAX2 = 0xFF;
|
||||
|
||||
var AcModeSize = 4; // Nr. of Bits
|
||||
const AcMode = Object.freeze({"Heat":1, "Dry":2, "Cool":3, "Fan":7, "Auto":8})
|
||||
|
||||
// Constants
|
||||
var AcTimes =
|
||||
{
|
||||
HdrMark:3000,
|
||||
HdrSpace:1650,
|
||||
BitMark:500,
|
||||
OneSpace: 1050,
|
||||
ZeroSpace: 325,
|
||||
Gap :kDefaultMessageGap
|
||||
// Total tolerance percentage to use for matching the header mark.
|
||||
// var AcHdrMarkTolerance = 6;
|
||||
// var AcTolerance = 5; // Extra Percentage for the rest.
|
||||
};
|
||||
|
||||
var AcFanSize = 3; // Nr. of Bits. Mask = 0b00000111
|
||||
var AcFan = Object.freeze({
|
||||
"Auto":0b000,
|
||||
"Low":0b010,
|
||||
"Med":0b011,
|
||||
"High":0b101});
|
||||
|
||||
//5
|
||||
var AcHalfDegreeOffset = 5;
|
||||
var AcTempMax = 31.0;
|
||||
var AcTempMin = 16.0;
|
||||
|
||||
var AcPowerOffset = 2;
|
||||
var AcBitEconoOffset = 7;
|
||||
var AcBitLightOffset = 6;
|
||||
var AcBitHealthOffset = 4;
|
||||
//3
|
||||
var AcBitSwingHOffset = 3;
|
||||
var AcSwingVOffset = 3; // Mask 0b00111000
|
||||
var AcSwingVSize = 3; // Nr. of bits.
|
||||
var AcSwingVOn = 0b111;
|
||||
var AcSwingVOff = 0b000;
|
||||
var AcBitTurboOffset = 6;
|
||||
//#endregion Constants
|
||||
|
||||
var buf = require('buffer');
|
||||
var initialState =new Int16Array([0x23, 0xCB, 0x26, 0x01, 0x00, 0x24, 0x03, 0x07, 0x40, 0x00, 0x00, 0x00, 0x00, 0x03]);
|
||||
var state;
|
||||
|
||||
state = Buffer.from(initialState.slice());
|
||||
//remote_state = initialState.slice();
|
||||
var b = setBits(state[0],0,5,0x0);
|
||||
// b = setBits(remote_state[0],0,6,0x0);
|
||||
// b = setBits(remote_state[0],0,6,0x0);
|
||||
// b = setBits(remote_state[0],0,7,0x0);
|
||||
// b = setBits(remote_state[0],0,8,0x0);
|
||||
// state[0] = setBits(state[0],0,8,0x0);
|
||||
// state[0] = setBit(state[0],0,true);
|
||||
// state[0] = setBit(state[0],1,true);
|
||||
// state[0] = setBit(state[0],2,true);
|
||||
// state[0] = setBit(state[0],1,0);
|
||||
// state[0] = setBits(state[0],0,8,0xFF);
|
||||
|
||||
|
||||
|
||||
|
||||
// console.log("" + state.toString('hex'));
|
||||
setTemp(23);
|
||||
setMode(AcMode.Heat);
|
||||
setPower(true);
|
||||
setFan(AcFan.Med);check();
|
||||
console.log("" + state.toString('hex'));
|
||||
var rawTime = "38000,"+GenerateTimingString();
|
||||
// console.log(rawTime);
|
||||
|
||||
|
||||
function GetState()
|
||||
{
|
||||
return state.toString('hex').toUpperCase();
|
||||
}
|
||||
|
||||
function GenerateTimingString()
|
||||
{
|
||||
var arr = [AcTimes.HdrMark, AcTimes.HdrSpace, AcTimes.BitMark];
|
||||
for(i=0; i<state.length; i++)
|
||||
{
|
||||
for(j=0; j<8; j++)
|
||||
{
|
||||
if(bit_test(state[i],j)){//on
|
||||
arr.push(AcTimes.OneSpace);arr.push(AcTimes.BitMark);
|
||||
}else{//off
|
||||
arr.push(AcTimes.ZeroSpace);arr.push(AcTimes.BitMark);
|
||||
}
|
||||
}
|
||||
}
|
||||
return arr.join(",");
|
||||
}
|
||||
function bit_test(num, bit){
|
||||
return ((num>>bit) % 2 != 0);
|
||||
}
|
||||
|
||||
function bit_set(num, bit){
|
||||
return num | 1<<bit;
|
||||
}
|
||||
|
||||
function bit_clear(num, bit){
|
||||
return num & ~(1<<bit);
|
||||
}
|
||||
|
||||
|
||||
function check()
|
||||
{
|
||||
var length = state.length;
|
||||
checksum(length);
|
||||
}
|
||||
|
||||
function validChecksum(state, length) {
|
||||
return (length > 1 && state[length - 1] == sumBytes(state, length));
|
||||
}
|
||||
// Calculate & set the checksum for the current internal state of the remote.
|
||||
function checksum(length) {
|
||||
if (length > 1)
|
||||
state[length - 1] = sumBytes(state, length-1);
|
||||
}
|
||||
|
||||
function sumBytes(state, length, start=0) {
|
||||
var checksum = 0;
|
||||
for (i = 0; i - start < length; i++) {checksum += state[i + start];}
|
||||
return checksum;
|
||||
}
|
||||
|
||||
function setBit(data, position, on) {
|
||||
if (position >= 8) return data; // Outside of range.
|
||||
mask = 1 << position;
|
||||
if (on){ data = data | mask; }
|
||||
else { data = data & ~mask; }
|
||||
return data;
|
||||
}
|
||||
|
||||
function setBits(data, offset, nbits, val) {
|
||||
if (offset >= 8 || !nbits) return data; // Short circuit as it won't change.
|
||||
// Calculate the mask for the supplied value.
|
||||
mask = UINT8_MAX >> (8 - ((nbits > 8) ? 8 : nbits));
|
||||
// Calculate the mask & clear the space for the data.
|
||||
// Clear the destination bits.
|
||||
data &= ~(mask << offset);
|
||||
// Merge in the data.
|
||||
data |= ((val & mask) << offset);
|
||||
return data;
|
||||
}
|
||||
|
||||
|
||||
|
||||
function setPower(on) {
|
||||
state[5] = setBit(state[5], AcPowerOffset, on);
|
||||
state[12] = setBit(state[12], 7, !on);
|
||||
}
|
||||
|
||||
function setMode(mode) {
|
||||
// If we get an unexpected mode, default to AUTO.
|
||||
switch (mode) {
|
||||
case AcMode.Fan:
|
||||
setFan(AcFanHigh);break;
|
||||
case AcMode.Auto:
|
||||
case AcMode.Cool:
|
||||
case AcMode.Heat:
|
||||
case AcMode.Dry:
|
||||
state[6] = setBits(state[6], kLowNibble, AcModeSize, mode);
|
||||
break;
|
||||
default:
|
||||
setMode(AcMode.Auto);
|
||||
}
|
||||
}
|
||||
|
||||
function setTemp(celsius) {
|
||||
// Make sure we have desired temp in the correct range.
|
||||
var tsafe = Math.max(celsius, AcTempMin);
|
||||
tsafe = Math.min(tsafe, AcTempMax);
|
||||
// Convert to integer nr. of half degrees.
|
||||
var nrHalfDegrees = tsafe * 2;
|
||||
// Do we have a half degree celsius?
|
||||
state[12] = setBit(state[12], AcHalfDegreeOffset, nrHalfDegrees & 1);
|
||||
|
||||
state[7] = setBits(state[7], kLowNibble, kNibbleSize, (nrHalfDegrees % 2) + (AcTempMax - nrHalfDegrees / 2));
|
||||
|
||||
}
|
||||
|
||||
function setFan(speed) {
|
||||
switch (speed) {
|
||||
case AcFan.Auto:
|
||||
case AcFan.Low:
|
||||
case AcFan.Med:
|
||||
case AcFan.High:
|
||||
state[8] = setBits(state[8], kLowNibble, AcFanSize, speed);
|
||||
break;
|
||||
default:
|
||||
setFan(AcFan.Auto);
|
||||
}
|
||||
}
|
||||
function setEcono(on) {
|
||||
console.log("[5]");
|
||||
state[5] = setBit(state[5], AcBitEconoOffset, on);
|
||||
}
|
||||
function setHealth(on) {
|
||||
console.log("[6]");
|
||||
state[6] = setBit(state[6], AcBitHealthOffset, on);
|
||||
}
|
||||
function setLight(on) {
|
||||
console.log("[5]");
|
||||
state[5] = setBit(state[5], AcBitLightOffset, !on); // Cleared when on.
|
||||
}
|
||||
function setSwingHorizontal(on) {
|
||||
console.log("[12]");
|
||||
state[12] = setBit(state[12], AcBitSwingHOffset, on);
|
||||
}
|
||||
function setSwingVertical(on) {
|
||||
console.log("[8]");
|
||||
state[8] = setBits(state[8], AcSwingVOffset, AcSwingVSize,
|
||||
on ? AcSwingVOn : AcSwingVOff);
|
||||
}
|
||||
function setTurbo(on) {
|
||||
console.log("[6]");
|
||||
state[6] = setBit(state[6], AcBitTurboOffset, on);
|
||||
if (on) {
|
||||
setFan(AcFanHigh);
|
||||
setSwingVertical(true);
|
||||
}
|
||||
}
|
||||
|
||||
var AcControl = {
|
||||
Init:function()
|
||||
{
|
||||
state = Buffer.from(initialState.slice());
|
||||
},
|
||||
SetPower: setPower,
|
||||
SetMode : setMode,
|
||||
SetTemp : setTemp,
|
||||
SetFan : setFan,
|
||||
SetEcono : setEcono,
|
||||
SetHealth: setHealth,
|
||||
SetLight: setLight,
|
||||
SetSwingHorizontal: setSwingHorizontal,
|
||||
SetSwingVertical: setSwingVertical,
|
||||
SetTurbo: setTurbo,
|
||||
GetCommand: function(){
|
||||
check();
|
||||
console.log("GetCommand:" + state.toString('hex'));
|
||||
return GenerateTimingString();
|
||||
},
|
||||
GetState:GetState(),
|
||||
|
||||
};
|
||||
|
||||
module.exports.Tlc112 = AcControl;
|
||||
module.exports.Mode = AcMode;
|
||||
module.exports.FanSpeed = AcFan;
|
||||
49
_archive/apache.conf
Normal file
49
_archive/apache.conf
Normal file
@@ -0,0 +1,49 @@
|
||||
|
||||
# <IfModule mod_ssl.c>
|
||||
# <VirtualHost *:443>
|
||||
# ServerName iot.d-popov.com
|
||||
# SSLProxyEngine on
|
||||
# #SSLEngine on
|
||||
# #KeepAliveEnabled ON
|
||||
# #SSLCipherSuite HIGH:MEDIUM
|
||||
# #SSLProtocol all
|
||||
# #SecureProxy ON
|
||||
|
||||
# # first deny access to everything
|
||||
# <Location />
|
||||
# Order Deny,Allow
|
||||
# Deny from All
|
||||
# </Location>
|
||||
# ProxyPreserveHost On
|
||||
# #ProxyPass /n https://localhost:8443
|
||||
# #ProxyPassReverse /n https://localhost:8443
|
||||
# <Location /n>
|
||||
# Order Allow,Deny
|
||||
# Allow from All
|
||||
# ProxyPass https://127.0.0.1:8443
|
||||
# ProxyPassReverse https://127.0.0.1:8443
|
||||
# </Location>
|
||||
# #<Location />
|
||||
# # ProxyPass http://127.0.0.1:8443
|
||||
# # ProxyPassReverse http://127.0.0.1:8443
|
||||
# #</Location>
|
||||
# SSLCertificateFile /etc/letsencrypt/live/iot.d-popov.com-0001/fullchain.pem
|
||||
# SSLCertificateKeyFile /etc/letsencrypt/live/iot.d-popov.com-0001/privkey.pem
|
||||
# Include /etc/letsencrypt/options-ssl-apache.conf
|
||||
# </VirtualHost>
|
||||
# </IfModule>
|
||||
# # vim: syntax=apache ts=4 sw=4 sts=4 sr noet
|
||||
|
||||
|
||||
|
||||
|
||||
# <mntent>
|
||||
# <uuid>3b32d635-48a9-42ee-b084-bc5f15279964</uuid>
|
||||
# <fsname>/srv/dev-disk-by-id-usb-Seagate_Expansion_NAADR4MD-0-0-part2/NAS/</fsname>
|
||||
# <dir>/export/NAS</dir>
|
||||
# <type>none</type>
|
||||
# <opts>bind,nofail</opts>
|
||||
# <freq>0</freq>
|
||||
# <passno>0</passno>
|
||||
# <hidden>0</hidden>
|
||||
# </mntent>
|
||||
446
_archive/dht.js.bak
Normal file
446
_archive/dht.js.bak
Normal file
@@ -0,0 +1,446 @@
|
||||
// ./src/index.js
|
||||
var config = require('./src/setup_const');
|
||||
|
||||
// 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 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/: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);
|
||||
});
|
||||
app.use('/water',function(req, res){
|
||||
var time = req.query.t;
|
||||
console.log("Watering cmd for: " + time);
|
||||
request('http://'+config.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://'+config.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(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
|
||||
}
|
||||
|
||||
// // # ┌────────────── 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://'+ config.HomeControllerMQTT);
|
||||
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('Garden/+');
|
||||
mqtt_client.subscribe('Garden/+/+');
|
||||
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("MQTT> " + 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 === "Garden/status/LWT")
|
||||
{
|
||||
//!console.log("Garden >'" + 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(formatDate(new Date()) + "Device is ONLINE! <" + dht.ssid + "> " + dht.rssi + "dB" );}
|
||||
//if(stat.event ==='OFF'){console.log(formatDate(new Date()) + "Device went ofline!");}
|
||||
handled = true;
|
||||
}
|
||||
if(topic === "Garden/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 = 0;
|
||||
}
|
||||
SaveDhtIf();
|
||||
handled = true;
|
||||
}
|
||||
if(topic === "Garden/bmp/Temperature")
|
||||
{
|
||||
dht.Temp = message.toString();
|
||||
console.log("Garden > air " + dht.Temp + " C");
|
||||
SaveDhtIf();
|
||||
handled = true;
|
||||
}
|
||||
if(topic === "Garden/bmp/Humidity")
|
||||
{
|
||||
dht.Hum = message.toString();
|
||||
console.log("Garden > air " + dht.Hum + "% RH");
|
||||
SaveDhtIf();
|
||||
handled = true;
|
||||
}
|
||||
if(topic === "Garden/bmp/Pressure")
|
||||
{
|
||||
dht.Pres = message.toString();
|
||||
console.log("Garden > air " + dht.Pres + " hPa");
|
||||
SaveDhtIf();
|
||||
handled = true;
|
||||
}
|
||||
if(topic === "Garden/Water/start")
|
||||
{
|
||||
var j = JSON.parse(message);
|
||||
dht.Soil = j.soil;
|
||||
SaveDhtIf();
|
||||
handled = true;
|
||||
console.log(formatDate(new Date()) + "Garden > Started watering at "+j.time+"(GMT) with " + j.soil + "% soil RH");
|
||||
}
|
||||
if(topic === "Garden/Water/stop")
|
||||
{
|
||||
var j = JSON.parse(message);
|
||||
dht.Soil = j.soil;
|
||||
SaveDhtIf();
|
||||
handled = true;
|
||||
console.log(formatDate(new Date()) + "Garden > Finished watering at "+j.time+"(GMT) 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 && dht.Soil < 5)
|
||||
// {
|
||||
// console.log("Soil reported below 5%! Probable loose sensor wire. Record discarded" );
|
||||
// dht = {};
|
||||
// return;
|
||||
// }
|
||||
var msg = JSON.stringify(dht);
|
||||
db.devicemessages.insert(1, "A23_Garden_dht", msg, function (err, data) {
|
||||
if (!err) {
|
||||
console.log("Saved to DB > ["+ data.id +"]:" + msg);//+"; SSID: '"+dht.ssid+"' RSSI:"+ dht.rssi + "dB");
|
||||
}
|
||||
else { console.log("error: " + err); }
|
||||
});
|
||||
dht = {};
|
||||
}else{
|
||||
console.log("T: %s; H: %s; P: $s", dht.Temp, dht.Hum, dht.Pres);
|
||||
// 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.appendFileSync('/var/www/dht.log', msg +"\r\n");
|
||||
}
|
||||
})();
|
||||
|
||||
// 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) +
|
||||
'] ';
|
||||
}
|
||||
0
_archive/sqltools_20210716130107_17192.log
Normal file
0
_archive/sqltools_20210716130107_17192.log
Normal file
Reference in New Issue
Block a user