ffffng/server/jobs/NodeInformationRetrievalJob.ts

import * as MonitoringService from "../services/monitoringService";
import {jobResultOkay, jobResultWarning} from "./scheduler";

export default {
    name: 'NodeInformationRetrievalJob',
    description: 'Fetches the nodes.json and calculates and stores the monitoring / online status for registered nodes.',

    async run () {
        const result = await MonitoringService.retrieveNodeInformation();
        if (result.failedParsingNodesCount > 0) {
            return jobResultWarning(
                `Warning: ${result.failedParsingNodesCount} of ${result.totalNodesCount} nodes could not be processed.`
            );
        } else {
            return jobResultOkay(
                `${result.totalNodesCount} nodes have been processed.`
            );
        }
    },
};