index.js

// Require Third-Party Dependencies
import FastPriorityQueue from "fastpriorityqueue";
import Addon from "@slimio/addon";

// Require Internal Dependencies
import { buildMICRow } from "./src/utils.js";

// CONSTANTS & GLOBALS
const AGGREGATE_INTERVAL_MS = 1000;
const Cards = new Map();

const Aggregator = new Addon("aggregator").lockOn("events");

/**
 * @function checkMic
 * @param {object} mic
 * @param {!number} micId
 */
async function checkMic(mic, micId) {
    try {
        const options = { withSubscriber: true };
        const stats = await Aggregator.sendOne("events.get_mic_stats", [micId, options]);

        // REVIEW: declare mic.sample_interval as milliseconds by default ?
        const maxSampleMilliseconds = (mic.sample_interval * 1000) * 720;
        const maxSampleTimestamp = Date.now() - maxSampleMilliseconds;

        for (const { level, count, timestamp } of stats) {
            console.log(`mic(${micId}) have ${count} metrics on level ${level}`);
            if (timestamp > maxSampleTimestamp) {
                continue;
            }


            const deleteOptions = { since: maxSampleTimestamp, level };
            await Aggregator.sendOne("events.delete_mic_rows", [micId, deleteOptions]);
        }
    }
    catch (error) {
        console.error(error);
    }
}

/**
 * @function aggregateInterval
 */
async function aggregateInterval() {
    for (const [id, mic] of Cards.entries()) {
        if (mic.timer.walk() && id > 2 && id < 4) {
            checkMic(mic, id);
        }
    }
}
Aggregator.registerInterval(aggregateInterval, AGGREGATE_INTERVAL_MS);

Aggregator.on("awake", async() => {
    const mics = await Aggregator.sendOne("events.get_mic");
    Aggregator.logger.writeLine(`fetch ${mics.length} metric identity cards`);

    const filteredMics = mics.filter((mic) => !Cards.has(mic.id));
    for (const mic of filteredMics) {
        Cards.set(mic.id, buildMICRow(mic));
    }

    await Aggregator.ready();
});

Aggregator.of(Addon.Subjects.micCreate).filter((row) => !Cards.has(row[1])).subscribe(async(row) => {
    try {
        const [, id] = row;
        const mic = await Aggregator.sendOne("events.get_mic", [id]);

        Cards.set(id, buildMICRow(mic));
    }
    catch (error) {
        Aggregator.logger.writeLine(error.message);
    }
}, console.error);

export default Aggregator;