experimenting with webrtc, obviously do not merge this, it's purely a pointless experiment I'm struggling to get working

src/node/handler/SocketIORouter.js

@@ -92,12 +92,19 @@ exports.setSocketIO = function(_socket)
       
     client.on('message', function(message)
     {
+
       if(message.protocolVersion && message.protocolVersion != 2)
       {
         messageLogger.warn("Protocolversion header is not correct:" + stringifyWithoutPassword(message));
         return;
       }
 
+      if (message.type == "candidate" || message.sdp){ // CRAZY SHIT DO NOT MERGE
+        console.warn((new Date()) + ' Received Message, broadcasting: ' + message);
+        client.broadcast.emit('message', message);
+        clientAuthorized = true; // This is bad and I feel bad, it's only temporary
+      }
+
       //client is authorized, everything ok
       if(clientAuthorized)
       {
@@ -119,6 +126,7 @@ exports.setSocketIO = function(_socket)
               clientAuthorized = true;
               handleMessage(message);
             }
+
             //no access, send the client a message that tell him why
             else
             {

src/static/js/pad.js

@@ -251,6 +251,7 @@ function handshake()
 
   socket.on('message', function(obj)
   {
+    // console.log("obj frmo server", obj);
     // the access was not granted, give the user a message
     if(!receivedClientVars && obj.accessStatus)
     {

src/templates/pad.html

@@ -50,6 +50,17 @@
         <!-- head and body had been removed intentionally -->
 
         <% e.begin_block("body"); %>
+
+<div style="z-index:9999;position:fixed;top:0;left:0">
+  <h1>WebRTC Demo using Socket.IO</h1>
+  <video id="webrtc-sourcevid" autoplay style="width: 320px; height: 240px; border: 1px solid black;"></video>
+  <button type="button" onclick="startVideo();">Start video</button>
+  <button type="button" onclick="stopVideo();">Stop video</button>
+  <video id="webrtc-remotevid" autoplay style="width: 320px; height: 240px; border: 1px solid black;"></video>
+  <button type="button" onclick="connect();">Connect</button>
+  <button type="button" onclick="hangUp();">Hang Up</button>
+</div>
+
         <div id="editbar" class="toolbar">
             <div id="overlay">
                 <div id="overlay-inner"></div>
@@ -460,6 +471,188 @@
               padeditbar = require('ep_etherpad-lite/static/js/pad_editbar').padeditbar;
               padimpexp = require('ep_etherpad-lite/static/js/pad_impexp').padimpexp;
             }());
+
+
+
+
+
+/* WUT webRTC EXPERIMENT */
+  var socket = io.connect(pad.socket);
+  var sourcevid = document.getElementById('webrtc-sourcevid');
+  var remotevid = document.getElementById('webrtc-remotevid');
+  var localStream = null;
+  var peerConn = null;
+  var started = false;
+  var channelReady = false;
+  var mediaConstraints = {'mandatory': {
+                          'OfferToReceiveAudio':true, 
+                          'OfferToReceiveVideo':true }};
+  var isVideoMuted = false;
+
+  // get the local video up
+  function startVideo() {
+      navigator.getUserMedia = navigator.getUserMedia || navigator.webkitGetUserMedia || window.navigator.mozGetUserMedia || navigator.msGetUserMedia;
+      window.URL = window.URL || window.webkitURL;
+
+      navigator.getUserMedia({video: true, audio: true}, successCallback, errorCallback);
+      function successCallback(stream) {
+          localStream = stream;
+          if (sourcevid.mozSrcObject) {
+            sourcevid.mozSrcObject = stream;
+            sourcevid.play();
+          } else {
+            try {
+              sourcevid.src = window.URL.createObjectURL(stream);
+              sourcevid.play();
+            } catch(e) {
+              console.log("Error setting video src: ", e);
+            }
+          }
+      }
+      function errorCallback(error) {
+          console.error('An error occurred: [CODE ' + error.code + ']');
+          return;
+      }
+  }
+
+  // stop local video
+  function stopVideo() {
+    if (sourcevid.mozSrcObject) {
+      sourcevid.mozSrcObject.stop();
+      sourcevid.src = null;
+    } else {
+      sourcevid.src = "";
+      localStream.stop();
+    }
+  }
+
+  // send SDP via socket connection
+  function setLocalAndSendMessage(sessionDescription) {
+    peerConn.setLocalDescription(sessionDescription);
+    console.log("Sending: SDP");
+    console.log(sessionDescription);
+    socket.json.send(sessionDescription);
+  }
+
+  function createOfferFailed() {
+    console.log("Create Answer failed");
+  }
+
+  // start the connection upon user request
+  function connect() {
+    if (!started && localStream && channelReady) {
+      createPeerConnection();
+      started = true;
+      peerConn.createOffer(setLocalAndSendMessage, createOfferFailed, mediaConstraints);
+    } else {
+      alert("Local stream not running yet - try again.");
+    }
+  }
+
+  // stop the connection upon user request
+  function hangUp() {
+    console.log("Hang up.");    
+    socket.json.send({type: "bye"});
+    stop();
+  }
+
+  function stop() {
+    peerConn.close();
+    peerConn = null;
+    started = false;    
+  }
+
+  // socket: channel connected
+  socket.on('connect', onChannelOpened)
+        .on('message', onMessage);
+
+  function onChannelOpened(evt) {
+    console.log('Channel opened.');
+    channelReady = true;
+  }
+
+  function createAnswerFailed() {
+    console.log("Create Answer failed");
+  }
+  // socket: accept connection request
+  function onMessage(evt) {
+    console.log("event", evt);
+    if (evt.type === 'offer') {
+      console.log("Received offer...")
+      if (!started) {
+        createPeerConnection();
+        started = true;
+      }
+      console.log('Creating remote session description...' );
+      peerConn.setRemoteDescription(new RTCSessionDescription(evt));
+      console.log('Sending answer...');
+      peerConn.createAnswer(setLocalAndSendMessage, createAnswerFailed, mediaConstraints);
+
+    } else if (evt.type === 'answer' && started) {
+      console.log('Received answer...');
+      console.log('Setting remote session description...' );
+      peerConn.setRemoteDescription(new RTCSessionDescription(evt));
+
+    } else if (evt.type === 'candidate' && started) {
+      console.log('Received ICE candidate...');
+      var candidate = new RTCIceCandidate({sdpMLineIndex:evt.sdpMLineIndex, sdpMid:evt.sdpMid, candidate:evt.candidate});
+      console.log(candidate);
+      peerConn.addIceCandidate(candidate);
+
+    } else if (evt.type === 'bye' && started) {
+      console.log("Received bye");
+      stop();
+    }
+  }
+
+  function createPeerConnection() {
+    console.log("Creating peer connection");
+    RTCPeerConnection = webkitRTCPeerConnection || mozRTCPeerConnection;
+    var pc_config = {"iceServers":[]};
+    try {
+      peerConn = new RTCPeerConnection(pc_config);
+    } catch (e) {
+      console.log("Failed to create PeerConnection, exception: " + e.message);
+    }
+    // send any ice candidates to the other peer
+    peerConn.onicecandidate = function (evt) {
+      if (event.candidate) {
+        console.log('Sending ICE candidate...');
+        console.log(evt.candidate);
+        socket.json.send({type: "candidate",
+                          sdpMLineIndex: evt.candidate.sdpMLineIndex,
+                          sdpMid: evt.candidate.sdpMid,
+                          candidate: evt.candidate.candidate});
+      } else {
+        console.log("End of candidates.");
+      }
+    };
+    console.log('Adding local stream...');
+    peerConn.addStream(localStream);
+
+    peerConn.addEventListener("addstream", onRemoteStreamAdded, false);
+    peerConn.addEventListener("removestream", onRemoteStreamRemoved, false)
+
+    // when remote adds a stream, hand it on to the local video element
+    function onRemoteStreamAdded(event) {
+      console.log("Added remote stream", event.stream);
+      remotevid.src = window.URL.createObjectURL(event.stream);
+    }
+
+    // when remote removes a stream, remove it from the local video element
+    function onRemoteStreamRemoved(event) {
+      console.log("Remove remote stream");
+      remotevid.src = "";
+    }
+  }
+
+
+
+/* END WUT */
+
+
+
+
         </script>
         <% e.end_block(); %>
 </html>