exports.readme = `# send all data to projects.worksys.io, required to monitor status of controller(unipi)`;
-const fs = require('fs');
-var path = require('path');
+exports.install = function(instance) {
-exports.install = async function(instance) {
-
+ let id;
let allValues = {};
let sendAllValuesInterval;
+ let configured = false;
let now = new Date();
console.log(exports.title, "INSTALLED", now.toLocaleString("sk-SK"));
@@ -37,69 +33,49 @@ exports.install = async function(instance) {
let ipAddresses = Object.create(null); // Or just '{}', an empty object
for (const name of Object.keys(nets)) {
- for (const net of nets[name]) {
- // Skip over non-IPv4 and internal (i.e. 127.0.0.1) addresses
- if (net.family === 'IPv4' && !net.internal) {
- if (!ipAddresses[name]) {
- ipAddresses[name] = [];
- }
- ipAddresses[name].push(net.address);
- }
+ for (const net of nets[name]) {
+ // Skip over non-IPv4 and internal (i.e. 127.0.0.1) addresses
+ if (net.family === 'IPv4' && !net.internal) {
+ if (!ipAddresses[name]) {
+ ipAddresses[name] = [];
+ }
+ ipAddresses[name].push(net.address);
}
- }
-
-
- function sendValues()
- {
- const id = FLOW.OMS_projects_id;
-
- if(Object.keys(allValues).length > 0)
- {
- if(id !== undefined)
- {
- delete allValues.__force__;
- let dataToSend = {...allValues};
- dataToSend.id = id;
- dataToSend.ipAddresses = ipAddresses;
- //dataToSend.notify_date = new Date().toISOString().slice(0, 19).replace('T', ' ');
-
- //console.log(exports.title, "------------>sendValues", dataToSend);
-
- instance.send(0, dataToSend);
-
- allValues = {};
- }
- else
- {
- console.log(exports.title, "unable to send data, id is undefined");
- }
-
}
}
-
+
+ function sendValues() {
+ if (!configured) return;
+
+ if (Object.keys(allValues).length > 0) {
+ let dataToSend = { ...allValues };
+ dataToSend.id = id;
+ dataToSend.ipAddresses = ipAddresses;
+
+ instance.send(0, dataToSend);
+
+ allValues = {};
+ }
+ }
+
instance.on("close", () => {
clearInterval(sendAllValuesInterval);
})
- instance.on("data", (flowdata) => {
-
- allValues = { ...allValues, ...flowdata.data};
+ instance.on("0", _ => {
+ id = FLOW.GLOBALS.settings.project_id;
+ if (id) configured = true;
+ else console.log(exports.title, "InfoSender: Unable to send data, no id");
+ })
+ instance.on("1", flowdata => {
+ allValues = { ...allValues, ...flowdata.data };
//console.log("DATA RECEIVED", flowdata.data);
-
- //__force__
- if(flowdata.data.hasOwnProperty("__force__"))
- {
- if(flowdata.data.__force__)
- {
- sendValues();
- }
- }
})
sendAllValuesInterval = setInterval(() => {
sendValues();
- }, 60000*3);
-
+ }, 60000 * 3);
+
}
diff --git a/flow/modbus_reader.js b/flow/modbus_reader.js
index f34ec9a..5852ff3 100644
--- a/flow/modbus_reader.js
+++ b/flow/modbus_reader.js
@@ -3,6 +3,7 @@ exports.title = 'Modbus reader';
exports.version = '2.0.0';
exports.group = 'Worksys';
exports.color = '#2134B0';
+exports.input = 1;
exports.output = ["red", "white", "yellow"];
exports.click = false;
exports.author = 'Rastislav Kovac';
@@ -15,7 +16,7 @@ exports.readme = `
`;
const modbus = require('jsmodbus');
-const SerialPort = require('serialport');
+const {SerialPort} = require('serialport');
const { timeoutInterval, deviceConfig } = require("../databases/modbus_config");
const { sendNotification } = require('./helper/notification_reporter');
@@ -31,13 +32,16 @@ const SEND_TO = {
const numberOfNotResponding = {};
let tbName = null;
let mainSocket;
-
+//number of phases inRVO
+let phases;
+//phases where voltage is 0 (set)
+let noVoltage;
exports.install = function(instance) {
class SocketWithClients {
- constructor () {
+ constructor() {
this.stream = null;
this.socket = null;
this.clients = {};
@@ -51,31 +55,39 @@ exports.install = function(instance) {
this.indexInDeviceConfig = 0; // first item in deviceConfig
this.lengthOfActualDeviceStream = null;
this.device = null;
-
+
// lampSwitchNotification helper variables
this.onNotificationSent = false;
this.offNotificationSent = false;
+ this.phases = this.buildPhases();
this.startSocket();
}
+ buildPhases = () => {
+ let a = [];
+ for (let i = 1; i <= phases; i++) {
+ a.push(`Phase_${i}_voltage`)
+ }
+ return a;
+ }
+
startSocket = () => {
let obj = this;
- this.socket = new SerialPort("/dev/ttymxc0", {
- baudRate: 9600,
+ this.socket = new SerialPort({path: "/dev/ttymxc0",
+ baudRate: 9600
})
// we create a client for every deviceAddress ( = address) in list and push them into dictionary
- for( let i = 0; i < deviceConfig.length; i++)
- {
+ for (let i = 0; i < deviceConfig.length; i++) {
this.clients[deviceConfig[i].deviceAddress] = new modbus.client.RTU(this.socket, deviceConfig[i].deviceAddress, 2000); // 2000 is timeout in register request, default is 5000, which is too long
}
this.socket.on('error', function(e) {
console.log('socket connection error', e);
- if(e.code == 'ECONNREFUSED' || e.code == 'ECONNRESET') {
+ if (e.code == 'ECONNREFUSED' || e.code == 'ECONNRESET') {
console.log(exports.title + ' Waiting 10 seconds before trying to connect again');
setTimeout(obj.startSocket, 10000);
}
@@ -86,7 +98,7 @@ exports.install = function(instance) {
setTimeout(obj.startSocket, 10000);
});
- this.socket.on('open', function () {
+ this.socket.on('open', function() {
console.log("socket connected");
obj.getActualStreamAndDevice();
obj.timeoutInterval = timeoutInterval - DELAY_BETWEEN_DEVICES; // to make sure readout always runs in timeoutinterval we substract DELAY_BETWEEN_DEVICES
@@ -99,11 +111,11 @@ exports.install = function(instance) {
this.index = 0;
this.errors = 0;
this.stream = dev.stream;
- this.lengthOfActualDeviceStream = dev.stream.length;
+ this.lengthOfActualDeviceStream = dev.stream.length;
this.deviceAddress = dev.deviceAddress; // 1 or 2 or any number
this.device = dev.device; //em340, twilight_sensor
- if(this.indexInDeviceConfig == 0) setTimeout(this.readRegisters, this.timeoutInterval);
+ if (this.indexInDeviceConfig == 0) setTimeout(this.readRegisters, this.timeoutInterval);
else setTimeout(this.readRegisters, DELAY_BETWEEN_DEVICES);
}
@@ -117,21 +129,18 @@ exports.install = function(instance) {
let obj = this;
this.clients[this.deviceAddress].readHoldingRegisters(register, size)
- .then( function (resp) {
-
+ .then(function(resp) {
+
resp = resp.response._body.valuesAsArray; //resp is array of length 1 or 2, f.e. [2360,0]
// console.log(deviceAddress, register, tbAttribute, resp);
//device is responding again after NOK status
- if(numberOfNotResponding.hasOwnProperty(obj.device))
- {
+ if (numberOfNotResponding.hasOwnProperty(obj.device)) {
let message = "";
- if(obj.device == "em340")
- {
+ if (obj.device == "em340") {
message = "electrometer_ok";
}
- else if(obj.device == "twilight_sensor")
- {
+ else if (obj.device == "twilight_sensor") {
message = "twilight_sensor_ok";
}
message && sendNotification("modbus_reader: readRegisters", tbName, message, {}, "", SEND_TO.tb, instance);
@@ -144,25 +153,21 @@ exports.install = function(instance) {
obj.index++;
obj.readAnotherRegister();
- }).catch (function () {
+ }).catch(function() {
+
+ //console.log("errors pri citani modbus registra", register, obj.indexInDeviceConfig, tbName, tbAttribute);
- console.log("errors pri citani modbus registra", register, obj.indexInDeviceConfig, tbName, tbAttribute);
-
obj.errors++;
- if(obj.errors == obj.lengthOfActualDeviceStream)
- {
- instance.send(SEND_TO.dido_controller, {status: "NOK-" + obj.device}); // NOK-em340, NOK-em111, NOK-twilight_sensor, NOK-thermometer
-
+ if (obj.errors == obj.lengthOfActualDeviceStream) {
+ instance.send(SEND_TO.dido_controller, { status: "NOK-" + obj.device }); // NOK-em340, NOK-em111, NOK-twilight_sensor, NOK-thermometer
+
//todo - neposlalo notification, ked sme vypojili twilight a neposle to do tb, ale do dido ??
- if(!numberOfNotResponding.hasOwnProperty(obj.device))
- {
+ if (!numberOfNotResponding.hasOwnProperty(obj.device)) {
let message = "";
- if(obj.device == "twilight_sensor")
- {
+ if (obj.device == "twilight_sensor") {
message = "twilight_sensor_nok";
}
- else if(obj.device == "em340")
- {
+ else if (obj.device == "em340") {
message = "electrometer_nok";
}
message && sendNotification("modbus_reader: readingTimeouted", tbName, message, {}, "", SEND_TO.tb, instance);
@@ -170,17 +175,16 @@ exports.install = function(instance) {
}
obj.errors = 0;
- numberOfNotResponding[obj.device] += 1;
+ numberOfNotResponding[obj.device] += 1;
}
- console.error(require('util').inspect(arguments, {
- depth: null
- }))
+ // console.error(require('util').inspect(arguments, {
+ // depth: null
+ // }))
// if reading out of device's last register returns error, we send accumulated allValues to dido_controller (if allValues are not an empty object)
- if(obj.index + 1 >= obj.lengthOfActualDeviceStream)
- {
- if(!isObjectEmpty(obj.allValues)) instance.send(SEND_TO.dido_controller, {values: obj.allValues});
+ if (obj.index + 1 >= obj.lengthOfActualDeviceStream) {
+ if (!isObjectEmpty(obj.allValues)) instance.send(SEND_TO.dido_controller, { values: obj.allValues });
obj.allValues = {};
}
obj.index++;
@@ -190,7 +194,7 @@ exports.install = function(instance) {
};
readAnotherRegister = () => {
- if(this.index < this.lengthOfActualDeviceStream) setTimeout(this.readRegisters, 0);
+ if (this.index < this.lengthOfActualDeviceStream) setTimeout(this.readRegisters, 0);
else this.setNewStream();
}
@@ -199,18 +203,16 @@ exports.install = function(instance) {
for (let i = 0; i < this.lengthOfActualDeviceStream; i++) {
let a = this.stream[i];
- if (a.register === register)
- {
+ if (a.register === register) {
let tbAttribute = a.tbAttribute;
let multiplier = a.multiplier;
-
- let value = this.calculateValue(response, multiplier);
+
+ let value = this.calculateValue(response, multiplier);
// console.log(register, tbName, tbAttribute, response, a.multiplier, value);
// if(tbName == undefined) return;
- if(this.index + 1 < this.lengthOfActualDeviceStream)
- {
+ if (this.index + 1 < this.lengthOfActualDeviceStream) {
this.allValues[tbAttribute] = value;
return;
}
@@ -223,54 +225,45 @@ exports.install = function(instance) {
this.checkNullVoltage(values);
this.lampSwitchNotification(values);
- instance.send(SEND_TO.dido_controller, {values: values});
+ instance.send(SEND_TO.dido_controller, { values: values });
this.allValues = {};
break;
}
-
- }
-
+ }
}
- setNewStream = () =>
- {
- if(this.lengthOfActualDeviceStream == this.index)
- {
- if(this.indexInDeviceConfig + 1 == deviceConfig.length)
- {
+ setNewStream = () => {
+ if (this.lengthOfActualDeviceStream == this.index) {
+ if (this.indexInDeviceConfig + 1 == deviceConfig.length) {
this.indexInDeviceConfig = 0;
- }
- else
- {
+ }
+ else {
this.indexInDeviceConfig += 1;
}
this.getActualStreamAndDevice();
- }
+ }
}
- calculateValue = (response, multiplier) =>
- {
+ calculateValue = (response, multiplier) => {
let value = 0;
let l = response.length;
- if (l === 2)
- {
- value = (response[1]*(2**16) + response[0]);
+ if (l === 2) {
+ value = (response[1] * (2 ** 16) + response[0]);
- if(value >= (2**31)) // ak je MSB bit nastavený, eventuálne sa dá použiť aj (value & 0x80000000), ak vieš robiť logický súčin
- {
- value = value - "0xFFFFFFFF" + 1;
- }
+ if (value >= (2 ** 31)) // ak je MSB bit nastavený, eventuálne sa dá použiť aj (value & 0x80000000), ak vieš robiť logický súčin
+ {
+ value = value - "0xFFFFFFFF" + 1;
+ }
}
- else if (l === 1)
- {
+ else if (l === 1) {
value = response[0];
- if(value >= (2**15)) // ak je MSB bit nastavený, eventuálne sa dá použiť aj (value & 0x8000), ak vieš robiť logický súčin
+ if (value >= (2 ** 15)) // ak je MSB bit nastavený, eventuálne sa dá použiť aj (value & 0x8000), ak vieš robiť logický súčin
{
- value = value - "0xFFFF" + 1;
+ value = value - "0xFFFF" + 1;
}
}
@@ -279,70 +272,75 @@ exports.install = function(instance) {
checkNullVoltage = (values) => {
- if(!(values.hasOwnProperty("Phase_1_voltage") || values.hasOwnProperty("Phase_2_voltage") || values.hasOwnProperty("Phase_3_voltage"))) return;
+ if (!(values.hasOwnProperty("Phase_1_voltage") || values.hasOwnProperty("Phase_2_voltage") || values.hasOwnProperty("Phase_3_voltage"))) return;
Object.keys(values).map(singleValue => {
- if (["Phase_1_voltage", "Phase_2_voltage", "Phase_3_voltage"].includes(singleValue))
- {
+ if (this.phases.includes(singleValue)) {
let l = singleValue.split("_");
let phase = parseInt(l[1]);
- if(FLOW.OMS_no_voltage == undefined) FLOW.OMS_no_voltage = new Set();
// console.log(values[singleValue], tbName);
- if(values[singleValue] == 0)
- {
- FLOW.OMS_no_voltage.add(phase);
- sendNotification("modbus_reader: checkNullVoltage", tbName, "no_voltage_on_phase", {phase: phase}, "", SEND_TO.tb, instance, "voltage" + phase );
+ if (values[singleValue] == 0) {
+ noVoltage.add(phase);
+ sendNotification("modbus_reader: checkNullVoltage", tbName, "no_voltage_on_phase", { phase: phase }, "", SEND_TO.tb, instance, "voltage" + phase);
// console.log('no voltage')
}
- else
- {
- FLOW.OMS_no_voltage.delete(phase);
+ else {
+ noVoltage.delete(phase);
// console.log('voltage detected')
- sendNotification("modbus_reader: checkNullVoltage", tbName, "voltage_on_phase_restored", {phase: phase}, "", SEND_TO.tb, instance, "voltage" + phase);
+ sendNotification("modbus_reader: checkNullVoltage", tbName, "voltage_on_phase_restored", { phase: phase }, "", SEND_TO.tb, instance, "voltage" + phase);
}
- }
+ }
})
}
/**
- * function sends notification to slack and to tb, if EM total_power value changes more than 500. This should show, that RVO lamps has been switched on or off
- */
+ * function sends notification to slack and to tb, if EM total_power value changes more than numberOfNodes*15. This should show, that RVO lamps has been switched on or off
+ */
lampSwitchNotification = (values) => {
- if(!values.hasOwnProperty("total_power")) return;
+ if (!values.hasOwnProperty("total_power")) return;
const actualTotalPower = values.total_power;
- if(actualTotalPower > 600 && this.onNotificationSent == false)
- {
+
+ const numberOfNodes = Object.keys(FLOW.GLOBALS.nodesData).length;
+ if (numberOfNodes == 0) numberOfNodes = 20; // to make sure, we send notification if totalPower is more than 300
+
+ if (actualTotalPower > numberOfNodes * 15 && this.onNotificationSent == false) {
sendNotification("modbus_reader: lampSwitchNotification", tbName, "lamps_have_turned_on", {}, "", SEND_TO.tb, instance);
this.onNotificationSent = true;
this.offNotificationSent = false;
- }
- else if(actualTotalPower <= 600 && this.offNotificationSent == false)
- {
+ }
+ else if (actualTotalPower <= numberOfNodes * 15 && this.offNotificationSent == false) {
sendNotification("modbus_reader: lampSwitchNotification", tbName, "lamps_have_turned_off", {}, "", SEND_TO.tb, instance);
this.onNotificationSent = false;
this.offNotificationSent = true;
}
}
- }
-
- const isObjectEmpty = (objectName) => {
- return Object.keys(objectName).length === 0 && objectName.constructor === Object;
}
- setTimeout(() => {
-
+ const isObjectEmpty = (objectName) => {
+ return Object.keys(objectName).length === 0 && objectName.constructor === Object;
+ }
+
+ function main() {
+
+ phases = FLOW.GLOBALS.settings.phases;
+ tbName = FLOW.GLOBALS.settings.rvoTbName;
+ noVoltage = FLOW.GLOBALS.settings.no_voltage;
mainSocket = new SocketWithClients();
- tbName = FLOW.OMS_rvo_tbname;
+
+ console.log("novoltage: ", noVoltage, typeof noVoltage);
// this notification is to show, that flow (unipi) has been restarted
sendNotification("modbus_reader", tbName, "flow_restart", {}, "", SEND_TO.slack, instance);
+ }
- }, 25000);
+ instance.on("0", function(_) {
+ main();
+ })
}
diff --git a/flow/nodesdb_changecheck.js b/flow/nodesdb_changecheck.js
new file mode 100644
index 0000000..be1e700
--- /dev/null
+++ b/flow/nodesdb_changecheck.js
@@ -0,0 +1,70 @@
+exports.id = 'nodesdb_change_check';
+exports.title = 'Nodes DB change check';
+exports.group = 'Worksys';
+exports.color = '#888600';
+exports.version = '1.0.2';
+exports.icon = 'sign-out';
+exports.input = 1;
+exports.output = 1;
+exports.readme = `Check, if nodes.table db changed compared to original database`;
+
+const fs = require('fs');
+const path = require('path');
+const { sendNotification } = require('./helper/notification_reporter');
+const nodesOriginalFile = path.join(__dirname, '../databases/nodes_original/', 'nodes_original.table');
+
+
+exports.install = function(instance) {
+
+ function compareArrays(array1, array2) {
+ let message = "";
+ let areEqual = true;
+ let zmenene = []
+
+ if (array1.length !== array2.length) {
+ message += "Nezhoda v pocte nodov. "
+ }
+
+ const set1 = new Set(array1.map(obj => JSON.stringify(obj)));
+ const set2 = new Set(array2.map(obj => JSON.stringify(obj)));
+
+ for (const objStr of set1) {
+
+ if (!set2.has(objStr)) {
+ zmenene.push(objStr)
+ areEqual = false;
+ } else {
+ set2.delete(objStr);
+ }
+ }
+
+ if(!areEqual) {
+ message += `Aktualne nody: ${zmenene.toString()}. Zmenene proti originalu: ${Array.from(set2).join(' ')}`;
+ sendNotification("Nodesdb_changecheck", FLOW.GLOBALS.settings.rvoTbName, "nodes_db_changed", "", message, 0, instance);
+ }
+ else console.log("Arrays are equal.");
+
+ console.log(message)
+ }
+
+
+ instance.on("data", _ => {
+
+ let nodesData = FLOW.GLOBALS.nodesData;
+
+ // we check if nodes.table has changed compared to nodes_original.table (we have array of nodes e.g. [{node:255, tbname: "agruhuwhgursuhgo34hgsdiguhrr"}]
+ const nodes_actual = Object.keys(nodesData).map(node => ({[node]: nodesData[node].tbname}))
+ let nodes_original = fs.readFileSync(nodesOriginalFile, { encoding: 'utf8', flag: 'r' });
+
+ try {
+ nodes_original = JSON.parse(nodes_original);
+ } catch(e) {
+ console.log(e)
+ }
+
+
+ setTimeout(() => compareArrays(nodes_actual, nodes_original),10000);
+ })
+
+}
+
diff --git a/flow/notifikacie.csv b/flow/notifikacie.csv
deleted file mode 100644
index 520c997..0000000
--- a/flow/notifikacie.csv
+++ /dev/null
@@ -1,31 +0,0 @@
-key;weight;en;sk
-switching_profile_point_applied_to_line;INFO;Switching profile point applied to line no. ${line} : ${value};Aplikovaný bod spínacieho profilu na línií č. ${line} : ${value}
-dusk_has_occured;INFO;Dusk has occured;Nastal súmrak
-dawn_has_occured;INFO;Dawn has occured;Nastal úsvit
-dimming_profile_was_successfully_received_by_node;NOTICE;Dimming profile was successfully received by node no. ${node};Stmievací profil bol úspešne prijatý nodom č. ${node}
-master_node_is_responding_again;NOTICE;Master node is responding again;Master node začal znovu odpovedať
-command_was_sent_from_terminal_interface;DEBUG;A command was sent from terminal interface;Z terminálu bol odoslaný príkaz
-master_node_is_not_responding;ALERT;Master node is not responding;Master node neodpovedá
-configuration_of_dimming_profile_to_node_failed;ALERT;Configuration of dimming profile to node no. ${node} has failed;Konfigurácia stmievacieho profilu pre node č. ${node} zlyhala
-circuit_breaker_was_turned_on_line;NOTICE;Circuit breaker was turned on - line no. ${line};Zapnutie ističa na línii č. ${line}
-circuit_breaker_was_turned_off_line;ERROR;Circuit breaker was turned off - line no. ${line};Vypnutie ističa na línií č. ${line}
-dimming_profile_was_processed_for_node;INFO;Dimming profile was processed for node no. ${node};Stmievací profil bol spracovaný pre node č. ${node}
-switching_profile_was_processed_for_line;INFO;Switching profile was processed for line no. ${line};Spínací profil bol spracovaný pre líniu č. ${line}
-thermometer_is_not_responding;WARNING;Thermometer is not responding;Teplomer neodpovedá
-thermometer_is_responding_again;NOTICE;Thermometer is responding again;Teplomer znovu odpovedá
-thermometer_sends_invalid_data;WARNING;Thermometer sends invalid data;Teplomer posiela neplatné hodnoty
-main_switch_has_been_turned_off;CRITICAL;Main switch has been turned off;Hlavný vypínač bol vypnutý
-main_switch_has_been_turned_on;NOTICE;Main switch has been turned on;Hlavný vypínač bol zapnutý
-power_supply_has_disconnected_input;ALERT;Power supply has disconnected input;Napájací zdroj nemá napätie na vstupe
-power_supply_works_correctly;NOTICE;Power supply works correctly ;Napájací zdroj pracuje správne
-battery_level_is_low;ERROR;Battery level is low;Batéria má nízku úroveň napätia
-battery_level_is_ok;NOTICE;Battery level is OK;Batéria má správnu úroveň napätia
-door_has_been_open;NOTICE;Door has been open;Dvere boli otvorené
-door_has_been_closed;NOTICE;Door has been closed;Dvere boli zatvorené
-door_has_been_open_without_permision_alarm_is_on;WARNING;Door has been open without permision - alarm is on;Dvere boli otvorené bez povolania - zapnutá siréna
-state_of_contactor_for_line;INFO;State of contactor for line no. ${line} is ${value};Stav stýkača pre líniu č. ${line} je ${value}
-local_database_is_corrupted;CRITICAL;;
-electrometer_is_not_responding;ERROR;Electrometer is not responding;Elektromer neodpovedá
-no_voltage_detected_on_phase;CRITICAL;No voltage detected on phase no. ${phase};Na fáze č. ${phase} nie je napätie
-electrometer_is_responding_again;NOTICE;Electrometer is responding again;Elektromer znovu odpovedá
-voltaga_on_phase_has_been_restored;NOTICE;Voltaga on phase no. ${phase} has been restored;Napätie na fáze č. ${phase} bolo obnovené
diff --git a/flow/show_dbdata.js b/flow/show_dbdata.js
new file mode 100644
index 0000000..1e23ff7
--- /dev/null
+++ b/flow/show_dbdata.js
@@ -0,0 +1,243 @@
+exports.id = 'showdb';
+exports.title = 'Show db data';
+exports.group = 'Worksys';
+exports.color = '#888600';
+exports.version = '1.0.2';
+exports.icon = 'sign-out';
+exports.input = 8;
+exports.output = 1;
+
+const { exec } = require('child_process');
+
+exports.install = function(instance) {
+
+ instance.on("0", _ => {
+ instance.send(0, FLOW.GLOBALS.settings);
+ })
+ instance.on("1", _ => {
+ instance.send(0, FLOW.GLOBALS.relaysData);
+ })
+ instance.on("2", _ => {
+ instance.send(0, FLOW.GLOBALS.nodesData);
+ })
+ instance.on("3", _ => {
+ instance.send(0, FLOW.GLOBALS.pinsData);
+ })
+ instance.on("4", _ => {
+ instance.send(0, { rpcSwitchOffLine, rpcSetNodeDimming, rpcLineProfile, rpcNodeProfile, sunCalcExample, dataFromTerminalBroadcast })
+ })
+ instance.on("5", _ => {
+ exec("sudo tail -n 25 monitor.txt", (err, stdout, stderr) => {
+ if (err || stderr) instance.send(0, { err, stderr });
+ else instance.send(0, stdout);
+ })
+ })
+ instance.on("6", _ => {
+ exec("sudo tail -n 25 err.txt", (err, stdout, stderr) => {
+ if (err || stderr) instance.send(0, { err, stderr });
+ else instance.send(0, stdout);
+ })
+ })
+ instance.on("7", _ => {
+ instance.send(0, FLOW.deviceStatus);
+ })
+};
+
+
+const rpcSwitchOffLine =
+{
+ "topic": "v1/gateway/rpc",
+ "content": {
+ "device": "jbN4q7JPZmexgdnz2yKbWGDYAWwO0Q3BMX6ERLoV",
+ "data": {
+ "id": 8,
+ "method": "set_command",
+ "params": {
+ "entities": [
+ {
+ "entity_type": "edb_line",
+ "tb_name": "MgnK93rkoAazbqdQ4yB2Q0yZ1YXGx6pmwBeVEP2O"
+ }
+ ],
+ "command": "switch",
+ "payload": {
+ "value": false
+ }
+ }
+ }
+ }
+}
+
+const rpcSetNodeDimming =
+{
+ "topic": "v1/gateway/rpc",
+ "content": {
+ "device": "jbN4q7JPZmexgdnz2yKbWGDYAWwO0Q3BMX6ERLoV",
+ "data": {
+ "id": 10,
+ "method": "set_command",
+ "params": {
+ "entities": [
+ {
+ "entity_type": "street_luminaire",
+ "tb_name": "jbN4q7JPZmexgdnz2yKbWdDYAWwO0Q3BMX6ERLoV"
+ }
+ ],
+ "command": "dimming",
+ "payload": {
+ "value": 5
+ }
+ }
+ }
+ }
+}
+
+const rpcLineProfile =
+{
+ "topic": "v1/gateway/rpc",
+ "content": {
+ "device": "jbN4q7JPZmexgdnz2yKbWGDYAWwO0Q3BMX6ERLoV",
+ "data": {
+ "id": 9,
+ "method": "set_profile",
+ "params": {
+ "entities": [
+ {
+ "entity_type": "edb_line",
+ "tb_name": "MgnK93rkoAazbqdQ4yB2Q0yZ1YXGx6pmwBeVEP2O"
+ }
+ ],
+ "payload": {
+ "intervals": [
+ {
+ "value": 0,
+ "end_time": "20:00",
+ "start_time": "13:00"
+ },
+ {
+ "value": 1,
+ "end_time": "05:30",
+ "start_time": "20:00"
+ },
+ {
+ "value": 0,
+ "end_time": "13:00",
+ "start_time": "05:30"
+ }
+ ],
+ "astro_clock": true,
+ "dawn_lux_sensor": false,
+ "dusk_lux_sensor": false,
+ "dawn_lux_sensor_value": 5,
+ "dusk_lux_sensor_value": 5,
+ "dawn_astro_clock_offset": 0,
+ "dusk_astro_clock_offset": 0,
+ "dawn_lux_sensor_time_window": 30,
+ "dusk_lux_sensor_time_window": 30,
+ "dawn_astro_clock_time_window": 60,
+ "dusk_astro_clock_time_window": 60
+ }
+ }
+ }
+ }
+}
+
+
+const rpcNodeProfile =
+{
+ "topic": "v1/gateway/rpc",
+ "content": {
+ "device": "jbN4q7JPZmexgdnz2yKbWGDYAWwO0Q3BMX6ERLoV",
+ "data": {
+ "id": 11,
+ "method": "set_profile",
+ "params": {
+ "entities": [
+ {
+ "entity_type": "street_luminaire",
+ "tb_name": "jbN4q7JPZmexgdnz2yKbWdDYAWwO0Q3BMX6ERLoV"
+ }
+ ],
+ "payload": {
+ "intervals": [
+ {
+ "cct": 3000,
+ "value": 0,
+ "end_time": "17:50",
+ "start_time": "13:00"
+ },
+ {
+ "cct": 3000,
+ "value": 100,
+ "end_time": "21:30",
+ "start_time": "17:50"
+ },
+ {
+ "cct": 3000,
+ "value": 0,
+ "end_time": "13:00",
+ "start_time": "07:10"
+ },
+ {
+ "cct": 3000,
+ "value": 50,
+ "end_time": "00:00",
+ "start_time": "21:30"
+ },
+ {
+ "cct": 3000,
+ "value": 10,
+ "end_time": "04:30",
+ "start_time": "00:00"
+ },
+ {
+ "cct": 3000,
+ "value": 100,
+ "end_time": "07:10",
+ "start_time": "04:30"
+ }
+ ],
+ "astro_clock": true,
+ "dawn_lux_sensor": false,
+ "dusk_lux_sensor": false,
+ "dawn_lux_sensor_value": 5,
+ "dusk_lux_sensor_value": 5,
+ "dawn_astro_clock_offset": 30,
+ "dusk_astro_clock_offset": 20,
+ "dawn_lux_sensor_time_window": 30,
+ "dusk_lux_sensor_time_window": 30,
+ "dawn_astro_clock_time_window": 60,
+ "dusk_astro_clock_time_window": 60
+ }
+ }
+ }
+ }
+}
+
+const sunCalcExample = {
+ dusk_no_offset: '20:18',
+ dawn_no_offset: '05:19',
+ dusk: '20:18',
+ dusk_hours: 20,
+ dusk_minutes: 18,
+ dawn: '05:19',
+ dawn_hours: 5,
+ dawn_minutes: 19,
+ dusk_time: 1715278688962,
+ dawn_time: 1715224744357,
+ dusk_astro_clock_offset: 0,
+ dawn_astro_clock_offset: 0
+}
+
+
+const dataFromTerminalBroadcast = {
+ address: 4294967295,
+ byte1: 0,
+ byte2: 0,
+ byte3: 0,
+ byte4: 96,
+ name: "Time Schedule settings",
+ recipient: 2,
+ register: 8,
+ rw: 1
+}
diff --git a/flow/slack_connector.js b/flow/slack_connector.js
deleted file mode 100644
index 8c073a6..0000000
--- a/flow/slack_connector.js
+++ /dev/null
@@ -1,124 +0,0 @@
-exports.id = 'slack_connector';
-exports.title = 'Slack_Connector';
-exports.version = '1.0.0';
-exports.group = 'Worksys';
-exports.color = '#888600';
-exports.input = 1;
-exports.output = 1;
-exports.click = false;
-exports.author = 'Jakub Klena';
-exports.icon = 'sign-out';
-exports.options = { slack_channel: "C071KN2Q8SK", api_key: "", bot_name: "Flow DEMO", bot_icon: ":totaljs:" };
-// Slack channel - where to post the messages, can be name like "backend-alerts"
-// Bot Name - Name of the "user" that will post these messages, it should be based on which server it is running on.
-// Bot Icon - We can use any slack icon (even custom ones uploaded by us) as the "user" profile picture
-
-exports.html = `
`;
-
-exports.readme = `Sends any string received on input to Slack Channel.`;
-
-var log4js = require("log4js");
-var path = require('path');
-
-log4js.configure({
- appenders: {
- errLogs: { type: 'file', compress:true, daysToKeep: 2, maxLogSize: 1048576, backups: 1, keepFileExt: true, filename: path.join(__dirname + "/../", 'err.txt') },
- monitorLogs: { type: 'file', compress:true, daysToKeep: 2, maxLogSize: 1048576, backups: 1, keepFileExt: true, filename: path.join(__dirname + "/../", 'monitor.txt') },
- console: { type: 'console' }
- },
- categories: {
- errLogs: { appenders: ['console', 'errLogs'], level: 'error' },
- monitorLogs: { appenders: ['console', 'monitorLogs'], level: 'trace' },
- //another: { appenders: ['console'], level: 'trace' },
- default: { appenders: ['console'], level: 'trace' }
- }
-});
-
-const errLogger = log4js.getLogger("errLogs");
-const logger = log4js.getLogger();
-const monitor = log4js.getLogger("monitorLogs");
-
-exports.install = function(instance) {
- var can = false;
-
- process.on('uncaughtException', function (err) {
- errLogger.error('uncaughtException:', err.message);
- errLogger.error(err.stack);
- instance.error(err);
- });
-
- instance.on('data', function(data) {
- if (!can) return;
-
- let str = String(data.data); // Ensuring data get converted to string
- let message = {
- 'channel': instance.options.slack_channel,
- 'username': instance.options.bot_name,
- 'icon_emoji': instance.options.bot_icon,
- 'text': str
- };
- let headers = {
- 'Content-type': `application/json`,
- 'Authorization': `Bearer ${instance.options.api_key}`
- };
-
- if (F.is4) {
- let opt = {
- 'method': 'post',
- 'url': 'https://slack.com/api/chat.postMessage',
- 'headers': headers,
- 'body': JSON.stringify(message),
- 'type': 'json',
- 'callback': function(err, response) {
- if (response && !err) {
- var msg = { data: response.body, status: response.status, headers: response.headers, host: response.host, cookies: response.cookies };
- instance.send2(msg);
- } else if (err) {
- errLogger.error('Slack post failed - err:', err, '\n - response was:', response);
- instance.error(err, response);
- }
- }
- };
- REQUEST(opt);
-
- } else {
- U.request('https://slack.com/api/chat.postMessage', ['json', 'post'], JSON.stringify(message), function(err, data, status, headers, host) {
- if (response && !err) {
- response.data = { data: data, status: status, headers: headers, host: host };
- instance.send2(response);
- } else if (err) {
- errLogger.error('Slack post failed - err:', err, '\n - response was:', response);
- instance.error(err, response);
- }
- }, null, headers);
- }
- });
-
- instance.reconfigure = function() {
- var options = instance.options;
- can = options.slack_channel && options.bot_name && options.bot_icon && options.api_key ? true : false;
- instance.status(can ? '' : 'Not configured', can ? undefined : 'red');
- };
-
- instance.on('options', instance.reconfigure);
- instance.reconfigure();
-}
diff --git a/flow/slack_filter.js b/flow/slack_filter.js
index a27c9e1..6b2d2a5 100644
--- a/flow/slack_filter.js
+++ b/flow/slack_filter.js
@@ -7,13 +7,10 @@ exports.output = 1;
exports.author = 'Jakub Klena';
exports.icon = 'plug';
exports.version = '1.0.8';
-exports.options = { 'name':'', 'types': '["emergency", "critical", "error", "alert"]', 'message_includes':'["is responding again"]', 'tag_on_include':'[{"user_id":"U072JE5JUQG", "includes":["Electrometer", "Twilight sensor"]}]', 'slack_channel':'' };
+exports.options = { 'name': '', 'types': '["emergency", "critical", "error", "alert"]', 'message_includes': '["is responding again"]', 'tag_on_include': '[{"user_id":"U072JE5JUQG", "includes":["Electrometer", "Twilight sensor"]}]', 'slack_channel': '' };
exports.html = `
-
-
@(Name of this server)
-
@(Slack channel to receive the alerts)
@@ -40,7 +37,7 @@ exports.install = function(instance) {
if (!running) return;
let value = response.data;
if (typeof value !== 'object') return;
-
+
let can = false
var k = Object.keys(value);
var interested = JSON.parse(instance.options.types);
@@ -60,11 +57,11 @@ exports.install = function(instance) {
let icon = ':totaljs:';
let type = value[k[0]][0]['values']['_event']['type'];
let source = value[k[0]][0]['values']['_event']['source']['func'];
- let message = value[k[0]][0]['values']['_event']['message'];
+ let message = value[k[0]][0]['values']['_event']['message']['en'];
let message_data = value[k[0]][0]['values']['_event']['message_data'];
let tag = '';
- switch(type){
+ switch (type) {
case 'debug':
icon = ':beetle:';
break;
@@ -92,15 +89,15 @@ exports.install = function(instance) {
}
// Check if this message includes one of the strings we are watching for
- for (const msg of msg_incl){
- if (message.includes(msg)){
+ for (const msg of msg_incl) {
+ if (message.includes(msg)) {
if (msg == 'is responding again') icon = ':large_green_circle:';
can = true;
break;
}
}
// Check if message is one of the types we are watching for
- if (interested.includes(type)){
+ if (interested.includes(type)) {
can = true;
}
@@ -108,10 +105,10 @@ exports.install = function(instance) {
// Check for each person tags based on what the message includes
- for (const person of tags){
- for (const msg of person.includes){
- if (message.includes(msg)){
- tag += '<@'+person.user_id+'> ';
+ for (const person of tags) {
+ for (const msg of person.includes) {
+ if (message.includes(msg)) {
+ tag += '<@' + person.user_id + '> ';
break; // Break out from this person checks as they are already tagged now
}
}
@@ -119,46 +116,46 @@ exports.install = function(instance) {
// Now that all people are tagged add new line symbol
if (tag != '') tag += '\n';
- let send_data = tag+instance.options.name+' '+type.toUpperCase()+'\n*Source*: '+source+'\n*Message*: '+message;
+ let send_data = tag + instance.options.name + ' ' + type.toUpperCase() + '\n*Source*: ' + source + '\n*Message*: ' + message;
if (message_data) {
- send_data += '\nData: '+message_data;
+ send_data += '\nData: ' + message_data;
}
let ignore_msg = false
- if (message.includes('Configuration of dimming profile to node no')){
- for (let i = 0; i < FLOW["savedSlackMessages"].length; i++){
- if (FLOW["savedSlackMessages"][i].message == message){
+ if (message.includes('Configuration of dimming profile to node no')) {
+ for (let i = 0; i < FLOW["savedSlackMessages"].length; i++) {
+ if (FLOW["savedSlackMessages"][i].message == message) {
ignore_msg = true;
break;
}
}
- if (!ignore_msg){
- FLOW["savedSlackMessages"].push({message, 'dateandtime': Date.now()});
- if (timer === null){
- timer = setTimeout(checkSavedMessages, 60*60000);
+ if (!ignore_msg) {
+ FLOW["savedSlackMessages"].push({ message, 'dateandtime': Date.now() });
+ if (timer === null) {
+ timer = setTimeout(checkSavedMessages, 60 * 60000);
}
}
}
- if (!ignore_msg){
- instance.send2({'msg':send_data,'bot_name':instance.options.name+' '+type.toUpperCase(),'bot_icon':icon,'channel':instance.options.slack_channel});
+ if (!ignore_msg) {
+ instance.send2({ 'msg': send_data, 'bot_name': instance.options.name + ' ' + type.toUpperCase(), 'bot_icon': icon, 'channel': instance.options.slack_channel });
}
});
- function checkSavedMessages(){
+ function checkSavedMessages() {
var d = Date.now();
d = d - 86400000; // older then 24hr
var a = [];
//Remove msgs older then 24hr
- for (let i = 0; i < FLOW["savedSlackMessages"].length; i++){
- if (FLOW["savedSlackMessages"][i].dateandtime > d){
+ for (let i = 0; i < FLOW["savedSlackMessages"].length; i++) {
+ if (FLOW["savedSlackMessages"][i].dateandtime > d) {
a.push(FLOW["savedSlackMessages"][i]);
}
}
FLOW["savedSlackMessages"] = a;
if (FLOW["savedSlackMessages"].length > 0) {
- timer = setTimeout(checkSavedMessages, 60*60000);
+ timer = setTimeout(checkSavedMessages, 60 * 60000);
} else {
timer = null;
}
@@ -166,15 +163,16 @@ exports.install = function(instance) {
instance.reconfigure = function() {
try {
- if (!FLOW["savedSlackMessages"]){
+ if (!FLOW["savedSlackMessages"]) {
FLOW["savedSlackMessages"] = [];
}
+ instance.options.name = FLOW.GLOBALS.settings.rvo_name;
if (instance.options.name) {
instance.status('Running');
running = true;
} else {
- instance.status('Please enter name', 'red');
+ instance.status('Please run options again', 'red');
running = false;
}
} catch (e) {
@@ -183,5 +181,6 @@ exports.install = function(instance) {
};
instance.on('options', instance.reconfigure);
- instance.reconfigure();
-};
\ No newline at end of file
+ setTimeout(instance.reconfigure, 10000);
+
+};
diff --git a/flow/thermometer.js b/flow/thermometer.js
index 1a5714f..fc7074d 100644
--- a/flow/thermometer.js
+++ b/flow/thermometer.js
@@ -1,220 +1,99 @@
-exports.id = 'thermometer';
-exports.title = 'Thermometer';
-exports.group = 'Worksys';
-exports.color = '#5CB36D';
-exports.version = '1.0.3';
-exports.output = ["red", "white", "blue"];
-exports.author = 'Rastislav Kovac';
-exports.icon = 'thermometer-three-quarters';
-
-exports.readme = `# Getting temperature values for RVO. In case of LM, you need device address. In case of unipi, evok sends values, in case thermometer is installed`;
-
-const instanceSendTo = {
- debug: 0,
- tb: 1,
- dido_controller: 2
-}
-
-//read temperature - frequency
-let timeoutMin = 5;//minutes
-
-var path = require('path');
-var log4js = require("log4js");
-
-log4js.configure({
- appenders: {
- errLogs: { type: 'file', filename: path.join(__dirname + "/../", 'err.txt') },
- monitorLogs: { type: 'file', compress:true, daysToKeep: 2, maxLogSize: 1048576, backups: 1, keepFileExt: true, filename: path.join(__dirname + "/../", 'monitor.txt') },
- console: { type: 'console' }
- },
- categories: {
- errLogs: { appenders: ['console', 'errLogs'], level: 'error' },
- monitorLogs: { appenders: ['console', 'monitorLogs'], level: 'trace' },
- //another: { appenders: ['console'], level: 'trace' },
- default: { appenders: ['console'], level: 'trace' }
- }
-});
-
-const errLogger = log4js.getLogger("errLogs");
-const logger = log4js.getLogger();
-const monitor = log4js.getLogger("monitorLogs");
-
-//logger.debug("text")
-//monitor.info('info');
-//errLogger.error("some error");
-
-const { promisifyBuilder, makeMapFromDbResult } = require('./helper/db_helper');
-const dbSettings = TABLE("settings");
-let temperatureAddress = "";
-
-async function loadSettings()
-{
- //todo global FLOW.OMS_edgeName is making problem, so we load it here as well, it should not be
- let responseSettings = await promisifyBuilder(dbSettings.find());
- temperatureAddress = responseSettings[0]["temperature_adress"];
-}
-
-loadSettings();
-
-
-exports.install = function(instance) {
-
- const { exec } = require('child_process');
- const { sendNotification, ERRWEIGHT } = require('./helper/notification_reporter');
-
- let startRead;
- let dataToTb;
- let counter = 0;
-
- let edgeName = "";
-
-
- logger.debug(exports.title, "installed");
-
- instance.on("close", function(){
- clearInterval(startRead);
- })
-
-
- const start = function() {
-
- try {
-
- if(FLOW.OMS_controller_type === "unipi")
- {
- clearInterval(startRead);
- return;
- }
-
- if(temperatureAddress === "") throw "gettemperature: temperatureAddress is not defined";
-
- logger.debug("FLOW.OMS_temperature_adress", FLOW.OMS_temperature_adress);
-
- exec(`owread -C ${temperatureAddress}/temperature`, (error, stdout, stderr) => {
-
- edgeName = FLOW.OMS_edgeName;
-
- if(edgeName !== "")
- {
- if(error)
- {
-
- if(FLOW.OMS_brokerready == undefined)
- {
- logger.debug("gettemparature - FLOW.OMS_brokerready is undefined");
-
- setTimeout(function(){
- start();
- }, 3000);
-
- return;
- }
-
- if(FLOW.OMS_brokerready)
- {
- //sendNotification("start", edgeName, ERRWEIGHT.WARNING, "Thermometer is not responding", {"Error": error}, instanceSendTo.tb, instance, "thermometer");
- sendNotification("start", edgeName, "thermometer_is_not_responding", {}, {"Error": error}, instanceSendTo.tb, instance, "thermometer");
- }
-
- let status = "NOK";
- dataToTb = {
- [edgeName]: [
- {
- "ts": Date.now(),
- "values": {
- "status": status
- }
- }
- ]
- }
-
- monitor.info("Thermometer is not responding", error, FLOW.OMS_brokerready);
-
- // instance.send(instanceSendTo.tb, dataToTb); // poslat stav nok do tb, ak to handluje dido_controller ??
- instance.send(instanceSendTo.dido_controller, {status: "NOK-thermometer"});
- }
- else parseData(stdout);
- }
- else
- {
- monitor.info("gettemperature: edgeName is not defined", FLOW.OMS_edgeName);
-
- setTimeout(function(){
- start();
- }, 3000);
-
- return;
- }
-
-
- //instance.send({"Temp":stdout,"stderr":stderr,"err":error});
- });
-
- }
- catch(err) {
- errLogger.error(exports.title, err);
- }
- }
-
- const parseData = function(data) {
-
- data = parseFloat(data);
-
- logger.debug("gettemperature", data);
-
- if(!isNaN(data)) {
-
- if(counter > 290)
- {
- instance.send(instanceSendTo.debug, "[Get temperature component] - temperature data are comming again from RVO after more than 1 day break");
-
- //sendNotification("parseData", edgeName, ERRWEIGHT.NOTICE, "Thermometer is working again", "", instanceSendTo.tb, instance, "thermometer");
- if(FLOW.OMS_brokerready) sendNotification("parseData", edgeName, "thermometer_is_responding_again", {}, "", instanceSendTo.tb, instance, "thermometer");
- }
-
- logger.debug("gettemperature", data);
- const values = {
- "temperature": Number(data.toFixed(2)),
- "status": "OK"
- }
-
- dataToTb = {
- [edgeName]: [
- {
- "ts": Date.now(),
- "values":values
- }
- ]
- }
-
- instance.send(instanceSendTo.tb, dataToTb);
- instance.send(instanceSendTo.dido_controller, values);
-
- counter = 0;
-
- } else {
-
- counter++;
- monitor.info("gettemperature err", counter, data);
-
- //ked je problem 1 den
- let day = 24 * 60 / timeoutMin;
- if ( counter > day && counter < day + 2 ) {
- //sendNotification("parseData", edgeName, ERRWEIGHT.WARNING, "Thermometer receives invalid data", "", instanceSendTo.tb, instance, "thermometer");
- sendNotification("parseData", edgeName, "thermometer_sends_invalid_data", {}, "", instanceSendTo.tb, instance, "thermometer");
-
- instance.send(instanceSendTo.debug, "[Get temperature component] - no temperature data from RVO for more than 1 day");
- instance.send(instanceSendTo.dido_controller, {status: "NOK-thermometer"});
- }
-
- }
-
- }
-
- setTimeout(function(){
- start();
- }, 15000);
-
- startRead = setInterval(start, timeoutMin * 1000 * 60);
-
-};
\ No newline at end of file
+exports.id = 'thermometer';
+exports.title = 'Thermometer';
+exports.group = 'Worksys';
+exports.color = '#5CB36D';
+exports.input = 1;
+exports.version = '1.0.3';
+exports.output = ["red", "white", "blue"];
+exports.icon = 'thermometer-three-quarters';
+
+exports.readme = `# Getting temperature values for RVO. In case of LM, you need device address. In case of unipi, evok sends values, in case thermometer is installed`;
+
+const { errLogger, logger, monitor } = require('./helper/logger');
+
+const SEND_TO = {
+ debug: 0,
+ tb: 1,
+ dido_controller: 2
+}
+
+//read temperature - frequency
+let timeoutMin = 5;//minutes
+let NUMBER_OF_FAILURES_TO_SEND_ERROR = 13;
+
+exports.install = function(instance) {
+
+ const { exec } = require('child_process');
+ const { sendNotification } = require('./helper/notification_reporter');
+
+ let startRead;
+ let counter = 0;
+ let rvoTbName = "";
+ let temperatureAddress = "";
+
+ logger.debug(exports.title, "installed");
+
+ instance.on("close", function() {
+ clearInterval(startRead);
+ })
+
+
+ const main = function() {
+
+ try {
+
+ if (temperatureAddress === "") throw "Thermometer: temperatureAddress is not defined";
+
+ exec(`owread -C ${temperatureAddress}/temperature`, (error, stdout, stderr) => {
+
+ if (!error) {
+ parseData(stdout)
+ return;
+ }
+
+ counter++;
+ if (counter == NUMBER_OF_FAILURES_TO_SEND_ERROR) {
+ sendNotification("Thermometer_main", rvoTbName, "thermometer_is_not_responding", {}, { "Error": error }, SEND_TO.tb, instance, "thermometer");
+ monitor.info("Thermometer is not responding", error);
+ }
+ instance.send(SEND_TO.dido_controller, { status: "NOK-thermometer" });
+ });
+
+ }
+ catch (err) {
+ errLogger.error(exports.title, err);
+ clearInterval(startRead);
+ }
+ }
+
+ const parseData = function(data) {
+
+ data = parseFloat(data);
+ //logger.debug("Thermometer", data);
+
+ if (isNaN(data)) {
+ errLogger.error("Thermometer sends invalid data");
+ return;
+ }
+
+ if (counter > NUMBER_OF_FAILURES_TO_SEND_ERROR) //1 hour
+ {
+ instance.send(SEND_TO.debug, "Thermometer - temperature data are comming again");
+ sendNotification("Thermometer_parseData", rvoTbName, "thermometer_is_responding_again", {}, "", SEND_TO.tb, instance, "thermometer");
+ }
+
+ const values = {
+ "temperature": Number(data.toFixed(2)),
+ }
+
+ instance.send(SEND_TO.dido_controller, { values: values });
+ counter = 0;
+ }
+
+ instance.on("data", _ => {
+ temperatureAddress = FLOW.GLOBALS.settings.temperature_address;
+ rvoTbName = FLOW.GLOBALS.settings.rvoTbName;
+ startRead = setInterval(main, timeoutMin * 1000 * 60);
+ setTimeout(main, 20000);
+ })
+};
diff --git a/flow/wsmqttpublish.js b/flow/wsmqttpublish.js
index 794fedc..acc3c33 100644
--- a/flow/wsmqttpublish.js
+++ b/flow/wsmqttpublish.js
@@ -4,30 +4,27 @@ exports.group = 'MQTT';
exports.color = '#888600';
exports.version = '1.0.2';
exports.icon = 'sign-out';
-exports.input = 1;
-exports.output = ["red", "white", "blue"];
-exports.author = 'Daniel Segeš';
+exports.input = 2;
+exports.output = 3;
exports.options = { host: 'tb-stage.worksys.io', port: 1883, clientid: "", username: "" };
-exports.npm = ['mqtt'];
-
exports.html = `
-
-
-
Hostname or IP address (if not empty - setting will override db setting)
-
-
-
-
+
+
+
Hostname or IP address (if not empty - setting will override db setting)
+
+
+
+
`;
@@ -41,79 +38,47 @@ Added:
- rpc response
`;
-const instanceSendTo = {
- debug: 0,
- rpcCall: 1,
- services: 2
+const { promisifyBuilder } = require('./helper/db_helper');
+const { errLogger, monitor } = require('./helper/logger');
+const fs = require('fs');
+const mqtt = require('mqtt');
+
+const SEND_TO = {
+ debug: 0,
+ rpcCall: 1,
+ services: 2
}
-const { promisifyBuilder, makeMapFromDbResult } = require('./helper/db_helper.js');
-
//CONFIG
-let useLog4js = true;
let createTelemetryBackup = true;
let saveTelemetryOnError = true;//backup_on_failure overrides this value
//------------------------
-var fs = require('fs');
let rollers;
-if(createTelemetryBackup) rollers = require('streamroller');
+if (createTelemetryBackup) rollers = require('streamroller');
const noSqlFileSizeLimit = 4194304;//use 5MB - 4194304
let insertNoSqlCounter = 0;
let insertBackupNoSqlCounter = 0;
let processingData = false;
-let backup_on_failure = false;//== saveTelemetryOnError - create backup broker send failure
+let backup_on_failure = false;//== saveTelemetryOnError - create backup client send failure
let restore_from_backup = 0; //how many rows process at once?
let restore_backup_wait = 0;//wait seconds
let lastRestoreTime = 0;
-let errLogger;
-let logger;
-let monitor;
+// if there is an error in client connection, flow logs to monitor.txt. Not to log messages every second, we use sendClientError variable
+let sendClientError = true;
-if(useLog4js)
-{
- var path = require('path');
- var log4js = require("log4js");
-
- log4js.configure({
- appenders: {
- errLogs: { type: 'file', filename: path.join(__dirname + "/../", 'err.txt') },
- monitorLogs: { type: 'file', compress:true, daysToKeep: 2, maxLogSize: 1048576, backups: 1, keepFileExt: true, filename: path.join(__dirname + "/../", 'monitor.txt') },
- console: { type: 'console' }
- },
- categories: {
- errLogs: { appenders: ['console', 'errLogs'], level: 'error' },
- monitorLogs: { appenders: ['console', 'monitorLogs'], level: 'trace' },
- //another: { appenders: ['console'], level: 'trace' },
- default: { appenders: ['console'], level: 'trace' }
- }
- });
-
- errLogger = log4js.getLogger("errLogs");
- logger = log4js.getLogger();
- monitor = log4js.getLogger("monitorLogs");
+process.on('uncaughtException', function(err) {
- //USAGE
- //logger.debug("text");
- //monitor.info('info');
- //errLogger.error("some error");
-}
+ errLogger.error('uncaughtException:', err.message)
+ errLogger.error(err.stack);
-process.on('uncaughtException', function (err) {
+ //TODO
+ //send to service
- if(errLogger)
- {
- errLogger.error('uncaughtException:', err.message)
- errLogger.error(err.stack);
- }
-
- //TODO
- //send to service
-
- //process.exit(1);
+ //process.exit(1);
})
const nosql = NOSQL('tbdata');
@@ -122,410 +87,364 @@ const nosqlBackup = NOSQL('/backup/tbdata');
exports.install = function(instance) {
- var broker;
- var opts;
- var brokerready = false;
+ var client;
+ var opts;
+ var clientReady = false;
- instance.on('options', loadSettings);
+ // wsmqtt status for notification purposes on projects.worksys.io database
+ let wsmqttName = null;
+ let sendWsStatusVar = null;
+ let wsmqtt_status = 'disconnected';
- mqtt = require('mqtt');
+ function getWsmqttName(host) {
+ if (host == "tb-demo.worksys.io" || host == '192.168.252.4') return 'wsmqtt_demo';
+ else if (host == "tb-qas01.worksys.io" || host == '192.168.252.5') return 'wsmqtt_qas01';
+ else if (host == "tb-prod01.worksys.io" || host == '192.168.252.1') return 'wsmqtt_prod01';
+ }
- // wsmqtt status for notification purposes on projects.worksys.io database
- let wsmqttName = null;
- let sendWsStatusVar = null;
- let wsmqtt_status = 'disconnected';
-
- function getWsmqttName(host)
- {
- if(host == "tb-demo.worksys.io" || host == '192.168.252.4') return 'wsmqtt_demo';
- else if(host == "tb-qas01.worksys.io" || host == '192.168.252.5') return 'wsmqtt_qas01';
- else if(host == "tb-prod01.worksys.io" || host == '192.168.252.1') return 'wsmqtt_prod01';
- }
-
- function sendWsStatus()
- {
- instance.send(instanceSendTo.services, {[wsmqttName]: wsmqtt_status});
- }
-
- sendWsStatusVar = setInterval(sendWsStatus, 180000);
+ function sendWsStatus() {
+ instance.send(SEND_TO.services, { [wsmqttName]: wsmqtt_status });
+ }
- //set opts according to db settings
- async function loadSettings()
- {
+ function main() {
+ if (!FLOW.dbLoaded) return;
- if(instance.options.host !== "")
- {
- //override settings from database
- var o = instance.options;
- opts = {
- host: o.host,
- port: o.port,
- clientId: o.clientid,
- username: o.username,
- rejectUnauthorized: false,
- resubscribe: false
- };
+ loadSettings();
+ clearInterval(sendWsStatus);
+ sendWsStatusVar = setInterval(sendWsStatus, 180000);
+ }
- wsmqttName = getWsmqttName(o.host);
+ //set opts according to db settings
+ function loadSettings() {
- console.log("wsmqttpublich -> loadSettings from instance.options", instance.options);
- }
- else
- {
-
- const dbSettings = TABLE("settings");
- let responseSettings = await promisifyBuilder(dbSettings.find());
-
- backup_on_failure = responseSettings[0]["backup_on_failure"];
- saveTelemetryOnError = backup_on_failure;
-
- restore_from_backup = responseSettings[0]["restore_from_backup"];
- restore_backup_wait = responseSettings[0]["restore_backup_wait"];
+ if (instance.options.host !== "") {
+ //override settings from database
+ var o = instance.options;
+ opts = {
+ host: o.host,
+ port: o.port,
+ clientId: o.clientid,
+ username: o.username,
+ rejectUnauthorized: false,
+ resubscribe: false
+ };
- let mqtt_host = responseSettings[0]["mqtt_host"];
- let mqtt_clientid = responseSettings[0]["mqtt_clientid"];
- let mqtt_username = responseSettings[0]["mqtt_username"];
- let mqtt_port = responseSettings[0]["mqtt_port"];
+ wsmqttName = getWsmqttName(o.host);
- console.log("wsmqttpublich -> loadSettings from db", responseSettings[0]);
+ console.log("wsmqttpublich -> loadSettings from instance.options", instance.options);
+ }
+ else {
- opts = {
- host: mqtt_host,
- port: mqtt_port,
- keepalive: 10,
- clientId: mqtt_clientid,
- username: mqtt_username,
- rejectUnauthorized: false,
- resubscribe: false
- };
+ const SETTINGS = FLOW.GLOBALS.settings;
+ backup_on_failure = SETTINGS.backup_on_failure;
+ saveTelemetryOnError = backup_on_failure;
- wsmqttName = getWsmqttName(mqtt_host);
- }
+ restore_from_backup = SETTINGS.restore_from_backup;
+ restore_backup_wait = SETTINGS.restore_backup_wait;
- connectToTbServer();
- }
+ let mqtt_host = SETTINGS.mqtt_host;
+ let mqtt_clientid = SETTINGS.mqtt_clientid;
+ let mqtt_username = SETTINGS.mqtt_username;
+ let mqtt_port = SETTINGS.mqtt_port;
- function connectToTbServer()
- {
- var url = "mqtt://" + opts.host + ":" + opts.port;
- console.log("MQTT URL: ", url);
+ opts = {
+ host: mqtt_host,
+ port: mqtt_port,
+ keepalive: 10,
+ clientId: mqtt_clientid,
+ username: mqtt_username,
+ rejectUnauthorized: false,
+ resubscribe: false,
+ };
- broker = mqtt.connect(url, opts);
+ wsmqttName = getWsmqttName(mqtt_host);
+ }
- broker.on('connect', function() {
- instance.status("Connected", "green");
- monitor.info("MQTT broker connected");
+ connectToTbServer();
+ }
- brokerready = true;
- FLOW.OMS_brokerready = brokerready;
- wsmqtt_status = 'connected';
- });
+ function connectToTbServer() {
+ var url = "mqtt://" + opts.host + ":" + opts.port;
+ console.log("MQTT URL: ", url);
- broker.on('reconnect', function() {
- instance.status("Reconnecting", "yellow");
- brokerready = false;
+ client = mqtt.connect(url, opts);
- FLOW.OMS_brokerready = brokerready;
- });
+ client.on('connect', function() {
+ instance.status("Connected", "green");
+ //monitor.info("MQTT client connected");
- broker.on('message', function(topic, message) {
- // message is type of buffer
- message = message.toString();
- if (message[0] === '{') {
- TRY(function() {
+ sendClientError = true;
+ clientReady = true;
+ wsmqtt_status = 'connected';
+ });
- message = JSON.parse(message);
- if (message.hasOwnProperty("device") && message.hasOwnProperty("data") && message.data.hasOwnProperty("id")) {
- broker.publish(topic, `{"device": ${message.device}, "id": ${message.data.id}, "data": {"success": true}}`, {qos:1});
- instance.send(instanceSendTo.rpcCall, {"device": message.device, "id": message.data.id, "RPC response": {"success": true}});
- }
+ client.on('reconnect', function() {
+ instance.status("Reconnecting", "yellow");
+ clientReady = false;
+ });
- }, () => instance.debug('MQTT: Error parsing data', message));
- }
+ client.on('message', function(topic, message) {
+ // message is type of buffer
+ message = message.toString();
+ if (message[0] === '{') {
- instance.send(instanceSendTo.rpcCall, {"topic":topic, "content":message });
- });
+ try {
+ message = JSON.parse(message);
+ if (message.hasOwnProperty("device") && message.hasOwnProperty("data") && message.data.hasOwnProperty("id")) {
+ client.publish(topic, `{"device": ${message.device}, "id": ${message.data.id}, "data": {"success": true}}`, { qos: 1 });
+ instance.send(SEND_TO.rpcCall, { "device": message.device, "id": message.data.id, "RPC response": { "success": true } });
+ }
- broker.on('close', function(err) {
- brokerready = false;
- FLOW.OMS_brokerready = brokerready;
- wsmqtt_status = 'disconnected';
+ } catch (e) {
+ console.log('MQTT: Error parsing data', e);
+ }
+ }
- if (err && err.toString().indexOf('Error')) {
- instance.status("Err: "+err.code, "red");
- instance.send(instanceSendTo.debug, {"message":"Broker CLOSE signal received !", "error":err, "opt":opts });
- } else {
- instance.status("Disconnected", "red");
- instance.send(instanceSendTo.debug, {"message":"Broker CLOSE signal received !", "error":err, "opt":opts });
- }
+ instance.send(SEND_TO.rpcCall, { "topic": topic, "content": message });
+ });
- broker.reconnect();
- });
+ client.on('close', function() {
+ clientReady = false;
+ wsmqtt_status = 'disconnected';
- broker.on('error', function(err) {
- instance.status("Err: "+ err.code, "red");
- instance.send(instanceSendTo.debug, {"message":"Broker ERROR signal received !", "error":err, "opt":opts });
- monitor.info('MQTT broker error', err);
+ instance.status("Disconnected", "red");
+ instance.send(SEND_TO.debug, { "message": "Client CLOSE signal received !" });
+ });
- brokerready = false;
- FLOW.OMS_brokerready = brokerready;
- wsmqtt_status = 'disconnected';
+ client.on('error', function(err) {
+ instance.status("Err: " + err.code, "red");
+ instance.send(SEND_TO.debug, { "message": "Client ERROR signal received !", "error": err, "opt": opts });
+ if (sendClientError) {
+ monitor.info('MQTT client error', err);
+ sendClientError = false;
+ }
+ clientReady = false;
+ wsmqtt_status = 'disconnected';
+ });
- });
+ }
- }
- instance.on('data', function(data) {
+ instance.on("0", _ => {
+ main();
+ })
- if (brokerready)
- {
- //do we have some data in backup file?
- //if any, process data from database
- if(saveTelemetryOnError)
- {
- //read telemetry data and send back to server
- if(!processingData) processDataFromDatabase();
- }
-
- }
- if (brokerready)
- {
- let stringifiedJson = JSON.stringify(data.data);
- broker.publish("v1/gateway/telemetry", stringifiedJson, {qos: 1});
+ instance.on('1', function(data) {
- //backup telemetry
- if(createTelemetryBackup)
- {
- data.data.id = UID();
- nosqlBackup.insert(data.data);
+ if (clientReady) {
+ //do we have some data in backup file? if any, process data from database
+ if (saveTelemetryOnError) {
+ //read telemetry data and send back to server
+ if (!processingData) processDataFromDatabase();
+ }
- insertBackupNoSqlCounter++;
- if(insertBackupNoSqlCounter > 150)
- {
- let options = {compress: true};
- let path = __dirname + "/../databases/backup/tbdata.nosql";
- var stream = new rollers.RollingFileStream(path, noSqlFileSizeLimit, 150, options);
- stream.write("");
- stream.end();
+ let stringifiedJson = JSON.stringify(data.data);
+ client.publish("v1/gateway/telemetry", stringifiedJson, { qos: 1 });
- insertBackupNoSqlCounter = 0;
- }
- }
-
- }
- else
- {
+ //backup telemetry
+ if (createTelemetryBackup) {
+ data.data.id = UID();
+ nosqlBackup.insert(data.data);
- if(logger) logger.debug("Broker unavailable. Data not sent !", data.data);
- instance.send(instanceSendTo.debug, {"message":"Broker unavailable. Data not sent !", "data": data.data });
+ insertBackupNoSqlCounter++;
+ if (insertBackupNoSqlCounter > 150) {
+ let options = { compress: true };
+ let path = __dirname + "/../databases/backup/tbdata.nosql";
+ var stream = new rollers.RollingFileStream(path, noSqlFileSizeLimit, 150, options);
+ stream.write("");
+ stream.end();
- if(saveTelemetryOnError)
- {
- //create new file from tbdata.nosql, if file size exceeds given limit, and clear tbdata.nosql
- makeBackupFromDbFile();
+ insertBackupNoSqlCounter = 0;
+ }
+ }
- //write to tb
- data.data.id = UID();
- nosql.insert(data.data);
- }
+ }
+ else {
+ //logger.debug("Client unavailable. Data not sent !", JSON.stringify(data.data));
+ instance.send(SEND_TO.debug, { "message": "Client unavailable. Data not sent !", "data": data.data });
- }
- });
+ if (saveTelemetryOnError) {
+ //create new file from tbdata.nosql, if file size exceeds given limit, and clear tbdata.nosql
+ makeBackupFromDbFile();
+
+ //write to tb
+ data.data.id = UID();
+ nosql.insert(data.data);
+ }
+ }
+ });
instance.close = function(done) {
- if (brokerready){
- broker.end();
- clearInterval(sendWsStatusVar);
- }
- };
-
-
- function getDbBackupFileCounter(type)
- {
- var files = fs.readdirSync(__dirname + "/../databases");
-
- let counter = 0;
- for(var i = 0; i < files.length; i++)
- {
-
- if(files[i] == "tbdata.nosql") continue;
-
- if(files[i].endsWith(".nosql"))
- {
-
- let pos = files[i].indexOf(".");
- if(pos > -1)
- {
-
- let fileCounter = counter;
- let firstDigit = files[i].slice(0, pos);
-
- fileCounter = parseInt(firstDigit);
- if (isNaN(fileCounter)) fileCounter = 0;
- //console.log("getDbBackupFileCounter digit:", files[i], firstDigit, fileCounter, isNaN(fileCounter), type);
-
- if(type == "max")
- {
- if(fileCounter > counter)
- {
- counter = fileCounter;
- }
- }
- else if(type == "min")
- {
- if(counter == 0) counter = fileCounter;
-
- if(fileCounter < counter)
- {
- counter = fileCounter;
- }
- }
- }
- }
-
- }
-
- if(type == "max") counter++;
-
- return counter;
- }
-
- const makeBackupFromDbFile = async () => {
-
- if(!saveTelemetryOnError) return;
-
- //to avoid large file: tbdata.nosql
-
- //init value is 0!
- if(insertNoSqlCounter > 0)
- {
- --insertNoSqlCounter;
- return;
- }
-
- insertNoSqlCounter = 100;
-
- let source = __dirname + "/../databases/tbdata.nosql";
-
- var stats = fs.statSync(source);
- var fileSizeInBytes = stats.size;
-
- if(fileSizeInBytes > noSqlFileSizeLimit)
- {
-
- let counter = 1;
- counter = getDbBackupFileCounter("max");
-
- let destination = __dirname + "/../databases/" + counter + "." + "tbdata.nosql";
-
- //make backup file
- fs.copyFileSync(source, destination);
- //fs.renameSync(p, p + "." + counter);
-
- //clear tbdata.nosql
- fs.writeFileSync(source, "");
- fs.truncateSync(source, 0);
-
- }
- }
-
- const processDataFromDatabase = async () => {
-
- if(restore_from_backup <= 0)
- {
- return;
- }
-
- //calculate diff
- const now = new Date();
- let currentTime = now.getTime();
- let diff = currentTime - lastRestoreTime;
-
- if( (diff / 1000) < restore_backup_wait)
- {
- //console.log("*********restore_backup_wait", diff, restore_backup_wait);
- return;
- }
-
- processingData = true;
-
- //get filename to process
- let counter = getDbBackupFileCounter("min");
-
- //we have some backup files
- let dataBase = 'tbdata';
-
- var nosql;
- if(counter == 0) dataBase = 'tbdata';
- else dataBase = counter + "." + 'tbdata';
-
- nosql = NOSQL(dataBase);
-
- //select all data - use limit restore_from_backup
- let records = await promisifyBuilder(nosql.find().take(restore_from_backup));
-
- for(let i = 0; i < records.length; i++)
- {
- if (brokerready) {
-
- let item = records[i];
- let id = item.id;
-
- if(id !== undefined)
- {
- //console.log("------------processDataFromDatabase - remove", id, dataBase, i);
-
- try{
-
- let o = JSON.parse(JSON.stringify(item));
- delete o.id;
- let message = JSON.stringify(o);
-
- broker.publish("v1/gateway/telemetry", message, {qos:1});
-
- //remove from database
- await promisifyBuilder(nosql.remove().where("id", id));
-
- } catch (error) {
- //process error
- console.log("processDataFromDatabase", error);
- }
+ if (clientReady) {
+ client.end();
+ clearInterval(sendWsStatusVar);
+ }
+ };
- }
-
- }
- else
- {
- processingData = false;
- return;
- }
- }
+ function getDbBackupFileCounter(type) {
+ var files = fs.readdirSync(__dirname + "/../databases");
- if(records.length > 0)
- {
- //clean backup file
- if(counter > 0) nosql.clean();
- }
+ let counter = 0;
+ for (var i = 0; i < files.length; i++) {
- //no data in db, remove
- if(records.length == 0)
- {
- if(counter > 0) nosql.drop();
- }
+ if (files[i] == "tbdata.nosql") continue;
- const d = new Date();
- lastRestoreTime = d.getTime();
+ if (files[i].endsWith(".nosql")) {
- processingData = false;
+ let pos = files[i].indexOf(".");
+ if (pos > -1) {
- }
+ let fileCounter = counter;
+ let firstDigit = files[i].slice(0, pos);
- loadSettings();
+ fileCounter = parseInt(firstDigit);
+ if (isNaN(fileCounter)) fileCounter = 0;
+ //console.log("getDbBackupFileCounter digit:", files[i], firstDigit, fileCounter, isNaN(fileCounter), type);
- //instance.on('options', instance.reconfigure);
+ if (type == "max") {
+ if (fileCounter > counter) {
+ counter = fileCounter;
+ }
+ }
+ else if (type == "min") {
+ if (counter == 0) counter = fileCounter;
+
+ if (fileCounter < counter) {
+ counter = fileCounter;
+ }
+ }
+ }
+ }
+
+ }
+
+ if (type == "max") counter++;
+
+ return counter;
+ }
+
+ const makeBackupFromDbFile = async () => {
+
+ if (!saveTelemetryOnError) return;
+
+ //to avoid large file: tbdata.nosql
+
+ //init value is 0!
+ if (insertNoSqlCounter > 0) {
+ --insertNoSqlCounter;
+ return;
+ }
+
+ insertNoSqlCounter = 100;
+
+ let source = __dirname + "/../databases/tbdata.nosql";
+
+ var stats = fs.statSync(source);
+ var fileSizeInBytes = stats.size;
+
+ if (fileSizeInBytes > noSqlFileSizeLimit) {
+
+ let counter = 1;
+ counter = getDbBackupFileCounter("max");
+
+ let destination = __dirname + "/../databases/" + counter + "." + "tbdata.nosql";
+
+ //make backup file
+ fs.copyFileSync(source, destination);
+ //fs.renameSync(p, p + "." + counter);
+
+ //clear tbdata.nosql
+ fs.writeFileSync(source, "");
+ fs.truncateSync(source, 0);
+
+ }
+ }
+
+ const processDataFromDatabase = async () => {
+
+ if (restore_from_backup <= 0) return;
+
+ //calculate diff
+ const now = new Date();
+ let currentTime = now.getTime();
+ let diff = currentTime - lastRestoreTime;
+
+ if ((diff / 1000) < restore_backup_wait) {
+ //console.log("*********restore_backup_wait", diff, restore_backup_wait);
+ return;
+ }
+
+ processingData = true;
+
+ //get filename to process
+ let counter = getDbBackupFileCounter("min");
+
+ //we have some backup files
+ let dataBase = 'tbdata';
+
+ var nosql;
+ if (counter == 0) dataBase = 'tbdata';
+ else dataBase = counter + "." + 'tbdata';
+
+ nosql = NOSQL(dataBase);
+
+ //select all data - use limit restore_from_backup
+ let records = await promisifyBuilder(nosql.find().take(restore_from_backup));
+
+ for (let i = 0; i < records.length; i++) {
+ if (clientReady) {
+
+ let item = records[i];
+ let id = item.id;
+
+ if (id !== undefined) {
+ //console.log("------------processDataFromDatabase - remove", id, dataBase, i);
+
+ try {
+
+ let message = JSON.parse(JSON.stringify(item));
+ delete message.id;
+
+ client.publish("v1/gateway/telemetry", JSON.stringify(message), { qos: 1 });
+
+ //remove from database
+ await promisifyBuilder(nosql.remove().where("id", id));
+
+ } catch (error) {
+ //process error
+ console.log("processDataFromDatabase", error);
+ }
+
+ }
+
+ }
+ else {
+ processingData = false;
+ return;
+ }
+ }
+
+ if (records.length > 0) {
+ //clean backup file
+ if (counter > 0) nosql.clean();
+ }
+
+ //no data in db, remove
+ if (records.length == 0) {
+ if (counter > 0) nosql.drop();
+ }
+
+ const d = new Date();
+ lastRestoreTime = d.getTime();
+
+ processingData = false;
+
+ }
+
+ instance.on('options', main);
//instance.reconfigure();
};
diff --git a/package.json b/package.json
index e524d7c..7f7c795 100644
--- a/package.json
+++ b/package.json
@@ -8,6 +8,7 @@
"easy-crc": "0.0.2",
"jsmodbus": "^4.0.6",
"log4js": "^6.3.0",
+ "moment": "^2.30.1",
"mqtt": "^4.2.6",
"nodemailer": "^6.9.7",
"serialport": "^9.2.8",