action on primus reconnect

primus-reconnect.js

'use strict';

var disconnectClient = true;
var http = require('http');
var Primus = require('primus');
var primusServer;
var httpServer;

(function createServer() {
    httpServer = http.createServer();
    primusServer = new Primus(httpServer);

    primusServer.on('connection', function(spark) {

        if (!disconnectClient) return;
        disconnectClient = false;

        // Close the server and trigger a client side reconnection
        primusServer.end({
            end: false
        });
        spark.end(null, {
            reconnect: true
        });

        // Reopen the server after 20 seconds
        setTimeout(createServer, 20000);
    });
    httpServer.listen(3000);
})();

var socket = new primusServer.Socket('http://localhost:3000');

socket.on('open', function() {
    console.log('client is connected');
}).on('close', function() {
    console.log('client is disconnected');
}).on('reconnect', function() {
    console.log('client is attempting to reconnect');
}).on('reconnecting', function() {
    console.log('client will reconnect');
});