index.js

var express = require("express");
var bodyParser = require("body-parser");
var pm2 = require('pm2');
var moment = require("moment");
var { Limits } = require("./models/limits");
var { setLimits } = require("./utility/setLimits.js");
var schedule = require('node-schedule');
var fs = require('fs');

var cors = require("cors");
var app = express();
app.use(cors());

app.get("/", function (req, res) {
  res.send("I'm listening");
});

app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());

app.get("/list", function (req, res) {
  pm2.list(function (err, processDescriptionList) {
    if (err) {
      res.status(500);
    }
    else {

      console.log("list retrived");
      var jsonarr = processDescriptionList;
      var json = {};
      var stat = [];
      var date = moment();
      var dat = date.format('MMM Do, YYYY');
      var time = date.format('HH:mm:ss');
      jsonarr.forEach(proc => {
        var tmpJson = {};
        tmpJson.pid = proc.pid;
        tmpJson.name = proc.name;
        tmpJson.cpu = proc.monit.cpu;
        tmpJson.memory = proc.monit.memory;
        tmpJson.date = dat;
        tmpJson.time = time;
        tmpJson.pm_id = proc.pm_id;
        // TODO: check if details like uptime, createdAt, version, number of instances, etc are required
        stat.push(tmpJson);
      });
      json.stat = stat;
      res.json(json);
    }
  });
});

app.post("/setLimits", async function (req, res) {
  var data = req.body;
  console.log(data);
  await setLimits(data)
    .then(ob => {
      //console.log(ob);
      res.status(200).send();
    })
    .catch(err => {
      res.status(400).json({ err: err.message });
    });
});

app.get("/limits", function (req, res) {
  Limits.find({}, function (err, docs) {
    res.send(docs);
  });
});


app.get("/checkViolations", async function (req, res) {
  var violations = [];
  await pm2.list(function (err, processDescriptionList) {
    Limits.find({}, function (err, docs) {
      processDescriptionList.forEach(proc => {
        var tmpJson = {};
        tmpJson.pid = proc.pid;
        tmpJson.name = proc.name;
        tmpJson.cpu = proc.monit.cpu;
        tmpJson.memory = proc.monit.memory;
        tmpJson.pm_id = proc.pm_id;
        docs.forEach(lim => {
          var param = lim.parameter;
          if (lim.pm_id === tmpJson.pm_id && tmpJson[param] > lim.threshold) {
            violations.push(tmpJson);
            //console.log(tmpJson);
          }
        });
      });
      res.send(violations);
    });
  });
});


app.get("/specs", async function (req, res) {
  si.getStaticData()
    .then(data => {
      res.send(data);
    })
    .catch(error => console.error(error));
});

app.get("/data", function (req, res) {
  //var ct = req.params.count;
  var arr = fs.readFileSync('log.txt').toString().split("\n");
  arr.pop();
  var array = [];
  arr.forEach(line => {
    array.push(JSON.parse(line.replace(/\\/g, "")));
    //array.push(line.replace(/\\/g, '\\'));
  });
  var size = Math.min(array.length, 20);
  var data = array.slice(Math.max(array.length - size, 0));
  var json = {};
  json.data = data;
  res.json(json);
});

const PORT = 8088;
const HOST = "0.0.0.0";

app.listen(PORT, () => {
  console.log(`Server Up and Running on 8088`);
});

var logStream = fs.createWriteStream('log.txt', { 'flags': 'a' });

var j1 = schedule.scheduleJob('5 * * * * *', function () {
  pm2.list(function (err, processDescriptionList) {
    if (err) {
      console.log(err);
    }
    else {
      var jsonarr = processDescriptionList;
      var json = {};
      var stat = [];
      var date = moment();
      var dat = date.format('MMM Do, YYYY');
      var time = date.format('HH:mm:ss');
      jsonarr.forEach(proc => {
        var tmpJson = {};
        tmpJson.pid = proc.pid;
        tmpJson.name = proc.name;
        tmpJson.cpu = proc.monit.cpu;
        tmpJson.memory = proc.monit.memory;
        tmpJson.date = dat;
        tmpJson.time = time;
        tmpJson.pm_id = proc.pm_id;
        // TODO: check if details like uptime, createdAt, version, number of instances, etc are required
        stat.push(tmpJson);
      });
      json.stat = stat;
      // fs.appendFile('output.txt', JSON.stringify(json), function (err) {
      //   if (err) { /* Do whatever is appropriate if append fails*/
      //     console.log(err);
      //   }
      // });
      logStream.write(JSON.stringify(json) + '\n');
    }
  });
});

var errStream = fs.createWriteStream('violations.txt', { 'flags': 'a' });

var j2 = schedule.scheduleJob('10 * * * * *', async function () {
  var violations = [];
  await pm2.list(function (err, processDescriptionList) {
    Limits.find({}, function (err, docs) {
      processDescriptionList.forEach(proc => {
        var tmpJson = {};
        tmpJson.pid = proc.pid;
        tmpJson.name = proc.name;
        tmpJson.cpu = proc.monit.cpu;
        tmpJson.memory = proc.monit.memory;
        tmpJson.pm_id = proc.pm_id;
        docs.forEach(lim => {
          var param = lim.parameter;
          if (lim.pm_id === tmpJson.pm_id && tmpJson[param] > lim.threshold) {
            violations.push(tmpJson);
            //console.log(tmpJson);
          }
        });
      });
      if (violations.length > 0) {
        errStream.write(JSON.stringify(violations) + '\n');
        //TODO: send alert
      }
    });
  });
});