index.js

/**
* AXI Sentry is a application which manages Thargoid Incursions via a database and discord bot which listens and interfaces with EDDN.
* @author   CMDR Mgram, CMDR Airom
*/

//------------------ DEV SWITCHES ------------------
// To enable or disble components for testing purposes
const enableListener = 1; // Set to 0 to disable listener from running
const enableAPI = 1; // Set to 0 to disable API from running
//--------------------------------------------------

require("dotenv").config();
const zlib = require("zlib");
const zmq = require("zeromq");
const api = require('express')();
const path = require('path');
const db = require('./db/index');
const endpoint = require('./api/index');

// Global Variables
const SOURCE_URL = 'tcp://eddn.edcd.io:9500'; //EDDN Data Stream URL
const targetAllegiance = "Thargoid";
const targetGovernment = "$government_Dictatorship;";
let msg;
let watchlist;

// Star System processing logic
async function processSystem(msg) {
  const { StarSystem, timestamp, SystemAllegiance, SystemGovernment } = msg.message;  // Destructuring msg
  let date = new Date();
  let time = date.getTime(timestamp); // Converting msg timestamp to Unix Epoch

  if (SystemAllegiance != undefined && time >= Date.now() - 86400000) { // Checking if report is recent
    id = await db.getSysID(StarSystem);

    if (watchlist.includes(StarSystem)) { // Check in watchlist
      if (SystemAllegiance == targetAllegiance && SystemGovernment == targetGovernment) { // Check if the system is under Incursion
        db.addIncursions(id,time);
        console.log(`Incursion Logged: ${StarSystem}`);
        watchlist = await db.getWatchlist(); // Refresh the watchlist with the new systems to monitor
      } else {
        db.setStatus(StarSystem,0);
        console.log(`${StarSystem} removed from Watchlist because alli = [${SystemAllegiance}], gov = [${SystemGovernment}]`)
        watchlist = await db.getWatchlist();
      }
    } else { // Not in watchlist
      if (SystemAllegiance == targetAllegiance && SystemGovernment == targetGovernment) { // Check if the system is under Incursion
        if (id == 0) { // Check if system is NOT in DB
          db.addSystem(StarSystem).then((res) => {
            db.addIncursions(res,time);
          });

        } else {
          db.setStatus(StarSystem, 1);
          db.addIncursions(id,time);
        }
        console.log(`System Logged: ${StarSystem}`);
        watchlist = await db.getWatchlist();
      }
    }
  }
}

// Sentry Listener
async function run() {
  const sock = new zmq.Subscriber;

  watchlist = await db.getWatchlist();

  sock.connect(SOURCE_URL);
  sock.subscribe('');
  console.log("[✔] EDDN Listener Connected: ", SOURCE_URL);

  // Data Stream Loop
  for await (const [src] of sock) { // For each data packet
    msg = JSON.parse(zlib.inflateSync(src));
    processSystem(msg);
  }
}

// API Code
if (enableAPI == 1) {
  api.listen(process.env.PORT,() => {
    console.log('[✔] Sentry API Operational');  // Upon a successful connection will log to console
  });
} else { console.error(`WARN: API Disabled`)}

api.get('/', function(req, res) {
  res.sendFile(path.join(__dirname, '/dist/index.html'));
});

api.get('/styles.css', function(req, res) {
  res.sendFile(path.join(__dirname, '/dist/styles.css'));
});

api.get('/incursionshistory', async function(req, res) {
    const { rows } = await db.query(
      `SELECT incursions.inc_id,systems.system_id,systems.name,incursions.time
      FROM incursions
      INNER JOIN systems
      ON incursions.system_id=systems.system_id;`
    );
    res.json(endpoint.Response(rows))
  },
);

api.get('/incursions', async function(req, res) {
    const { rows } = await db.query(`SELECT * FROM systems WHERE status = '1'`);
    res.json(endpoint.Response(rows))
  },
);

api.get('/systems', async function(req, res) {
    const { rows } = await db.query(`SELECT * FROM systems`);
    res.json(endpoint.Response(rows))
  },
);

api.get('/presence', async function(req, res) {
    const { rows } = await db.query(`SELECT systems.name,presence.presence_lvl,presence.time
    FROM presence
    INNER JOIN systems
    ON presence.system_id=systems.system_id;`);
    res.json(endpoint.Response(rows));
  },
);

// Switch Statements
if (enableListener == 1) { run(); } else { console.error(`WARN: Sentry Disabled`)}