first draft

Author: 256dpi

.gitignore

@@ -1,3 +1,5 @@
+.DS_Store
+
 # Logs
 logs
 *.log

.travis.yml

@@ -0,0 +1,10 @@
+language: node_js
+node_js:
+  - 0.10
+  - 0.8
+before_install:
+  - npm install [email protected] -g
+matrix:
+  fast_finish: true
+  allow_failures:
+    - node_js: "0.11"

README.md

@@ -1 +1,46 @@
 # create-stream-server
+
+**create multiple stream servers easily**
+
+## Example
+
+```js
+var css = require('create-stream-server');
+
+var servers = css({
+  s1: 'tcp://localhost:8080',
+  s2: 'ssl://0.0.0.0:80',
+  s3: {
+    protocol: 'wss',
+    host: 'localhost',
+    port: 8888,
+    ssl: {
+      key: fs.readFileSync('./wss_server.key'),
+      cert: fs.readFileSync('./wss_server.crt')
+    }
+  }
+}, {
+  ssl: {
+    key: fs.readFileSync('./server.key'),
+    cert: fs.readFileSync('./server.crt')
+  }
+}, function(clientStream, server){
+  // handle the connected client as a stream
+});
+
+// to start
+servers.listen(function(){
+  console.log('launched!');
+});
+
+// after some time
+servers.close(function(){
+  console.log('done!');
+});
+
+// to release all resources
+servers.destroy(function(){
+  console.log('all gone!');
+});
+```
+

index.js

@@ -0,0 +1,111 @@
+var net = require('net');
+var tls = require('tls');
+var http = require('http');
+var https = require('https');
+var ws = require('ws');
+var _ = require('underscore');
+var url = require('url');
+var wsStream = require('websocket-stream');
+var async = require('async');
+var enableDestroy = require('server-destroy');
+
+function createServer(clientHandler) {
+  return net.createServer(function(client){
+    clientHandler(client);
+  });
+}
+
+function createSecureServer(sslOptions, clientHandler){
+  return tls.createServer(sslOptions, function(client){
+    clientHandler(client);
+  });
+}
+
+function attachServer(server, clientHandler) {
+  (new ws.Server({
+    server: server
+  })).on('connection', function(ws) {
+    clientHandler(wsStream(ws));
+  });
+}
+
+function createWebSocketServer(clientHandler){
+  var server = http.createServer();
+  attachServer(server, clientHandler);
+  return server;
+}
+
+function createSecureWebSocketServer(sslOptions, clientHandler){
+  var server = https.createServer(sslOptions);
+  attachServer(server, clientHandler);
+  return server;
+}
+
+module.exports = function(serverConfig, sharedConfig, clientStreamHandler){
+  if(typeof sharedConfig == 'function') {
+    clientStreamHandler = sharedConfig;
+    sharedConfig = {};
+  }
+
+  if(typeof sharedConfig != 'object') {
+    sharedConfig = {};
+  }
+
+  var servers = {};
+
+  _.each(serverConfig, function(config, id){
+    if(typeof config == 'string') {
+      var c = url.parse(config);
+      config = {
+        protocol: c.protocol.replace(/:$/, ''),
+        port: c.port,
+        host: c.hostname
+      };
+    }
+
+    config = _.defaults(config, sharedConfig, {
+      host: 'localhost'
+    });
+
+    var server;
+
+    if(config.protocol == 'tcp') {
+      server = createServer(clientStreamHandler);
+    } else if(config.protocol == 'ssl') {
+      server = createSecureServer(config.ssl, clientStreamHandler);
+    } else if(config.protocol == 'ws') {
+      server = createWebSocketServer(clientStreamHandler);
+    } else if(config.protocol == 'wss') {
+      server = createSecureWebSocketServer(config.ssl, clientStreamHandler);
+    }
+
+    server._host = config.host;
+    server._port = config.port;
+
+    servers[id] = server;
+  });
+
+  return {
+    servers: servers,
+    listen: function(callback){
+      async.series(_.map(servers, function(server){
+        return function(cb){
+          server.listen(server._port, server._host, function(){
+            enableDestroy(server);
+            cb();
+          });
+        }
+      }), callback);
+    },
+    close: function(cb){
+      async.series(_.map(servers, function(server){
+        return server.close.bind(server);
+      }), cb);
+    },
+    destroy: function(cb){
+      async.series(_.map(servers, function(server){
+        return server.destroy.bind(server);
+      }), cb);
+    }
+  };
+};

package.json

@@ -0,0 +1,29 @@
+{
+  "name": "create-stream-server",
+  "version": "0.0.1",
+  "description": "create multiple stream servers easily",
+  "main": "index.js",
+  "scripts": {
+    "test": "./node_modules/.bin/mocha --reporter list *.js"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/mqttjs/create-stream-server.git"
+  },
+  "author": "Joël Gähwiler <[email protected]>",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/mqttjs/create-stream-server/issues"
+  },
+  "homepage": "https://github.com/mqttjs/create-stream-server",
+  "dependencies": {
+    "async": "0.9.0",
+    "server-destroy": "1.0.0",
+    "underscore": "1.7.0",
+    "websocket-stream": "1.3.2",
+    "ws": "0.7.0"
+  },
+  "devDependencies": {
+    "mocha": "2.1.0"
+  }
+}

support/server.crt

@@ -0,0 +1,19 @@
+-----BEGIN CERTIFICATE-----
+MIIDLDCCAhQCCQD0OFi+lx3bpjANBgkqhkiG9w0BAQUFADBYMQswCQYDVQQGEwJD
+SDEPMA0GA1UECBMGWnVyaWNoMQ8wDQYDVQQHEwZadXJpY2gxEjAQBgNVBAoTCXNo
+aWZ0ci5pbzETMBEGA1UEAxMKbWVrb25nLmRldjAeFw0xNDEyMjgxMTMzNTdaFw0x
+NTEyMjgxMTMzNTdaMFgxCzAJBgNVBAYTAkNIMQ8wDQYDVQQIEwZadXJpY2gxDzAN
+BgNVBAcTBlp1cmljaDESMBAGA1UEChMJc2hpZnRyLmlvMRMwEQYDVQQDEwptZWtv
+bmcuZGV2MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAyqZScnDkk3lc
+h9MG00RlpD+U0jvGDGGykHi19J0bUZY+GmwCXHEdHqE2GuJDWEQcaB5RVBU5UOBd
+KqBcQ5AhU8HWoL3txO9+Z+E7JzchDHPhabBtwTNDD5TKcL9XcrYd3Al7FpGARsDd
+H8U3AC4i6srtUZb37lILQeD628qw5gL2OWL4noOr9Eszek63zURZhQQZ4aZqTi3W
+2EU4brYSEy1ZW0WhkSYGm8gpeCC8f8gmufPFyalMwVPXLjNVJnD9EdWVyhmtiEYG
+Q5iJweFaiQwIuFvYC5jxeVAji86UFV/pE5qZ/ffZHgRMBwdoNh8TZiFMV/psRv6C
+6JuKBeBauwIDAQABMA0GCSqGSIb3DQEBBQUAA4IBAQCgQTneRLx35T1XcEbKvqZq
+DGZnB+cVH7D5VGUGwOlWhVrxxRfurR3Yrcb4mUCqu6EjUrWXhauczsAdoXqrrzRY
+YyR9CbarAm6f80xj+aSINBm/lLZJ/GJd7XhrOUTbM3VIIHUGF3MbAP7a16t2aYsf
+IDa2U1GXllJfMBWyFbn53AH6Lf85fLbcmg47K1ffx+4Baw+IzIsVGuvzHG73TCA9
+R1/ygrIDABAXw/919zOe2vsF+BKIWZiDIeTPVxzM4M8gTuoky2ecHBBjVyAS2yXS
+73mi7srYyxs+7iCmixn2csZUpSnrYmJE61CDPgMtmQSt3cXnyldq6gDzefiCnZdR
+-----END CERTIFICATE-----

support/server.key

@@ -0,0 +1,27 @@
+-----BEGIN RSA PRIVATE KEY-----
+MIIEoAIBAAKCAQEAyqZScnDkk3lch9MG00RlpD+U0jvGDGGykHi19J0bUZY+GmwC
+XHEdHqE2GuJDWEQcaB5RVBU5UOBdKqBcQ5AhU8HWoL3txO9+Z+E7JzchDHPhabBt
+wTNDD5TKcL9XcrYd3Al7FpGARsDdH8U3AC4i6srtUZb37lILQeD628qw5gL2OWL4
+noOr9Eszek63zURZhQQZ4aZqTi3W2EU4brYSEy1ZW0WhkSYGm8gpeCC8f8gmufPF
+yalMwVPXLjNVJnD9EdWVyhmtiEYGQ5iJweFaiQwIuFvYC5jxeVAji86UFV/pE5qZ
+/ffZHgRMBwdoNh8TZiFMV/psRv6C6JuKBeBauwIDAQABAoIBAFGneNsiAAgoQ497
+CWoBSk9HS0j2ytNcXl32NaLt1v8l4bo1wTHMZiZcYPeuKeKb9zJA3RZbQvACp6ew
+W9zha3xbQ4cbYH4U3kMvLu2bOhbRbodujprlc+UIWBXcE3lmRlvN+ina0OwxdCgE
+CChrbqhawgs5IIeHyX9vDsWXQ3Y6DbzjC4OREUHZHTxx7KArheuqF86Wb40YMUQv
+un/dHyf7Bl/LoS7EmKk2Y3ldUSI9sMCroiVXx9shQ8IIOeAGrPtZdITCrlZOn9f2
+SQwHi+kVfQ73/rNcjgEXH8VKMOgWCyLv67WbP4ICVGIB+/OBnAZHVzbbNQuNI1AS
+T/mkmjkCgYEA5AH1yQBKqzjQgkPXA3bZWv1KW6yAnal9Jpicnl++UFSvlFZ054ax
+42MA1p/HfVq/gYvmEUROyIT1CHQ502CH/BmFpCj2JCMWNSxs4x6FBxdln8wmMj/6
+nVT3Ckcl6jRneoaer9iQ9TqEgmm8v+UXiuv8lRlUMf0jvm7lWcIMhi0CgYEA44dj
+VSYaehZwLsTqYPl57rUEhWHTqEs7lhllFVYeYQ0Z9lr4LGbc4aQa1Y6dc51zGXhs
+24MTe9dh8xjTJaeKvrzSvfJO3qXeQZ4OoDUrGS8m/Dv+c3BwrxQyKFu92AzvXYwD
+mJT+mz78nlhU8ZKE9EA3QaPa0h1k7vHPPQhsnYcCgYBKXllMtkukjWN1GauH9bvv
+ca5POHS6+A1aCW0MOy5YBUc/mvOGkOh0wlYDqxnmSTMtjfP8rcsEnFlP6Jjz2QiB
+sdFlOfcO0mLr9RGPAuVg6sC63luXCEc2CgCJ2asEOROHY2Fe+cROOEgAQXzPGmoT
+ZeV8vEY6B9cgxgsIu8JaAQKBgFOFKkBiaUuxmuKAJC0OxuSKDCvOGjznyOqzTbjE
+UQh9H6+f+wOJisFFVRhZbpC3Fj4eR49YkTlfebQbw75JvxN/CrjxDmSKbIiXtXS3
+r6dh+KSUfTXw61xJRJQuAQUi0mb7c4J6BvAD8gVKFXxLtYRXYjE1Laj9Y0SW/OTB
+h+VXAn88nRH/8k/9Xs1zHXHnEyvC5SJCBm9G+FR2RfueqygMWmsSzr2nE78bWDuj
+sHvrdW39qyciTYZSNJNrmdYIwqkbvWj8rIqPqQ6dloRpQHNupYPrF93IJxg6UWPU
+JvpC/dEKzLT+btYlgKExz6hgk15pqTHfcqgG7859aBIEMyip
+-----END RSA PRIVATE KEY-----