bioreactor-multiparametric-daq-shield/api/acquisition.js

const {
    collectReadings,
    publishAllOffline,
    readRuntimeConfig
} = require('./acquisition-service');

let stopping = false;

function wait(milliseconds) {
    return new Promise((resolve) => setTimeout(resolve, milliseconds));
}

async function run() {
    console.log('[ACQUISITION] Recolector iniciado.');

    while (!stopping) {
        const startedAt = Date.now();

        try {
            const result = await collectReadings();
            const onlineCount = result.results.filter((item) => item.online).length;
            const expectedCount = result.enabledSensors.length;
            const alarmCount = result.alarmEvents.length;
            console.log(
                `[ACQUISITION] ${result.timestamp} ${result.mode}: ${onlineCount}/${expectedCount} sensores habilitados, ${alarmCount} eventos de alarma.`
            );
        } catch (error) {
            console.error(`[ACQUISITION] ${error.message}`);
            await publishAllOffline(error);
        }

        const config = await readRuntimeConfig();
        const elapsed = Date.now() - startedAt;
        await wait(Math.max(100, config.loggingRateSeconds * 1000 - elapsed));
    }
}

function stop() {
    stopping = true;
}

process.on('SIGINT', stop);
process.on('SIGTERM', stop);

run().catch((error) => {
    console.error('[ACQUISITION] Error fatal:', error);
    process.exitCode = 1;
});