start working on the streaming aspect

packages/desktop/src/providers/RealTimeRoomProvider.tsx

@@ -110,6 +110,7 @@ export function RealTimeRoomProvider({ children }: { children: React.ReactChild
 
   const [moveLineState, moveLine] = useAsyncFn(updateLineMemberState);
 
+  /** All line listeners */
   useEffect(() => {
     // when me or anyone just initially connects to line
     $ws.on(ServerResponseChannels.SOMEONE_CONNECTED_TO_LINE, (res: SomeoneConnectedResponse) => {

packages/desktop/src/providers/StreamProvider.tsx

@@ -18,3 +18,48 @@
  *
  * listen for any calls to me, as well as any answers back to me
  */
+
+import React, { useEffect } from 'react';
+import Peer from 'simple-peer';
+import useRealTimeRooms from './RealTimeRoomProvider';
+import useAuth from './AuthProvider';
+import { useImmer } from 'use-immer';
+
+type PeerMap = {
+  [userId: string]: Peer;
+};
+interface IStreamProvider {
+  peerMap: PeerMap;
+}
+
+const StreamProviderContext = React.createContext<IStreamProvider>({
+  peerMap: {},
+});
+
+export function StreamProvider({ children }: { children: React.ReactChild }) {
+  const { roomsMap } = useRealTimeRooms();
+  const { user } = useAuth();
+
+  const [peerMap, setPeerMap] = useImmer<PeerMap>({});
+
+  useEffect(() => {
+    // get distinct peers that we need to build a connection with
+    const userIdsSet = new Set<string>();
+
+    Object.values(roomsMap).forEach((line) => {
+      if (!line.tunedInMemberIds?.includes(user._id.toString())) {
+        return;
+      }
+
+      line.tunedInMemberIds.forEach((tunedUserId) => userIdsSet.add(tunedUserId));
+    });
+
+    console.log(userIdsSet);
+
+    // go call all of them
+  }, [user, roomsMap]);
+
+  return (
+    <StreamProviderContext.Provider value={{ peerMap }}>{children}</StreamProviderContext.Provider>
+  );
+}

packages/desktop/src/tree/electronApp.tsx

@@ -7,6 +7,7 @@ import { ElectronProvider } from '../providers/ElectronProvider';
 import { SocketProvider } from '../providers/SocketProvider';
 import ProtectedRoute from './protected/ProtectedRoute';
 import Terminal from './protected/terminal/Terminal';
+import { StreamProvider } from '../providers/StreamProvider';
 
 export default function ElectronApp() {
   return (
@@ -16,7 +17,9 @@ export default function ElectronApp() {
           <SocketProvider>
             <RoomsProvider>
               <RealTimeRoomProvider>
-                <Terminal />
+                <StreamProvider>
+                  <Terminal />
+                </StreamProvider>
               </RealTimeRoomProvider>
             </RoomsProvider>
           </SocketProvider>