main.js

import dotenv from "dotenv";
import * as fs from "node:fs";

import PreComServlet from "./precom/servlet.js";
import P2000RSSServlet from "./p2000rss/servlet.js";
import TelegramServlet from "./telegram/bot.js";

dotenv.config();

let capcodes = JSON.parse(fs.readFileSync('capcodes.json', 'utf-8'));
let activePollers = process.env.POLL_METHODS.split(',');

TelegramServlet.initialize();

/** PreCom webhook **/
if (activePollers.indexOf('precom-hook') !== -1) {
    PreComServlet.initialize(
        (capcode, message) => {
            TelegramServlet.broadcastLocation(`${capcode}: ${message}`, capcodes[capcode]['coordinates']);
        },
        (sender, message) => {
            let handled = false;

            /**
             * Check if we can get a capcode from the message, e.g.:
             * Proefalarm, opkomen UGS Amsterdam -> UGS Amsterdam
             * 0723141 - Code 30 -> Lichtkrant 0723141
             */
            capcodes.forEach((item, capcode) => {
                if (
                    message.toLowerCase().includes(item.name.toLowerCase()) ||
                    message.includes(capcode)
                ) {
                    TelegramServlet.broadcastLocation(`${capcode}: ${message}`, capcodes[capcode]['coordinates']);

                    handled = true;
                }
            });

            if (handled) {
                return;
            }

            // Nope, just send it out and hope for the best
            TelegramServlet.broadcastTextMessage(message);
        },
        (message) => {
            TelegramServlet.broadcastTextMessage(message);
        }
    );
}

/** P2000 RSS Feed **/
if (activePollers.indexOf('p2000-rss') !== -1) {
    P2000RSSServlet.initialize(
        Object.keys(capcodes),
        (capcode, message) => {
            TelegramServlet.broadcastLocation(`${capcode}: ${message}`, capcodes[capcode]['coordinates']);
        }
    )
}