Implement multi tenancy

www/app/[domain]/transcripts/useWebRTC.ts

@@ -0,0 +1,75 @@
+import { useEffect, useState } from "react";
+import Peer from "simple-peer";
+import {
+  DefaultApi,
+  V1TranscriptRecordWebrtcRequest,
+} from "../../api/apis/DefaultApi";
+import { useError } from "../../(errors)/errorContext";
+
+const useWebRTC = (
+  stream: MediaStream | null,
+  transcriptId: string | null,
+  api: DefaultApi,
+): Peer => {
+  const [peer, setPeer] = useState<Peer | null>(null);
+  const { setError } = useError();
+
+  useEffect(() => {
+    if (!stream || !transcriptId) {
+      return;
+    }
+
+    console.debug("Using WebRTC", stream, transcriptId);
+
+    let p: Peer;
+
+    try {
+      p = new Peer({ initiator: true, stream: stream });
+    } catch (error) {
+      setError(error);
+      return;
+    }
+
+    p.on("error", (err) => {
+      setError(new Error(`WebRTC error: ${err}`));
+    });
+
+    p.on("signal", (data: any) => {
+      if ("sdp" in data) {
+        const requestParameters: V1TranscriptRecordWebrtcRequest = {
+          transcriptId: transcriptId,
+          rtcOffer: {
+            sdp: data.sdp,
+            type: data.type,
+          },
+        };
+
+        api
+          .v1TranscriptRecordWebrtc(requestParameters)
+          .then((answer) => {
+            try {
+              p.signal(answer);
+            } catch (error) {
+              setError(error);
+            }
+          })
+          .catch((error) => {
+            setError(error);
+          });
+      }
+    });
+
+    p.on("connect", () => {
+      console.log("WebRTC connected");
+      setPeer(p);
+    });
+
+    return () => {
+      p.destroy();
+    };
+  }, [stream, transcriptId]);
+
+  return peer;
+};
+
+export default useWebRTC;