exports.readme = `# send all data to projects.worksys.io, required to monitor status of controller(unipi)`;
-exports.install = function(instance) {
+const fs = require('fs');
+var path = require('path');
- let id;
+exports.install = async function(instance) {
+
let allValues = {};
let sendAllValuesInterval;
- let configured = false;
let now = new Date();
console.log(exports.title, "INSTALLED", now.toLocaleString("sk-SK"));
@@ -33,49 +37,69 @@ exports.install = 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() {
- if (!configured) return;
+
+ function sendValues()
+ {
+ const id = FLOW.OMS_projects_id;
- if (Object.keys(allValues).length > 0) {
- let dataToSend = { ...allValues };
- dataToSend.id = id;
- dataToSend.ipAddresses = ipAddresses;
+ 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', ' ');
- instance.send(0, dataToSend);
+ //console.log(exports.title, "------------>sendValues", dataToSend);
+
+ instance.send(0, dataToSend);
+
+ allValues = {};
+ }
+ else
+ {
+ console.log(exports.title, "unable to send data, id is undefined");
+ }
- allValues = {};
}
}
-
+
instance.on("close", () => {
clearInterval(sendAllValuesInterval);
})
- 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("data", (flowdata) => {
+
+ allValues = { ...allValues, ...flowdata.data};
- 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 d6d9dad..f34ec9a 100644
--- a/flow/modbus_reader.js
+++ b/flow/modbus_reader.js
@@ -3,7 +3,6 @@ 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';
@@ -32,17 +31,13 @@ const SEND_TO = {
const numberOfNotResponding = {};
let tbName = null;
let mainSocket;
-//number of phases inRVO
-let phases;
-//phases where voltage is 0 (set)
-let noVoltage;
-let energyToSwitchLamps;
+
exports.install = function(instance) {
class SocketWithClients {
- constructor() {
+ constructor () {
this.stream = null;
this.socket = null;
this.clients = {};
@@ -56,51 +51,42 @@ 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;
- if (this.socket) {
- this.socket.removeAllListeners();
- this.socket = null;
- }
-
this.socket = new SerialPort("/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('Modbus_reader: Socket connection error', e); //'ECONNREFUSED' or 'ECONNRESET' ??
+ console.log('socket connection error', e);
+ if(e.code == 'ECONNREFUSED' || e.code == 'ECONNRESET') {
+ console.log(exports.title + ' Waiting 10 seconds before trying to connect again');
+ setTimeout(obj.startSocket, 10000);
+ }
});
this.socket.on('close', function() {
- console.log('Modbus_reader: Socket connection closed - Waiting 10 seconds before connecting again');
+ console.log('Socket connection closed ' + exports.title + ' Waiting 10 seconds before trying to connect again');
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
@@ -113,12 +99,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 we just start to loop devices from the beginning, or there is just 1 device in config, we wait whole timeoutInterval
- if (this.indexInDeviceConfig == 0 || deviceConfig.length === 1) setTimeout(this.readRegisters, this.timeoutInterval);
+ if(this.indexInDeviceConfig == 0) setTimeout(this.readRegisters, this.timeoutInterval);
else setTimeout(this.readRegisters, DELAY_BETWEEN_DEVICES);
}
@@ -132,18 +117,21 @@ 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);
@@ -156,21 +144,25 @@ exports.install = function(instance) {
obj.index++;
obj.readAnotherRegister();
- }).catch(function() {
-
- //console.log("errors pri citani modbus registra", register, obj.indexInDeviceConfig, tbName, tbAttribute);
+ }).catch (function () {
+ 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);
@@ -178,16 +170,17 @@ 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++;
@@ -197,7 +190,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();
}
@@ -206,16 +199,18 @@ 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;
}
@@ -228,45 +223,54 @@ 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;
}
}
@@ -275,72 +279,70 @@ 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 (this.phases.includes(singleValue)) {
+ if (["Phase_1_voltage", "Phase_2_voltage", "Phase_3_voltage"].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) {
- noVoltage.add(phase);
- sendNotification("modbus_reader: checkNullVoltage", tbName, "no_voltage_on_phase", { phase: phase }, "", SEND_TO.tb, instance, "voltage" + phase);
+ 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 );
// console.log('no voltage')
}
- else {
- noVoltage.delete(phase);
+ else
+ {
+ FLOW.OMS_no_voltage.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 numberOfNodes*15. 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 500. 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 > energyToSwitchLamps && this.onNotificationSent == false) {
+ if(actualTotalPower > 600 && 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 <= energyToSwitchLamps && this.offNotificationSent == false) {
+ }
+ else if(actualTotalPower <= 600 && 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;
+ 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;
- energyToSwitchLamps = FLOW.GLOBALS.settings.energy_to_switch_lamps / 2.5; //half value is enought to show if lamps are turned on or off
- if (deviceConfig.length) mainSocket = new SocketWithClients();
- else console.log("Modbus_reader: no modbus device in configuration");
+ setTimeout(() => {
+
+ mainSocket = new SocketWithClients();
+ tbName = FLOW.OMS_rvo_tbname;
// this notification is to show, that flow (unipi) has been restarted
sendNotification("modbus_reader", tbName, "flow_restart", {}, "", SEND_TO.slack, instance);
- }
- instance.on("0", function(_) {
- main();
- })
+ }, 25000);
}
diff --git a/flow/nodesdb_changecheck.js b/flow/nodesdb_changecheck.js
deleted file mode 100644
index 195623f..0000000
--- a/flow/nodesdb_changecheck.js
+++ /dev/null
@@ -1,70 +0,0 @@
-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
new file mode 100644
index 0000000..520c997
--- /dev/null
+++ b/flow/notifikacie.csv
@@ -0,0 +1,31 @@
+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
deleted file mode 100644
index 1e23ff7..0000000
--- a/flow/show_dbdata.js
+++ /dev/null
@@ -1,243 +0,0 @@
-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
new file mode 100644
index 0000000..8c073a6
--- /dev/null
+++ b/flow/slack_connector.js
@@ -0,0 +1,124 @@
+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 6618523..a27c9e1 100644
--- a/flow/slack_filter.js
+++ b/flow/slack_filter.js
@@ -2,15 +2,18 @@ exports.id = 'slack_filter';
exports.title = 'Slack Filter';
exports.group = 'Citysys';
exports.color = '#30E193';
-exports.input = 2;
+exports.input = 1;
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)
@@ -33,11 +36,11 @@ exports.install = function(instance) {
instance["savedSlackMessages"] = [];
var timer = null;
- instance.on('0', function(response) {
+ instance.on('data', function(response) {
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);
@@ -57,11 +60,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']['en'];
+ let message = value[k[0]][0]['values']['_event']['message'];
let message_data = value[k[0]][0]['values']['_event']['message_data'];
let tag = '';
- switch (type) {
+ switch(type){
case 'debug':
icon = ':beetle:';
break;
@@ -89,15 +92,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;
}
@@ -105,10 +108,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
}
}
@@ -116,46 +119,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;
}
@@ -163,16 +166,15 @@ 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 run options again', 'red');
+ instance.status('Please enter name', 'red');
running = false;
}
} catch (e) {
@@ -181,8 +183,5 @@ exports.install = function(instance) {
};
instance.on('options', instance.reconfigure);
-
- instance.on("1", _ => {
- instance.reconfigure();
- })
-};
+ instance.reconfigure();
+};
\ No newline at end of file
diff --git a/flow/thermometer.js b/flow/thermometer.js
index fc7074d..1a5714f 100644
--- a/flow/thermometer.js
+++ b/flow/thermometer.js
@@ -1,99 +1,220 @@
-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);
- })
-};
+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
diff --git a/databases/tbdatacloud.nosql b/flow/variables.txt
similarity index 100%
rename from databases/tbdatacloud.nosql
rename to flow/variables.txt
diff --git a/flow/wsmqttpublish.js b/flow/wsmqttpublish.js
index 0eba804..794fedc 100644
--- a/flow/wsmqttpublish.js
+++ b/flow/wsmqttpublish.js
@@ -4,27 +4,30 @@ exports.group = 'MQTT';
exports.color = '#888600';
exports.version = '1.0.2';
exports.icon = 'sign-out';
-exports.input = 2;
-exports.output = 3;
+exports.input = 1;
+exports.output = ["red", "white", "blue"];
+exports.author = 'Daniel Segeš';
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)
+
+
+
+
`;
@@ -38,46 +41,78 @@ Added:
- rpc response
`;
-const { promisifyBuilder } = require('./helper/db_helper');
-const { errLogger, monitor } = require('./helper/logger');
-const fs = require('fs');
-const mqtt = require('mqtt');
-
-const SEND_TO = {
+const instanceSendTo = {
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 client send failure
+let backup_on_failure = false;//== saveTelemetryOnError - create backup broker send failure
let restore_from_backup = 0; //how many rows process at once?
let restore_backup_wait = 0;//wait seconds
let lastRestoreTime = 0;
-// 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;
+let errLogger;
+let logger;
+let monitor;
-process.on('uncaughtException', function(err) {
+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");
- errLogger.error('uncaughtException:', err.message)
- errLogger.error(err.stack);
+ //USAGE
+ //logger.debug("text");
+ //monitor.info('info');
+ //errLogger.error("some error");
+}
+
+process.on('uncaughtException', function (err) {
+
+ if(errLogger)
+ {
+ errLogger.error('uncaughtException:', err.message)
+ errLogger.error(err.stack);
+ }
//TODO
//send to service
-
+
//process.exit(1);
})
@@ -87,38 +122,40 @@ const nosqlBackup = NOSQL('/backup/tbdata');
exports.install = function(instance) {
- var client;
+ var broker;
var opts;
- var clientReady = false;
+ var brokerready = false;
+
+ instance.on('options', loadSettings);
+
+ mqtt = require('mqtt');
// 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 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(SEND_TO.services, { [wsmqttName]: wsmqtt_status });
+ function sendWsStatus()
+ {
+ instance.send(instanceSendTo.services, {[wsmqttName]: wsmqtt_status});
}
+ sendWsStatusVar = setInterval(sendWsStatus, 180000);
- function main() {
- if (!FLOW.dbLoaded) return;
-
- loadSettings();
- clearInterval(sendWsStatus);
- sendWsStatusVar = setInterval(sendWsStatus, 180000);
- }
//set opts according to db settings
- function loadSettings() {
+ async function loadSettings()
+ {
- if (instance.options.host !== "") {
+ if(instance.options.host !== "")
+ {
//override settings from database
var o = instance.options;
opts = {
@@ -134,19 +171,24 @@ exports.install = function(instance) {
console.log("wsmqttpublich -> loadSettings from instance.options", instance.options);
}
- else {
-
- const SETTINGS = FLOW.GLOBALS.settings;
- backup_on_failure = SETTINGS.backup_on_failure;
+ 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"];
- restore_from_backup = SETTINGS.restore_from_backup;
- restore_backup_wait = SETTINGS.restore_backup_wait;
+ 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"];
- let mqtt_host = SETTINGS.mqtt_host;
- let mqtt_clientid = SETTINGS.mqtt_clientid;
- let mqtt_username = SETTINGS.mqtt_username;
- let mqtt_port = SETTINGS.mqtt_port;
+ console.log("wsmqttpublich -> loadSettings from db", responseSettings[0]);
opts = {
host: mqtt_host,
@@ -164,106 +206,123 @@ exports.install = function(instance) {
connectToTbServer();
}
- function connectToTbServer() {
+ function connectToTbServer()
+ {
var url = "mqtt://" + opts.host + ":" + opts.port;
console.log("MQTT URL: ", url);
- client = mqtt.connect(url, opts);
+ broker = mqtt.connect(url, opts);
- client.on('connect', function() {
+ broker.on('connect', function() {
instance.status("Connected", "green");
- //monitor.info("MQTT client connected");
+ monitor.info("MQTT broker connected");
- sendClientError = true;
- clientReady = true;
+ brokerready = true;
+ FLOW.OMS_brokerready = brokerready;
wsmqtt_status = 'connected';
});
- client.on('reconnect', function() {
+ broker.on('reconnect', function() {
instance.status("Reconnecting", "yellow");
- clientReady = false;
+ brokerready = false;
+
+ FLOW.OMS_brokerready = brokerready;
});
- client.on('message', function(topic, message) {
+ broker.on('message', function(topic, message) {
// message is type of buffer
message = message.toString();
if (message[0] === '{') {
TRY(function() {
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 } });
+ 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}});
}
}, () => instance.debug('MQTT: Error parsing data', message));
}
- instance.send(SEND_TO.rpcCall, { "topic": topic, "content": message });
+ instance.send(instanceSendTo.rpcCall, {"topic":topic, "content":message });
});
- client.on('close', function() {
- clientReady = false;
+ broker.on('close', function(err) {
+ brokerready = false;
+ FLOW.OMS_brokerready = brokerready;
wsmqtt_status = 'disconnected';
- instance.status("Disconnected", "red");
- instance.send(SEND_TO.debug, { "message": "Client CLOSE signal received !" });
- });
-
- 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;
+ 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 });
}
- clientReady = false;
+
+ broker.reconnect();
+ });
+
+ 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);
+
+ brokerready = false;
+ FLOW.OMS_brokerready = brokerready;
wsmqtt_status = 'disconnected';
+
});
}
+ instance.on('data', function(data) {
- instance.on("0", _ => {
- main();
- })
-
-
- instance.on('1', function(data) {
-
- if (clientReady) {
- //do we have some data in backup file? if any, process data from database
- if (saveTelemetryOnError) {
+ 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(!processingData) processDataFromDatabase();
}
+
+ }
+ if (brokerready)
+ {
let stringifiedJson = JSON.stringify(data.data);
- client.publish("v1/gateway/telemetry", stringifiedJson, { qos: 1 });
+ broker.publish("v1/gateway/telemetry", stringifiedJson, {qos: 1});
//backup telemetry
- if (createTelemetryBackup) {
+ if(createTelemetryBackup)
+ {
data.data.id = UID();
nosqlBackup.insert(data.data);
insertBackupNoSqlCounter++;
- if (insertBackupNoSqlCounter > 150) {
- let options = { compress: true };
+ 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();
insertBackupNoSqlCounter = 0;
- }
+ }
}
-
+
}
- 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 });
+ else
+ {
- if (saveTelemetryOnError) {
+ if(logger) logger.debug("Broker unavailable. Data not sent !", data.data);
+ instance.send(instanceSendTo.debug, {"message":"Broker 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();
@@ -271,68 +330,78 @@ exports.install = function(instance) {
data.data.id = UID();
nosql.insert(data.data);
}
+
}
});
- instance.close = function(done) {
- if (clientReady) {
- client.end();
+ instance.close = function(done) {
+ if (brokerready){
+ broker.end();
clearInterval(sendWsStatusVar);
}
};
+
-
- function getDbBackupFileCounter(type) {
+ function getDbBackupFileCounter(type)
+ {
var files = fs.readdirSync(__dirname + "/../databases");
let counter = 0;
- for (var i = 0; i < files.length; i++) {
+ for(var i = 0; i < files.length; i++)
+ {
- if (files[i] == "tbdata.nosql") continue;
+ if(files[i] == "tbdata.nosql") continue;
- if (files[i].endsWith(".nosql")) {
+ if(files[i].endsWith(".nosql"))
+ {
let pos = files[i].indexOf(".");
- if (pos > -1) {
+ if(pos > -1)
+ {
let fileCounter = counter;
let firstDigit = files[i].slice(0, pos);
fileCounter = parseInt(firstDigit);
- if (isNaN(fileCounter)) fileCounter = 0;
+ if (isNaN(fileCounter)) fileCounter = 0;
//console.log("getDbBackupFileCounter digit:", files[i], firstDigit, fileCounter, isNaN(fileCounter), type);
-
- if (type == "max") {
- if (fileCounter > counter) {
+
+ if(type == "max")
+ {
+ if(fileCounter > counter)
+ {
counter = fileCounter;
}
}
- else if (type == "min") {
- if (counter == 0) counter = fileCounter;
+ else if(type == "min")
+ {
+ if(counter == 0) counter = fileCounter;
- if (fileCounter < counter) {
+ if(fileCounter < counter)
+ {
counter = fileCounter;
}
}
}
}
-
+
}
-
- if (type == "max") counter++;
+
+ if(type == "max") counter++;
return counter;
}
const makeBackupFromDbFile = async () => {
- if (!saveTelemetryOnError) return;
+ if(!saveTelemetryOnError) return;
//to avoid large file: tbdata.nosql
//init value is 0!
- if (insertNoSqlCounter > 0) {
+ if(insertNoSqlCounter > 0)
+ {
--insertNoSqlCounter;
return;
}
@@ -344,7 +413,8 @@ exports.install = function(instance) {
var stats = fs.statSync(source);
var fileSizeInBytes = stats.size;
- if (fileSizeInBytes > noSqlFileSizeLimit) {
+ if(fileSizeInBytes > noSqlFileSizeLimit)
+ {
let counter = 1;
counter = getDbBackupFileCounter("max");
@@ -358,20 +428,24 @@ exports.install = function(instance) {
//clear tbdata.nosql
fs.writeFileSync(source, "");
fs.truncateSync(source, 0);
-
+
}
}
const processDataFromDatabase = async () => {
-
- if (restore_from_backup <= 0) return;
+
+ 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) {
+ if( (diff / 1000) < restore_backup_wait)
+ {
//console.log("*********restore_backup_wait", diff, restore_backup_wait);
return;
}
@@ -385,30 +459,33 @@ exports.install = function(instance) {
let dataBase = 'tbdata';
var nosql;
- if (counter == 0) dataBase = 'tbdata';
+ 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) {
+
+ for(let i = 0; i < records.length; i++)
+ {
+ if (brokerready) {
let item = records[i];
let id = item.id;
- if (id !== undefined) {
+ 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 });
+ 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));
@@ -417,23 +494,27 @@ exports.install = function(instance) {
console.log("processDataFromDatabase", error);
}
- }
+ }
+
}
- else {
+ else
+ {
processingData = false;
return;
}
}
- if (records.length > 0) {
+ if(records.length > 0)
+ {
//clean backup file
- if (counter > 0) nosql.clean();
+ if(counter > 0) nosql.clean();
}
//no data in db, remove
- if (records.length == 0) {
- if (counter > 0) nosql.drop();
+ if(records.length == 0)
+ {
+ if(counter > 0) nosql.drop();
}
const d = new Date();
@@ -443,6 +524,8 @@ exports.install = function(instance) {
}
- instance.on('options', main);
- //instance.reconfigure();
+ loadSettings();
+
+ //instance.on('options', instance.reconfigure);
+ //instance.reconfigure();
};
diff --git a/package.json b/package.json
index 7f7c795..e524d7c 100644
--- a/package.json
+++ b/package.json
@@ -8,7 +8,6 @@
"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",
diff --git a/readme.md b/readme.md
index 1e8fac4..f2e23d2 100644
--- a/readme.md
+++ b/readme.md
@@ -1,18 +1,15 @@
-# Total.js version 3 - Flow
+[](https://www.totaljs.com/support/)
+- [__Live chat with professional support__](https://messenger.totaljs.com)
+- [__HelpDesk with professional support__](https://helpdesk.totaljs.com)
+- [Documentation](https://docs.totaljs.com)
+- [Wiki](https://wiki.totaljs.com)
+
+# Total.js: Empty Project - Flow
+
+- download example
- open terminal / command-line
- open app directory
-- run `$ npm install`
-- run `$ node index.js`
-- open browser `http://0.0.0.0:12345`
-
-# Settings configuration:
-- set in databases directory
-- chosen options:
- - restore_from_backup => number of records, that are restored from db after thingsboard reconnected
- - restore_backup_wait => number of seconds between bulk of records are sent
- - node_status_nok_time => number of hours after which the node sends a message to thingsboard that its status is NOK
- - phases => number of phases in RVO
- - cloud_topic => we need to set cloud_topic, if we want to send telemetry to RADO's thingsboard
- - daily_report => if we want to create and send daily reports by email, set this to 1
- - send_changed_node_numbers => if we are sending daily reports, we need to keep a track of changed node numbers. They are processed on the cloud. Set this to 1 if yes.
+- install latest version of Total.js from NPM `$ npm install total.js`
+- run `$ node debug.js`
+- open browser `http://127.0.0.1:8000`
\ No newline at end of file