From e9fd74c82c8ba02ac2ba71f7ba8415666fb9e073 Mon Sep 17 00:00:00 2001
From: Timo K <toger5@hotmail.de>
Date: Thu, 28 Aug 2025 10:34:43 +0200
Subject: [PATCH] add local storage + more readable + remoteParticipants + use
 publishingParticipants

Signed-off-by: Timo K <toger5@hotmail.de>
---
 src/rtcSessionHelpers.ts   | 10 ++++++++++
 src/state/CallViewModel.ts | 39 +++++++++++++++++++++++++++-----------
 2 files changed, 38 insertions(+), 11 deletions(-)

diff --git a/src/rtcSessionHelpers.ts b/src/rtcSessionHelpers.ts
index c08fcd40..07cc49fc 100644
--- a/src/rtcSessionHelpers.ts
+++ b/src/rtcSessionHelpers.ts
@@ -44,6 +44,16 @@ async function makeFocusInternal(
 
   // Prioritize the .well-known/matrix/client, if available, over the configured SFU
   const domain = rtcSession.room.client.getDomain();
+  if (localStorage.getItem("timo-focus-url")) {
+    const timoFocusUrl = JSON.parse(localStorage.getItem("timo-focus-url")!);
+    const focusFromUrl: LivekitFocus = {
+      type: "livekit",
+      livekit_service_url: timoFocusUrl,
+      livekit_alias: livekitAlias,
+    };
+    logger.log("Using LiveKit focus from localStorage: ", timoFocusUrl);
+    return focusFromUrl;
+  }
   if (domain) {
     // we use AutoDiscovery instead of relying on the MatrixClient having already
     // been fully configured and started
diff --git a/src/state/CallViewModel.ts b/src/state/CallViewModel.ts
index 51bf2134..a39108ac 100644
--- a/src/state/CallViewModel.ts
+++ b/src/state/CallViewModel.ts
@@ -55,7 +55,7 @@ import { logger } from "matrix-js-sdk/lib/logger";
 import {
   type CallMembership,
   isLivekitFocusConfig,
-  LivekitFocusConfig,
+  type LivekitFocusConfig,
   type MatrixRTCSession,
   MatrixRTCSessionEvent,
   MembershipManagerEvent,
@@ -478,7 +478,7 @@ class Connection {
     this.stopped = true;
   }
 
-  public readonly participantsIncludingJustSubscribers$ = this.scope.behavior(
+  public readonly participantsIncludingSubscribers$ = this.scope.behavior(
     connectedParticipantsObserver(this.livekitRoom),
     [],
   );
@@ -547,12 +547,14 @@ export class CallViewModel extends ViewModel {
       ),
   );
 
-  private readonly memberships$ = fromEvent(
-    this.matrixRTCSession,
-    MatrixRTCSessionEvent.MembershipsChanged,
-  ).pipe(
-    startWith(null),
-    map(() => this.matrixRTCSession.memberships),
+  private readonly memberships$ = this.scope.behavior(
+    fromEvent(
+      this.matrixRTCSession,
+      MatrixRTCSessionEvent.MembershipsChanged,
+    ).pipe(
+      startWith(null),
+      map(() => this.matrixRTCSession.memberships),
+    ),
   );
 
   private readonly foci$ = this.memberships$.pipe(
@@ -702,9 +704,24 @@ export class CallViewModel extends ViewModel {
    * The RemoteParticipants including those that are being "held" on the screen
    */
   private readonly remoteParticipants$ = this.scope
-    .behavior<
-      RemoteParticipant[]
-    >(combineLatest([this.localConnection, this.remoteConnections$], (localConnection, remoteConnections) => combineLatest([localConnection.participantsIncludingJustSubscribers$, ...[...remoteConnections.values()].map((c) => c.participantsIncludingJustSubscribers$)], (...ps) => ps.flat(1))).pipe(switchAll(), startWith([])))
+    .behavior<RemoteParticipant[]>(
+      combineLatest(
+        [this.localConnection, this.remoteConnections$],
+        (localConnection, remoteConnections) => {
+          const remoteConnectionsParticipants = [
+            ...remoteConnections.values(),
+          ].map((c) => c.publishingParticipants$(this.memberships$));
+
+          return combineLatest(
+            [
+              localConnection.publishingParticipants$(this.memberships$),
+              ...remoteConnectionsParticipants,
+            ],
+            (...ps) => ps.flat(1),
+          );
+        },
+      ).pipe(switchAll(), startWith([])),
+    )
     .pipe(pauseWhen(this.pretendToBeDisconnected$));
 
   /**