Test a node-nats connection

testconnection.js

'use strict';

var NATS = require('../');

var nc = NATS.connect({maxReconnectAttempts: -1});

nc.on('error', function(e) {
    console.error(e);
    process.exit();
});

nc.on('disconnect', () => console.log('disconnected'));

nc.on('reconnecting', () => console.log('reconnecting'));

nc.on('close', () => console.log('close'));

nc.on('connect', () => console.log('initial connect'));

// this here for testing by stopping the server/ctrl-Z etc.
setInterval(testConnection, 5000);

// test the connection - by flushing and expecting the flushing
// to be done before some external timeout.
var timeout = null;
function testConnection() {
    timeout = setTimeout(function() {
        console.log('not connected');
        // re-establish your connection
        timeout = null;
    }, 500);
    nc.flush(function() {
        if(timeout) {
            console.log('connected');
            clearTimeout(timeout);
            timeout = null;
        }
    });
}