Fix server

[rbdr/junction] / extension / content_script.js

diff --git a/extension/content_script.js b/extension/content_script.js
index 4a6c7e65315e19b2aa761aec95deb0dd6bf82585..6785a6556427ab48b49495eda7f51fc907717465 100644 (file)
--- a/extension/content_script.js
+++ b/extension/content_script.js
@@ -1,47 +1,136 @@
-(() => {
+import { io } from 'socket.io-client';
+import Peers from './peers';
+import Media from './media';
 
-  const internals = {
-    port: null,
+const internals = {
 
-    onMessage(message) {
-      internals[message.action](message.data);
-    },
+  kSocketUrl: 'https://junction.tranquil.services',
+       kIceServers: [
+               {url:"stun:stun.l.google.com:19302"}
+       ],
 
-    async joinAudioCall(data) {
+  port: null,
+  socket: null,
+  peers: {},
 
-      try {
-        const mediaStream = await navigator.mediaDevices.getUserMedia({ audio: true });
-        internals.createAudioElement(data.tada);
-      }
-      catch (err) {
+  onMessage(message) {
+    internals[message.action](message.data);
+  },
 
-        internals.port.postMessage({
-          action: 'error'
+  async joinAudioCall(data) {
+
+    internals.tada = data.tada; // Keeping for fun
+
+    try {
+      const mediaStream = await Media.start();
+
+      internals.socket = io(internals.kSocketUrl, {
+        transports: ['websocket']
+      });
+
+      internals.socket.on('error', function(error) {
+
+        console.error('GENERAL ERROR', error);
+      });
+
+      internals.socket.on('connect_error', function(error) {
+
+        console.error('CONNNECT ERROR', error);
+      });
+
+      internals.socket.on('connect', function() {
+
+        console.log("Connected to signaling server, group: ", data.currentUrl);
+        internals.socket.emit('join', {
+          'url': data.currentUrl,
         });
-        internals.port.disconnect();
-        internals.createAudioElement(data.tada);
-      }
-    },
+      });
 
-    hangUp() {
-      document.querySelectorAll('.junction-call-audio').forEach((audioElement) => audioElement.remove());
-      internals.port.disconnect();
-    },
+      internals.socket.on('disconnect', function() {
+
+        console.log("disconnected from signaling server");
+      });
+
+      internals.socket.on('addPeer', function(data) {
+
+        console.log(data);
+        Peers.add(data.peer_id, internals.tada);
+          const peerId = data.peer_id;
 
-    createAudioElement(source, type = 'audio/wav') {
+          const peerConn = new RTCPeerConnection(
+              {"iceServers": internals.kIceServers},
+              {"optional": [{"DtlsSrtpKeyAgreement": true}]}
+          );
 
-      const audioElement = document.createElement('audio');
-      audioElement.setAttribute('class', 'junction-call-audio');
-      audioElement.src = source;
-      audioElement.autoplay = 'autoplay';
-      audioElement.type = type;
-      document.querySelector('body').appendChild(audioElement);
+          internals.peers[peerId] = peerConn;
+
+          peerConn.onicecandidate = (event) => {
+            if (event.candidate) {
+              internals.socket.emit('relayICECandidate', {
+                'peer_id': peerId,
+                'ice_candidate': {
+                  'sdpMLineIndex': event.candidate.sdpMLineIndex,
+                  'candidate': event.candidate.candidate
+                }
+              });
+            }
+          }
+
+          peerConn.onaddstream = (stream) => {
+            console.log(`Received stream for peer ${peerId}`);
+            console.log(stream);
+          }
+
+          peerConn.addStream(mediaStream);
+
+          if (data.should_create_offer) {
+            console.log("Creating RTC offer to ", peerId);
+            peerConn.createOffer((local_description) => {
+                  console.log("Local offer description is: ", local_description);
+                  peerConn.setLocalDescription(local_description, () => {
+                        internals.socket.emit('relaySessionDescription', {
+                          'peer_id': peerId,
+                          'session_description': local_description
+                        });
+
+                        console.log("Offer setLocalDescription succeeded");
+                      }, () => { console.log("Offer setLocalDescription failed!"); }
+                  );
+                },
+                (error) => { console.log("Error sending offer: ", error) }
+            );
+          }
+        console.log(`There are now ${Peers.count()} participants`);
+      });
+
+      internals.socket.on('removePeer', function() {
+
+        Peers.remove('id-'+(Peers.count() - 1)); // This is only for testing, don't use count to remove ids.
+        console.log(`There are now ${Peers.count()} participants`);
+      });
     }
-  };
+    catch (err) {
+
+      internals.port.postMessage({
+        action: 'error'
+      });
+      internals.port.disconnect();
+    }
+  },
+
+  hangUp() {
+
+    Peers.reset();
+    Media.stop();
+    internals.socket.close();
+    internals.port.disconnect();
+  }
+};
+
+internals.port = chrome.runtime.connect({ name:"content" });
+internals.port.onMessage.addListener(internals.onMessage);
 
-  internals.port = chrome.runtime.connect({ name:"content" });
-  internals.port.onMessage.addListener(internals.onMessage);
-})();
+console.log('Content Script Loaded');
 
 // Indicates to the background script that we executed correctly
 true;