Merge pull request #5 from slidewiki/SWIK-2115-reveal-multiplex

SWIK-2115 Reveal Multiplex

README.md

@@ -6,7 +6,7 @@
 [![Webserver](https://img.shields.io/badge/Socket%20Framework-Socket.io%202.0-blue.svg)](http://hapijs.com/)
 
 
-Simple STUN Service for the WebRTC parts of slidewiki-platform.
+Simple STUN service for the WebRTC parts of slidewiki-platform and also for the reveal multiplexing plugin.
 
 ### Install NodeJS ###
 ---

application/routes.js

@@ -4,7 +4,9 @@ const Joi = require('joi'),
   server = require('./server'),
   os = require('os'),
   twitter = require('twitter'),
-  _ = require('lodash');
+  _ = require('lodash'),
+  crypto = require('crypto'),
+  URL = require('url');
 
 const twitterclient = new twitter(require('./config.json'));
 
@@ -43,6 +45,17 @@ module.exports = function(server) {
       description: 'Get rooms for a specific deck with their opening time'
     }
   });
+
+  server.route({
+    method: 'GET',
+    path: '/token',
+    handler: getNewRevealMultiplexToken,
+    config: {
+      cors: {origin: ['http://localhost*', URL.parse(process.env.VIRTUAL_HOST).hostname]},
+      tags: ['api'],
+      description: 'Get a new token pair for the reveal multiplex plugin'
+    }
+  });
 };
 
 let rooms = {};//{deckid: [{roomName: string, openingTime: UTC, twitterStream: stream}, ...], ...}
@@ -60,6 +73,20 @@ function getRoomsForDeckWithTime(request, reply) {
   reply(response.map((el) => {return {'roomName': el.roomName, 'openingTime': el.openingTime};}));
 }
 
+function getNewRevealMultiplexToken(request, reply) {
+  let ts = new Date().getTime();
+  let rand = Math.floor(Math.random()*9999999);
+  let secret = ts.toString() + rand.toString();
+  let socketID = createHash(secret);
+  console.log({secret: secret, socketId: socketID});
+  reply({secret: secret, socketId: socketID});
+}
+
+function createHash(secret) {
+  let cipher = crypto.createCipher('blowfish', secret);
+  return(cipher.final('hex'));
+}
+
 let io = require('socket.io')(server.listener);
 io.on('connection', (socket) => {
 
@@ -158,4 +185,12 @@ io.on('connection', (socket) => {
     }
   });
 
+  socket.on('multiplex-statechanged', (data) => {
+    if (typeof data.secret == 'undefined' || data.secret == null || data.secret === '') return;
+    if (createHash(data.secret) === data.socketId) {
+      data.secret = null;
+      socket.broadcast.emit(data.socketId, data);
+    }
+  });
+
 });