Add ssl option

Author: jmwohl

index.js

@@ -4,25 +4,38 @@
  */
 
 var http = require('http'),
+    https = require('https'),
     faye = require('faye'),
     server_auth = require('./server-auth'),
     client_auth = require('./client-auth'),
+    sslConfig = require('./ssl-config'),
     debug = require('debug')('openframe:pubsub'),
 
     // Exported object
     pubsub = module.exports = {};
 
 pubsub.connectedFrames = {};
 
-pubsub.start = function(_port, _host) {
+pubsub.start = function (_port, _host) {
     var port = _port || process.env.PS_PORT || '8889',
         host = _host || process.env.PS_HOST || '0.0.0.0',
+        protocol = process.env.PS_HOST || 'http',
         path = process.env.PS_PATH || '/faye',
         api_url = process.env.API_EXPOSED_URL || 'http://0.0.0.0:8888/api',
-        server = http.createServer(),
-        bayeux = new faye.NodeAdapter({mount: path, timeout: 5}),
+        // server = http.createServer(),
+        bayeux = new faye.NodeAdapter({ mount: path, timeout: 5 }),
         client = bayeux.getClient();
 
+    let server = null;
+    if (protocol === 'https') {
+        const options = {
+            key: sslConfig.getPrivateKey(),
+            cert: sslConfig.getCertificate(),
+        };
+        server = https.createServer(options);
+    } else {
+        server = http.createServer();
+    }
 
     // add server_auth extension
     bayeux.addExtension(server_auth(api_url));
@@ -33,13 +46,13 @@ pubsub.start = function(_port, _host) {
     /**
      * Handle new client connection
      */
-    bayeux.on('handshake', function(clientId) {
+    bayeux.on('handshake', function (clientId) {
         debug('new bayeux connection: ', clientId);
     });
 
     // When a client disconnects, see if it's in the hash of connected frames.
     // If so, publish a disconnect event to any subscribed pubsub clients (e.g. the API server)
-    bayeux.on('disconnect', function(clientId) {
+    bayeux.on('disconnect', function (clientId) {
         debug('bayeux connection closed: ', clientId);
         if (pubsub.connectedFrames[clientId]) {
             var frame_id = pubsub.connectedFrames[clientId];
@@ -54,7 +67,7 @@ pubsub.start = function(_port, _host) {
     // add it to the list of connected frames
     //
     // also re-publish frame_id-namespaced  connect event
-    bayeux.on('publish', function(clientId, channel, data) {
+    bayeux.on('publish', function (clientId, channel, data) {
         debug('published', channel, data);
         if (channel === '/frame/connected') {
             pubsub.connectedFrames[clientId] = data;
@@ -70,11 +83,11 @@ pubsub.start = function(_port, _host) {
     // Just some logging...
     // TODO: log to file.
 
-    client.subscribe('/frame/connected', function(data) {
+    client.subscribe('/frame/connected', function (data) {
         debug('/frame/connected', data);
     });
 
-    client.subscribe('/frame/disconnected', function(data) {
+    client.subscribe('/frame/disconnected', function (data) {
         debug('/frame/disconnected', data);
     });
 

ssl-config.js

@@ -0,0 +1,8 @@
+var fs = require('fs');
+
+exports.getPrivateKey = () => {
+    return fs.readFileSync(process.env.PATH_TO_PRIVATE_KEY).toString()
+}
+exports.getCertificate = () => {
+    return fs.readFileSync(process.env.PATH_TO_CERT).toString()
+}