heartbeat.js

var later = require('later');
const axios = require('axios');

var callRemoteURL = function (remoteURL) {
    axios
        .get(remoteURL)
        .then(function (response) {
            // handle success
            logger.debug(`HEARTBEAT: Sent heartbeat to ${remoteURL}`);
        })
        .catch(function (error) {
            // handle error
            logger.error(`HEARTBEAT: Error sending heartbeat: ${error}`);
        });
};

function setupHeartbeatTimer(config, logger) {
    try {
        logger.debug(
            `HEARTBEAT: Setting up heartbeat to remote: ${config.get('heartbeat.remoteURL')}`,
        );

        var sched = later.parse.text(config.get('heartbeat.frequency'));
        var t = later.setInterval(function () {
            callRemoteURL(config.get('heartbeat.remoteURL'));
        }, sched);

        // Do an initial ping to the remote URL
        callRemoteURL(config.get('heartbeat.remoteURL'));
    } catch (err) {
        logger.error(`HEARTBEAT: Error ${err}`);
    }
}

module.exports = {
    setupHeartbeatTimer,
};