Merge pull request #185 from matiu/feat/ssl-cluster

clustering!

bws.js

@@ -1,18 +1,50 @@
 #!/usr/bin/env node
 
+var fs = require('fs');
+
 var ExpressApp = require('./lib/expressapp');
 var WsApp = require('./lib/wsapp');
 var config = require('./config');
 
 var port = process.env.BWS_PORT || config.port || 3232;
 
-var app = ExpressApp.start(config);
+var cluster = require('cluster');
-//app.listen(port);
+var http = require('http');
+var numCPUs = require('os').cpus().length;
 
-var server = require('http').Server(app);
+var serverModule = config.https ? require('https') : require('http');
+var serverOpts = {};
 
-var ws = WsApp.start(server, config);
+if (config.https) {
+  serverOpts.key = fs.readFileSync(config.privateKeyFile || './ssl/privatekey.pem');
+  serverOpts.cert = fs.readFileSync(config.certificateFile || './ssl/certificate.pem');
+}
 
+var startOne = function() {
+  var app = ExpressApp.start(config);
+  var server = config.https ? serverModule.createServer(serverOpts, app) :
+    serverModule.Server(app);
+  var ws = WsApp.start(server, config);
   server.listen(port);
-
   console.log('Bitcore Wallet Service running on port ' + port);
+};
+
+if (!config.cluster) {
+  startOne();
+} else {
+  if (!config.storageOpts.multiLevel || !config.lockOpts.lockerServer)
+    throw 'When running in cluster mode, multilevel and locker server need to be configured';
+
+  var clusterInstances = config.clusterInstances || numCpus;
+
+  if (cluster.isMaster) {
+    for (var i = 0; i < clusterInstances; i++) {
+      cluster.fork();
+    }
+    cluster.on('exit', function(worker, code, signal) {
+      console.log('worker ' + worker.process.pid + ' died');
+    });
+  } else {
+    startOne();
+  }
+}

config.js

@@ -2,19 +2,28 @@ var config = {
   basePath: '/bws/api',
   disableLogs: false,
   port: 3232, 
+  // Uncomment to make BWS a forking server
+  cluster: true,
+  // Uncomment to use the nr of availalbe CPUs
+  clusterInstances: 4,
+
+  // https: true,
+  // privateKeyFile: 'private.pem',
+  // certificateFile: 'cert.pem',
+
   storageOpts: {
-    dbPath: './db',
+    // dbPath: './db',
-    // multiLevel: {
+    multiLevel: {
-    //   host: 'localhost',
+      host: 'localhost',
-    //   port: 3230,
+      port: 3230,
-    // },
+    },
   },
   lockOpts: {
     //  To use locker-server, uncomment this:
-    // lockerServer: {
+    lockerServer: {
-    //   host: 'localhost',
+      host: 'localhost',
-    //   port: 3231,
+      port: 3231,
-    // },
+    },
   },
   blockchainExplorerOpts: {
     livenet: {