send client spectating broadcasts on connect for bookkeeping

src/broadcast/spectate.worker.ts

@@ -17,6 +17,7 @@ interface Methods {
   dolphinClosed(playbackId: string): Promise<void>;
   connect(authToken: string): Promise<void>;
   refreshBroadcastList(): Promise<void>;
+  getOpenBroadcasts(): Promise<{ broadcastId: string; dolphinId: string }[]>;
   getLogObservable(): Observable<string>;
   getErrorObservable(): Observable<Error | string>;
   getBroadcastListObservable(): Observable<BroadcasterItem[]>;
@@ -91,6 +92,9 @@ const methods: WorkerSpec = {
   async refreshBroadcastList(): Promise<void> {
     await spectateManager.refreshBroadcastList();
   },
+  async getOpenBroadcasts() {
+    return await spectateManager.getOpenBroadcasts();
+  },
   getLogObservable(): Observable<string> {
     return Observable.from(logSubject);
   },

src/broadcast/spectate_manager.ts

@@ -297,4 +297,11 @@ export class SpectateManager extends EventEmitter {
 
     this.stopWatchingBroadcast(broadcastInfo.broadcastId);
   }
+
+  public getOpenBroadcasts() {
+    return Object.values(this.openBroadcasts).map((value) => ({
+      broadcastId: value.broadcastId,
+      dolphinId: value.dolphinId,
+    }));
+  }
 }

src/broadcast/types.ts

@@ -90,6 +90,7 @@ export interface SpectateController {
   dolphinClosed(playbackId: string): Promise<void>;
   connect(authToken: string): Promise<void>;
   refreshBroadcastList(): Promise<void>;
+  getOpenBroadcasts(): Promise<{ broadcastId: string; dolphinId: string }[]>;
   getBroadcastListObservable(): Observable<BroadcasterItem[]>;
   getSpectateDetailsObservable(): Observable<{ playbackId: string; filePath: string; broadcasterName: string }>;
   getGameEndObservable(): Observable<string>;

src/remote/remote_server.ts

@@ -145,6 +145,12 @@ export class RemoteServer {
           });
           this.connection = newConnection;
           ipc_remoteStateEvent.main!.trigger({ connected: true, started: true }).catch(log.error);
+          this.connection.sendUTF(
+            JSON.stringify({
+              op: "spectating-broadcasts-event",
+              spectatingBroadcasts: await this.spectateController!.getOpenBroadcasts(),
+            }),
+          );
         } else {
           request.reject();
         }