gracefulShutdown.js

gracefulShutdown.js

api.socketServer.gracefulShutdown = function(api, next, alreadyShutdown){
  if(alreadyShutdown == null){alreadyShutdown = false;}
  if(alreadyShutdown == false){
    api.socketServer.server.close();
    alreadyShutdown = true;
  }
  for(var i in api.socketServer.connections){
    var connection = api.socketServer.connections[i];
    if (connection.responsesWaitingCount == 0){
      api.socketServer.connections[i].end("Server going down NOW\r\nBye!\r\n");
    }
  }
  if(api.socketServer.connections.length != 0){
    api.log("[socket] waiting on shutdown, there are still " + api.socketServer.connections.length + " connected clients waiting on a response");
    setTimeout(function(){
      api.socketServer.gracefulShutdown(api, next, alreadyShutdown);
    }, 3000);
  }else{
    next();
  }
}