Build with Babel

[rbdr/junction] / extension / content_script.js

diff --git a/extension/content_script.js b/extension/content_script.js
index 4a6c7e65315e19b2aa761aec95deb0dd6bf82585..741e1c4a88df1b03e1ca4c348d910adc866b193e 100644 (file)
--- a/extension/content_script.js
+++ b/extension/content_script.js
@@ -1,7 +1,14 @@
 (() => {
 
 (() => {
 

+  const io = require('socket.io-client');
+

   const internals = {
   const internals = {

+
+    kSocketUrl: 'http://unlimited.pizza:8000/',
+

     port: null,
     port: null,

+    socket: null,
+    peers: 0,

 
     onMessage(message) {
       internals[message.action](message.data);
 
     onMessage(message) {
       internals[message.action](message.data);


@@ -11,6 +18,37 @@
 
       try {
         const mediaStream = await navigator.mediaDevices.getUserMedia({ audio: true });
 
       try {
         const mediaStream = await navigator.mediaDevices.getUserMedia({ audio: true });

+
+        internals.socket = io(internals.kSocketUrl);
+
+        console.log('Connecting to server');
+        internals.socket.on('connect', function() {
+
+          console.log("Connected to signaling server");
+          internals.socket.emit('join', {
+            'url': currentUrl,
+          });
+        });
+
+        internals.socket.on('disconnect', function() {
+
+          console.log("disconnected from signaling server");
+        });
+
+        internals.socket.on('addPeer', function(data) {
+
+          console.log(data);
+          internals.peers++;
+          console.log(`There are now ${internals.peers} participants`);
+        });
+
+        internals.socket.on('removePeer', function() {
+
+          internals.peers--;
+          console.log(`There are now ${internals.peers} participants`);
+        });
+
+        console.log('Done!');

         internals.createAudioElement(data.tada);
       }
       catch (err) {
         internals.createAudioElement(data.tada);
       }
       catch (err) {


@@ -25,6 +63,7 @@
 
     hangUp() {
       document.querySelectorAll('.junction-call-audio').forEach((audioElement) => audioElement.remove());
 
     hangUp() {
       document.querySelectorAll('.junction-call-audio').forEach((audioElement) => audioElement.remove());

+      internals.socket.close();

       internals.port.disconnect();
     },
 
       internals.port.disconnect();
     },