citysys-flowserver/flow/nodesdb_changecheck.js

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);
  })

}