X-Git-Url: https://git.r.bdr.sh/rbdr/junction/blobdiff_plain/b9a2baf2a7c957089e63844b857e05c07b87c2fb..6717f3d8b71abf255b0e07a5024caa602b5a3d3c:/extension/content_script.js

diff --git a/extension/content_script.js b/extension/content_script.js
index 26da2b0..0c7012b 100644
--- a/extension/content_script.js
+++ b/extension/content_script.js
@@ -1,6 +1,14 @@
 import { io } from "socket.io-client";
-import Peers from "./peers";
-import Media from "./media";
+import { initializeTada } from "./tada";
+import {
+  addPeer,
+  addIceCandidate,
+  answerPeerOffer,
+  processPeerAnswer,
+  removePeer,
+  resetPeers,
+} from "./peers";
+import { startMedia, stopMedia } from "./media";
 
 const internals = {
   kSocketUrl: "https://junction.tranquil.services",
@@ -8,118 +16,63 @@ const internals = {
 
   port: null,
   socket: null,
-  peers: {},
 
   onMessage(message) {
     internals[message.action](message.data);
   },
 
+  onError(error) {
+    // TODO: How do we want to handle errors?
+    console.error(error.stack || error);
+  },
+
+  connect() {
+    internals.port = chrome.runtime.connect({ name: "content" });
+    internals.port.onMessage.addListener(internals.onMessage);
+  },
+
   async joinAudioCall({ currentUrl, tada }) {
     try {
-      const mediaStream = await Media.start();
+      const mediaStream = await startMedia();
+      const playTada = initializeTada(tada);
 
-      internals.socket = io(internals.kSocketUrl, {
+      const socket = (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);
-      });
+      socket.on("error", internals.handleError);
+      socket.on("connect_error", internals.handleError);
 
-      internals.socket.on("connect", function () {
-        console.log("Connected to signaling server, group: ", currentUrl);
-        internals.socket.emit("join", {
+      socket.on("connect", () => {
+        console.debug("Connected to signaling server, group: ", currentUrl);
+        playTada();
+        socket.emit("join", {
           room: currentUrl,
         });
       });
 
-      internals.socket.on("disconnect", function () {
-        console.log("disconnected from signaling server");
+      socket.on("disconnect", () => {
+        console.debug("disconnected from signaling server");
       });
 
-      internals.socket.on("addPeer", function ({ peerId }) {
-        /**
-         * Eventually the whole rtc connection logic should be moved to Peers.
-         * Now it only plays tadas.
-         */
-        Peers.add(peerId, tada);
-
-        const peerConnection = new RTCPeerConnection(
-          { iceServers: internals.kIceServers },
-          { optional: [{ DtlsSrtpKeyAgreement: true }] },
-        );
-
-        internals.peers[peerId] = peerConnection;
-        mediaStream.getTracks().forEach((track) => {
-          peerConnection.addTrack(track, mediaStream);
+      socket.on("addPeer", ({ peerId, shouldCreateOffer }) => {
+        addPeer({
+          peerId,
+          shouldCreateOffer,
+          mediaStream,
+          onOffer: (data) => socket.emit("relayOffer", data),
+          socket,
         });
-
-        peerConnection.onicecandidate = (event) => {
-          if (event.candidate) {
-            internals.socket.emit("relayICECandidate", {
-              peerId: peerId,
-              candidate: event.candidate,
-            });
-          }
-        };
-
-        const remoteStream = new MediaStream();
-        peerConnection.ontrack = (event) => {
-          remoteStream.addTrack(event.track);
-          const remoteAudioElement = new Audio();
-          remoteAudioElement.srcObject = remoteStream;
-          remoteAudioElement.play();
-        };
-
-        peerConnection.onnegotiationneeded = async () => {
-          console.log("Creating RTC offer to ", peerId);
-          const offer = await peerConnection.createOffer();
-          await peerConnection.setLocalDescription(offer);
-
-          // Emit the offer to the peer
-          internals.socket.emit("relayOffer", { offer, peerId });
-        };
-
-        console.log(`There are now ${Peers.count()} participants`);
+        playTada();
       });
 
-      internals.socket.on("offerReceived", async ({ offer, peerId }) => {
-        const peerConnection = internals.peers[peerId];
-
-        const remoteDescription = new RTCSessionDescription(offer);
-        await peerConnection.setRemoteDescription(remoteDescription);
-
-        const answer = await peerConnection.createAnswer();
-        await peerConnection.setLocalDescription(answer);
-
-        // Send the answer to the peer
-        internals.socket.emit("relayAnswer", { answer, peerId });
+      socket.on("offerReceived", async ({ peerId, offer }) => {
+        socket.emit("relayAnswer", await answerPeerOffer({ peerId, offer }));
       });
 
-      internals.socket.on("answerReceived", async ({ answer, peerId }) => {
-        const peerConnection = internals.peers[peerId];
-        const remoteDescription = new RTCSessionDescription(answer);
-        await peerConnection.setRemoteDescription(remoteDescription);
-      });
-
-      internals.socket.on(
-        "ICECandidateReceived",
-        async ({ candidate, peerId }) => {
-          const peerConnection = internals.peers[peerId];
-          const iceCandidate = new RTCIceCandidate(candidate);
-          await peerConnection.addIceCandidate(iceCandidate);
-        },
-      );
-
-      internals.socket.on("removePeer", function ({ peerId }) {
-        delete internals.peers[peerId];
-        Peers.remove(peerId);
-        console.log(`There are now ${Peers.count()} participants`);
-      });
+      socket.on("answerReceived", (data) => processPeerAnswer(data));
+      socket.on("ICECandidateReceived", (data) => addIceCandidate(data));
+      socket.on("removePeer", (data) => removePeer(data));
     } catch (err) {
       internals.port.postMessage({
         action: "error",
@@ -129,17 +82,19 @@ const internals = {
   },
 
   hangUp() {
-    Peers.reset();
-    Media.stop();
+    resetPeers();
+    stopMedia();
     internals.socket.close();
     internals.port.disconnect();
   },
 };
 
-internals.port = chrome.runtime.connect({ name: "content" });
-internals.port.onMessage.addListener(internals.onMessage);
+internals.connect();
+chrome.runtime.onConnect.addListener(() => {
+  internals.connect();
+});
 
-console.log("Content Script Loaded");
+console.debug("Content Script Loaded");
 
 // Indicates to the background script that we executed correctly
 true;