explore more error behavior

.eslintrc.cjs

@@ -43,29 +43,6 @@ module.exports = {
     // To encourage good usage of RxJS:
     "rxjs/no-exposed-subjects": "error",
     "rxjs/finnish": ["error", { names: { "^this$": false } }],
-    "no-restricted-imports": [
-      "error",
-      {
-        paths: ["matrix-widget-api", "matrix-js-sdk"].flatMap((lib) =>
-          ["src", "src/", "src/index", "lib", "lib/", "lib/index"]
-            .map((path) => `${lib}/${path}`)
-            .map((name) => ({ name, message: `Please use ${lib} instead` })),
-        ),
-        patterns: [
-          ...["matrix-widget-api"].map((lib) => ({
-            group: ["src", "src/", "src/**", "lib", "lib/", "lib/**"].map(
-              (path) => `${lib}/${path}`,
-            ),
-            message: `Please use ${lib} instead`,
-          })),
-          // XXX: We use /lib in lots of places, so allow for now.
-          ...["matrix-js-sdk"].map((lib) => ({
-            group: ["src", "src/", "src/**"].map((path) => `${lib}/${path}`),
-            message: `Please use ${lib} instead`,
-          })),
-        ],
-      },
-    ],
   },
   overrides: [
     {

.github/workflows/build-and-publish-docker.yaml

@@ -23,7 +23,7 @@ jobs:
       packages: write
     steps:
       - name: Check it out
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
 
       - name: 📥 Download artifact
         uses: actions/download-artifact@d3f86a106a0bac45b974a628896c90dbdf5c8093 # v4
@@ -42,7 +42,7 @@ jobs:
 
       - name: Extract metadata (tags, labels) for Docker
         id: meta
-        uses: docker/metadata-action@318604b99e75e41977312d83839a89be02ca4893 # v5.9.0
+        uses: docker/metadata-action@c1e51972afc2121e065aed6d45c65596fe445f3f # v5.8.0
         with:
           images: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}
           tags: ${{ inputs.docker_tags}}

.github/workflows/build-element-call.yaml

@@ -32,7 +32,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout code
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
       - name: Enable Corepack
         run: corepack enable
       - name: Yarn cache

.github/workflows/lint.yaml

@@ -7,7 +7,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout code
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
       - name: Enable Corepack
         run: corepack enable
       - name: Yarn cache

.github/workflows/publish-embedded-packages.yaml

@@ -85,7 +85,7 @@ jobs:
         run: find ${{ env.FILENAME_PREFIX }} -type f -print0 | sort -z | xargs -0 sha256sum | tee ${{ env.FILENAME_PREFIX }}.sha256
       - name: Upload
         if: ${{ needs.versioning.outputs.DRY_RUN == 'false' }}
-        uses: softprops/action-gh-release@a06a81a03ee405af7f2048a818ed3f03bbf83c7b # v2
+        uses: softprops/action-gh-release@aec2ec56f94eb8180ceec724245f64ef008b89f5 # v2
         with:
           files: |
             ${{ env.FILENAME_PREFIX }}.tar.gz
@@ -100,10 +100,10 @@ jobs:
       ARTIFACT_VERSION: ${{ steps.artifact_version.outputs.ARTIFACT_VERSION }}
     permissions:
       contents: read
-      id-token: write # Allow npm to authenticate as a trusted publisher
+      id-token: write # required for the provenance flag on npm publish
     steps:
       - name: Checkout
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
 
       - name: 📥 Download built element-call artifact
         uses: actions/download-artifact@d3f86a106a0bac45b974a628896c90dbdf5c8093 # v4
@@ -126,6 +126,8 @@ jobs:
           npm version ${{ needs.versioning.outputs.PREFIXED_VERSION }} --no-git-tag-version
           echo "ARTIFACT_VERSION=$(jq '.version' --raw-output package.json)" >> "$GITHUB_ENV"
           npm publish --provenance --access public --tag ${{ needs.versioning.outputs.TAG }} ${{ needs.versioning.outputs.DRY_RUN == 'true' && '--dry-run' || '' }}
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_RELEASE_TOKEN }}
 
       - id: artifact_version
         name: Output artifact version
@@ -142,7 +144,7 @@ jobs:
       contents: read
     steps:
       - name: Checkout
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
 
       - name: 📥 Download built element-call artifact
         uses: actions/download-artifact@d3f86a106a0bac45b974a628896c90dbdf5c8093 # v4
@@ -197,7 +199,7 @@ jobs:
       contents: read
     steps:
       - name: Checkout
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
         with:
           path: element-call
 
@@ -210,7 +212,7 @@ jobs:
           path: element-call/embedded/ios/Sources/dist
 
       - name: Checkout element-call-swift
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
         with:
           repository: element-hq/element-call-swift
           path: element-call-swift
@@ -262,7 +264,7 @@ jobs:
           echo "iOS: ${{ needs.publish_ios.outputs.ARTIFACT_VERSION }}"
       - name: Add release notes
         if: ${{ needs.versioning.outputs.DRY_RUN == 'false' }}
-        uses: softprops/action-gh-release@a06a81a03ee405af7f2048a818ed3f03bbf83c7b # v2
+        uses: softprops/action-gh-release@aec2ec56f94eb8180ceec724245f64ef008b89f5 # v2
         with:
           append_body: true
           body: |

.github/workflows/publish.yaml

@@ -42,7 +42,7 @@ jobs:
       - name: Create Checksum
         run: find ${{ env.FILENAME_PREFIX }} -type f -print0 | sort -z | xargs -0 sha256sum | tee ${{ env.FILENAME_PREFIX }}.sha256
       - name: Upload
-        uses: softprops/action-gh-release@a06a81a03ee405af7f2048a818ed3f03bbf83c7b # v2
+        uses: softprops/action-gh-release@aec2ec56f94eb8180ceec724245f64ef008b89f5 # v2
         with:
           files: |
             ${{ env.FILENAME_PREFIX }}.tar.gz
@@ -68,7 +68,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Add release note
-        uses: softprops/action-gh-release@a06a81a03ee405af7f2048a818ed3f03bbf83c7b # v2
+        uses: softprops/action-gh-release@aec2ec56f94eb8180ceec724245f64ef008b89f5 # v2
         with:
           append_body: true
           body: |

.github/workflows/test.yaml

@@ -9,7 +9,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout code
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
       - name: Enable Corepack
         run: corepack enable
       - name: Yarn cache
@@ -33,7 +33,7 @@ jobs:
     timeout-minutes: 60
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+      - uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
       - name: Enable Corepack
         run: corepack enable
       - uses: actions/setup-node@49933ea5288caeca8642d1e84afbd3f7d6820020 # v4

.github/workflows/translations-download.yaml

@@ -13,7 +13,7 @@ jobs:
 
     steps:
       - name: Checkout the code
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
 
       - name: Enable Corepack
         run: corepack enable
@@ -42,7 +42,7 @@ jobs:
 
       - name: Create Pull Request
         id: cpr
-        uses: peter-evans/create-pull-request@84ae59a2cdc2258d6fa0732dd66352dddae2a412 # v7.0.9
+        uses: peter-evans/create-pull-request@271a8d0340265f705b14b6d32b9829c1cb33d45e # v7.0.8
         with:
           token: ${{ secrets.ELEMENT_BOT_TOKEN }}
           branch: actions/localazy-download

.github/workflows/translations-upload.yaml

@@ -14,7 +14,7 @@ jobs:
 
     steps:
       - name: Checkout the code
-        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5 # v4
+        uses: actions/checkout@08eba0b27e820071cde6df949e0beb9ba4906955 # v4
 
       - name: Upload
         uses: localazy/upload@27e6b5c0fddf4551596b42226b1c24124335d24a # v1

.node-version

@@ -1 +1 @@
-24
+22

codecov.yaml

@@ -13,6 +13,7 @@ coverage:
         informational: true
     patch:
       default:
-        # Enforce 80% coverage on all lines that a PR
+        # Encourage (but don't enforce) 80% coverage on all lines that a PR
         # touches
         target: 80%
+        informational: true

config/config_netlify_preview.json

@@ -18,7 +18,7 @@
     "api_host": "https://posthog-element-call.element.io"
   },
   "rageshake": {
-    "submit_url": "https://rageshakes.element.io/api/submit"
+    "submit_url": "https://element.io/bugreports/submit"
   },
   "sentry": {
     "environment": "netlify-pr-preview",

docs/self-hosting.md

@@ -136,8 +136,8 @@ handle @jwt_service {
   reverse_proxy http://[::1]:8080 {
     header_up Host {host}
     header_up X-Forwarded-Server {host}
-    header_up X-Real-IP {remote_host}
-    header_up X-Forwarded-For {remote_host}
+    header_up X-Real-IP {remote_addr}
+    header_up X-Forwarded-For {remote_addr}
   }
 }
 
@@ -146,8 +146,8 @@ handle {
   reverse_proxy http://localhost:7880 {
     header_up Host {host}
     header_up X-Forwarded-Server {host}
-    header_up X-Real-IP {remote_host}
-    header_up X-Forwarded-For {remote_host}
+    header_up X-Real-IP {remote_addr}
+    header_up X-Forwarded-For {remote_addr}
   }
 }
 ```

docs/url-params.md

@@ -96,6 +96,6 @@ These parameters are only supported in the [embedded](./embedded-standalone.md)
 | -------------------- | -------------------------------------------------------------------------- | -------- | ---------------------------------------------------------------------------------------------------------------------------------- |
 | `posthogApiHost`     | Posthog server URL                                                         | No       | e.g. `https://posthog-element-call.element.io`. Only supported in embedded package. In full package the value from config is used. |
 | `posthogApiKey`      | Posthog project API key                                                    | No       | Only supported in embedded package. In full package the value from config is used.                                                 |
-| `rageshakeSubmitUrl` | Rageshake server URL endpoint                                              | No       | e.g. `https://rageshakes.element.io/api/submit`. In full package the value from config is used.                                    |
+| `rageshakeSubmitUrl` | Rageshake server URL endpoint                                              | No       | e.g. `https://element.io/bugreports/submit`. In full package the value from config is used.                                        |
 | `sentryDsn`          | Sentry [DSN](https://docs.sentry.io/concepts/key-terms/dsn-explainer/)     | No       | In full package the value from config is used.                                                                                     |
 | `sentryEnvironment`  | Sentry [environment](https://docs.sentry.io/concepts/key-terms/key-terms/) | No       | In full package the value from config is used.                                                                                     |

embedded/android/gradle/libs.versions.toml

@@ -2,11 +2,11 @@
 # https://docs.gradle.org/current/userguide/platforms.html#sub::toml-dependencies-format
 
 [versions]
-android_gradle_plugin = "8.13.1"
+android_gradle_plugin = "8.11.1"
 
 [libraries]
 android_gradle_plugin = { module = "com.android.tools.build:gradle", version.ref = "android_gradle_plugin" }
 
 [plugins]
 android_library = { id = "com.android.library", version.ref = "android_gradle_plugin" }
-maven_publish = { id = "com.vanniktech.maven.publish", version = "0.35.0" }
+maven_publish = { id = "com.vanniktech.maven.publish", version = "0.34.0" }

locales/en/app.json

@@ -64,14 +64,6 @@
   "developer_mode": {
     "always_show_iphone_earpiece": "Show iPhone earpiece option on all platforms",
     "crypto_version": "Crypto version: {{version}}",
-    "custom_livekit_url": {
-      "current_url": "Currently set to: ",
-      "from_config": "Currently, no overwrite is set. Url from well-known or config is used.",
-      "label": "Custom Livekit-url",
-      "reset": "Reset overwrite",
-      "save": "Save",
-      "saving": "Saving..."
-    },
     "debug_tile_layout_label": "Debug tile layout",
     "device_id": "Device ID: {{id}}",
     "duplicate_tiles_label": "Number of additional tile copies per participant",
@@ -108,14 +100,11 @@
     "connection_lost_description": "You were disconnected from the call.",
     "e2ee_unsupported": "Incompatible browser",
     "e2ee_unsupported_description": "Your web browser does not support encrypted calls. Supported browsers include Chrome, Safari, and Firefox 117+.",
-    "failed_to_start_livekit": "Failed to start Livekit connection",
     "generic": "Something went wrong",
     "generic_description": "Submitting debug logs will help us track down the problem.",
     "insufficient_capacity": "Insufficient capacity",
     "insufficient_capacity_description": "The server has reached its maximum capacity and you cannot join the call at this time. Try again later, or contact your server admin if the problem persists.",
     "matrix_rtc_transport_missing": "The server is not configured to work with {{brand}}. Please contact your server admin (Domain: {{domain}}, Error Code: {{ errorCode }}).",
-    "membership_manager": "Membership Manager Error",
-    "membership_manager_description": "The Membership Manager had to shut down. This is caused by many consequtive failed network requests.",
     "open_elsewhere": "Opened in another tab",
     "open_elsewhere_description": "{{brand}} has been opened in another tab. If that doesn't sound right, try reloading the page.",
     "room_creation_restricted": "Failed to create call",

package.json

@@ -71,7 +71,7 @@
     "@types/grecaptcha": "^3.0.9",
     "@types/jsdom": "^21.1.7",
     "@types/lodash-es": "^4.17.12",
-    "@types/node": "^24.0.0",
+    "@types/node": "^22.0.0",
     "@types/pako": "^2.0.3",
     "@types/qrcode": "^1.5.5",
     "@types/react": "^19.0.0",
@@ -109,8 +109,8 @@
     "livekit-client": "^2.13.0",
     "lodash-es": "^4.17.21",
     "loglevel": "^1.9.1",
-    "matrix-js-sdk": "^39.2.0",
-    "matrix-widget-api": "^1.14.0",
+    "matrix-js-sdk": "github:matrix-org/matrix-js-sdk#head=toger5/sticky-events&commit=e7f5bec51b6f70501a025b79fe5021c933385b21",
+    "matrix-widget-api": "^1.13.0",
     "normalize.css": "^8.0.1",
     "observable-hooks": "^4.2.3",
     "pako": "^2.0.4",

playwright/errors.spec.ts

@@ -75,12 +75,7 @@ test("Should automatically retry non fatal JWT errors", async ({
 
 test("Should show error screen if call creation is restricted", async ({
   page,
-  browserName,
 }) => {
-  test.skip(
-    browserName === "firefox",
-    "The is test is not working on firefox CI environment.",
-  );
   await page.goto("/");
 
   // We need the socket connection to fail, but this cannot be done by using the websocket route.

playwright/fixtures/widget-user.ts

@@ -159,11 +159,7 @@ export const widgetTest = test.extend<MyFixtures>({
     } = await registerUser(browser, userB);
 
     // Invite the second user
-    await ewPage1
-      .getByRole("navigation", { name: "Room list" })
-      .getByRole("button", { name: "New conversation" })
-      .click();
-
+    await ewPage1.getByRole("button", { name: "Add", exact: true }).click();
     await ewPage1.getByRole("menuitem", { name: "New Room" }).click();
     await ewPage1.getByRole("textbox", { name: "Name" }).fill("Welcome Room");
     await ewPage1.getByRole("button", { name: "Create room" }).click();

src/UrlParams.test.ts

@@ -332,42 +332,6 @@ describe("UrlParams", () => {
       expect(computeUrlParams("?intent=join_existing").skipLobby).toBe(false);
     });
   });
-
-  describe("noiseSuppression", () => {
-    it("defaults to true", () => {
-      expect(computeUrlParams().noiseSuppression).toBe(true);
-    });
-
-    it("is parsed", () => {
-      expect(
-        computeUrlParams("?intent=start_call&noiseSuppression=true")
-          .noiseSuppression,
-      ).toBe(true);
-      expect(
-        computeUrlParams("?intent=start_call&noiseSuppression&bar=foo")
-          .noiseSuppression,
-      ).toBe(true);
-      expect(computeUrlParams("?noiseSuppression=false").noiseSuppression).toBe(
-        false,
-      );
-    });
-  });
-
-  describe("echoCancellation", () => {
-    it("defaults to true", () => {
-      expect(computeUrlParams().echoCancellation).toBe(true);
-    });
-
-    it("is parsed", () => {
-      expect(computeUrlParams("?echoCancellation=true").echoCancellation).toBe(
-        true,
-      );
-      expect(computeUrlParams("?echoCancellation=false").echoCancellation).toBe(
-        false,
-      );
-    });
-  });
-
   describe("header", () => {
     it("uses header if provided", () => {
       expect(computeUrlParams("?header=app_bar&hideHeader=true").header).toBe(

src/UrlParams.ts

@@ -233,17 +233,6 @@ export interface UrlConfiguration {
    */
   waitForCallPickup: boolean;
 
-  /**
-   * Whether to enable echo cancellation for audio capture.
-   * Defaults to true.
-   */
-  echoCancellation?: boolean;
-  /**
-   * Whether to enable noise suppression for audio capture.
-   * Defaults to true.
-   */
-  noiseSuppression?: boolean;
-
   callIntent?: RTCCallIntent;
 }
 interface IntentAndPlatformDerivedConfiguration {
@@ -536,8 +525,6 @@ export const computeUrlParams = (search = "", hash = ""): UrlParams => {
     ]),
     waitForCallPickup: parser.getFlag("waitForCallPickup"),
     autoLeaveWhenOthersLeft: parser.getFlag("autoLeave"),
-    noiseSuppression: parser.getFlagParam("noiseSuppression", true),
-    echoCancellation: parser.getFlagParam("echoCancellation", true),
   };
 
   // Log the final configuration for debugging purposes.

src/config/ConfigOptions.ts

@@ -122,7 +122,7 @@ export interface ConfigOptions {
     delayed_leave_event_delay_ms?: number;
 
     /**
-     * The time (in milliseconds) after which we consider a delayed event restart http request to have failed.
+     * The time (in milliseconds) after which a we consider a delayed event restart http request to have failed.
      * Setting this to a lower value will result in more frequent retries but also a higher chance of failiour.
      *
      * In the presence of network packet loss (hurting TCP connections), the custom delayedEventRestartLocalTimeoutMs

src/livekit/openIDSFU.ts

@@ -21,16 +21,7 @@ export type OpenIDClientParts = Pick<
   MatrixClient,
   "getOpenIdToken" | "getDeviceId"
 >;
-/**
- * Gets a bearer token from the homeserver and then use it to authenticate
- * to the matrix RTC backend in order to get acces to the SFU.
- * It has built-in retry for calls to the homeserver with a backoff policy.
- * @param client
- * @param serviceUrl
- * @param matrixRoomId
- * @returns Object containing the token information
- * @throws FailToGetOpenIdToken
- */
+
 export async function getSFUConfigWithOpenID(
   client: OpenIDClientParts,
   serviceUrl: string,

src/reactions/RaisedHandIndicator.test.tsx

@@ -5,7 +5,7 @@ SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.
 */
 
-import { beforeEach, describe, expect, test, vi } from "vitest";
+import { describe, expect, test } from "vitest";
 import { render, configure } from "@testing-library/react";
 
 import { RaisedHandIndicator } from "./RaisedHandIndicator";
@@ -15,13 +15,6 @@ configure({
 });
 
 describe("RaisedHandIndicator", () => {
-  const fixedTime = new Date("2025-01-01T12:00:00.000Z");
-
-  beforeEach(() => {
-    vi.useFakeTimers();
-    vi.setSystemTime(fixedTime);
-  });
-
   test("renders nothing when no hand has been raised", () => {
     const { container } = render(<RaisedHandIndicator />);
     expect(container.firstChild).toBeNull();

src/reactions/__snapshots__/RaisedHandIndicator.test.tsx.snap

@@ -15,7 +15,7 @@ exports[`RaisedHandIndicator > renders a smaller indicator when miniature is spe
     </span>
   </div>
   <p>
-    00:00
+    00:01
   </p>
 </div>
 `;
@@ -35,7 +35,7 @@ exports[`RaisedHandIndicator > renders an indicator when a hand has been raised
     </span>
   </div>
   <p>
-    00:00
+    00:01
   </p>
 </div>
 `;
@@ -55,7 +55,7 @@ exports[`RaisedHandIndicator > renders an indicator when a hand has been raised
     </span>
   </div>
   <p>
-    01:00
+    01:01
   </p>
 </div>
 `;

src/room/GroupCallErrorBoundary.tsx

@@ -22,7 +22,6 @@ import {
   WebBrowserIcon,
 } from "@vector-im/compound-design-tokens/assets/web/icons";
 import { Button } from "@vector-im/compound-web";
-import { logger } from "matrix-js-sdk/lib/logger";
 
 import {
   ConnectionLostError,
@@ -54,7 +53,7 @@ const ErrorPage: FC<ErrorPageProps> = ({
   widget,
 }: ErrorPageProps): ReactElement => {
   const { t } = useTranslation();
-  logger.error("Error boundary caught:", error);
+
   let icon: ComponentType<SVGAttributes<SVGElement>>;
   switch (error.category) {
     case ErrorCategory.CONFIGURATION_ISSUE:

src/room/GroupCallView.test.tsx

@@ -29,7 +29,6 @@ import userEvent from "@testing-library/user-event";
 import { type RelationsContainer } from "matrix-js-sdk/lib/models/relations-container";
 import { useState } from "react";
 import { TooltipProvider } from "@vector-im/compound-web";
-import { type ITransport } from "matrix-widget-api";
 
 import { prefetchSounds } from "../soundUtils";
 import { useAudioContext } from "../useAudioContext";
@@ -44,7 +43,7 @@ import {
   MockRTCSession,
 } from "../utils/test";
 import { GroupCallView } from "./GroupCallView";
-import { ElementWidgetActions, type WidgetHelpers } from "../widget";
+import { type WidgetHelpers } from "../widget";
 import { LazyEventEmitter } from "../LazyEventEmitter";
 import { MatrixRTCTransportMissingError } from "../utils/errors";
 import { ProcessorProvider } from "../livekit/TrackProcessorContext";
@@ -113,10 +112,6 @@ beforeEach(() => {
       return (
         <div>
           <button onClick={() => onLeave("user")}>Leave</button>
-          <button onClick={() => onLeave("allOthersLeft")}>
-            SimulateOtherLeft
-          </button>
-          <button onClick={() => onLeave("error")}>SimulateErrorLeft</button>
         </div>
       );
     },
@@ -248,112 +243,6 @@ test.skip("GroupCallView plays a leave sound synchronously in widget mode", asyn
   expect(leaveRTCSession).toHaveBeenCalledOnce();
 });
 
-test.skip("Should close widget when all other left and have time to play a sound", async () => {
-  const user = userEvent.setup();
-  const widgetClosedCalled = Promise.withResolvers<void>();
-  const widgetSendMock = vi.fn().mockImplementation((action: string) => {
-    if (action === ElementWidgetActions.Close) {
-      widgetClosedCalled.resolve();
-    }
-  });
-  const widgetStopMock = vi.fn().mockResolvedValue(undefined);
-  const widget = {
-    api: {
-      setAlwaysOnScreen: vi.fn().mockResolvedValue(true),
-      transport: {
-        send: widgetSendMock,
-        reply: vi.fn().mockResolvedValue(undefined),
-        stop: widgetStopMock,
-      } as unknown as ITransport,
-    } as Partial<WidgetHelpers["api"]>,
-    lazyActions: new LazyEventEmitter(),
-  };
-  const resolvePlaySound = Promise.withResolvers<void>();
-  playSound = vi.fn().mockReturnValue(resolvePlaySound);
-  (useAudioContext as MockedFunction<typeof useAudioContext>).mockReturnValue({
-    playSound,
-    playSoundLooping: vitest.fn(),
-    soundDuration: {},
-  });
-
-  const { getByText } = createGroupCallView(widget as WidgetHelpers);
-  const leaveButton = getByText("SimulateOtherLeft");
-  await user.click(leaveButton);
-  await flushPromises();
-  expect(widgetSendMock).not.toHaveBeenCalled();
-  resolvePlaySound.resolve();
-  await flushPromises();
-
-  expect(playSound).toHaveBeenCalledWith("left");
-
-  await widgetClosedCalled.promise;
-  await flushPromises();
-  expect(widgetStopMock).toHaveBeenCalledOnce();
-});
-
-test("Should close widget when all other left", async () => {
-  const user = userEvent.setup();
-  const widgetClosedCalled = Promise.withResolvers<void>();
-  const widgetSendMock = vi.fn().mockImplementation((action: string) => {
-    if (action === ElementWidgetActions.Close) {
-      widgetClosedCalled.resolve();
-    }
-  });
-  const widgetStopMock = vi.fn().mockResolvedValue(undefined);
-  const widget = {
-    api: {
-      setAlwaysOnScreen: vi.fn().mockResolvedValue(true),
-      transport: {
-        send: widgetSendMock,
-        reply: vi.fn().mockResolvedValue(undefined),
-        stop: widgetStopMock,
-      } as unknown as ITransport,
-    } as Partial<WidgetHelpers["api"]>,
-    lazyActions: new LazyEventEmitter(),
-  };
-
-  const { getByText } = createGroupCallView(widget as WidgetHelpers);
-  const leaveButton = getByText("SimulateOtherLeft");
-  await user.click(leaveButton);
-  await flushPromises();
-
-  await widgetClosedCalled.promise;
-  await flushPromises();
-  expect(widgetStopMock).toHaveBeenCalledOnce();
-});
-
-test("Should not close widget when auto leave due to error", async () => {
-  const user = userEvent.setup();
-
-  const widgetStopMock = vi.fn().mockResolvedValue(undefined);
-  const widgetSendMock = vi.fn().mockResolvedValue(undefined);
-  const widget = {
-    api: {
-      setAlwaysOnScreen: vi.fn().mockResolvedValue(true),
-      transport: {
-        send: widgetSendMock,
-        reply: vi.fn().mockResolvedValue(undefined),
-        stop: widgetStopMock,
-      } as unknown as ITransport,
-    } as Partial<WidgetHelpers["api"]>,
-    lazyActions: new LazyEventEmitter(),
-  };
-
-  const alwaysOnScreenSpy = vi.spyOn(widget.api, "setAlwaysOnScreen");
-
-  const { getByText } = createGroupCallView(widget as WidgetHelpers);
-  const leaveButton = getByText("SimulateErrorLeft");
-  await user.click(leaveButton);
-  await flushPromises();
-
-  // When onLeft is called, we first set always on screen to false
-  await waitFor(() => expect(alwaysOnScreenSpy).toHaveBeenCalledWith(false));
-  await flushPromises();
-  // But then we do not close the widget automatically
-  expect(widgetStopMock).not.toHaveBeenCalledOnce();
-  expect(widgetSendMock).not.toHaveBeenCalledOnce();
-});
-
 test.skip("GroupCallView leaves the session when an error occurs", async () => {
   (ActiveCall as MockedFunction<typeof ActiveCall>).mockImplementation(() => {
     const [error, setError] = useState<Error | null>(null);

src/room/GroupCallView.tsx

@@ -159,7 +159,6 @@ export const GroupCallView: FC<Props> = ({
     };
   }, [rtcSession]);
 
-  // TODO move this into the callViewModel LocalMembership.ts
   useTypedEventEmitter(
     rtcSession,
     MatrixRTCSessionEvent.MembershipManagerError,
@@ -314,9 +313,7 @@ export const GroupCallView: FC<Props> = ({
   const navigate = useNavigate();
 
   const onLeft = useCallback(
-    (
-      reason: "timeout" | "user" | "allOthersLeft" | "decline" | "error",
-    ): void => {
+    (reason: "timeout" | "user" | "allOthersLeft" | "decline"): void => {
       let playSound: CallEventSounds = "left";
       if (reason === "timeout" || reason === "decline") playSound = reason;
 
@@ -369,7 +366,7 @@ export const GroupCallView: FC<Props> = ({
             }
             // On a normal user hangup we can shut down and close the widget. But if an
             // error occurs we should keep the widget open until the user reads it.
-            if (reason != "error" && !getUrlParams().returnToLobby) {
+            if (reason === "user" && !getUrlParams().returnToLobby) {
               try {
                 await widget.api.transport.send(ElementWidgetActions.Close, {});
               } catch (e) {
@@ -521,7 +518,8 @@ export const GroupCallView: FC<Props> = ({
       }}
       onError={
         (/**error*/) => {
-          if (rtcSession.isJoined()) onLeft("error");
+          // TODO this should not be "user". It needs a new case
+          if (rtcSession.isJoined()) onLeft("user");
         }
       }
     >

src/room/InCallView.tsx

@@ -115,9 +115,7 @@ export interface ActiveCallProps
   extends Omit<InCallViewProps, "vm" | "livekitRoom" | "connState"> {
   e2eeSystem: EncryptionSystem;
   // TODO refactor those reasons into an enum
-  onLeft: (
-    reason: "user" | "timeout" | "decline" | "allOthersLeft" | "error",
-  ) => void;
+  onLeft: (reason: "user" | "timeout" | "decline" | "allOthersLeft") => void;
 }
 
 export const ActiveCall: FC<ActiveCallProps> = (props) => {
@@ -146,8 +144,6 @@ export const ActiveCall: FC<ActiveCallProps> = (props) => {
       reactionsReader.reactions$,
       scope.behavior(trackProcessorState$),
     );
-    // TODO move this somewhere else once we use the callViewModel in the lobby as well!
-    vm.join();
     setVm(vm);
 
     vm.leave$.pipe(scope.bind()).subscribe(props.onLeft);
@@ -268,7 +264,7 @@ export const InCallView: FC<InCallViewProps> = ({
   const sharingScreen = useBehavior(vm.sharingScreen$);
 
   const ringOverlay = useBehavior(vm.ringOverlay$);
-  const fatalCallError = useBehavior(vm.fatalError$);
+  const fatalCallError = useBehavior(vm.configError$);
   // Stop the rendering and throw for the error boundary
   if (fatalCallError) throw fatalCallError;
 

src/settings/DeveloperSettingsTab.test.tsx

@@ -1,95 +0,0 @@
-/*
-Copyright 2025 New Vector Ltd.
-
-SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
-Please see LICENSE in the repository root for full details.
-*/
-
-import { describe, expect, it, vi } from "vitest";
-import { render, waitFor } from "@testing-library/react";
-
-import type { MatrixClient } from "matrix-js-sdk";
-import type { Room as LivekitRoom } from "livekit-client";
-import { DeveloperSettingsTab } from "./DeveloperSettingsTab";
-
-// Mock url params hook to avoid environment-dependent snapshot churn.
-vi.mock("../UrlParams", () => ({
-  useUrlParams: (): { mocked: boolean; answer: number } => ({
-    mocked: true,
-    answer: 42,
-  }),
-}));
-
-// Provide a minimal mock of a Livekit Room structure used by the component.
-function createMockLivekitRoom(
-  wsUrl: string,
-  serverInfo: object,
-  metadata: string,
-): { isLocal: boolean; url: string; room: LivekitRoom } {
-  const mockRoom = {
-    serverInfo,
-    metadata,
-    engine: { client: { ws: { url: wsUrl } } },
-  } as unknown as LivekitRoom;
-
-  return {
-    isLocal: true,
-    url: wsUrl,
-    room: mockRoom,
-  };
-}
-
-// Minimal MatrixClient mock with only the methods used by the component.
-function createMockMatrixClient(): MatrixClient {
-  return {
-    doesServerSupportUnstableFeature: vi.fn().mockResolvedValue(true), // ensure stickyEventsSupported eventually becomes true
-    getCrypto: (): { getVersion: () => string } | undefined => ({
-      getVersion: () => "crypto-1.0.0",
-    }),
-    getUserId: () => "@alice:example.org",
-    getDeviceId: () => "DEVICE123",
-  } as unknown as MatrixClient;
-}
-
-describe("DeveloperSettingsTab", () => {
-  it("renders and matches snapshot", async () => {
-    const client = createMockMatrixClient();
-
-    const livekitRooms: {
-      room: LivekitRoom;
-      url: string;
-      isLocal?: boolean;
-    }[] = [
-      createMockLivekitRoom(
-        "wss://local-sfu.example.org",
-        { region: "local", version: "1.2.3" },
-        "local-metadata",
-      ),
-      {
-        isLocal: false,
-        url: "wss://remote-sfu.example.org",
-        room: {
-          serverInfo: { region: "remote", version: "4.5.6" },
-          metadata: "remote-metadata",
-          engine: { client: { ws: { url: "wss://remote-sfu.example.org" } } },
-        } as unknown as LivekitRoom,
-      },
-    ];
-
-    const { container } = render(
-      <DeveloperSettingsTab
-        client={client}
-        livekitRooms={livekitRooms}
-        env={{ MY_MOCK_ENV: 10, ENV: "test" } as unknown as ImportMetaEnv}
-      />,
-    );
-
-    // Wait for the async sticky events feature check to resolve so the final UI
-    // (e.g. enabled Matrix_2_0 radio button) appears deterministically.
-    await waitFor(() =>
-      expect(client.doesServerSupportUnstableFeature).toHaveBeenCalled(),
-    );
-
-    expect(container).toMatchSnapshot();
-  });
-});

src/settings/DeveloperSettingsTab.tsx

@@ -11,8 +11,8 @@ import {
   useCallback,
   useEffect,
   useMemo,
-  useId,
   useState,
+  useId,
 } from "react";
 import { useTranslation } from "react-i18next";
 import {
@@ -21,7 +21,6 @@ import {
 } from "matrix-js-sdk";
 import { logger } from "matrix-js-sdk/lib/logger";
 import {
-  EditInPlace,
   Root as Form,
   Heading,
   HelpMessage,
@@ -39,7 +38,6 @@ import {
   muteAllAudio as muteAllAudioSetting,
   alwaysShowIphoneEarpiece as alwaysShowIphoneEarpieceSetting,
   matrixRTCMode as matrixRTCModeSetting,
-  customLivekitUrl as customLivekitUrlSetting,
   MatrixRTCMode,
 } from "./settings";
 import type { Room as LivekitRoom } from "livekit-client";
@@ -49,14 +47,9 @@ import { useUrlParams } from "../UrlParams";
 interface Props {
   client: MatrixClient;
   livekitRooms?: { room: LivekitRoom; url: string; isLocal?: boolean }[];
-  env: ImportMetaEnv;
 }
 
-export const DeveloperSettingsTab: FC<Props> = ({
-  client,
-  livekitRooms,
-  env,
-}) => {
+export const DeveloperSettingsTab: FC<Props> = ({ client, livekitRooms }) => {
   const { t } = useTranslation();
   const [duplicateTiles, setDuplicateTiles] = useSetting(duplicateTilesSetting);
   const [debugTileLayout, setDebugTileLayout] = useSetting(
@@ -92,15 +85,6 @@ export const DeveloperSettingsTab: FC<Props> = ({
     alwaysShowIphoneEarpieceSetting,
   );
 
-  const [customLivekitUrl, setCustomLivekitUrl] = useSetting(
-    customLivekitUrlSetting,
-  );
-  const [customLivekitUrlTextBuffer, setCustomLivekitUrlTextBuffer] =
-    useState(customLivekitUrl);
-  useEffect(() => {
-    setCustomLivekitUrlTextBuffer(customLivekitUrl);
-  }, [customLivekitUrl]);
-
   const [muteAllAudio, setMuteAllAudio] = useSetting(muteAllAudioSetting);
 
   const urlParams = useUrlParams();
@@ -117,7 +101,7 @@ export const DeveloperSettingsTab: FC<Props> = ({
   }, [livekitRooms]);
 
   return (
-    <>
+    <Form>
       <p>
         {t("developer_mode.hostname", {
           hostname: window.location.hostname || "unknown",
@@ -216,93 +200,55 @@ export const DeveloperSettingsTab: FC<Props> = ({
           )}
         />{" "}
       </FieldRow>
-      <EditInPlace
-        onSubmit={(e) => e.preventDefault()}
-        helpLabel={
-          customLivekitUrl === null
-            ? t("developer_mode.custom_livekit_url.from_config")
-            : t("developer_mode.custom_livekit_url.current_url") +
-              customLivekitUrl
-        }
-        label={t("developer_mode.custom_livekit_url.label")}
-        saveButtonLabel={t("developer_mode.custom_livekit_url.save")}
-        savingLabel={t("developer_mode.custom_livekit_url.saving")}
-        cancelButtonLabel={t("developer_mode.custom_livekit_url.reset")}
-        onSave={useCallback(
-          (e: React.FormEvent<HTMLFormElement>) => {
-            setCustomLivekitUrl(
-              customLivekitUrlTextBuffer === ""
-                ? null
-                : customLivekitUrlTextBuffer,
-            );
-          },
-          [setCustomLivekitUrl, customLivekitUrlTextBuffer],
-        )}
-        value={customLivekitUrlTextBuffer ?? ""}
-        onChange={useCallback(
-          (event: ChangeEvent<HTMLInputElement>): void => {
-            setCustomLivekitUrlTextBuffer(event.target.value);
-          },
-          [setCustomLivekitUrlTextBuffer],
-        )}
-        onCancel={useCallback(
-          (e: React.FormEvent<HTMLFormElement>) => {
-            setCustomLivekitUrl(null);
-          },
-          [setCustomLivekitUrl],
-        )}
-      />
       <Heading as="h3" type="body" weight="semibold" size="lg">
         {t("developer_mode.matrixRTCMode.title")}
       </Heading>
-      <Form>
-        <InlineField
-          name={matrixRTCModeRadioGroup}
-          control={
-            <RadioControl
-              checked={matrixRTCMode === MatrixRTCMode.Legacy}
-              value={MatrixRTCMode.Legacy}
-              onChange={onMatrixRTCModeChange}
-            />
-          }
-        >
-          <Label>{t("developer_mode.matrixRTCMode.Legacy.label")}</Label>
-          <HelpMessage>
-            {t("developer_mode.matrixRTCMode.Legacy.description")}
-          </HelpMessage>
-        </InlineField>
-        <InlineField
-          name={matrixRTCModeRadioGroup}
-          control={
-            <RadioControl
-              checked={matrixRTCMode === MatrixRTCMode.Compatibil}
-              value={MatrixRTCMode.Compatibil}
-              onChange={onMatrixRTCModeChange}
-            />
-          }
-        >
-          <Label>{t("developer_mode.matrixRTCMode.Comptibility.label")}</Label>
-          <HelpMessage>
-            {t("developer_mode.matrixRTCMode.Comptibility.description")}
-          </HelpMessage>
-        </InlineField>
-        <InlineField
-          name={matrixRTCModeRadioGroup}
-          control={
-            <RadioControl
-              checked={matrixRTCMode === MatrixRTCMode.Matrix_2_0}
-              value={MatrixRTCMode.Matrix_2_0}
-              disabled={!stickyEventsSupported}
-              onChange={onMatrixRTCModeChange}
-            />
-          }
-        >
-          <Label>{t("developer_mode.matrixRTCMode.Matrix_2_0.label")}</Label>
-          <HelpMessage>
-            {t("developer_mode.matrixRTCMode.Matrix_2_0.description")}
-          </HelpMessage>
-        </InlineField>
-      </Form>
+      <InlineField
+        name={matrixRTCModeRadioGroup}
+        control={
+          <RadioControl
+            checked={matrixRTCMode === MatrixRTCMode.Legacy}
+            value={MatrixRTCMode.Legacy}
+            onChange={onMatrixRTCModeChange}
+          />
+        }
+      >
+        <Label>{t("developer_mode.matrixRTCMode.Legacy.label")}</Label>
+        <HelpMessage>
+          {t("developer_mode.matrixRTCMode.Legacy.description")}
+        </HelpMessage>
+      </InlineField>
+      <InlineField
+        name={matrixRTCModeRadioGroup}
+        control={
+          <RadioControl
+            checked={matrixRTCMode === MatrixRTCMode.Compatibil}
+            value={MatrixRTCMode.Compatibil}
+            onChange={onMatrixRTCModeChange}
+          />
+        }
+      >
+        <Label>{t("developer_mode.matrixRTCMode.Comptibility.label")}</Label>
+        <HelpMessage>
+          {t("developer_mode.matrixRTCMode.Comptibility.description")}
+        </HelpMessage>
+      </InlineField>
+      <InlineField
+        name={matrixRTCModeRadioGroup}
+        control={
+          <RadioControl
+            checked={matrixRTCMode === MatrixRTCMode.Matrix_2_0}
+            value={MatrixRTCMode.Matrix_2_0}
+            disabled={!stickyEventsSupported}
+            onChange={onMatrixRTCModeChange}
+          />
+        }
+      >
+        <Label>{t("developer_mode.matrixRTCMode.Matrix_2_0.label")}</Label>
+        <HelpMessage>
+          {t("developer_mode.matrixRTCMode.Matrix_2_0.description")}
+        </HelpMessage>
+      </InlineField>
       {livekitRooms?.map((livekitRoom) => (
         <>
           <h3>
@@ -324,9 +270,9 @@ export const DeveloperSettingsTab: FC<Props> = ({
         </>
       ))}
       <p>{t("developer_mode.environment_variables")}</p>
-      <pre>{JSON.stringify(env, null, 2)}</pre>
+      <pre>{JSON.stringify(import.meta.env, null, 2)}</pre>
       <p>{t("developer_mode.url_params")}</p>
       <pre>{JSON.stringify(urlParams, null, 2)}</pre>
-    </>
+    </Form>
   );
 };

src/settings/SettingsModal.tsx

@@ -209,11 +209,7 @@ export const SettingsModal: FC<Props> = ({
     key: "developer",
     name: t("settings.developer_tab_title"),
     content: (
-      <DeveloperSettingsTab
-        env={import.meta.env}
-        client={client}
-        livekitRooms={livekitRooms}
-      />
+      <DeveloperSettingsTab client={client} livekitRooms={livekitRooms} />
     ),
   };
 

src/settings/__snapshots__/DeveloperSettingsTab.test.tsx.snap

@@ -1,411 +0,0 @@
-// Vitest Snapshot v1, https://vitest.dev/guide/snapshot.html
-
-exports[`DeveloperSettingsTab > renders and matches snapshot 1`] = `
-<div>
-  <p>
-    Hostname: localhost
-  </p>
-  <p>
-    Element Call version: dev
-  </p>
-  <p>
-    Crypto version: crypto-1.0.0
-  </p>
-  <p>
-    Matrix ID: @alice:example.org
-  </p>
-  <p>
-    Device ID: DEVICE123
-  </p>
-  <div
-    class="fieldRow"
-  >
-    <div
-      class="field inputField"
-    >
-      <input
-        aria-describedby="«r1»"
-        id="duplicateTiles"
-        min="0"
-        type="number"
-        value="0"
-      />
-      <label
-        for="duplicateTiles"
-      >
-        Number of additional tile copies per participant
-      </label>
-    </div>
-  </div>
-  <div
-    class="fieldRow"
-  >
-    <div
-      class="field checkboxField"
-    >
-      <input
-        aria-describedby="«r2»"
-        id="debugTileLayout"
-        type="checkbox"
-      />
-      <label
-        for="debugTileLayout"
-      >
-        <div
-          class="checkbox"
-        >
-          <svg
-            fill="none"
-            height="24"
-            stroke="#000"
-            stroke-linecap="round"
-            stroke-linejoin="round"
-            stroke-width="2"
-            viewBox="0 0 24 24"
-            width="24"
-            xmlns="http://www.w3.org/2000/svg"
-          >
-            <path
-              d="m20 6-11 11-5-5"
-            />
-          </svg>
-        </div>
-        Debug tile layout
-      </label>
-    </div>
-  </div>
-  <div
-    class="fieldRow"
-  >
-    <div
-      class="field checkboxField"
-    >
-      <input
-        aria-describedby="«r3»"
-        id="showConnectionStats"
-        type="checkbox"
-      />
-      <label
-        for="showConnectionStats"
-      >
-        <div
-          class="checkbox"
-        >
-          <svg
-            fill="none"
-            height="24"
-            stroke="#000"
-            stroke-linecap="round"
-            stroke-linejoin="round"
-            stroke-width="2"
-            viewBox="0 0 24 24"
-            width="24"
-            xmlns="http://www.w3.org/2000/svg"
-          >
-            <path
-              d="m20 6-11 11-5-5"
-            />
-          </svg>
-        </div>
-        Show connection statistics
-      </label>
-    </div>
-  </div>
-  <div
-    class="fieldRow"
-  >
-    <div
-      class="field checkboxField"
-    >
-      <input
-        aria-describedby="«r4»"
-        id="muteAllAudio"
-        type="checkbox"
-      />
-      <label
-        for="muteAllAudio"
-      >
-        <div
-          class="checkbox"
-        >
-          <svg
-            fill="none"
-            height="24"
-            stroke="#000"
-            stroke-linecap="round"
-            stroke-linejoin="round"
-            stroke-width="2"
-            viewBox="0 0 24 24"
-            width="24"
-            xmlns="http://www.w3.org/2000/svg"
-          >
-            <path
-              d="m20 6-11 11-5-5"
-            />
-          </svg>
-        </div>
-        Mute all audio (participants, reactions, join sounds)
-      </label>
-    </div>
-  </div>
-   
-  <div
-    class="fieldRow"
-  >
-    <div
-      class="field checkboxField"
-    >
-      <input
-        aria-describedby="«r5»"
-        id="alwaysShowIphoneEarpiece"
-        type="checkbox"
-      />
-      <label
-        for="alwaysShowIphoneEarpiece"
-      >
-        <div
-          class="checkbox"
-        >
-          <svg
-            fill="none"
-            height="24"
-            stroke="#000"
-            stroke-linecap="round"
-            stroke-linejoin="round"
-            stroke-width="2"
-            viewBox="0 0 24 24"
-            width="24"
-            xmlns="http://www.w3.org/2000/svg"
-          >
-            <path
-              d="m20 6-11 11-5-5"
-            />
-          </svg>
-        </div>
-        Show iPhone earpiece option on all platforms
-      </label>
-    </div>
-     
-  </div>
-  <form
-    class="_root_19upo_16"
-  >
-    <div
-      class="_field_19upo_26"
-    >
-      <label
-        class="_label_19upo_59"
-        for="radix-«r6»"
-      >
-        Custom Livekit-url
-      </label>
-      <div
-        class="_controls_17lij_8"
-      >
-        <input
-          aria-describedby="radix-«r7»"
-          class="_control_sqdq4_10"
-          id="radix-«r6»"
-          name="input"
-          title=""
-          value=""
-        />
-      </div>
-      <span
-        class="_message_19upo_85 _help-message_19upo_91"
-        id="radix-«r7»"
-      >
-        Currently, no overwrite is set. Url from well-known or config is used.
-      </span>
-    </div>
-  </form>
-  <h3
-    class="_typography_6v6n8_153 _font-body-lg-semibold_6v6n8_74"
-  >
-    MatrixRTC mode
-  </h3>
-  <form
-    class="_root_19upo_16"
-  >
-    <div
-      class="_inline-field_19upo_32"
-    >
-      <div
-        class="_inline-field-control_19upo_44"
-      >
-        <div
-          class="_container_1e0uz_10"
-        >
-          <input
-            aria-describedby="radix-«r9» radix-«rb» radix-«rd»"
-            checked=""
-            class="_input_1e0uz_18"
-            id="radix-«r8»"
-            name="«r0»"
-            title=""
-            type="radio"
-            value="legacy"
-          />
-          <div
-            class="_ui_1e0uz_19"
-          />
-        </div>
-      </div>
-      <div
-        class="_inline-field-body_19upo_38"
-      >
-        <label
-          class="_label_19upo_59"
-          for="radix-«r8»"
-        >
-          Legacy: state events & oldest membership SFU
-        </label>
-        <span
-          class="_message_19upo_85 _help-message_19upo_91"
-          id="radix-«r9»"
-        >
-          Compatible with old versions of EC that do not support multi SFU
-        </span>
-      </div>
-    </div>
-    <div
-      class="_inline-field_19upo_32"
-    >
-      <div
-        class="_inline-field-control_19upo_44"
-      >
-        <div
-          class="_container_1e0uz_10"
-        >
-          <input
-            aria-describedby="radix-«r9» radix-«rb» radix-«rd»"
-            class="_input_1e0uz_18"
-            id="radix-«ra»"
-            name="«r0»"
-            title=""
-            type="radio"
-            value="compatibil"
-          />
-          <div
-            class="_ui_1e0uz_19"
-          />
-        </div>
-      </div>
-      <div
-        class="_inline-field-body_19upo_38"
-      >
-        <label
-          class="_label_19upo_59"
-          for="radix-«ra»"
-        >
-          Compatibility: state events & multi SFU
-        </label>
-        <span
-          class="_message_19upo_85 _help-message_19upo_91"
-          id="radix-«rb»"
-        >
-          Compatible with homeservers that do not support sticky events (but all other EC clients are v0.17.0 or later)
-        </span>
-      </div>
-    </div>
-    <div
-      class="_inline-field_19upo_32"
-    >
-      <div
-        class="_inline-field-control_19upo_44"
-      >
-        <div
-          class="_container_1e0uz_10"
-        >
-          <input
-            aria-describedby="radix-«r9» radix-«rb» radix-«rd»"
-            class="_input_1e0uz_18"
-            id="radix-«rc»"
-            name="«r0»"
-            title=""
-            type="radio"
-            value="matrix_2_0"
-          />
-          <div
-            class="_ui_1e0uz_19"
-          />
-        </div>
-      </div>
-      <div
-        class="_inline-field-body_19upo_38"
-      >
-        <label
-          class="_label_19upo_59"
-          for="radix-«rc»"
-        >
-          Matrix 2.0: sticky events & multi SFU
-        </label>
-        <span
-          class="_message_19upo_85 _help-message_19upo_91"
-          id="radix-«rd»"
-        >
-          Compatible only with homservers supporting sticky events and all EC clients v0.17.0 or later
-        </span>
-      </div>
-    </div>
-  </form>
-  <h3>
-    LiveKit SFU: wss://local-sfu.example.org
-  </h3>
-  <p>
-    ws-url: 
-    wss://local-sfu.example.org/
-  </p>
-  <p>
-    LiveKit Server Info
-    (
-    local
-    )
-  </p>
-  <pre
-    class="pre"
-  >
-    {
-  "region": "local",
-  "version": "1.2.3"
-}
-    local-metadata
-  </pre>
-  <h3>
-    LiveKit SFU: wss://remote-sfu.example.org
-  </h3>
-  <p>
-    LiveKit Server Info
-    (
-    remote
-    )
-  </p>
-  <pre
-    class="pre"
-  >
-    {
-  "region": "remote",
-  "version": "4.5.6"
-}
-    remote-metadata
-  </pre>
-  <p>
-    Environment variables
-  </p>
-  <pre>
-    {
-  "MY_MOCK_ENV": 10,
-  "ENV": "test"
-}
-  </pre>
-  <p>
-    URL parameters
-  </p>
-  <pre>
-    {
-  "mocked": true,
-  "answer": 42
-}
-  </pre>
-</div>
-`;

src/settings/settings.ts

@@ -134,8 +134,3 @@ export const matrixRTCMode = new Setting<MatrixRTCMode>(
   "matrix-rtc-mode",
   MatrixRTCMode.Legacy,
 );
-
-export const customLivekitUrl = new Setting<string | null>(
-  "custom-livekit-url",
-  null,
-);

src/state/Behavior.ts

@@ -16,10 +16,7 @@ import { BehaviorSubject } from "rxjs";
  * distinction between Behaviors and Observables, see
  * https://monoid.dk/post/behaviors-and-streams-why-both/.
  */
-export type Behavior<T> = Omit<
-  BehaviorSubject<T>,
-  "next" | "observers" | "error"
->;
+export type Behavior<T> = Omit<BehaviorSubject<T>, "next" | "observers">;
 
 /**
  * Creates a Behavior which never changes in value.

src/state/CallViewModel/CallNotificationLifecycle.test.ts

@@ -1,5 +1,5 @@
 /*
-Copyright 2025 Element Creations Ltd.
+Copyright 2025 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.

src/state/CallViewModel/CallNotificationLifecycle.ts

@@ -1,5 +1,5 @@
 /*
-Copyright 2025 Element Creations Ltd.
+Copyright 2025 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.

src/state/CallViewModel/CallViewModel.test.ts

@@ -1,12 +1,12 @@
 /*
-Copyright 2025 Element Creations Ltd.
 Copyright 2024 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.
 */
 
-import { test, vi, onTestFinished, it, describe } from "vitest";
+import { test, vi, onTestFinished, it, describe, expect } from "vitest";
+import EventEmitter from "events";
 import {
   BehaviorSubject,
   combineLatest,
@@ -18,11 +18,12 @@ import {
   of,
   switchMap,
 } from "rxjs";
-import { SyncState } from "matrix-js-sdk";
+import { SyncState, type MatrixClient } from "matrix-js-sdk";
 import {
   ConnectionState,
   type LocalTrackPublication,
   type RemoteParticipant,
+  type Room as LivekitRoom,
 } from "livekit-client";
 import * as ComponentsCore from "@livekit/components-core";
 import {
@@ -34,18 +35,27 @@ import {
   type LivekitTransport,
 } from "matrix-js-sdk/lib/matrixrtc";
 import { deepCompare } from "matrix-js-sdk/lib/utils";
+import { AutoDiscovery } from "matrix-js-sdk/lib/autodiscovery";
 
+import { createCallViewModel$ } from "./CallViewModel";
 import { type Layout } from "../layout-types.ts";
 import {
   mockLocalParticipant,
+  mockMatrixRoom,
   mockMatrixRoomMember,
   mockRemoteParticipant,
   withTestScheduler,
   mockRtcMembership,
+  MockRTCSession,
+  mockMediaDevices,
+  mockMuteStates,
+  mockConfig,
   testScope,
+  mockLivekitRoom,
   exampleTransport,
 } from "../../utils/test.ts";
 import { E2eeType } from "../../e2ee/e2eeType.ts";
+import type { RaisedHandInfo, ReactionInfo } from "../../reactions/index.ts";
 import {
   aliceId,
   aliceParticipant,
@@ -60,6 +70,10 @@ import {
 import { MediaDevices } from "../MediaDevices.ts";
 import { getValue } from "../../utils/observable.ts";
 import { type Behavior, constant } from "../Behavior.ts";
+import {
+  type ElementCallError,
+  MatrixRTCTransportMissingError,
+} from "../../utils/errors.ts";
 import { withCallViewModel } from "./CallViewModelTestUtils.ts";
 
 vi.mock("rxjs", async (importOriginal) => ({
@@ -230,6 +244,71 @@ function mockRingEvent(
 const mockLegacyRingEvent = {} as { event_id: string } & ICallNotifyContent;
 
 describe("CallViewModel", () => {
+  // TODO: Restore this test. It requires makeTransport to not be mocked, unlike
+  // the rest of the tests in this file… what do we do?
+  it.skip("test missing RTC config error", async () => {
+    const rtcMemberships$ = new BehaviorSubject<CallMembership[]>([]);
+    const emitter = new EventEmitter();
+    const client = vi.mocked<MatrixClient>({
+      on: emitter.on.bind(emitter),
+      off: emitter.off.bind(emitter),
+      getSyncState: vi.fn().mockReturnValue(SyncState.Syncing),
+      getUserId: vi.fn().mockReturnValue("@user:localhost"),
+      getUser: vi.fn().mockReturnValue(null),
+      getDeviceId: vi.fn().mockReturnValue("DEVICE"),
+      credentials: {
+        userId: "@user:localhost",
+      },
+      getCrypto: vi.fn().mockReturnValue(undefined),
+      getDomain: vi.fn().mockReturnValue("example.org"),
+    } as unknown as MatrixClient);
+
+    const matrixRoom = mockMatrixRoom({
+      roomId: "!myRoomId:example.com",
+      client,
+      getMember: vi.fn().mockReturnValue(undefined),
+    });
+
+    const fakeRtcSession = new MockRTCSession(matrixRoom).withMemberships(
+      rtcMemberships$,
+    );
+
+    mockConfig({});
+
+    vi.spyOn(AutoDiscovery, "getRawClientConfig").mockResolvedValue({});
+
+    const callVM = createCallViewModel$(
+      testScope(),
+      fakeRtcSession.asMockedSession(),
+      matrixRoom,
+      mockMediaDevices({}),
+      mockMuteStates(),
+      {
+        encryptionSystem: { kind: E2eeType.PER_PARTICIPANT },
+        autoLeaveWhenOthersLeft: false,
+        livekitRoomFactory: (): LivekitRoom =>
+          mockLivekitRoom({
+            localParticipant,
+            disconnect: async () => Promise.resolve(),
+            setE2EEEnabled: async () => Promise.resolve(),
+          }),
+      },
+      new BehaviorSubject({} as Record<string, RaisedHandInfo>),
+      new BehaviorSubject({} as Record<string, ReactionInfo>),
+      constant({ processor: undefined, supported: false }),
+    );
+
+    const failPromise = Promise.withResolvers<ElementCallError>();
+    callVM.configError$.subscribe((error) => {
+      if (error) {
+        failPromise.resolve(error);
+      }
+    });
+
+    const error = await failPromise.promise;
+    expect(error).toBeInstanceOf(MatrixRTCTransportMissingError);
+  });
+
   test("participants are retained during a focus switch", () => {
     withTestScheduler(({ behavior, expectObservable }) => {
       // Participants disappear on frame 2 and come back on frame 3
@@ -267,7 +346,7 @@ describe("CallViewModel", () => {
     });
   });
 
-  test("screen sharing activates spotlight layout", () => {
+  it.skip("screen sharing activates spotlight layout", () => {
     withTestScheduler(({ behavior, schedule, expectObservable }) => {
       // Start with no screen shares, then have Alice and Bob share their screens,
       // then return to no screen shares, then have just Alice share for a bit

src/state/CallViewModel/CallViewModel.ts

@@ -1,5 +1,4 @@
 /*
-Copyright 2025 Element Creations Ltd.
 Copyright 2023, 2024, 2025 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
@@ -17,6 +16,7 @@ import { type Room as MatrixRoom } from "matrix-js-sdk";
 import {
   combineLatest,
   distinctUntilChanged,
+  EMPTY,
   filter,
   fromEvent,
   map,
@@ -27,6 +27,7 @@ import {
   pairwise,
   race,
   scan,
+  skip,
   skipWhile,
   startWith,
   Subject,
@@ -39,10 +40,7 @@ import {
   timer,
 } from "rxjs";
 import { logger as rootLogger } from "matrix-js-sdk/lib/logger";
-import {
-  type LivekitTransport,
-  type MatrixRTCSession,
-} from "matrix-js-sdk/lib/matrixrtc";
+import { type MatrixRTCSession } from "matrix-js-sdk/lib/matrixrtc";
 import { type IWidgetApiRequest } from "matrix-widget-api";
 
 import {
@@ -95,11 +93,9 @@ import {
 } from "../layout-types.ts";
 import { type ElementCallError } from "../../utils/errors.ts";
 import { type ObservableScope } from "../ObservableScope.ts";
-import { createHomeserverConnected$ } from "./localMember/HomeserverConnected.ts";
 import {
   createLocalMembership$,
-  enterRTCSession,
-  RTCBackendState,
+  type LocalMemberConnectionState,
 } from "./localMember/LocalMembership.ts";
 import { createLocalTransport$ } from "./localMember/LocalTransport.ts";
 import {
@@ -123,9 +119,6 @@ import {
   createMatrixMemberMetadata$,
   createRoomMembers$,
 } from "./remoteMembers/MatrixMemberMetadata.ts";
-import { Publisher } from "./localMember/Publisher.ts";
-import { type Connection } from "./remoteMembers/Connection.ts";
-import { createLayoutModeSwitch } from "./LayoutSwitch.ts";
 
 const logger = rootLogger.getChild("[CallViewModel]");
 //TODO
@@ -180,7 +173,7 @@ type AudioLivekitItem = {
 
 /**
  * The return of createCallViewModel$
- * this interface represents the root source of data for the call view.
+ * This interface represents the root snapshot for the call view. Snapshots in EC with rxjs behave like snapshot trees.
  * They are a list of observables and objects containing observables to allow for a very granular update mechanism.
  *
  * This allows to have one huge call view model that represents the entire view without a unnecessary amount of updates.
@@ -200,7 +193,7 @@ export interface CallViewModel {
   hangup: () => void;
 
   // joining
-  join: () => void;
+  join: () => LocalMemberConnectionState;
 
   // screen sharing
   /**
@@ -236,7 +229,7 @@ export interface CallViewModel {
    * This is a fatal error that prevents the call from being created/joined.
    * Should render a blocking error screen.
    */
-  fatalError$: Behavior<ElementCallError | null>;
+  configError$: Behavior<ElementCallError | null>;
 
   // participants and counts
   /**
@@ -343,7 +336,6 @@ export interface CallViewModel {
   // DISCUSSION own membership manager ALSO this probably can be simplifis
   reconnecting$: Behavior<boolean>;
 }
-
 /**
  * A view model providing all the application logic needed to show the in-call
  * UI (may eventually be expanded to cover the lobby and feedback screens in the
@@ -364,9 +356,9 @@ export function createCallViewModel$(
   reactionsSubject$: Observable<Record<string, ReactionInfo>>,
   trackProcessorState$: Behavior<ProcessorState>,
 ): CallViewModel {
-  const client = matrixRoom.client;
-  const userId = client.getUserId()!;
-  const deviceId = client.getDeviceId()!;
+  const userId = matrixRoom.client.getUserId()!;
+  const deviceId = matrixRoom.client.getDeviceId()!;
+
   const livekitKeyProvider = getE2eeKeyProvider(
     options.encryptionSystem,
     matrixRTCSession,
@@ -378,8 +370,8 @@ export function createCallViewModel$(
   // For mocking purposes it is recommended to only mock the functions creating those outputs.
   // All other fields are just temp computations for the mentioned output.
   // The class does not need anything except the values underneath the bar.
-  // The creations of the values under the bar are all tested independently and testing the callViewModel Should
-  // not test their creation. Call view model only needs:
+  // The creation of the values under the bar are all tested independently and testing the callViewModel Should
+  // not test their cretation. Call view model only needs:
   //  - memberships$ via createMemberships$
   //  - localMembership via createLocalMembership$
   //  - callLifecycle via createCallNotificationLifecycle$
@@ -400,7 +392,7 @@ export function createCallViewModel$(
   const localTransport$ = createLocalTransport$({
     scope: scope,
     memberships$: memberships$,
-    client,
+    client: matrixRoom.client,
     roomId: matrixRoom.roomId,
     useOldestMember$: scope.behavior(
       matrixRTCMode.value$.pipe(map((v) => v === MatrixRTCMode.Legacy)),
@@ -408,14 +400,12 @@ export function createCallViewModel$(
   });
 
   const connectionFactory = new ECConnectionFactory(
-    client,
+    matrixRoom.client,
     mediaDevices,
     trackProcessorState$,
     livekitKeyProvider,
     getUrlParams().controlledAudioDevices,
     options.livekitRoomFactory,
-    getUrlParams().echoCancellation,
-    getUrlParams().noiseSuppression,
   );
 
   const connectionManager = createConnectionManager$({
@@ -447,7 +437,7 @@ export function createCallViewModel$(
     matrixRTCMode.value$.pipe(
       map((mode) => ({
         encryptMedia: livekitKeyProvider !== undefined,
-        // TODO. This might need to get called again on each change of matrixRTCMode...
+        // TODO. This might need to get called again on each cahnge of matrixRTCMode...
         matrixRTCMode: mode,
       })),
     ),
@@ -455,34 +445,15 @@ export function createCallViewModel$(
 
   const localMembership = createLocalMembership$({
     scope: scope,
-    homeserverConnected$: createHomeserverConnected$(
-      scope,
-      client,
-      matrixRTCSession,
-    ),
     muteStates: muteStates,
-    joinMatrixRTC: async (transport: LivekitTransport) => {
-      return enterRTCSession(
-        matrixRTCSession,
-        transport,
-        connectOptions$.value,
-      );
-    },
-    createPublisherFactory: (connection: Connection) => {
-      return new Publisher(
-        scope,
-        connection,
-        mediaDevices,
-        muteStates,
-        trackProcessorState$,
-        logger.getChild(
-          "[Publisher" + connection.transport.livekit_service_url + "]",
-        ),
-      );
-    },
+    mediaDevices: mediaDevices,
     connectionManager: connectionManager,
     matrixRTCSession: matrixRTCSession,
+    matrixRoom: matrixRoom,
     localTransport$: localTransport$,
+    trackProcessorState$: trackProcessorState$,
+    widget,
+    options: connectOptions$,
     logger: logger.getChild(`[${Date.now()}]`),
   });
 
@@ -576,6 +547,15 @@ export function createCallViewModel$(
     ),
   );
 
+  // CODESMELL?
+  // This is functionally the same Observable as leave$, except here it's
+  // hoisted to the top of the class. This enables the cyclic dependency between
+  // leave$ -> autoLeave$ -> callPickupState$ -> livekitConnectionState$ ->
+  // localConnection$ -> transports$ -> joined$ -> leave$.
+  const leaveHoisted$ = new Subject<
+    "user" | "timeout" | "decline" | "allOthersLeft"
+  >();
+
   /**
    * Whether various media/event sources should pretend to be disconnected from
    * all network input, even if their connection still technically works.
@@ -586,6 +566,7 @@ export function createCallViewModel$(
   // in a split-brained state.
   // DISCUSSION own membership manager ALSO this probably can be simplifis
   const reconnecting$ = localMembership.reconnecting$;
+  const pretendToBeDisconnected$ = reconnecting$;
 
   const audioParticipants$ = scope.behavior(
     matrixLivekitMembers$.pipe(
@@ -634,7 +615,7 @@ export function createCallViewModel$(
   );
 
   const handsRaised$ = scope.behavior(
-    handsRaisedSubject$.pipe(pauseWhen(reconnecting$)),
+    handsRaisedSubject$.pipe(pauseWhen(pretendToBeDisconnected$)),
   );
 
   const reactions$ = scope.behavior(
@@ -647,13 +628,14 @@ export function createCallViewModel$(
           ]),
         ),
       ),
-      pauseWhen(reconnecting$),
+      pauseWhen(pretendToBeDisconnected$),
     ),
   );
 
   /**
    * List of user media (camera feeds) that we want tiles for.
    */
+  // TODO this also needs the local participant to be added.
   const userMedia$ = scope.behavior<UserMedia[]>(
     combineLatest([
       localMatrixLivekitMember$,
@@ -668,7 +650,7 @@ export function createCallViewModel$(
           { value: matrixLivekitMembers },
           duplicateTiles,
         ]) {
-          let localParticipantId: string | undefined = undefined;
+          let localParticipantId = undefined;
           // add local member if available
           if (localMatrixLivekitMember) {
             const { userId, participant$, connection$, membership$ } =
@@ -738,7 +720,7 @@ export function createCallViewModel$(
             livekitRoom$,
             focusUrl$,
             mediaDevices,
-            reconnecting$,
+            pretendToBeDisconnected$,
             displayName$,
             matrixMemberMetadataStore.createAvatarUrlBehavior$(userId),
             handsRaised$.pipe(map((v) => v[participantId]?.time ?? null)),
@@ -834,7 +816,10 @@ export function createCallViewModel$(
     merge(
       autoLeave$,
       merge(userHangup$, widgetHangup$).pipe(map(() => "user" as const)),
-    ).pipe(scope.share);
+    ).pipe(
+      scope.share,
+      tap((reason) => leaveHoisted$.next(reason)),
+    );
 
   const spotlightSpeaker$ = scope.behavior<UserMediaViewModel | null>(
     userMedia$.pipe(
@@ -983,11 +968,36 @@ export function createCallViewModel$(
     spotlightExpandedToggle$.pipe(accumulate(false, (expanded) => !expanded)),
   );
 
-  const { setGridMode, gridMode$ } = createLayoutModeSwitch(
-    scope,
-    windowMode$,
-    hasRemoteScreenShares$,
-  );
+  const gridModeUserSelection$ = new Subject<GridMode>();
+  /**
+   * The layout mode of the media tile grid.
+   */
+  const gridMode$ =
+    // If the user hasn't selected spotlight and somebody starts screen sharing,
+    // automatically switch to spotlight mode and reset when screen sharing ends
+    scope.behavior<GridMode>(
+      gridModeUserSelection$.pipe(
+        switchMap((userSelection) =>
+          (userSelection === "spotlight"
+            ? EMPTY
+            : combineLatest([hasRemoteScreenShares$, windowMode$]).pipe(
+                skip(userSelection === null ? 0 : 1),
+                map(
+                  ([hasScreenShares, windowMode]): GridMode =>
+                    hasScreenShares || windowMode === "flat"
+                      ? "spotlight"
+                      : "grid",
+                ),
+              )
+          ).pipe(startWith(userSelection ?? "grid")),
+        ),
+      ),
+      "grid",
+    );
+
+  const setGridMode = (value: GridMode): void => {
+    gridModeUserSelection$.next(value);
+  };
 
   const gridLayoutMedia$: Observable<GridLayoutMedia> = combineLatest(
     [grid$, spotlight$],
@@ -1414,13 +1424,16 @@ export function createCallViewModel$(
   // reassigned here to make it publicly accessible
   const toggleScreenSharing = localMembership.toggleScreenSharing;
 
+  const join = localMembership.requestConnect;
+  // TODO-MULTI-SFU: Use this view model for the lobby as well, and only call this once 'join' is clicked?
+  join();
   return {
     autoLeave$: autoLeave$,
     callPickupState$: callPickupState$,
     ringOverlay$: ringOverlay$,
     leave$: leave$,
     hangup: (): void => userHangup$.next(),
-    join: localMembership.requestConnect,
+    join: join,
     toggleScreenSharing: toggleScreenSharing,
     sharingScreen$: sharingScreen$,
 
@@ -1429,14 +1442,7 @@ export function createCallViewModel$(
     hoverScreen: (): void => screenHover$.next(),
     unhoverScreen: (): void => screenUnhover$.next(),
 
-    fatalError$: scope.behavior(
-      localMembership.connectionState.livekit$.pipe(
-        filter((v) => v.state === RTCBackendState.Error),
-        map((s) => s.error),
-      ),
-      null,
-    ),
-
+    configError$: localMembership.configError$,
     participantCount$: participantCount$,
     audioParticipants$: audioParticipants$,
 
@@ -1468,6 +1474,8 @@ export function createCallViewModel$(
     reconnecting$: reconnecting$,
   };
 }
+// TODO-MULTI-SFU   // Setup and update the keyProvider which was create by `createRoom` was a thing before. Now we never update if the E2EEsystem changes
+// do we need this?
 
 function getE2eeKeyProvider(
   e2eeSystem: EncryptionSystem,

src/state/CallViewModel/LayoutSwitch.test.ts

@@ -1,202 +0,0 @@
-/*
-Copyright 2025 Element Creations Ltd.
-
-SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
-Please see LICENSE in the repository root for full details.
-*/
-
-import { afterEach, beforeEach, describe, expect, test } from "vitest";
-import { firstValueFrom, of } from "rxjs";
-
-import { createLayoutModeSwitch } from "./LayoutSwitch";
-import { ObservableScope } from "../ObservableScope";
-import { constant } from "../Behavior";
-import { withTestScheduler } from "../../utils/test";
-
-let scope: ObservableScope;
-beforeEach(() => {
-  scope = new ObservableScope();
-});
-afterEach(() => {
-  scope.end();
-});
-
-describe("Default mode", () => {
-  test("Should be in grid layout by default", async () => {
-    const { gridMode$ } = createLayoutModeSwitch(
-      scope,
-      constant("normal"),
-      of(false),
-    );
-
-    const mode = await firstValueFrom(gridMode$);
-    expect(mode).toBe("grid");
-  });
-
-  test("Should switch to spotlight mode when window mode is flat", async () => {
-    const { gridMode$ } = createLayoutModeSwitch(
-      scope,
-      constant("flat"),
-      of(false),
-    );
-
-    const mode = await firstValueFrom(gridMode$);
-    expect(mode).toBe("spotlight");
-  });
-});
-
-test("Should allow switching modes manually", () => {
-  withTestScheduler(({ cold, behavior, expectObservable, schedule }): void => {
-    const { gridMode$, setGridMode } = createLayoutModeSwitch(
-      scope,
-      behavior("n", { n: "normal" }),
-      cold("f", { f: false, t: true }),
-    );
-
-    schedule("--sgs", {
-      s: () => setGridMode("spotlight"),
-      g: () => setGridMode("grid"),
-    });
-
-    expectObservable(gridMode$).toBe("g-sgs", {
-      g: "grid",
-      s: "spotlight",
-    });
-  });
-});
-
-test("Should switch to spotlight mode when there is a remote screen share", () => {
-  withTestScheduler(({ cold, behavior, expectObservable }): void => {
-    const shareMarble = "f--t";
-    const gridsMarble = "g--s";
-    const { gridMode$ } = createLayoutModeSwitch(
-      scope,
-      behavior("n", { n: "normal" }),
-      cold(shareMarble, { f: false, t: true }),
-    );
-
-    expectObservable(gridMode$).toBe(gridsMarble, {
-      g: "grid",
-      s: "spotlight",
-    });
-  });
-});
-
-test("Can manually force grid when there is a screenshare", () => {
-  withTestScheduler(({ cold, behavior, expectObservable, schedule }): void => {
-    const { gridMode$, setGridMode } = createLayoutModeSwitch(
-      scope,
-      behavior("n", { n: "normal" }),
-      cold("-ft", { f: false, t: true }),
-    );
-
-    schedule("---g", {
-      g: () => setGridMode("grid"),
-    });
-
-    expectObservable(gridMode$).toBe("ggsg", {
-      g: "grid",
-      s: "spotlight",
-    });
-  });
-});
-
-test("Should auto-switch after manually selected grid", () => {
-  withTestScheduler(({ cold, behavior, expectObservable, schedule }): void => {
-    const { gridMode$, setGridMode } = createLayoutModeSwitch(
-      scope,
-      behavior("n", { n: "normal" }),
-      // Two screenshares will happen in sequence
-      cold("-ft-ft", { f: false, t: true }),
-    );
-
-    // There was a screen-share that forced spotlight, then
-    // the user manually switch back to grid
-    schedule("---g", {
-      g: () => setGridMode("grid"),
-    });
-
-    // If we did want to respect manual selection, the expectation would be:
-    // const expectation = "ggsg";
-    const expectation = "ggsg-s";
-
-    expectObservable(gridMode$).toBe(expectation, {
-      g: "grid",
-      s: "spotlight",
-    });
-  });
-});
-
-test("Should switch back to grid mode when the remote screen share ends", () => {
-  withTestScheduler(({ cold, behavior, expectObservable }): void => {
-    const shareMarble = "f--t--f-";
-    const gridsMarble = "g--s--g-";
-    const { gridMode$ } = createLayoutModeSwitch(
-      scope,
-      behavior("n", { n: "normal" }),
-      cold(shareMarble, { f: false, t: true }),
-    );
-
-    expectObservable(gridMode$).toBe(gridsMarble, {
-      g: "grid",
-      s: "spotlight",
-    });
-  });
-});
-
-test("can auto-switch to spotlight again after first screen share ends", () => {
-  withTestScheduler(({ cold, behavior, expectObservable }): void => {
-    const shareMarble = "ftft";
-    const gridsMarble = "gsgs";
-    const { gridMode$ } = createLayoutModeSwitch(
-      scope,
-      behavior("n", { n: "normal" }),
-      cold(shareMarble, { f: false, t: true }),
-    );
-
-    expectObservable(gridMode$).toBe(gridsMarble, {
-      g: "grid",
-      s: "spotlight",
-    });
-  });
-});
-
-test("can switch manually to grid after screen share while manually in spotlight", () => {
-  withTestScheduler(({ cold, behavior, schedule, expectObservable }): void => {
-    // Initially, no one is sharing. Then the user manually switches to
-    // spotlight. After a screen share starts, the user manually switches to
-    // grid.
-    const shareMarbles = "  f-t-";
-    const setModeMarbles = "-s-g";
-    const expectation = "   gs-g";
-    const { gridMode$, setGridMode } = createLayoutModeSwitch(
-      scope,
-      behavior("n", { n: "normal" }),
-      cold(shareMarbles, { f: false, t: true }),
-    );
-    schedule(setModeMarbles, {
-      g: () => setGridMode("grid"),
-      s: () => setGridMode("spotlight"),
-    });
-
-    expectObservable(gridMode$).toBe(expectation, {
-      g: "grid",
-      s: "spotlight",
-    });
-  });
-});
-
-test("Should auto-switch to spotlight when in flat window mode", () => {
-  withTestScheduler(({ cold, behavior, expectObservable }): void => {
-    const { gridMode$ } = createLayoutModeSwitch(
-      scope,
-      behavior("naf", { n: "normal", a: "narrow", f: "flat" }),
-      cold("f", { f: false, t: true }),
-    );
-
-    expectObservable(gridMode$).toBe("g-s-", {
-      g: "grid",
-      s: "spotlight",
-    });
-  });
-});

src/state/CallViewModel/LayoutSwitch.ts

@@ -1,130 +0,0 @@
-/*
-Copyright 2025 Element Creations Ltd.
-
-SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
-Please see LICENSE in the repository root for full details.
-*/
-
-import {
-  BehaviorSubject,
-  combineLatest,
-  map,
-  type Observable,
-  scan,
-} from "rxjs";
-import { logger } from "matrix-js-sdk/lib/logger";
-
-import { type GridMode, type WindowMode } from "./CallViewModel.ts";
-import { type Behavior } from "../Behavior.ts";
-import { type ObservableScope } from "../ObservableScope.ts";
-
-/**
- * Creates a layout mode switch that allows switching between grid and spotlight modes.
- * The actual layout mode can be overridden to spotlight mode if there is a remote screen share active
- * or if the window mode is flat.
- *
- * @param scope - The observable scope to manage subscriptions.
- * @param windowMode$ - The current window mode observable.
- * @param hasRemoteScreenShares$ - An observable indicating if there are remote screen shares active.
- */
-export function createLayoutModeSwitch(
-  scope: ObservableScope,
-  windowMode$: Behavior<WindowMode>,
-  hasRemoteScreenShares$: Observable<boolean>,
-): {
-  gridMode$: Behavior<GridMode>;
-  setGridMode: (value: GridMode) => void;
-} {
-  const gridModeUserSelection$ = new BehaviorSubject<GridMode>("grid");
-
-  // Callback to set the grid mode desired by the user.
-  // Notice that this is only a preference, the actual grid mode can be overridden
-  // if there is a remote screen share active.
-  const setGridMode = (value: GridMode): void => {
-    gridModeUserSelection$.next(value);
-  };
-  /**
-   * The layout mode of the media tile grid.
-   */
-  const gridMode$ =
-    // If the user hasn't selected spotlight and somebody starts screen sharing,
-    // automatically switch to spotlight mode and reset when screen sharing ends
-    scope.behavior<GridMode>(
-      combineLatest([
-        gridModeUserSelection$,
-        hasRemoteScreenShares$,
-        windowMode$,
-      ]).pipe(
-        // Scan to keep track if we have auto-switched already or not.
-        // To allow the user to override the auto-switch by selecting grid mode again.
-        scan<
-          [GridMode, boolean, WindowMode],
-          {
-            mode: GridMode;
-            /** Remember if the change was user driven or not */
-            hasAutoSwitched: boolean;
-            /** To know if it is new screen share or an already handled */
-            hasScreenShares: boolean;
-          }
-        >(
-          (prev, [userSelection, hasScreenShares, windowMode]) => {
-            const isFlatMode = windowMode === "flat";
-
-            // Always force spotlight in flat mode, grid layout is not supported
-            // in that mode.
-            // TODO: strange that we do that for flat mode but not for other modes?
-            // TODO: Why is this not handled in layoutMedia$ like other window modes?
-            if (isFlatMode) {
-              logger.debug(`Forcing spotlight mode, windowMode=${windowMode}`);
-              return {
-                mode: "spotlight",
-                hasAutoSwitched: prev.hasAutoSwitched,
-                hasScreenShares,
-              };
-            }
-
-            // User explicitly chose spotlight.
-            // Respect that choice.
-            if (userSelection === "spotlight") {
-              return {
-                mode: "spotlight",
-                hasAutoSwitched: prev.hasAutoSwitched,
-                hasScreenShares,
-              };
-            }
-
-            // User has chosen grid mode. If a screen share starts, we will
-            // auto-switch to spotlight mode for better experience.
-            // But we only do it once, if the user switches back to grid mode,
-            // we respect that choice until they explicitly change it again.
-            const isNewShare = hasScreenShares && !prev.hasScreenShares;
-            if (isNewShare && !prev.hasAutoSwitched) {
-              return {
-                mode: "spotlight",
-                hasAutoSwitched: true,
-                hasScreenShares: true,
-              };
-            }
-
-            // Respect user's grid choice
-            // XXX If we want to forbid switching automatically again after we can
-            // return hasAutoSwitched: acc.hasAutoSwitched here instead of setting to false.
-            return {
-              mode: "grid",
-              hasAutoSwitched: false,
-              hasScreenShares,
-            };
-          },
-          // initial value
-          { mode: "grid", hasAutoSwitched: false, hasScreenShares: false },
-        ),
-        map(({ mode }) => mode),
-      ),
-      "grid",
-    );
-
-  return {
-    gridMode$,
-    setGridMode,
-  };
-}

src/state/CallViewModel/localMember/HomeserverConnected.test.ts

@@ -1,202 +0,0 @@
-/*
-Copyright 2025 Element Creations Ltd.
-Copyright 2024 New Vector Ltd.
-
-SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
-Please see LICENSE in the repository root for full details.
-*/
-
-import { describe, it, expect, beforeEach, afterEach } from "vitest";
-import { EventEmitter } from "events";
-import { ClientEvent, SyncState } from "matrix-js-sdk";
-import { MembershipManagerEvent, Status } from "matrix-js-sdk/lib/matrixrtc";
-
-import { ObservableScope } from "../../ObservableScope";
-import { createHomeserverConnected$ } from "./HomeserverConnected";
-
-/**
- * Minimal stub of a Matrix client sufficient for our tests:
- ```
-  createHomeserverConnected$(
-     scope: ObservableScope,
-     client: NodeStyleEventEmitter & Pick<MatrixClient, "getSyncState">,
-     matrixRTCSession: NodeStyleEventEmitter &
-       Pick<MatrixRTCSession, "membershipStatus" | "probablyLeft">,
- )
- ```
- */
-class MockMatrixClient extends EventEmitter {
-  private syncState: SyncState;
-  public constructor(initial: SyncState) {
-    super();
-    this.syncState = initial;
-  }
-  public setSyncState(state: SyncState): void {
-    this.syncState = state;
-    // Matrix's Sync event in createHomeserverConnected$ expects [SyncState]
-    this.emit(ClientEvent.Sync, [state]);
-  }
-  public getSyncState(): SyncState {
-    return this.syncState;
-  }
-}
-
-/**
- * Minimal stub of MatrixRTCSession (membership manager):
- ```
-  createHomeserverConnected$(
-     scope: ObservableScope,
-     client: NodeStyleEventEmitter & Pick<MatrixClient, "getSyncState">,
-     matrixRTCSession: NodeStyleEventEmitter &
-       Pick<MatrixRTCSession, "membershipStatus" | "probablyLeft">,
- )
- ```
- */
-class MockMatrixRTCSession extends EventEmitter {
-  public membershipStatus: Status;
-  public probablyLeft: boolean;
-
-  public constructor(props: {
-    membershipStatus: Status;
-    probablyLeft: boolean;
-  }) {
-    super();
-    this.membershipStatus = props.membershipStatus;
-    this.probablyLeft = props.probablyLeft;
-  }
-
-  public setMembershipStatus(status: Status): void {
-    this.membershipStatus = status;
-    this.emit(MembershipManagerEvent.StatusChanged);
-  }
-
-  public setProbablyLeft(flag: boolean): void {
-    this.probablyLeft = flag;
-    this.emit(MembershipManagerEvent.ProbablyLeft);
-  }
-}
-
-describe("createHomeserverConnected$", () => {
-  let scope: ObservableScope;
-  let client: MockMatrixClient;
-  let session: MockMatrixRTCSession;
-
-  beforeEach(() => {
-    scope = new ObservableScope();
-    client = new MockMatrixClient(SyncState.Error); // start disconnected
-    session = new MockMatrixRTCSession({
-      membershipStatus: Status.Disconnected,
-      probablyLeft: false,
-    });
-  });
-
-  afterEach(() => {
-    scope.end();
-  });
-
-  // LLM generated test cases. They are a bit overkill but I improved the mocking so it is
-  // easy enough to read them so I think they can stay.
-  it("is false when sync state is not Syncing", () => {
-    const hsConnected$ = createHomeserverConnected$(scope, client, session);
-    expect(hsConnected$.value).toBe(false);
-  });
-
-  it("remains false while membership status is not Connected even if sync is Syncing", () => {
-    const hsConnected$ = createHomeserverConnected$(scope, client, session);
-    client.setSyncState(SyncState.Syncing);
-    expect(hsConnected$.value).toBe(false); // membership still disconnected
-  });
-
-  it("is false when membership status transitions to Connected but ProbablyLeft is true", () => {
-    const hsConnected$ = createHomeserverConnected$(scope, client, session);
-    // Make sync loop OK
-    client.setSyncState(SyncState.Syncing);
-    // Indicate probable leave before connection
-    session.setProbablyLeft(true);
-    session.setMembershipStatus(Status.Connected);
-    expect(hsConnected$.value).toBe(false);
-  });
-
-  it("becomes true only when all three conditions are satisfied", () => {
-    const hsConnected$ = createHomeserverConnected$(scope, client, session);
-    // 1. Sync loop connected
-    client.setSyncState(SyncState.Syncing);
-    expect(hsConnected$.value).toBe(false); // not yet membership connected
-    // 2. Membership connected
-    session.setMembershipStatus(Status.Connected);
-    expect(hsConnected$.value).toBe(true); // probablyLeft is false
-  });
-
-  it("drops back to false when sync loop leaves Syncing", () => {
-    const hsConnected$ = createHomeserverConnected$(scope, client, session);
-    // Reach connected state
-    client.setSyncState(SyncState.Syncing);
-    session.setMembershipStatus(Status.Connected);
-    expect(hsConnected$.value).toBe(true);
-
-    // Sync loop error => should flip false
-    client.setSyncState(SyncState.Error);
-    expect(hsConnected$.value).toBe(false);
-  });
-
-  it("drops back to false when membership status becomes disconnected", () => {
-    const hsConnected$ = createHomeserverConnected$(scope, client, session);
-    client.setSyncState(SyncState.Syncing);
-    session.setMembershipStatus(Status.Connected);
-    expect(hsConnected$.value).toBe(true);
-
-    session.setMembershipStatus(Status.Disconnected);
-    expect(hsConnected$.value).toBe(false);
-  });
-
-  it("drops to false when ProbablyLeft is emitted after being true", () => {
-    const hsConnected$ = createHomeserverConnected$(scope, client, session);
-    client.setSyncState(SyncState.Syncing);
-    session.setMembershipStatus(Status.Connected);
-    expect(hsConnected$.value).toBe(true);
-
-    session.setProbablyLeft(true);
-    expect(hsConnected$.value).toBe(false);
-  });
-
-  it("recovers to true if ProbablyLeft becomes false again while other conditions remain true", () => {
-    const hsConnected$ = createHomeserverConnected$(scope, client, session);
-    client.setSyncState(SyncState.Syncing);
-    session.setMembershipStatus(Status.Connected);
-    expect(hsConnected$.value).toBe(true);
-
-    session.setProbablyLeft(true);
-    expect(hsConnected$.value).toBe(false);
-
-    // Simulate clearing the flag (in realistic scenario membership manager would update)
-    session.setProbablyLeft(false);
-    expect(hsConnected$.value).toBe(true);
-  });
-
-  it("composite sequence reflects each individual failure reason", () => {
-    const hsConnected$ = createHomeserverConnected$(scope, client, session);
-
-    // Initially false (sync error + disconnected + not probably left)
-    expect(hsConnected$.value).toBe(false);
-
-    // Fix sync only
-    client.setSyncState(SyncState.Syncing);
-    expect(hsConnected$.value).toBe(false);
-
-    // Fix membership
-    session.setMembershipStatus(Status.Connected);
-    expect(hsConnected$.value).toBe(true);
-
-    // Introduce probablyLeft -> false
-    session.setProbablyLeft(true);
-    expect(hsConnected$.value).toBe(false);
-
-    // Restore notProbablyLeft -> true again
-    session.setProbablyLeft(false);
-    expect(hsConnected$.value).toBe(true);
-
-    // Drop sync -> false
-    client.setSyncState(SyncState.Error);
-    expect(hsConnected$.value).toBe(false);
-  });
-});

src/state/CallViewModel/localMember/HomeserverConnected.ts

@@ -1,85 +0,0 @@
-/*
-Copyright 2025 Element Creations Ltd.
-Copyright 2024 New Vector Ltd.
-
-SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
-Please see LICENSE in the repository root for full details.
-*/
-
-import {
-  MembershipManagerEvent,
-  Status,
-  type MatrixRTCSession,
-} from "matrix-js-sdk/lib/matrixrtc";
-import { ClientEvent, type MatrixClient, SyncState } from "matrix-js-sdk";
-import { fromEvent, startWith, map, tap, type Observable } from "rxjs";
-import { logger as rootLogger } from "matrix-js-sdk/lib/logger";
-
-import { type ObservableScope } from "../../ObservableScope";
-import { type Behavior } from "../../Behavior";
-import { and$ } from "../../../utils/observable";
-import { type NodeStyleEventEmitter } from "../../../utils/test";
-
-/**
- * Logger instance (scoped child) for homeserver connection updates.
- */
-const logger = rootLogger.getChild("[HomeserverConnected]");
-
-/**
- * Behavior representing whether we consider ourselves connected to the Matrix homeserver
- * for the purposes of a MatrixRTC session.
- *
- * Becomes FALSE if ANY sub-condition is fulfilled:
- * 1. Sync loop is not in SyncState.Syncing
- * 2. membershipStatus !== Status.Connected
- * 3. probablyLeft === true
- */
-export function createHomeserverConnected$(
-  scope: ObservableScope,
-  client: NodeStyleEventEmitter & Pick<MatrixClient, "getSyncState">,
-  matrixRTCSession: NodeStyleEventEmitter &
-    Pick<MatrixRTCSession, "membershipStatus" | "probablyLeft">,
-): Behavior<boolean> {
-  const syncing$ = (
-    fromEvent(client, ClientEvent.Sync) as Observable<[SyncState]>
-  ).pipe(
-    startWith([client.getSyncState()]),
-    map(([state]) => state === SyncState.Syncing),
-  );
-
-  const membershipConnected$ = fromEvent(
-    matrixRTCSession,
-    MembershipManagerEvent.StatusChanged,
-  ).pipe(
-    startWith(null),
-    map(() => matrixRTCSession.membershipStatus === Status.Connected),
-  );
-
-  // This is basically notProbablyLeft$
-  //
-  // probablyLeft is computed by a local timer that mimics the server delayed event.
-  // If we locally predict our server event timed out. We consider ourselves as probablyLeft
-  // even though we might not yet have received the delayed event leave.
-  //
-  // If that is not the case we certainly still have a valid membership on the matrix network
-  // independet if the sync currently works.
-  const certainlyConnected$ = fromEvent(
-    matrixRTCSession,
-    MembershipManagerEvent.ProbablyLeft,
-  ).pipe(
-    startWith(null),
-    map(() => matrixRTCSession.probablyLeft !== true),
-  );
-
-  const connectedCombined$ = and$(
-    syncing$,
-    membershipConnected$,
-    certainlyConnected$,
-  ).pipe(
-    tap((connected) => {
-      logger.info(`Homeserver connected update: ${connected}`);
-    }),
-  );
-
-  return scope.behavior(connectedCombined$);
-}

src/state/CallViewModel/localMember/LocalMembership.test.ts

@@ -1,492 +1,158 @@
 /*
-Copyright 2025 Element Creations Ltd.
 Copyright 2024 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.
 */
 
-import {
-  type LivekitTransport,
-  type MatrixRTCSession,
-} from "matrix-js-sdk/lib/matrixrtc";
-import { describe, expect, it, vi } from "vitest";
+import { type MatrixRTCSession } from "matrix-js-sdk/lib/matrixrtc";
+import { expect, test, vi } from "vitest";
 import { AutoDiscovery } from "matrix-js-sdk/lib/autodiscovery";
-import { BehaviorSubject, map, of } from "rxjs";
-import { logger } from "matrix-js-sdk/lib/logger";
-import {
-  ConnectionState as LivekitConnectionState,
-  type LocalParticipant,
-  type LocalTrack,
-} from "livekit-client";
+import EventEmitter from "events";
 
 import { MatrixRTCMode } from "../../../settings/settings";
-import {
-  flushPromises,
-  mockConfig,
-  mockLivekitRoom,
-  mockMuteStates,
-  withTestScheduler,
-} from "../../../utils/test";
-import {
-  createLocalMembership$,
-  enterRTCSession,
-  RTCBackendState,
-} from "./LocalMembership";
-import { MatrixRTCTransportMissingError } from "../../../utils/errors";
-import { Epoch, ObservableScope } from "../../ObservableScope";
-import { constant } from "../../Behavior";
-import { ConnectionManagerData } from "../remoteMembers/ConnectionManager";
-import { type Connection } from "../remoteMembers/Connection";
-import { type Publisher } from "./Publisher";
+import { mockConfig } from "../../../utils/test";
+import { enterRTCSession } from "./LocalMembership";
 
 const MATRIX_RTC_MODE = MatrixRTCMode.Legacy;
 const getUrlParams = vi.hoisted(() => vi.fn(() => ({})));
 vi.mock("../../../UrlParams", () => ({ getUrlParams }));
-vi.mock("@livekit/components-core", () => ({
-  observeParticipantEvents: vi
-    .fn()
-    .mockReturnValue(of({ isScreenShareEnabled: false })),
+
+vi.mock("../../../widget", async (importOriginal) => ({
+  ...(await importOriginal()),
+  widget: {
+    api: {
+      setAlwaysOnScreen: (): void => {},
+      transport: { send: vi.fn(), reply: vi.fn(), stop: vi.fn() },
+    },
+    lazyActions: new EventEmitter(),
+  },
 }));
 
-describe("LocalMembership", () => {
-  describe("enterRTCSession", () => {
-    it("It joins the correct Session", async () => {
-      const focusFromOlderMembership = {
-        type: "livekit",
-        livekit_service_url: "http://my-oldest-member-service-url.com",
-        livekit_alias: "my-oldest-member-service-alias",
-      };
-
-      const focusConfigFromWellKnown = {
-        type: "livekit",
-        livekit_service_url: "http://my-well-known-service-url.com",
-      };
-      const focusConfigFromWellKnown2 = {
-        type: "livekit",
-        livekit_service_url: "http://my-well-known-service-url2.com",
-      };
-      const clientWellKnown = {
-        "org.matrix.msc4143.rtc_foci": [
-          focusConfigFromWellKnown,
-          focusConfigFromWellKnown2,
-        ],
-      };
-
-      mockConfig({
-        livekit: { livekit_service_url: "http://my-default-service-url.com" },
-      });
-
-      vi.spyOn(AutoDiscovery, "getRawClientConfig").mockImplementation(
-        async (domain) => {
-          if (domain === "example.org") {
-            return Promise.resolve(clientWellKnown);
-          }
-          return Promise.resolve({});
-        },
-      );
-
-      const mockedSession = vi.mocked({
-        room: {
-          roomId: "roomId",
-          client: {
-            getDomain: vi.fn().mockReturnValue("example.org"),
-            getOpenIdToken: vi.fn().mockResolvedValue({
-              access_token: "ACCCESS_TOKEN",
-              token_type: "Bearer",
-              matrix_server_name: "localhost",
-              expires_in: 10000,
-            }),
-          },
-        },
-        memberships: [],
-        getFocusInUse: vi.fn().mockReturnValue(focusFromOlderMembership),
-        getOldestMembership: vi.fn().mockReturnValue({
-          getPreferredFoci: vi.fn().mockReturnValue([focusFromOlderMembership]),
-        }),
-        joinRoomSession: vi.fn(),
-      }) as unknown as MatrixRTCSession;
-
-      await enterRTCSession(
-        mockedSession,
-        {
-          livekit_alias: "roomId",
-          livekit_service_url: "http://my-well-known-service-url.com",
-          type: "livekit",
-        },
-        {
-          encryptMedia: true,
-          matrixRTCMode: MATRIX_RTC_MODE,
-        },
-      );
-
-      expect(mockedSession.joinRoomSession).toHaveBeenLastCalledWith(
-        [
-          {
-            livekit_alias: "roomId",
-            livekit_service_url: "http://my-well-known-service-url.com",
-            type: "livekit",
-          },
-        ],
-        undefined,
-        expect.objectContaining({
-          manageMediaKeys: true,
-          useLegacyMemberEvents: false,
-        }),
-      );
-    });
-
-    it("It should not fail with configuration error if homeserver config has livekit url but not fallback", async () => {
-      mockConfig({});
-      vi.spyOn(AutoDiscovery, "getRawClientConfig").mockResolvedValue({
-        "org.matrix.msc4143.rtc_foci": [
-          {
-            type: "livekit",
-            livekit_service_url: "http://my-well-known-service-url.com",
-          },
-        ],
-      });
-
-      const mockedSession = vi.mocked({
-        room: {
-          roomId: "roomId",
-          client: {
-            getDomain: vi.fn().mockReturnValue("example.org"),
-            getOpenIdToken: vi.fn().mockResolvedValue({
-              access_token: "ACCCESS_TOKEN",
-              token_type: "Bearer",
-              matrix_server_name: "localhost",
-              expires_in: 10000,
-            }),
-          },
-        },
-        memberships: [],
-        getFocusInUse: vi.fn(),
-        joinRoomSession: vi.fn(),
-      }) as unknown as MatrixRTCSession;
-
-      await enterRTCSession(
-        mockedSession,
-        {
-          livekit_alias: "roomId",
-          livekit_service_url: "http://my-well-known-service-url.com",
-          type: "livekit",
-        },
-        {
-          encryptMedia: true,
-          matrixRTCMode: MATRIX_RTC_MODE,
-        },
-      );
-    });
-  });
-
-  const defaultCreateLocalMemberValues = {
-    options: constant({
-      encryptMedia: false,
-      matrixRTCMode: MatrixRTCMode.Matrix_2_0,
-    }),
-    matrixRTCSession: {
-      updateCallIntent: () => {},
-      leaveRoomSession: () => {},
-    } as unknown as MatrixRTCSession,
-    muteStates: mockMuteStates(),
-    isHomeserverConnected: constant(true),
-    trackProcessorState$: constant({
-      supported: false,
-      processor: undefined,
-    }),
-    logger: logger,
-    createPublisherFactory: vi.fn(),
-    joinMatrixRTC: async (): Promise<void> => {},
-    homeserverConnected$: constant(true),
+test("It joins the correct Session", async () => {
+  const focusFromOlderMembership = {
+    type: "livekit",
+    livekit_service_url: "http://my-oldest-member-service-url.com",
+    livekit_alias: "my-oldest-member-service-alias",
   };
 
-  it("throws error on missing RTC config error", () => {
-    withTestScheduler(({ scope, hot, expectObservable }) => {
-      const goodTransport = {
-        livekit_service_url: "other",
-      } as LivekitTransport;
+  const focusConfigFromWellKnown = {
+    type: "livekit",
+    livekit_service_url: "http://my-well-known-service-url.com",
+  };
+  const focusConfigFromWellKnown2 = {
+    type: "livekit",
+    livekit_service_url: "http://my-well-known-service-url2.com",
+  };
+  const clientWellKnown = {
+    "org.matrix.msc4143.rtc_foci": [
+      focusConfigFromWellKnown,
+      focusConfigFromWellKnown2,
+    ],
+  };
 
-      const localTransport$ = scope.behavior<LivekitTransport>(
-        hot("1ms #", {}, new MatrixRTCTransportMissingError("domain.com")),
-        goodTransport,
-      );
-
-      const mockConnectionManager = {
-        transports$: scope.behavior(
-          localTransport$.pipe(map((t) => new Epoch([t]))),
-        ),
-        connectionManagerData$: constant(
-          new Epoch(new ConnectionManagerData()),
-        ),
-      };
-
-      const localMembership = createLocalMembership$({
-        scope,
-        ...defaultCreateLocalMemberValues,
-        connectionManager: mockConnectionManager,
-        localTransport$,
-      });
-
-      expectObservable(localMembership.connectionState.livekit$).toBe("ne", {
-        n: { state: RTCBackendState.WaitingForConnection },
-        e: {
-          state: RTCBackendState.Error,
-          error: expect.toSatisfy(
-            (e) => e instanceof MatrixRTCTransportMissingError,
-          ),
-        },
-      });
-    });
+  mockConfig({
+    livekit: { livekit_service_url: "http://my-default-service-url.com" },
   });
 
-  const aTransport = {
-    livekit_service_url: "a",
-  } as LivekitTransport;
-  const bTransport = {
-    livekit_service_url: "b",
-  } as LivekitTransport;
-
-  const connectionManagerData = new ConnectionManagerData();
-
-  connectionManagerData.add(
-    {
-      livekitRoom: mockLivekitRoom({
-        localParticipant: {
-          isScreenShareEnabled: false,
-          trackPublications: [],
-        } as unknown as LocalParticipant,
-      }),
-      state$: constant({
-        state: "ConnectedToLkRoom",
-        livekitConnectionState$: constant(LivekitConnectionState.Connected),
-      }),
-      transport: aTransport,
-    } as unknown as Connection,
-    [],
-  );
-  connectionManagerData.add(
-    {
-      state$: constant({
-        state: "ConnectedToLkRoom",
-      }),
-      transport: bTransport,
-    } as unknown as Connection,
-    [],
+  vi.spyOn(AutoDiscovery, "getRawClientConfig").mockImplementation(
+    async (domain) => {
+      if (domain === "example.org") {
+        return Promise.resolve(clientWellKnown);
+      }
+      return Promise.resolve({});
+    },
   );
 
-  it("recreates publisher if new connection is used and ENDS always unpublish and end tracks", async () => {
-    const scope = new ObservableScope();
-
-    const localTransport$ = new BehaviorSubject(aTransport);
-
-    const publishers: Publisher[] = [];
-
-    defaultCreateLocalMemberValues.createPublisherFactory.mockImplementation(
-      () => {
-        const p = {
-          stopPublishing: vi.fn(),
-          stopTracks: vi.fn(),
-          publishing$: constant(false),
-        };
-        publishers.push(p as unknown as Publisher);
-        return p;
+  const mockedSession = vi.mocked({
+    room: {
+      roomId: "roomId",
+      client: {
+        getDomain: vi.fn().mockReturnValue("example.org"),
+        getOpenIdToken: vi.fn().mockResolvedValue({
+          access_token: "ACCCESS_TOKEN",
+          token_type: "Bearer",
+          matrix_server_name: "localhost",
+          expires_in: 10000,
+        }),
       },
-    );
-    const publisherFactory =
-      defaultCreateLocalMemberValues.createPublisherFactory as ReturnType<
-        typeof vi.fn
-      >;
+    },
+    memberships: [],
+    getFocusInUse: vi.fn().mockReturnValue(focusFromOlderMembership),
+    getOldestMembership: vi.fn().mockReturnValue({
+      getPreferredFoci: vi.fn().mockReturnValue([focusFromOlderMembership]),
+    }),
+    joinRoomSession: vi.fn(),
+  }) as unknown as MatrixRTCSession;
 
-    createLocalMembership$({
-      scope,
-      ...defaultCreateLocalMemberValues,
-      connectionManager: {
-        connectionManagerData$: constant(new Epoch(connectionManagerData)),
+  await enterRTCSession(
+    mockedSession,
+    {
+      livekit_alias: "roomId",
+      livekit_service_url: "http://my-well-known-service-url.com",
+      type: "livekit",
+    },
+    {
+      encryptMedia: true,
+      matrixRTCMode: MATRIX_RTC_MODE,
+    },
+  );
+
+  expect(mockedSession.joinRoomSession).toHaveBeenLastCalledWith(
+    [
+      {
+        livekit_alias: "roomId",
+        livekit_service_url: "http://my-well-known-service-url.com",
+        type: "livekit",
       },
-      localTransport$,
-    });
-    await flushPromises();
-    localTransport$.next(bTransport);
-    await flushPromises();
-    expect(publisherFactory).toHaveBeenCalledTimes(2);
-    expect(publishers.length).toBe(2);
-    // stop the first Publisher and let the second one life.
-    expect(publishers[0].stopTracks).toHaveBeenCalled();
-    expect(publishers[1].stopTracks).not.toHaveBeenCalled();
-    expect(publishers[0].stopPublishing).toHaveBeenCalled();
-    expect(publishers[1].stopPublishing).not.toHaveBeenCalled();
-    expect(publisherFactory.mock.calls[0][0].transport).toBe(aTransport);
-    expect(publisherFactory.mock.calls[1][0].transport).toBe(bTransport);
-    scope.end();
-    await flushPromises();
-    // stop all tracks after ending scopes
-    expect(publishers[1].stopPublishing).toHaveBeenCalled();
-    expect(publishers[1].stopTracks).toHaveBeenCalled();
-
-    defaultCreateLocalMemberValues.createPublisherFactory.mockReset();
-  });
-
-  it("only start tracks if requested", async () => {
-    const scope = new ObservableScope();
-
-    const localTransport$ = new BehaviorSubject(aTransport);
-
-    const publishers: Publisher[] = [];
-
-    const tracks$ = new BehaviorSubject<LocalTrack[]>([]);
-    const publishing$ = new BehaviorSubject<boolean>(false);
-    defaultCreateLocalMemberValues.createPublisherFactory.mockImplementation(
-      () => {
-        const p = {
-          stopPublishing: vi.fn(),
-          stopTracks: vi.fn(),
-          createAndSetupTracks: vi.fn().mockImplementation(async () => {
-            tracks$.next([{}, {}] as LocalTrack[]);
-            return Promise.resolve();
-          }),
-          tracks$,
-          publishing$,
-        };
-        publishers.push(p as unknown as Publisher);
-        return p;
-      },
-    );
-    const publisherFactory =
-      defaultCreateLocalMemberValues.createPublisherFactory as ReturnType<
-        typeof vi.fn
-      >;
-
-    const localMembership = createLocalMembership$({
-      scope,
-      ...defaultCreateLocalMemberValues,
-      connectionManager: {
-        connectionManagerData$: constant(new Epoch(connectionManagerData)),
-      },
-      localTransport$,
-    });
-    await flushPromises();
-    expect(publisherFactory).toHaveBeenCalledOnce();
-    expect(localMembership.tracks$.value.length).toBe(0);
-    localMembership.startTracks();
-    await flushPromises();
-    expect(localMembership.tracks$.value.length).toBe(2);
-    scope.end();
-    await flushPromises();
-    // stop all tracks after ending scopes
-    expect(publishers[0].stopPublishing).toHaveBeenCalled();
-    expect(publishers[0].stopTracks).toHaveBeenCalled();
-    publisherFactory.mockClear();
-  });
-  // TODO add an integration test combining publisher and localMembership
-  //
-  it("tracks livekit state correctly", async () => {
-    const scope = new ObservableScope();
-
-    const localTransport$ = new BehaviorSubject<null | LivekitTransport>(null);
-    const connectionManagerData$ = new BehaviorSubject<
-      Epoch<ConnectionManagerData>
-    >(new Epoch(new ConnectionManagerData()));
-    const publishers: Publisher[] = [];
-
-    const tracks$ = new BehaviorSubject<LocalTrack[]>([]);
-    const publishing$ = new BehaviorSubject<boolean>(false);
-    const createTrackResolver = Promise.withResolvers<void>();
-    const publishResolver = Promise.withResolvers<void>();
-    defaultCreateLocalMemberValues.createPublisherFactory.mockImplementation(
-      () => {
-        const p = {
-          stopPublishing: vi.fn(),
-          stopTracks: vi.fn().mockImplementation(() => {
-            logger.info("stopTracks");
-            tracks$.next([]);
-          }),
-          createAndSetupTracks: vi.fn().mockImplementation(async () => {
-            await createTrackResolver.promise;
-            tracks$.next([{}, {}] as LocalTrack[]);
-          }),
-          startPublishing: vi.fn().mockImplementation(async () => {
-            await publishResolver.promise;
-            publishing$.next(true);
-          }),
-          tracks$,
-          publishing$,
-        };
-        publishers.push(p as unknown as Publisher);
-        return p;
-      },
-    );
-
-    const publisherFactory =
-      defaultCreateLocalMemberValues.createPublisherFactory as ReturnType<
-        typeof vi.fn
-      >;
-
-    const localMembership = createLocalMembership$({
-      scope,
-      ...defaultCreateLocalMemberValues,
-      connectionManager: {
-        connectionManagerData$,
-      },
-      localTransport$,
-    });
-
-    await flushPromises();
-    expect(localMembership.connectionState.livekit$.value).toStrictEqual({
-      state: RTCBackendState.WaitingForTransport,
-    });
-    localTransport$.next(aTransport);
-    await flushPromises();
-    expect(localMembership.connectionState.livekit$.value).toStrictEqual({
-      state: RTCBackendState.WaitingForConnection,
-    });
-    connectionManagerData$.next(new Epoch(connectionManagerData));
-    await flushPromises();
-    expect(localMembership.connectionState.livekit$.value).toStrictEqual({
-      state: RTCBackendState.Initialized,
-    });
-    expect(publisherFactory).toHaveBeenCalledOnce();
-    expect(localMembership.tracks$.value.length).toBe(0);
-
-    // -------
-    localMembership.startTracks();
-    // -------
-
-    await flushPromises();
-    expect(localMembership.connectionState.livekit$.value).toStrictEqual({
-      state: RTCBackendState.CreatingTracks,
-    });
-    createTrackResolver.resolve();
-    await flushPromises();
-    expect(localMembership.connectionState.livekit$.value).toStrictEqual({
-      state: RTCBackendState.ReadyToPublish,
-    });
-
-    // -------
-    localMembership.requestConnect();
-    // -------
-
-    expect(localMembership.connectionState.livekit$.value).toStrictEqual({
-      state: RTCBackendState.WaitingToPublish,
-    });
-
-    publishResolver.resolve();
-    await flushPromises();
-    expect(localMembership.connectionState.livekit$.value).toStrictEqual({
-      state: RTCBackendState.Connected,
-    });
-    expect(publishers[0].stopPublishing).not.toHaveBeenCalled();
-
-    expect(localMembership.connectionState.livekit$.isStopped).toBe(false);
-    scope.end();
-    await flushPromises();
-    // stays in connected state because it is stopped before the update to tracks update the state.
-    expect(localMembership.connectionState.livekit$.value).toStrictEqual({
-      state: RTCBackendState.Connected,
-    });
-    // stop all tracks after ending scopes
-    expect(publishers[0].stopPublishing).toHaveBeenCalled();
-    expect(publishers[0].stopTracks).toHaveBeenCalled();
-  });
-  // TODO add tests for matrix local matrix participation.
+    ],
+    undefined,
+    expect.objectContaining({
+      manageMediaKeys: true,
+      useLegacyMemberEvents: false,
+    }),
+  );
+});
+
+test("It should not fail with configuration error if homeserver config has livekit url but not fallback", async () => {
+  mockConfig({});
+  vi.spyOn(AutoDiscovery, "getRawClientConfig").mockResolvedValue({
+    "org.matrix.msc4143.rtc_foci": [
+      {
+        type: "livekit",
+        livekit_service_url: "http://my-well-known-service-url.com",
+      },
+    ],
+  });
+
+  const mockedSession = vi.mocked({
+    room: {
+      roomId: "roomId",
+      client: {
+        getDomain: vi.fn().mockReturnValue("example.org"),
+        getOpenIdToken: vi.fn().mockResolvedValue({
+          access_token: "ACCCESS_TOKEN",
+          token_type: "Bearer",
+          matrix_server_name: "localhost",
+          expires_in: 10000,
+        }),
+      },
+    },
+    memberships: [],
+    getFocusInUse: vi.fn(),
+    joinRoomSession: vi.fn(),
+  }) as unknown as MatrixRTCSession;
+
+  await enterRTCSession(
+    mockedSession,
+    {
+      livekit_alias: "roomId",
+      livekit_service_url: "http://my-well-known-service-url.com",
+      type: "livekit",
+    },
+    {
+      encryptMedia: true,
+      matrixRTCMode: MATRIX_RTC_MODE,
+    },
+  );
 });

src/state/CallViewModel/localMember/LocalMembership.ts

@@ -1,5 +1,5 @@
 /*
-Copyright 2025 Element Creations Ltd.
+Copyright 2025 New Vector Ltd.
 
 SPDX-License-IdFentifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.
@@ -10,20 +10,20 @@ import {
   type Participant,
   ParticipantEvent,
   type LocalParticipant,
-  type ScreenShareCaptureOptions,
-  ConnectionState,
 } from "livekit-client";
 import { observeParticipantEvents } from "@livekit/components-core";
 import {
   type LivekitTransport,
   type MatrixRTCSession,
+  MembershipManagerEvent,
+  Status,
 } from "matrix-js-sdk/lib/matrixrtc";
+import { ClientEvent, SyncState, type Room as MatrixRoom } from "matrix-js-sdk";
 import {
   BehaviorSubject,
-  catchError,
   combineLatest,
   distinctUntilChanged,
-  from,
+  fromEvent,
   map,
   type Observable,
   of,
@@ -33,73 +33,61 @@ import {
   tap,
 } from "rxjs";
 import { type Logger } from "matrix-js-sdk/lib/logger";
-import { deepCompare } from "matrix-js-sdk/lib/utils";
 
-import { constant, type Behavior } from "../../Behavior";
+import { type Behavior } from "../../Behavior";
 import { type IConnectionManager } from "../remoteMembers/ConnectionManager";
 import { ObservableScope } from "../../ObservableScope";
-import { type Publisher } from "./Publisher";
+import { Publisher } from "./Publisher";
 import { type MuteStates } from "../../MuteStates";
+import { type ProcessorState } from "../../../livekit/TrackProcessorContext";
+import { type MediaDevices } from "../../MediaDevices";
 import { and$ } from "../../../utils/observable";
+import { ElementCallError, UnknownCallError } from "../../../utils/errors";
 import {
-  ElementCallError,
-  MembershipManagerError,
-  UnknownCallError,
-} from "../../../utils/errors";
-import { ElementWidgetActions, widget } from "../../../widget";
+  ElementWidgetActions,
+  widget,
+  type WidgetHelpers,
+} from "../../../widget";
+import { areLivekitTransportsEqual } from "../remoteMembers/MatrixLivekitMembers";
 import { getUrlParams } from "../../../UrlParams.ts";
 import { PosthogAnalytics } from "../../../analytics/PosthogAnalytics.ts";
 import { MatrixRTCMode } from "../../../settings/settings.ts";
 import { Config } from "../../../config/Config.ts";
-import { type Connection } from "../remoteMembers/Connection.ts";
+import {
+  type Connection,
+  type ConnectionState,
+} from "../remoteMembers/Connection.ts";
 
-export enum RTCBackendState {
-  Error = "error",
-  /** Not even a transport is available to the LocalMembership */
-  WaitingForTransport = "waiting_for_transport",
-  /** A connection appeared so we can initialise the publisher */
-  WaitingForConnection = "waiting_for_connection",
-  /** Connection and transport arrived, publisher Initialized */
-  Initialized = "Initialized",
-  CreatingTracks = "creating_tracks",
-  ReadyToPublish = "ready_to_publish",
-  WaitingToPublish = "waiting_to_publish",
+export enum LivekitState {
+  Uninitialized = "uninitialized",
+  Connecting = "connecting",
   Connected = "connected",
+  Error = "error",
   Disconnected = "disconnected",
   Disconnecting = "disconnecting",
 }
 
-type LocalMemberRtcBackendState =
-  | { state: RTCBackendState.Error; error: ElementCallError }
-  | { state: RTCBackendState.WaitingForTransport }
-  | { state: RTCBackendState.WaitingForConnection }
-  | { state: RTCBackendState.Initialized }
-  | { state: RTCBackendState.CreatingTracks }
-  | { state: RTCBackendState.ReadyToPublish }
-  | { state: RTCBackendState.WaitingToPublish }
-  | { state: RTCBackendState.Connected }
-  | { state: RTCBackendState.Disconnected }
-  | { state: RTCBackendState.Disconnecting };
+type LocalMemberLivekitState =
+  | { state: LivekitState.Error; error: string }
+  | { state: LivekitState.Connected }
+  | { state: LivekitState.Connecting }
+  | { state: LivekitState.Uninitialized }
+  | { state: LivekitState.Disconnected }
+  | { state: LivekitState.Disconnecting };
 
 export enum MatrixState {
-  WaitingForTransport = "waiting_for_transport",
-  Ready = "ready",
-  Connecting = "connecting",
   Connected = "connected",
   Disconnected = "disconnected",
-  Error = "Error",
+  Connecting = "connecting",
 }
 
 type LocalMemberMatrixState =
   | { state: MatrixState.Connected }
-  | { state: MatrixState.WaitingForTransport }
-  | { state: MatrixState.Ready }
   | { state: MatrixState.Connecting }
-  | { state: MatrixState.Disconnected }
-  | { state: MatrixState.Error; error: Error };
+  | { state: MatrixState.Disconnected };
 
 export interface LocalMemberConnectionState {
-  livekit$: Behavior<LocalMemberRtcBackendState>;
+  livekit$: Behavior<LocalMemberLivekitState>;
   matrix$: Behavior<LocalMemberMatrixState>;
 }
 
@@ -114,21 +102,17 @@ export interface LocalMemberConnectionState {
  *   - Publisher.publishTracks()
  *   - send join state/sticky event
  */
-
 interface Props {
-  // TODO add a comment into some code style readme or file header callviewmodel
-  // that the inputs for those createSomething$() functions should NOT contain any js-sdk objectes
+  options: Behavior<EnterRTCSessionOptions>;
   scope: ObservableScope;
+  mediaDevices: MediaDevices;
   muteStates: MuteStates;
   connectionManager: IConnectionManager;
-  createPublisherFactory: (connection: Connection) => Publisher;
-  joinMatrixRTC: (transport: LivekitTransport) => Promise<void>;
-  homeserverConnected$: Behavior<boolean>;
+  matrixRTCSession: MatrixRTCSession;
+  matrixRoom: MatrixRoom;
   localTransport$: Behavior<LivekitTransport | null>;
-  matrixRTCSession: Pick<
-    MatrixRTCSession,
-    "updateCallIntent" | "leaveRoomSession"
-  >;
+  trackProcessorState$: Behavior<ProcessorState>;
+  widget: WidgetHelpers | null;
   logger: Logger;
 }
 
@@ -147,74 +131,75 @@ interface Props {
  */
 export const createLocalMembership$ = ({
   scope,
-  connectionManager,
-  localTransport$: localTransportCanThrow$,
-  homeserverConnected$,
-  createPublisherFactory,
-  joinMatrixRTC,
-  logger: parentLogger,
+  options,
   muteStates,
+  mediaDevices,
+  connectionManager,
   matrixRTCSession,
+  localTransport$,
+  matrixRoom,
+  trackProcessorState$,
+  widget,
+  logger: parentLogger,
 }: Props): {
-  /**
-   * This starts audio and video tracks. They will be reused when calling `requestConnect`.
-   */
+  // publisher: Publisher
+  requestConnect: () => LocalMemberConnectionState;
   startTracks: () => Behavior<LocalTrack[]>;
-  /**
-   * This sets a inner state (shouldConnect) to true and instructs the js-sdk and livekit to keep the user
-   * connected to matrix and livekit.
-   */
-  requestConnect: () => void;
-  requestDisconnect: () => void;
+  requestDisconnect: () => Observable<LocalMemberLivekitState> | null;
   connectionState: LocalMemberConnectionState;
   sharingScreen$: Behavior<boolean>;
   /**
    * Callback to toggle screen sharing. If null, screen sharing is not possible.
    */
   toggleScreenSharing: (() => void) | null;
-  tracks$: Behavior<LocalTrack[]>;
   participant$: Behavior<LocalParticipant | null>;
   connection$: Behavior<Connection | null>;
+  // deprecated fields
+  /** @deprecated use state instead*/
   homeserverConnected$: Behavior<boolean>;
+  /** @deprecated use state instead*/
+  connected$: Behavior<boolean>;
   // this needs to be discussed
   /** @deprecated use state instead*/
   reconnecting$: Behavior<boolean>;
+  // also needs to be disccues
+  /** @deprecated use state instead*/
+  configError$: Behavior<ElementCallError | null>;
 } => {
   const logger = parentLogger.getChild("[LocalMembership]");
   logger.debug(`Creating local membership..`);
+  const state = {
+    livekit$: new BehaviorSubject<LocalMemberLivekitState>({
+      state: LivekitState.Uninitialized,
+    }),
+    matrix$: new BehaviorSubject<LocalMemberMatrixState>({
+      state: MatrixState.Disconnected,
+    }),
+  };
 
-  // Unwrap the local transport and set the state of the LocalMembership to error in case the transport is an error.
-  const localTransport$ = scope.behavior(
-    localTransportCanThrow$.pipe(
-      catchError((e: unknown) => {
-        let error: ElementCallError;
-        if (e instanceof ElementCallError) {
-          error = e;
-        } else {
-          error = new UnknownCallError(
-            e instanceof Error
-              ? e
-              : new Error("Unknown error from localTransport"),
-          );
-        }
-        setLivekitError(error);
-        return of(null);
-      }),
-    ),
-  );
+  // This should be used in a combineLatest with publisher$ to connect.
+  // to make it possible to call startTracks before the preferredTransport$ has resolved.
+  const trackStartRequested$ = new BehaviorSubject(false);
+
+  // This should be used in a combineLatest with publisher$ to connect.
+  // to make it possible to call startTracks before the preferredTransport$ has resolved.
+  const connectRequested$ = new BehaviorSubject(false);
+
+  // This should be used in a combineLatest with publisher$ to connect.
+  const tracks$ = new BehaviorSubject<LocalTrack[]>([]);
 
   // Drop Epoch data here since we will not combine this anymore
   const localConnection$ = scope.behavior(
-    combineLatest([
-      connectionManager.connectionManagerData$,
-      localTransport$,
-    ]).pipe(
-      map(([{ value: connectionData }, localTransport]) => {
+    combineLatest([connectionManager.connections$, localTransport$]).pipe(
+      map(([connections, localTransport]) => {
         if (localTransport === null) {
           return null;
         }
-
-        return connectionData.getConnectionForTransport(localTransport);
+        return (
+          connections.value.find((connection) =>
+            areLivekitTransportsEqual(connection.transport, localTransport),
+          ) ?? null
+        );
       }),
       tap((connection) => {
         logger.info(
@@ -223,37 +208,88 @@ export const createLocalMembership$ = ({
       }),
     ),
   );
-
-  const localConnectionState$ = localConnection$.pipe(
-    switchMap((connection) => (connection ? connection.state$ : of(null))),
+  /**
+   * Whether we are connected to the MatrixRTC session.
+   */
+  const homeserverConnected$ = scope.behavior(
+    // To consider ourselves connected to MatrixRTC, we check the following:
+    and$(
+      // The client is connected to the sync loop
+      (
+        fromEvent(matrixRoom.client, ClientEvent.Sync) as Observable<
+          [SyncState]
+        >
+      ).pipe(
+        startWith([matrixRoom.client.getSyncState()]),
+        map(([state]) => state === SyncState.Syncing),
+      ),
+      // Room state observed by session says we're connected
+      fromEvent(matrixRTCSession, MembershipManagerEvent.StatusChanged).pipe(
+        startWith(null),
+        map(() => matrixRTCSession.membershipStatus === Status.Connected),
+      ),
+      // Also watch out for warnings that we've likely hit a timeout and our
+      // delayed leave event is being sent (this condition is here because it
+      // provides an earlier warning than the sync loop timeout, and we wouldn't
+      // see the actual leave event until we reconnect to the sync loop)
+      fromEvent(matrixRTCSession, MembershipManagerEvent.ProbablyLeft).pipe(
+        startWith(null),
+        map(() => matrixRTCSession.probablyLeft !== true),
+      ),
+    ).pipe(
+      tap((connected) => {
+        logger.info(`Homeserver connected update: ${connected}`);
+      }),
+    ),
   );
 
   // /**
   //  * Whether we are "fully" connected to the call. Accounts for both the
   //  * connection to the MatrixRTC session and the LiveKit publish connection.
   //  */
+  // // TODO use this in combination with the MemberState.
   const connected$ = scope.behavior(
     and$(
-      homeserverConnected$.pipe(
-        tap((v) => logger.debug("matrix: Connected state changed", v)),
+      homeserverConnected$,
+      localConnection$.pipe(
+        switchMap((c) =>
+          c
+            ? c.state$.pipe(map((state) => state.state === "ConnectedToLkRoom"))
+            : of(false),
+        ),
       ),
-      localConnectionState$.pipe(
-        switchMap((state) => {
-          logger.debug("livekit: Connected state changed", state);
-          if (!state) return of(false);
-          if (state.state === "ConnectedToLkRoom") {
-            logger.debug(
-              "livekit: Connected state changed (inner livekitConnectionState$)",
-              state.livekitConnectionState$.value,
-            );
-            return state.livekitConnectionState$.pipe(
-              map((lkState) => lkState === ConnectionState.Connected),
-            );
-          }
-          return of(false);
-        }),
-      ),
-    ).pipe(tap((v) => logger.debug("combined: Connected state changed", v))),
+    ),
+  );
+
+  const publisher$ = new BehaviorSubject<Publisher | null>(null);
+  localConnection$.subscribe((connection) => {
+    if (connection !== null && publisher$.value === null) {
+      // TODO looks strange to not change publisher if connection changes.
+      publisher$.next(
+        new Publisher(
+          scope,
+          connection,
+          mediaDevices,
+          muteStates,
+          trackProcessorState$,
+        ),
+      );
+    }
+  });
+
+  combineLatest([publisher$, trackStartRequested$]).subscribe(
+    ([publisher, shouldStartTracks]) => {
+      if (publisher && shouldStartTracks) {
+        publisher
+          .createAndSetupTracks()
+          .then((tracks) => {
+            tracks$.next(tracks);
+          })
+          .catch((error) => {
+            logger.error("Error creating tracks:", error);
+          });
+      }
+    },
   );
 
   // MATRIX RELATED
@@ -278,217 +314,83 @@ export const createLocalMembership$ = ({
     ),
   );
 
-  // This should be used in a combineLatest with publisher$ to connect.
-  // to make it possible to call startTracks before the preferredTransport$ has resolved.
-  const trackStartRequested = Promise.withResolvers<void>();
-
-  // This should be used in a combineLatest with publisher$ to connect.
-  // to make it possible to call startTracks before the preferredTransport$ has resolved.
-  const connectRequested$ = new BehaviorSubject(false);
-
-  /**
-   * The publisher is stored in here an abstracts creating and publishing tracks.
-   */
-  const publisher$ = new BehaviorSubject<Publisher | null>(null);
-  /**
-   * Extract the tracks from the published. Also reacts to changing publishers.
-   */
-  const tracks$ = scope.behavior(
-    publisher$.pipe(switchMap((p) => (p?.tracks$ ? p.tracks$ : constant([])))),
-  );
-  const publishing$ = scope.behavior(
-    publisher$.pipe(switchMap((p) => p?.publishing$ ?? constant(false))),
-  );
-
   const startTracks = (): Behavior<LocalTrack[]> => {
-    trackStartRequested.resolve();
+    trackStartRequested$.next(true);
     return tracks$;
   };
 
-  const requestConnect = (): void => {
-    trackStartRequested.resolve();
-    connectRequested$.next(true);
-  };
-
-  const requestDisconnect = (): void => {
-    connectRequested$.next(false);
-  };
-
-  // Take care of the publisher$
-  // create a new one as soon as a local Connection is available
-  //
-  // Recreate a new one once the local connection changes
-  //  - stop publishing
-  //  - destruct all current streams
-  //  - overwrite current publisher
-  scope.reconcile(localConnection$, async (connection) => {
-    if (connection !== null) {
-      publisher$.next(createPublisherFactory(connection));
+  combineLatest([publisher$, tracks$]).subscribe(([publisher, tracks]) => {
+    if (
+      tracks.length === 0 ||
+      // change this to !== Publishing
+      state.livekit$.value.state !== LivekitState.Uninitialized
+    ) {
+      return;
     }
-    return Promise.resolve(async (): Promise<void> => {
-      await publisher$?.value?.stopPublishing();
-      publisher$?.value?.stopTracks();
-    });
+    state.livekit$.next({ state: LivekitState.Connecting });
+    publisher
+      ?.startPublishing()
+      .then(() => {
+        state.livekit$.next({ state: LivekitState.Connected });
+      })
+      .catch((error) => {
+        state.livekit$.next({ state: LivekitState.Error, error });
+      });
   });
 
-  // Use reconcile here to not run concurrent createAndSetupTracks calls
-  // `tracks$` will update once they are ready.
-  scope.reconcile(
-    scope.behavior(
-      combineLatest([publisher$, tracks$, from(trackStartRequested.promise)]),
-      null,
-    ),
-    async (valueIfReady) => {
-      if (!valueIfReady) return;
-      const [publisher, tracks] = valueIfReady;
-      if (publisher && tracks.length === 0) {
-        await publisher.createAndSetupTracks().catch((e) => logger.error(e));
+  combineLatest([localTransport$, connectRequested$]).subscribe(
+    // TODO reconnect on options change.
+    ([transport, connectRequested]) => {
+      if (
+        transport === null ||
+        !connectRequested ||
+        state.matrix$.value.state !== MatrixState.Disconnected
+      ) {
+        logger.info(
+          "Not yet connecting because: ",
+          "transport === null:",
+          transport === null,
+          "!connectRequested:",
+          !connectRequested,
+          "state.matrix$.value.state !== MatrixState.Disconnected:",
+          state.matrix$.value.state !== MatrixState.Disconnected,
+        );
+        return;
       }
-    },
-  );
-
-  // Based on `connectRequested$` we start publishing tracks. (once they are there!)
-  scope.reconcile(
-    scope.behavior(combineLatest([publisher$, tracks$, connectRequested$])),
-    async ([publisher, tracks, shouldConnect]) => {
-      if (shouldConnect === publisher?.publishing$.value) return;
-      if (tracks.length !== 0 && shouldConnect) {
-        try {
-          await publisher?.startPublishing();
-        } catch (error) {
-          setLivekitError(error as ElementCallError);
-        }
-      } else if (tracks.length !== 0 && !shouldConnect) {
-        try {
-          await publisher?.stopPublishing();
-        } catch (error) {
-          setLivekitError(new UnknownCallError(error as Error));
-        }
-      }
-    },
-  );
-
-  const fatalLivekitError$ = new BehaviorSubject<ElementCallError | null>(null);
-  const setLivekitError = (e: ElementCallError): void => {
-    if (fatalLivekitError$.value !== null)
-      logger.error("Multiple Livkit Errors:", e);
-    else fatalLivekitError$.next(e);
-  };
-  const livekitState$: Behavior<LocalMemberRtcBackendState> = scope.behavior(
-    combineLatest([
-      publisher$,
-      localTransport$,
-      tracks$.pipe(
-        tap((t) => {
-          logger.info("tracks$: ", t);
-        }),
-      ),
-      publishing$,
-      connectRequested$,
-      from(trackStartRequested.promise).pipe(
-        map(() => true),
-        startWith(false),
-      ),
-      fatalLivekitError$,
-    ]).pipe(
-      map(
-        ([
-          publisher,
-          localTransport,
-          tracks,
-          publishing,
-          shouldConnect,
-          shouldStartTracks,
-          error,
-        ]) => {
-          // read this:
-          // if(!<A>) return {state: ...}
-          // if(!<B>) return {state: <MyState>}
-          //
-          // as:
-          // We do have <A> but not yet <B> so we are in <MyState>
-          if (error !== null) return { state: RTCBackendState.Error, error };
-          const hasTracks = tracks.length > 0;
-          if (!localTransport)
-            return { state: RTCBackendState.WaitingForTransport };
-          if (!publisher)
-            return { state: RTCBackendState.WaitingForConnection };
-          if (!shouldStartTracks) return { state: RTCBackendState.Initialized };
-          if (!hasTracks) return { state: RTCBackendState.CreatingTracks };
-          if (!shouldConnect) return { state: RTCBackendState.ReadyToPublish };
-          if (!publishing) return { state: RTCBackendState.WaitingToPublish };
-          return { state: RTCBackendState.Connected };
+      state.matrix$.next({ state: MatrixState.Connecting });
+      logger.info("Matrix State connecting");
+      enterRTCSession(matrixRTCSession, transport, options.value).catch(
+        (error) => {
+          logger.error(error);
         },
-      ),
-      distinctUntilChanged(deepCompare),
-    ),
-  );
-
-  const fatalMatrixError$ = new BehaviorSubject<ElementCallError | null>(null);
-  const setMatrixError = (e: ElementCallError): void => {
-    if (fatalMatrixError$.value !== null)
-      logger.error("Multiple Matrix Errors:", e);
-    else fatalMatrixError$.next(e);
-  };
-  const matrixState$: Behavior<LocalMemberMatrixState> = scope.behavior(
-    combineLatest([
-      localTransport$,
-      connectRequested$,
-      homeserverConnected$,
-    ]).pipe(
-      map(([localTransport, connectRequested, homeserverConnected]) => {
-        if (!localTransport) return { state: MatrixState.WaitingForTransport };
-        if (!connectRequested) return { state: MatrixState.Ready };
-        if (!homeserverConnected) return { state: MatrixState.Connecting };
-        return { state: MatrixState.Connected };
-      }),
-    ),
-  );
-
-  // Keep matrix rtc session in sync with localTransport$, connectRequested$ and muteStates.video.enabled$
-  scope.reconcile(
-    scope.behavior(combineLatest([localTransport$, connectRequested$])),
-    async ([transport, shouldConnect]) => {
-      if (!shouldConnect) return;
-
-      if (!transport) return;
-      try {
-        await joinMatrixRTC(transport);
-      } catch (error) {
-        logger.error("Error entering RTC session", error);
-        if (error instanceof Error)
-          setMatrixError(new MembershipManagerError(error));
-      }
-
-      // Update our member event when our mute state changes.
-      const callIntentScope = new ObservableScope();
-      // because this uses its own scope, we can start another reconciliation for the duration of one connection.
-      callIntentScope.reconcile(
-        muteStates.video.enabled$,
-        async (videoEnabled) =>
-          matrixRTCSession.updateCallIntent(videoEnabled ? "video" : "audio"),
       );
-
-      return async (): Promise<void> => {
-        callIntentScope.end();
-        try {
-          // Update matrixRTCSession to allow udpating the transport without leaving the session!
-          await matrixRTCSession.leaveRoomSession();
-        } catch (e) {
-          logger.error("Error leaving RTC session", e);
-        }
-        try {
-          await widget?.api.transport.send(ElementWidgetActions.HangupCall, {});
-        } catch (e) {
-          logger.error("Failed to send hangup action", e);
-        }
-      };
     },
   );
 
-  const participant$ = scope.behavior(
-    localConnection$.pipe(map((c) => c?.livekitRoom?.localParticipant ?? null)),
-  );
+  const requestConnect = (): LocalMemberConnectionState => {
+    trackStartRequested$.next(true);
+    connectRequested$.next(true);
+
+    return state;
+  };
+
+  const requestDisconnect = (): Behavior<LocalMemberLivekitState> | null => {
+    if (state.livekit$.value.state !== LivekitState.Connected) return null;
+    state.livekit$.next({ state: LivekitState.Disconnecting });
+    combineLatest([publisher$, tracks$], (publisher, tracks) => {
+      publisher
+        ?.stopPublishing()
+        .then(() => {
+          tracks.forEach((track) => track.stop());
+          state.livekit$.next({ state: LivekitState.Disconnected });
+        })
+        .catch((error) => {
+          state.livekit$.next({ state: LivekitState.Error, error });
+        });
+    });
+
+    return state.livekit$;
+  };
 
   // Pause upstream of all local media tracks when we're disconnected from
   // MatrixRTC, because it can be an unpleasant surprise for the app to say
@@ -496,12 +398,12 @@ export const createLocalMembership$ = ({
   // We use matrixConnected$ rather than reconnecting$ because we want to
   // pause tracks during the initial joining sequence too until we're sure
   // that our own media is displayed on screen.
-  // TODO refactor this based no livekitState$
-  combineLatest([participant$, homeserverConnected$])
+  combineLatest([localConnection$, homeserverConnected$])
     .pipe(scope.bind())
-    .subscribe(([participant, connected]) => {
-      if (!participant) return;
-      const publications = participant.trackPublications.values();
+    .subscribe(([connection, connected]) => {
+      if (connection?.state$.value.state !== "ConnectedToLkRoom") return;
+      const publications =
+        connection.livekitRoom.localParticipant.trackPublications.values();
       if (connected) {
         for (const p of publications) {
           if (p.track?.isUpstreamPaused === true) {
@@ -539,61 +441,118 @@ export const createLocalMembership$ = ({
       }
     });
 
+  const configError$ = new BehaviorSubject<ElementCallError | null>(null);
+  // TODO I do not fully understand what this does.
+  // Is it needed?
+  // Is this at the right place?
+  // Can this be simplified?
+  // Start and stop session membership as needed
+  scope.reconcile(localTransport$, async (advertised) => {
+    if (advertised !== null && advertised !== undefined) {
+      try {
+        await enterRTCSession(matrixRTCSession, advertised, options.value);
+        configError$.next(null);
+      } catch (e) {
+        logger.error("Error entering RTC session", e);
+      }
+
+      // Update our member event when our mute state changes.
+      const intentScope = new ObservableScope();
+      intentScope.reconcile(muteStates.video.enabled$, async (videoEnabled) =>
+        matrixRTCSession.updateCallIntent(videoEnabled ? "video" : "audio"),
+      );
+
+      return async (): Promise<void> => {
+        intentScope.end();
+        // Only sends Matrix leave event. The LiveKit session will disconnect
+        // as soon as either the stopConnection$ handler above gets to it or
+        // the view model is destroyed.
+        try {
+          await matrixRTCSession.leaveRoomSession();
+        } catch (e) {
+          logger.error("Error leaving RTC session", e);
+        }
+        try {
+          await widget?.api.transport.send(ElementWidgetActions.HangupCall, {});
+        } catch (e) {
+          logger.error("Failed to send hangup action", e);
+        }
+      };
+    }
+  });
+
+  localConnection$
+    .pipe(
+      distinctUntilChanged(),
+      switchMap((c) =>
+        c === null ? of({ state: "Initialized" } as ConnectionState) : c.state$,
+      ),
+      map((s) => {
+        logger.trace(`Local connection state update: ${s.state}`);
+        if (s.state == "FailedToStart") {
+          return s.error instanceof ElementCallError
+            ? s.error
+            : new UnknownCallError(s.error);
+        } else {
+          return null;
+        }
+      }),
+      scope.bind(),
+    )
+    .subscribe((fatalError) => {
+      configError$.next(fatalError);
+    });
+
   /**
    * Whether the user is currently sharing their screen.
    */
   const sharingScreen$ = scope.behavior(
-    participant$.pipe(
-      switchMap((p) => (p !== null ? observeSharingScreen$(p) : of(false))),
+    localConnection$.pipe(
+      switchMap((c) =>
+        c === null
+          ? of(false)
+          : observeSharingScreen$(c.livekitRoom.localParticipant),
+      ),
     ),
   );
 
-  let toggleScreenSharing: (() => void) | null = null;
-  if (
+  const toggleScreenSharing =
     "getDisplayMedia" in (navigator.mediaDevices ?? {}) &&
     !getUrlParams().hideScreensharing
-  ) {
-    toggleScreenSharing = (): void => {
-      const screenshareSettings: ScreenShareCaptureOptions = {
-        audio: true,
-        selfBrowserSurface: "include",
-        surfaceSwitching: "include",
-        systemAudio: "include",
-      };
-      const targetScreenshareState = !sharingScreen$.value;
-      logger.info(
-        `toggleScreenSharing called. Switching ${
-          targetScreenshareState ? "On" : "Off"
-        }`,
-      );
-      // If a connection is ready, toggle screen sharing.
-      // We deliberately do nothing in the case of a null connection because
-      // it looks nice for the call control buttons to all become available
-      // at once upon joining the call, rather than introducing a disabled
-      // state. The user can just click again.
-      // We also allow screen sharing to be toggled even if the connection
-      // is still initializing or publishing tracks, because there's no
-      // technical reason to disallow this. LiveKit will publish if it can.
-      participant$.value
-        ?.setScreenShareEnabled(targetScreenshareState, screenshareSettings)
-        .catch(logger.error);
-    };
-  }
+      ? (): void =>
+          // If a connection is ready, toggle screen sharing.
+          // We deliberately do nothing in the case of a null connection because
+          // it looks nice for the call control buttons to all become available
+          // at once upon joining the call, rather than introducing a disabled
+          // state. The user can just click again.
+          // We also allow screen sharing to be toggled even if the connection
+          // is still initializing or publishing tracks, because there's no
+          // technical reason to disallow this. LiveKit will publish if it can.
+          void localConnection$.value?.livekitRoom.localParticipant
+            .setScreenShareEnabled(!sharingScreen$.value, {
+              audio: true,
+              selfBrowserSurface: "include",
+              surfaceSwitching: "include",
+              systemAudio: "include",
+            })
+            .catch(logger.error)
+      : null;
 
+  const participant$ = scope.behavior(
+    localConnection$.pipe(map((c) => c?.livekitRoom.localParticipant ?? null)),
+  );
   return {
     startTracks,
     requestConnect,
     requestDisconnect,
-    connectionState: {
-      livekit$: livekitState$,
-      matrix$: matrixState$,
-    },
-    tracks$,
-    participant$,
+    connectionState: state,
     homeserverConnected$,
+    connected$,
     reconnecting$,
+    configError$,
     sharingScreen$,
     toggleScreenSharing,
+    participant$,
     connection$: localConnection$,
   };
 };
@@ -614,12 +573,7 @@ interface EnterRTCSessionOptions {
 }
 
 /**
- * Does the necessary steps to enter the RTC session on the matrix side:
- *  - Preparing the membership info (FOCUS to use, options)
- *  - Sends the matrix event to join the call, and starts the membership manager:
- *      - Delay events management
- *      - Handles retries (fails only after several attempts)
- *
+ * TODO! document this function properly
  * @param rtcSession
  * @param transport
  * @param options
@@ -644,7 +598,6 @@ export async function enterRTCSession(
   const { sendNotificationType: notificationType, callIntent } = getUrlParams();
   const multiSFU = matrixRTCMode !== MatrixRTCMode.Legacy;
   // Multi-sfu does not need a preferred foci list. just the focus that is actually used.
-  // TODO where/how do we track errors originating from the ongoing rtcSession?
   rtcSession.joinRoomSession(
     multiSFU ? [] : [transport],
     multiSFU ? transport : undefined,

src/state/CallViewModel/localMember/LocalTransport.test.ts

@@ -1,156 +0,0 @@
-/*
-Copyright 2025 Element Creations Ltd.
-
-SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
-Please see LICENSE in the repository root for full details.
-*/
-
-import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
-import { type CallMembership } from "matrix-js-sdk/lib/matrixrtc";
-import { BehaviorSubject } from "rxjs";
-
-import { mockConfig, flushPromises } from "../../../utils/test";
-import { createLocalTransport$ } from "./LocalTransport";
-import { constant } from "../../Behavior";
-import { Epoch, ObservableScope } from "../../ObservableScope";
-import {
-  MatrixRTCTransportMissingError,
-  FailToGetOpenIdToken,
-} from "../../../utils/errors";
-import * as openIDSFU from "../../../livekit/openIDSFU";
-
-describe("LocalTransport", () => {
-  let scope: ObservableScope;
-  beforeEach(() => (scope = new ObservableScope()));
-  afterEach(() => scope.end());
-
-  it("throws if config is missing", async () => {
-    const localTransport$ = createLocalTransport$({
-      scope,
-      roomId: "!room:example.org",
-      useOldestMember$: constant(false),
-      memberships$: constant(new Epoch<CallMembership[]>([])),
-      client: {
-        getDomain: () => "",
-        // These won't be called in this error path but satisfy the type
-        getOpenIdToken: vi.fn(),
-        getDeviceId: vi.fn(),
-      },
-    });
-    await flushPromises();
-
-    expect(() => localTransport$.value).toThrow(
-      new MatrixRTCTransportMissingError(""),
-    );
-  });
-
-  it("throws FailToGetOpenIdToken when OpenID fetch fails", async () => {
-    // Provide a valid config so makeTransportInternal resolves a transport
-    const scope = new ObservableScope();
-    mockConfig({
-      livekit: { livekit_service_url: "https://lk.example.org" },
-    });
-    const resolver = Promise.withResolvers<void>();
-    vi.spyOn(openIDSFU, "getSFUConfigWithOpenID").mockImplementation(
-      async () => {
-        await resolver.promise;
-        throw new FailToGetOpenIdToken(new Error("no openid"));
-      },
-    );
-    const observations: unknown[] = [];
-    const errors: Error[] = [];
-    const localTransport$ = createLocalTransport$({
-      scope,
-      roomId: "!room:example.org",
-      useOldestMember$: constant(false),
-      memberships$: constant(new Epoch<CallMembership[]>([])),
-      client: {
-        // Use empty domain to skip .well-known and use config directly
-        getDomain: () => "",
-        getOpenIdToken: vi.fn(),
-        getDeviceId: vi.fn(),
-      },
-    });
-    localTransport$.subscribe(
-      (o) => observations.push(o),
-      (e) => errors.push(e),
-    );
-    resolver.resolve();
-    await flushPromises();
-
-    const expectedError = new FailToGetOpenIdToken(new Error("no openid"));
-    expect(observations).toStrictEqual([null]);
-    expect(errors).toStrictEqual([expectedError]);
-    expect(() => localTransport$.value).toThrow(expectedError);
-  });
-
-  it("emits preferred transport after OpenID resolves", async () => {
-    // Use config so transport discovery succeeds, but delay OpenID JWT fetch
-    mockConfig({
-      livekit: { livekit_service_url: "https://lk.example.org" },
-    });
-
-    const openIdResolver = Promise.withResolvers<openIDSFU.SFUConfig>();
-
-    vi.spyOn(openIDSFU, "getSFUConfigWithOpenID").mockReturnValue(
-      openIdResolver.promise,
-    );
-
-    const localTransport$ = createLocalTransport$({
-      scope,
-      roomId: "!room:example.org",
-      useOldestMember$: constant(false),
-      memberships$: constant(new Epoch<CallMembership[]>([])),
-      client: {
-        getDomain: () => "",
-        getOpenIdToken: vi.fn(),
-        getDeviceId: vi.fn(),
-      },
-    });
-
-    openIdResolver.resolve?.({ url: "https://lk.example.org", jwt: "jwt" });
-    expect(localTransport$.value).toBe(null);
-    await flushPromises();
-    // final
-    expect(localTransport$.value).toStrictEqual({
-      livekit_alias: "!room:example.org",
-      livekit_service_url: "https://lk.example.org",
-      type: "livekit",
-    });
-  });
-
-  it("updates local transport when oldest member changes", async () => {
-    // Use config so transport discovery succeeds, but delay OpenID JWT fetch
-    mockConfig({
-      livekit: { livekit_service_url: "https://lk.example.org" },
-    });
-    const memberships$ = new BehaviorSubject(new Epoch([]));
-    const openIdResolver = Promise.withResolvers<openIDSFU.SFUConfig>();
-
-    vi.spyOn(openIDSFU, "getSFUConfigWithOpenID").mockReturnValue(
-      openIdResolver.promise,
-    );
-
-    const localTransport$ = createLocalTransport$({
-      scope,
-      roomId: "!room:example.org",
-      useOldestMember$: constant(true),
-      memberships$,
-      client: {
-        getDomain: () => "",
-        getOpenIdToken: vi.fn(),
-        getDeviceId: vi.fn(),
-      },
-    });
-
-    openIdResolver.resolve?.({ url: "https://lk.example.org", jwt: "jwt" });
-    expect(localTransport$.value).toBe(null);
-    await flushPromises();
-    // final
-    expect(localTransport$.value).toStrictEqual({
-      livekit_alias: "!room:example.org",
-      livekit_service_url: "https://lk.example.org",
-      type: "livekit",
-    });
-  });
-});

src/state/CallViewModel/localMember/LocalTransport.ts

@@ -1,5 +1,5 @@
 /*
-Copyright 2025 Element Creations Ltd.
+Copyright 2025 New Vector Ltd.
 
 SPDX-License-IdFentifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.
@@ -13,39 +13,32 @@ import {
   isLivekitTransportConfig,
 } from "matrix-js-sdk/lib/matrixrtc";
 import { type MatrixClient } from "matrix-js-sdk";
-import {
-  combineLatest,
-  distinctUntilChanged,
-  first,
-  from,
-  map,
-  switchMap,
-} from "rxjs";
-import { logger as rootLogger } from "matrix-js-sdk/lib/logger";
+import { combineLatest, distinctUntilChanged, first, from, map } from "rxjs";
+import { logger } from "matrix-js-sdk/lib/logger";
 import { AutoDiscovery } from "matrix-js-sdk/lib/autodiscovery";
 
 import { type Behavior } from "../../Behavior.ts";
 import { type Epoch, type ObservableScope } from "../../ObservableScope.ts";
 import { Config } from "../../../config/Config.ts";
 import { MatrixRTCTransportMissingError } from "../../../utils/errors.ts";
-import {
-  getSFUConfigWithOpenID,
-  type OpenIDClientParts,
-} from "../../../livekit/openIDSFU.ts";
+import { getSFUConfigWithOpenID } from "../../../livekit/openIDSFU.ts";
 import { areLivekitTransportsEqual } from "../remoteMembers/MatrixLivekitMembers.ts";
-import { customLivekitUrl } from "../../../settings/settings.ts";
-
-const logger = rootLogger.getChild("[LocalTransport]");
 
 /*
- * It figures out “which LiveKit focus URL/alias the local user should use,”
- * optionally aligning with the oldest member, and ensures the SFU path is primed
- * before advertising that choice.
+ * - get well known
+ * - get oldest membership
+ * - get transport to use
+ * - get openId + jwt token
+ * - wait for createTrack() call
+ *    - create tracks
+ * - wait for join() call
+ *   - Publisher.publishTracks()
+ *   - send join state/sticky event
  */
 interface Props {
   scope: ObservableScope;
   memberships$: Behavior<Epoch<CallMembership[]>>;
-  client: Pick<MatrixClient, "getDomain"> & OpenIDClientParts;
+  client: MatrixClient;
   roomId: string;
   useOldestMember$: Behavior<boolean>;
 }
@@ -56,8 +49,6 @@ interface Props {
  *
  * @prop useOldestMember Whether to use the same transport as the oldest member.
  * This will only update once the first oldest member appears. Will not recompute if the oldest member leaves.
- *
- * @throws MatrixRTCTransportMissingError | FailToGetOpenIdToken
  */
 export const createLocalTransport$ = ({
   scope,
@@ -84,20 +75,16 @@ export const createLocalTransport$ = ({
   /**
    * The transport that we would personally prefer to publish on (if not for the
    * transport preferences of others, perhaps).
-   *
-   * @throws
    */
   const preferredTransport$: Behavior<LivekitTransport | null> = scope.behavior(
-    customLivekitUrl.value$.pipe(
-      switchMap((customUrl) => from(makeTransport(client, roomId, customUrl))),
-    ),
+    from(makeTransport(client, roomId)),
     null,
   );
 
   /**
-   * The chosen transport we should advertise in our MatrixRTC membership.
+   * The transport we should advertise in our MatrixRTC membership.
    */
-  return scope.behavior(
+  const advertisedTransport$ = scope.behavior(
     combineLatest([
       useOldestMember$,
       oldestMemberTransport$,
@@ -111,78 +98,82 @@ export const createLocalTransport$ = ({
       distinctUntilChanged(areLivekitTransportsEqual),
     ),
   );
+  return advertisedTransport$;
 };
 
 const FOCI_WK_KEY = "org.matrix.msc4143.rtc_foci";
 
-/**
- *
- * @param client
- * @param roomId
- * @returns
- * @throws MatrixRTCTransportMissingError | FailToGetOpenIdToken
- */
-async function makeTransport(
-  client: Pick<MatrixClient, "getDomain"> & OpenIDClientParts,
+async function makeTransportInternal(
+  client: MatrixClient,
   roomId: string,
-  urlFromDevSettings: string | null,
 ): Promise<LivekitTransport> {
-  let transport: LivekitTransport | undefined;
-  logger.trace("Searching for a preferred transport");
+  logger.log("Searching for a preferred transport");
   //TODO refactor this to use the jwt service returned alias.
   const livekitAlias = roomId;
-
-  // DEVTOOL: Highest priority: Load from devtool setting
-  if (urlFromDevSettings !== null) {
+  // TODO-MULTI-SFU: Either remove this dev tool or make it more official
+  const urlFromStorage =
+    localStorage.getItem("robin-matrixrtc-auth") ??
+    localStorage.getItem("timo-focus-url");
+  if (urlFromStorage !== null) {
     const transportFromStorage: LivekitTransport = {
       type: "livekit",
-      livekit_service_url: urlFromDevSettings,
+      livekit_service_url: urlFromStorage,
       livekit_alias: livekitAlias,
     };
-    logger.info(
-      "Using LiveKit transport from dev tools: ",
+    logger.log(
+      "Using LiveKit transport from local storage: ",
       transportFromStorage,
     );
-    transport = transportFromStorage;
+    return transportFromStorage;
   }
 
-  // WELL_KNOWN: Prioritize the .well-known/matrix/client, if available, over the configured SFU
+  // Prioritize the .well-known/matrix/client, if available, over the configured SFU
   const domain = client.getDomain();
-  if (domain && transport === undefined) {
+  if (domain) {
     // we use AutoDiscovery instead of relying on the MatrixClient having already
     // been fully configured and started
     const wellKnownFoci = (await AutoDiscovery.getRawClientConfig(domain))?.[
       FOCI_WK_KEY
     ];
     if (Array.isArray(wellKnownFoci)) {
-      const wellKnownTransport: LivekitTransportConfig | undefined =
-        wellKnownFoci.find((f) => f && isLivekitTransportConfig(f));
-      if (wellKnownTransport !== undefined) {
-        logger.info("Using LiveKit transport from .well-known: ", transport);
-        transport = { ...wellKnownTransport, livekit_alias: livekitAlias };
+      const transport: LivekitTransportConfig | undefined = wellKnownFoci.find(
+        (f) => f && isLivekitTransportConfig(f),
+      );
+      if (transport !== undefined) {
+        logger.log("Using LiveKit transport from .well-known: ", transport);
+        return { ...transport, livekit_alias: livekitAlias };
       }
     }
   }
 
-  // CONFIG: Least prioritized; Load from config file
   const urlFromConf = Config.get().livekit?.livekit_service_url;
-  if (urlFromConf && transport === undefined) {
+  if (urlFromConf) {
     const transportFromConf: LivekitTransport = {
       type: "livekit",
       livekit_service_url: urlFromConf,
       livekit_alias: livekitAlias,
     };
-    logger.info("Using LiveKit transport from config: ", transportFromConf);
-    transport = transportFromConf;
+    logger.log("Using LiveKit transport from config: ", transportFromConf);
+    return transportFromConf;
   }
 
-  if (!transport) throw new MatrixRTCTransportMissingError(domain ?? ""); // this will call the jwt/sfu/get endpoint to pre create the livekit room.
-
-  await getSFUConfigWithOpenID(
-    client,
-    transport.livekit_service_url,
-    transport.livekit_alias,
-  );
+  throw new MatrixRTCTransportMissingError(domain ?? "");
+}
 
+async function makeTransport(
+  client: MatrixClient,
+  roomId: string,
+): Promise<LivekitTransport> {
+  const transport = await makeTransportInternal(client, roomId);
+  // this will call the jwt/sfu/get endpoint to pre create the livekit room.
+  try {
+    await getSFUConfigWithOpenID(
+      client,
+      transport.livekit_service_url,
+      transport.livekit_alias,
+    );
+  } catch (e) {
+    logger.warn(`Failed to get SFU config for transport: ${e}`);
+  }
   return transport;
 }

src/state/CallViewModel/localMember/Publisher.test.ts

@@ -1,140 +0,0 @@
-/*
-Copyright 2025 Element Creations Ltd.
-
-SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
-Please see LICENSE in the repository root for full details.
-*/
-
-import {
-  afterEach,
-  beforeEach,
-  describe,
-  expect,
-  it,
-  type Mock,
-  vi,
-} from "vitest";
-import { ConnectionState as LivekitConenctionState } from "livekit-client";
-import { type BehaviorSubject } from "rxjs";
-import { logger } from "matrix-js-sdk/lib/logger";
-
-import { ObservableScope } from "../../ObservableScope";
-import { constant } from "../../Behavior";
-import {
-  mockLivekitRoom,
-  mockLocalParticipant,
-  mockMediaDevices,
-} from "../../../utils/test";
-import { Publisher } from "./Publisher";
-import {
-  type Connection,
-  type ConnectionState,
-} from "../remoteMembers/Connection";
-import { type MuteStates } from "../../MuteStates";
-import { FailToStartLivekitConnection } from "../../../utils/errors";
-
-describe("Publisher", () => {
-  let scope: ObservableScope;
-  let connection: Connection;
-  let muteStates: MuteStates;
-  beforeEach(() => {
-    muteStates = {
-      audio: {
-        enabled$: constant(false),
-        unsetHandler: vi.fn(),
-        setHandler: vi.fn(),
-      },
-      video: {
-        enabled$: constant(false),
-        unsetHandler: vi.fn(),
-        setHandler: vi.fn(),
-      },
-    } as unknown as MuteStates;
-    scope = new ObservableScope();
-    connection = {
-      state$: constant({
-        state: "ConnectedToLkRoom",
-        livekitConnectionState$: constant(LivekitConenctionState.Connected),
-      }),
-      livekitRoom: mockLivekitRoom({
-        localParticipant: mockLocalParticipant({}),
-      }),
-    } as unknown as Connection;
-  });
-
-  afterEach(() => scope.end());
-
-  it("throws if livekit room could not publish", async () => {
-    const publisher = new Publisher(
-      scope,
-      connection,
-      mockMediaDevices({}),
-      muteStates,
-      constant({ supported: false, processor: undefined }),
-      logger,
-    );
-
-    // should do nothing if no tracks have been created yet.
-    await publisher.startPublishing();
-    expect(
-      connection.livekitRoom.localParticipant.publishTrack,
-    ).not.toHaveBeenCalled();
-
-    await expect(publisher.createAndSetupTracks()).rejects.toThrow(
-      Error("audio and video is false"),
-    );
-
-    (muteStates.audio.enabled$ as BehaviorSubject<boolean>).next(true);
-
-    (
-      connection.livekitRoom.localParticipant.createTracks as Mock
-    ).mockResolvedValue([{}, {}]);
-
-    await expect(publisher.createAndSetupTracks()).resolves.not.toThrow();
-    expect(
-      connection.livekitRoom.localParticipant.createTracks,
-    ).toHaveBeenCalledOnce();
-
-    // failiour due to localParticipant.publishTrack
-    (
-      connection.livekitRoom.localParticipant.publishTrack as Mock
-    ).mockRejectedValue(Error("testError"));
-
-    await expect(publisher.startPublishing()).rejects.toThrow(
-      new FailToStartLivekitConnection("testError"),
-    );
-
-    // does not try other conenction after the first one failed
-    expect(
-      connection.livekitRoom.localParticipant.publishTrack,
-    ).toHaveBeenCalledTimes(1);
-
-    // failiour due to connection.state$
-    const beforeState = connection.state$.value;
-    (connection.state$ as BehaviorSubject<ConnectionState>).next({
-      state: "FailedToStart",
-      error: Error("testStartError"),
-    });
-
-    await expect(publisher.startPublishing()).rejects.toThrow(
-      new FailToStartLivekitConnection("testStartError"),
-    );
-    (connection.state$ as BehaviorSubject<ConnectionState>).next(beforeState);
-
-    // does not try other conenction after the first one failed
-    expect(
-      connection.livekitRoom.localParticipant.publishTrack,
-    ).toHaveBeenCalledTimes(1);
-
-    // success case
-    (
-      connection.livekitRoom.localParticipant.publishTrack as Mock
-    ).mockResolvedValue({});
-
-    await expect(publisher.startPublishing()).resolves.not.toThrow();
-
-    expect(
-      connection.livekitRoom.localParticipant.publishTrack,
-    ).toHaveBeenCalledTimes(3);
-  });
-});

src/state/CallViewModel/localMember/Publisher.ts

@@ -1,5 +1,4 @@
 /*
-Copyright 2025 Element Creations Ltd.
 Copyright 2025 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
@@ -14,7 +13,6 @@ import {
   ConnectionState as LivekitConnectionState,
 } from "livekit-client";
 import {
-  BehaviorSubject,
   map,
   NEVER,
   type Observable,
@@ -34,10 +32,6 @@ import { getUrlParams } from "../../../UrlParams.ts";
 import { observeTrackReference$ } from "../../MediaViewModel.ts";
 import { type Connection } from "../remoteMembers/Connection.ts";
 import { type ObservableScope } from "../../ObservableScope.ts";
-import {
-  ElementCallError,
-  FailToStartLivekitConnection,
-} from "../../../utils/errors.ts";
 
 /**
  * A wrapper for a Connection object.
@@ -45,6 +39,7 @@ import {
  * The Publisher is also responsible for creating the media tracks.
  */
 export class Publisher {
+  public tracks: LocalTrack<Track.Kind>[] = [];
   /**
    * Creates a new Publisher.
    * @param scope - The observable scope to use for managing the publisher.
@@ -56,19 +51,19 @@ export class Publisher {
    */
   public constructor(
     private scope: ObservableScope,
-    private connection: Pick<Connection, "livekitRoom" | "state$">, //setE2EEEnabled,
+    private connection: Connection,
     devices: MediaDevices,
     private readonly muteStates: MuteStates,
     trackerProcessorState$: Behavior<ProcessorState>,
-    private logger: Logger,
+    private logger?: Logger,
   ) {
-    this.logger.info("Create LiveKit room");
+    this.logger?.info("[PublishConnection] Create LiveKit room");
     const { controlledAudioDevices } = getUrlParams();
 
     const room = connection.livekitRoom;
 
     room.setE2EEEnabled(room.options.e2ee !== undefined)?.catch((e: Error) => {
-      this.logger.error("Failed to set E2EE enabled on room", e);
+      this.logger?.error("Failed to set E2EE enabled on room", e);
     });
 
     // Setup track processor syncing (blur)
@@ -78,31 +73,13 @@ export class Publisher {
 
     this.workaroundRestartAudioInputTrackChrome(devices, scope);
     this.scope.onEnd(() => {
-      this.logger.info("Scope ended -> stop publishing all tracks");
+      this.logger?.info(
+        "[PublishConnection] Scope ended -> stop publishing all tracks",
+      );
       void this.stopPublishing();
     });
-
-    // TODO move mute state handling here using reconcile (instead of inside the mute state class)
-    // this.scope.reconcile(
-    //   this.scope.behavior(
-    //     combineLatest([this.muteStates.video.enabled$, this.tracks$]),
-    //   ),
-    //   async ([videoEnabled, tracks]) => {
-    //     const track = tracks.find((t) => t.kind == Track.Kind.Video);
-    //     if (!track) return;
-
-    //     if (videoEnabled) {
-    //       await track.unmute();
-    //     } else {
-    //       await track.mute();
-    //     }
-    //   },
-    // );
   }
 
-  private _tracks$ = new BehaviorSubject<LocalTrack<Track.Kind>[]>([]);
-  public tracks$ = this._tracks$ as Behavior<LocalTrack<Track.Kind>[]>;
-
   /**
    * Start the connection to LiveKit and publish local tracks.
    *
@@ -116,46 +93,51 @@ export class Publisher {
    * @throws {InsufficientCapacityError} if the LiveKit server indicates that it has insufficient capacity to accept the connection.
    * @throws {SFURoomCreationRestrictedError} if the LiveKit server indicates that the room does not exist and cannot be created.
    */
-  public async createAndSetupTracks(): Promise<void> {
-    this.logger.debug("createAndSetupTracks called");
+  public async createAndSetupTracks(): Promise<LocalTrack[]> {
     const lkRoom = this.connection.livekitRoom;
     // Observe mute state changes and update LiveKit microphone/camera states accordingly
     this.observeMuteStates(this.scope);
 
+    // TODO: This should be an autostarted connection no need to start here. just check the connection state.
+    // TODO: This will fetch the JWT token. Perhaps we could keep it preloaded
+    // instead? This optimization would only be safe for a publish connection,
+    // because we don't want to leak the user's intent to perhaps join a call to
+    // remote servers before they actually commit to it.
+    // const { promise, resolve, reject } = Promise.withResolvers<void>();
+    // const sub = this.connection.state$.subscribe((s) => {
+    //   if (s.state === "FailedToStart") {
+    //     reject(new Error("Disconnected from LiveKit server"));
+    //   } else if (s.state === "ConnectedToLkRoom") {
+    //     resolve();
+    //   }
+    // });
+    // try {
+    //   await promise;
+    // } catch (e) {
+    //   throw e;
+    // } finally {
+    //   sub.unsubscribe();
+    // }
     // TODO-MULTI-SFU: Prepublish a microphone track
     const audio = this.muteStates.audio.enabled$.value;
     const video = this.muteStates.video.enabled$.value;
     // createTracks throws if called with audio=false and video=false
     if (audio || video) {
       // TODO this can still throw errors? It will also prompt for permissions if not already granted
-      return lkRoom.localParticipant
-        .createTracks({
-          audio,
-          video,
-        })
-        .then((tracks) => {
-          this.logger.info(
-            "created track",
-            tracks.map((t) => t.kind + ", " + t.id),
-          );
-          this._tracks$.next(tracks);
-        })
-        .catch((error) => {
-          this.logger.error("Failed to create tracks", error);
-        });
+      this.tracks =
+        (await lkRoom.localParticipant
+          .createTracks({
+            audio,
+            video,
+          })
+          .catch((error) => {
+            this.logger?.error("Failed to create tracks", error);
+          })) ?? [];
     }
-    throw Error("audio and video is false");
+    return this.tracks;
   }
 
-  private _publishing$ = new BehaviorSubject<boolean>(false);
-  public publishing$ = this.scope.behavior(this._publishing$);
-  /**
-   *
-   * @returns
-   * @throws ElementCallError
-   */
   public async startPublishing(): Promise<LocalTrack[]> {
-    this.logger.debug("startPublishing called");
     const lkRoom = this.connection.livekitRoom;
     const { promise, resolve, reject } = Promise.withResolvers<void>();
     const sub = this.connection.state$.subscribe((s) => {
@@ -164,14 +146,10 @@ export class Publisher {
           resolve();
           break;
         case "FailedToStart":
-          reject(
-            s.error instanceof ElementCallError
-              ? s.error
-              : new FailToStartLivekitConnection(s.error.message),
-          );
+          reject(new Error("Failed to connect to LiveKit server"));
           break;
         default:
-          this.logger.info("waiting for connection: ", s.state);
+          this.logger?.info("waiting for connection: ", s.state);
       }
     });
     try {
@@ -181,27 +159,19 @@ export class Publisher {
     } finally {
       sub.unsubscribe();
     }
-
-    for (const track of this.tracks$.value) {
-      this.logger.info("publish ", this.tracks$.value.length, "tracks");
+    for (const track of this.tracks) {
       // TODO: handle errors? Needs the signaling connection to be up, but it has some retries internally
       // with a timeout.
       await lkRoom.localParticipant.publishTrack(track).catch((error) => {
-        this.logger.error("Failed to publish track", error);
-        throw new FailToStartLivekitConnection(
-          error instanceof Error ? error.message : error,
-        );
+        this.logger?.error("Failed to publish track", error);
       });
-      this.logger.info("published track ", track.kind, track.id);
 
       // TODO: check if the connection is still active? and break the loop if not?
     }
-    this._publishing$.next(true);
-    return this.tracks$.value;
+    return this.tracks;
   }
 
   public async stopPublishing(): Promise<void> {
-    this.logger.debug("stopPublishing called");
     // TODO-MULTI-SFU: Move these calls back to ObservableScope.onEnd once scope
     // actually has the right lifetime
     this.muteStates.audio.unsetHandler();
@@ -213,28 +183,7 @@ export class Publisher {
       if (p.track !== undefined) tracks.push(p.track);
     };
     localParticipant.trackPublications.forEach(addToTracksIfDefined);
-    this.logger.debug(
-      "list of tracks to unpublish:",
-      tracks.map((t) => t.kind + ", " + t.id),
-      "start unpublishing now",
-    );
-    await localParticipant.unpublishTracks(tracks).catch((error) => {
-      this.logger.error("Failed to unpublish tracks", error);
-      throw error;
-    });
-    this.logger.debug(
-      "unpublished tracks",
-      tracks.map((t) => t.kind + ", " + t.id),
-    );
-    this._publishing$.next(false);
-  }
-
-  /**
-   * Stops all tracks that are currently running
-   */
-  public stopTracks(): void {
-    this.tracks$.value.forEach((t) => t.stop());
-    this._tracks$.next([]);
+    await localParticipant.unpublishTracks(tracks);
   }
 
   /// Private methods
@@ -271,9 +220,6 @@ export class Publisher {
           // the process of being restarted.
           activeMicTrack.mediaStreamTrack.readyState !== "ended"
         ) {
-          this.logger?.info(
-            "Restarting audio device track due to active media device changed (workaroundRestartAudioInputTrackChrome)",
-          );
           // Restart the track, which will cause Livekit to do another
           // getUserMedia() call with deviceId: default to get the *new* default device.
           // Note that room.switchActiveDevice() won't work: Livekit will ignore it because
@@ -282,7 +228,7 @@ export class Publisher {
             .getTrackPublication(Track.Source.Microphone)
             ?.audioTrack?.restartTrack()
             .catch((e) => {
-              this.logger.error(`Failed to restart audio device track`, e);
+              this.logger?.error(`Failed to restart audio device track`, e);
             });
         }
       });
@@ -302,7 +248,7 @@ export class Publisher {
       selected$.pipe(scope.bind()).subscribe((device) => {
         if (lkRoom.state != LivekitConnectionState.Connected) return;
         // if (this.connectionState$.value !== ConnectionState.Connected) return;
-        this.logger.info(
+        this.logger?.info(
           "[LivekitRoom] syncDevice room.getActiveDevice(kind) !== d.id :",
           lkRoom.getActiveDevice(kind),
           " !== ",
@@ -315,7 +261,7 @@ export class Publisher {
           lkRoom
             .switchActiveDevice(kind, device.id)
             .catch((e: Error) =>
-              this.logger.error(
+              this.logger?.error(
                 `Failed to sync ${kind} device with LiveKit`,
                 e,
               ),
@@ -340,7 +286,10 @@ export class Publisher {
       try {
         await lkRoom.localParticipant.setMicrophoneEnabled(desired);
       } catch (e) {
-        this.logger.error("Failed to update LiveKit audio input mute state", e);
+        this.logger?.error(
+          "Failed to update LiveKit audio input mute state",
+          e,
+        );
       }
       return lkRoom.localParticipant.isMicrophoneEnabled;
     });
@@ -348,7 +297,10 @@ export class Publisher {
       try {
         await lkRoom.localParticipant.setCameraEnabled(desired);
       } catch (e) {
-        this.logger.error("Failed to update LiveKit video input mute state", e);
+        this.logger?.error(
+          "Failed to update LiveKit video input mute state",
+          e,
+        );
       }
       return lkRoom.localParticipant.isCameraEnabled;
     });

src/state/CallViewModel/remoteMembers/Connection.test.ts

@@ -1,5 +1,4 @@
 /*
-Copyright 2025 Element Creations Ltd.
 Copyright 2025 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
@@ -193,7 +192,7 @@ describe("Start connection states", () => {
     capturedState = capturedStates.pop();
     if (capturedState!.state === "FailedToStart") {
       expect(capturedState!.error.message).toEqual("Something went wrong");
-      expect(connection.transport.livekit_alias).toEqual(
+      expect(capturedState!.transport.livekit_alias).toEqual(
         livekitFocus.livekit_alias,
       );
     } else {
@@ -249,7 +248,7 @@ describe("Start connection states", () => {
       expect(capturedState?.error.message).toContain(
         "SFU Config fetch failed with exception Error",
       );
-      expect(connection.transport.livekit_alias).toEqual(
+      expect(capturedState?.transport.livekit_alias).toEqual(
         livekitFocus.livekit_alias,
       );
     } else {
@@ -313,7 +312,7 @@ describe("Start connection states", () => {
       expect(capturedState.error.message).toContain(
         "Failed to connect to livekit",
       );
-      expect(connection.transport.livekit_alias).toEqual(
+      expect(capturedState.transport.livekit_alias).toEqual(
         livekitFocus.livekit_alias,
       );
     } else {

src/state/CallViewModel/remoteMembers/Connection.ts

@@ -1,5 +1,4 @@
 /*
-Copyright 2025 Element Creations Ltd.
 Copyright 2025 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
@@ -19,7 +18,7 @@ import {
   RoomEvent,
 } from "livekit-client";
 import { type LivekitTransport } from "matrix-js-sdk/lib/matrixrtc";
-import { BehaviorSubject, map } from "rxjs";
+import { BehaviorSubject, map, type Observable } from "rxjs";
 import { type Logger } from "matrix-js-sdk/lib/logger";
 
 import {
@@ -50,14 +49,16 @@ export interface ConnectionOpts {
 
 export type ConnectionState =
   | { state: "Initialized" }
-  | { state: "FetchingConfig" }
-  | { state: "ConnectingToLkRoom" }
+  | { state: "FetchingConfig"; transport: LivekitTransport }
+  | { state: "ConnectingToLkRoom"; transport: LivekitTransport }
+  | { state: "PublishingTracks"; transport: LivekitTransport }
+  | { state: "FailedToStart"; error: Error; transport: LivekitTransport }
   | {
       state: "ConnectedToLkRoom";
-      livekitConnectionState$: Behavior<LivekitConenctionState>;
+      livekitConnectionState$: Observable<LivekitConenctionState>;
+      transport: LivekitTransport;
     }
-  | { state: "FailedToStart"; error: Error }
-  | { state: "Stopped" };
+  | { state: "Stopped"; transport: LivekitTransport };
 
 /**
  * A connection to a Matrix RTC LiveKit backend.
@@ -75,24 +76,6 @@ export class Connection {
    */
   public readonly state$: Behavior<ConnectionState> = this._state$;
 
-  /**
-   * The media transport to connect to.
-   */
-  public readonly transport: LivekitTransport;
-
-  public readonly livekitRoom: LivekitRoom;
-
-  private scope: ObservableScope;
-
-  /**
-   * An observable of the participants that are publishing on this connection. (Excluding our local participant)
-   * This is derived from `participantsIncludingSubscribers$` and `remoteTransports$`.
-   * It filters the participants to only those that are associated with a membership that claims to publish on this connection.
-   */
-  public readonly remoteParticipantsWithTracks$: Behavior<
-    PublishingParticipant[]
-  >;
-
   /**
    * Whether the connection has been stopped.
    * @see Connection.stop
@@ -112,6 +95,7 @@ export class Connection {
    * @throws {InsufficientCapacityError} if the LiveKit server indicates that it has insufficient capacity to accept the connection.
    * @throws {SFURoomCreationRestrictedError} if the LiveKit server indicates that the room does not exist and cannot be created.
    */
+  // TODO dont make this throw and instead store a connection error state in this class?
   // TODO consider an autostart pattern...
   public async start(): Promise<void> {
     this.logger.debug("Starting Connection");
@@ -119,6 +103,7 @@ export class Connection {
     try {
       this._state$.next({
         state: "FetchingConfig",
+        transport: this.transport,
       });
       const { url, jwt } = await this.getSFUConfigWithOpenID();
       // If we were stopped while fetching the config, don't proceed to connect
@@ -126,6 +111,7 @@ export class Connection {
 
       this._state$.next({
         state: "ConnectingToLkRoom",
+        transport: this.transport,
       });
       try {
         await this.livekitRoom.connect(url, jwt);
@@ -156,15 +142,15 @@ export class Connection {
 
       this._state$.next({
         state: "ConnectedToLkRoom",
-        livekitConnectionState$: this.scope.behavior(
-          connectionStateObserver(this.livekitRoom),
-        ),
+        transport: this.transport,
+        livekitConnectionState$: connectionStateObserver(this.livekitRoom),
       });
     } catch (error) {
       this.logger.debug(`Failed to connect to LiveKit room: ${error}`);
       this._state$.next({
         state: "FailedToStart",
         error: error instanceof Error ? error : new Error(`${error}`),
+        transport: this.transport,
       });
       throw error;
     }
@@ -192,11 +178,28 @@ export class Connection {
     await this.livekitRoom.disconnect();
     this._state$.next({
       state: "Stopped",
+      transport: this.transport,
     });
     this.stopped = true;
   }
 
+  /**
+   * An observable of the participants that are publishing on this connection. (Excluding our local participant)
+   * This is derived from `participantsIncludingSubscribers$` and `remoteTransports$`.
+   * It filters the participants to only those that are associated with a membership that claims to publish on this connection.
+   */
+  public readonly remoteParticipantsWithTracks$: Behavior<
+    PublishingParticipant[]
+  >;
+
+  /**
+   * The media transport to connect to.
+   */
+  public readonly transport: LivekitTransport;
+
   private readonly client: OpenIDClientParts;
+  public readonly livekitRoom: LivekitRoom;
+
   private readonly logger: Logger;
 
   /**
@@ -213,7 +216,6 @@ export class Connection {
     );
     const { transport, client, scope } = opts;
 
-    this.scope = scope;
     this.livekitRoom = opts.livekitRoomFactory();
     this.transport = transport;
     this.client = client;

src/state/CallViewModel/remoteMembers/ConnectionFactory.ts

@@ -7,11 +7,10 @@ Please see LICENSE in the repository root for full details.
 
 import { type LivekitTransport } from "matrix-js-sdk/lib/matrixrtc";
 import {
+  type E2EEOptions,
   Room as LivekitRoom,
   type RoomOptions,
   type BaseKeyProvider,
-  type E2EEManagerOptions,
-  type BaseE2EEManager,
 } from "livekit-client";
 import { type Logger } from "matrix-js-sdk/lib/logger";
 import E2EEWorker from "livekit-client/e2ee-worker?worker";
@@ -24,7 +23,6 @@ import type { Behavior } from "../../Behavior.ts";
 import type { ProcessorState } from "../../../livekit/TrackProcessorContext.tsx";
 import { defaultLiveKitOptions } from "../../../livekit/options.ts";
 
-// TODO evaluate if this should be done like the Publisher Factory
 export interface ConnectionFactory {
   createConnection(
     transport: LivekitTransport,
@@ -42,10 +40,8 @@ export class ECConnectionFactory implements ConnectionFactory {
    * @param client - The OpenID client parts for authentication, needed to get openID and JWT tokens.
    * @param devices - Used for video/audio out/in capture options.
    * @param processorState$ - Effects like background blur (only for publishing connection?)
-   * @param livekitKeyProvider
+   * @param e2eeLivekitOptions - The E2EE options to use for the LiveKit Room.
    * @param controlledAudioDevices - Option to indicate whether audio output device is controlled externally (native mobile app).
-   * @param echoCancellation - Whether to enable echo cancellation for audio capture.
-   * @param noiseSuppression - Whether to enable noise suppression for audio capture.
    * @param livekitRoomFactory - Optional factory function (for testing) to create LivekitRoom instances. If not provided, a default factory is used.
    */
   public constructor(
@@ -55,24 +51,20 @@ export class ECConnectionFactory implements ConnectionFactory {
     livekitKeyProvider: BaseKeyProvider | undefined,
     private controlledAudioDevices: boolean,
     livekitRoomFactory?: () => LivekitRoom,
-    echoCancellation: boolean = true,
-    noiseSuppression: boolean = true,
   ) {
     const defaultFactory = (): LivekitRoom =>
       new LivekitRoom(
-        generateRoomOption({
-          devices: this.devices,
-          processorState: this.processorState$.value,
-          e2eeLivekitOptions: livekitKeyProvider && {
+        generateRoomOption(
+          this.devices,
+          this.processorState$.value,
+          livekitKeyProvider && {
             keyProvider: livekitKeyProvider,
             // It's important that every room use a separate E2EE worker.
             // They get confused if given streams from multiple rooms.
             worker: new E2EEWorker(),
           },
-          controlledAudioDevices: this.controlledAudioDevices,
-          echoCancellation,
-          noiseSuppression,
-        }),
+          this.controlledAudioDevices,
+        ),
       );
     this.livekitRoomFactory = livekitRoomFactory ?? defaultFactory;
   }
@@ -97,24 +89,12 @@ export class ECConnectionFactory implements ConnectionFactory {
 /**
  *  Generate the initial LiveKit RoomOptions based on the current media devices and processor state.
  */
-function generateRoomOption({
-  devices,
-  processorState,
-  e2eeLivekitOptions,
-  controlledAudioDevices,
-  echoCancellation,
-  noiseSuppression,
-}: {
-  devices: MediaDevices;
-  processorState: ProcessorState;
-  e2eeLivekitOptions:
-    | E2EEManagerOptions
-    | { e2eeManager: BaseE2EEManager }
-    | undefined;
-  controlledAudioDevices: boolean;
-  echoCancellation: boolean;
-  noiseSuppression: boolean;
-}): RoomOptions {
+function generateRoomOption(
+  devices: MediaDevices,
+  processorState: ProcessorState,
+  e2eeLivekitOptions: E2EEOptions | undefined,
+  controlledAudioDevices: boolean,
+): RoomOptions {
   return {
     ...defaultLiveKitOptions,
     videoCaptureDefaults: {
@@ -125,8 +105,6 @@ function generateRoomOption({
     audioCaptureDefaults: {
       ...defaultLiveKitOptions.audioCaptureDefaults,
       deviceId: devices.audioInput.selected$.value?.id,
-      echoCancellation,
-      noiseSuppression,
     },
     audioOutput: {
       // When using controlled audio devices, we don't want to set the

src/state/CallViewModel/remoteMembers/ConnectionManager.test.ts

@@ -11,7 +11,7 @@ import { type LivekitTransport } from "matrix-js-sdk/lib/matrixrtc";
 import { type Participant as LivekitParticipant } from "livekit-client";
 import { logger } from "matrix-js-sdk/lib/logger";
 
-import { Epoch, mapEpoch, ObservableScope } from "../../ObservableScope.ts";
+import { Epoch, ObservableScope } from "../../ObservableScope.ts";
 import {
   createConnectionManager$,
   type ConnectionManagerData,
@@ -73,7 +73,7 @@ afterEach(() => {
 describe("connections$ stream", () => {
   test("Should create and start new connections for each transports", () => {
     withTestScheduler(({ behavior, expectObservable }) => {
-      const { connectionManagerData$ } = createConnectionManager$({
+      const { connections$ } = createConnectionManager$({
         scope: testScope,
         connectionFactory: fakeConnectionFactory,
         inputTransports$: behavior("a", {
@@ -82,9 +82,7 @@ describe("connections$ stream", () => {
         logger: logger,
       });
 
-      expectObservable(
-        connectionManagerData$.pipe(mapEpoch((d) => d.getConnections())),
-      ).toBe("a", {
+      expectObservable(connections$).toBe("a", {
         a: expect.toSatisfy((e: Epoch<Connection[]>) => {
           const connections = e.value;
           expect(connections.length).toBe(2);
@@ -112,7 +110,7 @@ describe("connections$ stream", () => {
 
   test("Should start connection only once", () => {
     withTestScheduler(({ behavior, expectObservable }) => {
-      const { connectionManagerData$ } = createConnectionManager$({
+      const { connections$ } = createConnectionManager$({
         scope: testScope,
         connectionFactory: fakeConnectionFactory,
         inputTransports$: behavior("abcdef", {
@@ -126,9 +124,7 @@ describe("connections$ stream", () => {
         logger: logger,
       });
 
-      expectObservable(
-        connectionManagerData$.pipe(mapEpoch((d) => d.getConnections())),
-      ).toBe("xxxxxa", {
+      expectObservable(connections$).toBe("xxxxxa", {
         x: expect.anything(),
         a: expect.toSatisfy((e: Epoch<Connection[]>) => {
           const connections = e.value;
@@ -157,7 +153,7 @@ describe("connections$ stream", () => {
 
   test("Should cleanup connections when not needed anymore", () => {
     withTestScheduler(({ behavior, expectObservable }) => {
-      const { connectionManagerData$ } = createConnectionManager$({
+      const { connections$ } = createConnectionManager$({
         scope: testScope,
         connectionFactory: fakeConnectionFactory,
         inputTransports$: behavior("abc", {
@@ -168,9 +164,7 @@ describe("connections$ stream", () => {
         logger: logger,
       });
 
-      expectObservable(
-        connectionManagerData$.pipe(mapEpoch((d) => d.getConnections())),
-      ).toBe("xab", {
+      expectObservable(connections$).toBe("xab", {
         x: expect.anything(),
         a: expect.toSatisfy((e: Epoch<Connection[]>) => {
           const connections = e.value;

src/state/CallViewModel/remoteMembers/ConnectionManager.ts

@@ -1,3 +1,6 @@
+// TODOs:
+// - make ConnectionManager its own actual class
+
 /*
 Copyright 2025 Element Creations Ltd.
 Copyright 2025 New Vector Ltd.
@@ -92,7 +95,9 @@ interface Props {
 }
 // TODO - write test for scopes (do we really need to bind scope)
 export interface IConnectionManager {
+  transports$: Behavior<Epoch<LivekitTransport[]>>;
   connectionManagerData$: Behavior<Epoch<ConnectionManagerData>>;
+  connections$: Behavior<Epoch<Connection[]>>;
 }
 /**
  * Crete a `ConnectionManager`
@@ -215,7 +220,7 @@ export function createConnectionManager$({
     new Epoch(new ConnectionManagerData()),
   );
 
-  return { connectionManagerData$ };
+  return { transports$, connectionManagerData$, connections$ };
 }
 
 function removeDuplicateTransports(

src/state/CallViewModel/remoteMembers/ECConnectionFactory.test.ts

@@ -1,133 +0,0 @@
-/*
-Copyright 2025 Element Creations Ltd.
-
-SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
-Please see LICENSE in the repository root for full details.
-*/
-
-import { afterEach, beforeEach, describe, expect, test, vi } from "vitest";
-import { Room as LivekitRoom } from "livekit-client";
-import { BehaviorSubject } from "rxjs";
-import fetchMock from "fetch-mock";
-import { logger } from "matrix-js-sdk/lib/logger";
-import EventEmitter from "events";
-
-import { ObservableScope } from "../../ObservableScope.ts";
-import { ECConnectionFactory } from "./ConnectionFactory.ts";
-import type { OpenIDClientParts } from "../../../livekit/openIDSFU.ts";
-import { exampleTransport, mockMediaDevices } from "../../../utils/test.ts";
-import type { ProcessorState } from "../../../livekit/TrackProcessorContext.tsx";
-import { constant } from "../../Behavior";
-
-// At the top of your test file, after imports
-vi.mock("livekit-client", async (importOriginal) => {
-  return {
-    ...(await importOriginal()),
-    Room: vi.fn().mockImplementation(function (this: LivekitRoom, options) {
-      const emitter = new EventEmitter();
-      return {
-        on: emitter.on.bind(emitter),
-        off: emitter.off.bind(emitter),
-        emit: emitter.emit.bind(emitter),
-        disconnect: vi.fn(),
-        remoteParticipants: new Map(),
-      } as unknown as LivekitRoom;
-    }),
-  };
-});
-
-let testScope: ObservableScope;
-let mockClient: OpenIDClientParts;
-
-beforeEach(() => {
-  testScope = new ObservableScope();
-  mockClient = {
-    getOpenIdToken: vi.fn().mockReturnValue(""),
-    getDeviceId: vi.fn().mockReturnValue("DEV000"),
-  };
-});
-
-describe("ECConnectionFactory - Audio inputs options", () => {
-  test.each([
-    { echo: true, noise: true },
-    { echo: true, noise: false },
-    { echo: false, noise: true },
-    { echo: false, noise: false },
-  ])(
-    "it sets echoCancellation=$echo and noiseSuppression=$noise based on constructor parameters",
-    ({ echo, noise }) => {
-      // test("it sets echoCancellation and noiseSuppression based on constructor parameters", () => {
-      const RoomConstructor = vi.mocked(LivekitRoom);
-
-      const ecConnectionFactory = new ECConnectionFactory(
-        mockClient,
-        mockMediaDevices({}),
-        new BehaviorSubject<ProcessorState>({
-          supported: true,
-          processor: undefined,
-        }),
-        undefined,
-        false,
-        undefined,
-        echo,
-        noise,
-      );
-      ecConnectionFactory.createConnection(exampleTransport, testScope, logger);
-
-      // Check if Room was constructed with expected options
-      expect(RoomConstructor).toHaveBeenCalledWith(
-        expect.objectContaining({
-          audioCaptureDefaults: expect.objectContaining({
-            echoCancellation: echo,
-            noiseSuppression: noise,
-          }),
-        }),
-      );
-    },
-  );
-});
-
-describe("ECConnectionFactory - ControlledAudioDevice", () => {
-  test.each([{ controlled: true }, { controlled: false }])(
-    "it sets controlledAudioDevice=$controlled then uses deviceId accordingly",
-    ({ controlled }) => {
-      // test("it sets echoCancellation and noiseSuppression based on constructor parameters", () => {
-      const RoomConstructor = vi.mocked(LivekitRoom);
-
-      const ecConnectionFactory = new ECConnectionFactory(
-        mockClient,
-        mockMediaDevices({
-          audioOutput: {
-            available$: constant(new Map<never, never>()),
-            selected$: constant({ id: "DEV00", virtualEarpiece: false }),
-            select: () => {},
-          },
-        }),
-        new BehaviorSubject<ProcessorState>({
-          supported: true,
-          processor: undefined,
-        }),
-        undefined,
-        controlled,
-        undefined,
-        false,
-        false,
-      );
-      ecConnectionFactory.createConnection(exampleTransport, testScope, logger);
-
-      // Check if Room was constructed with expected options
-      expect(RoomConstructor).toHaveBeenCalledWith(
-        expect.objectContaining({
-          audioOutput: expect.objectContaining({
-            deviceId: controlled ? undefined : "DEV00",
-          }),
-        }),
-      );
-    },
-  );
-});
-
-afterEach(() => {
-  testScope.end();
-  fetchMock.reset();
-});

src/state/CallViewModel/remoteMembers/MatrixMemberMetadata.test.ts

@@ -104,6 +104,7 @@ describe("MatrixMemberMetadata", () => {
       }
     }
 
+    // TODO this is a regression, now there the own user is not always in the map. Ask Timo if fine
     it("should show our own user if present in rtc session and room", () => {
       withTestScheduler(({ behavior, expectObservable }) => {
         fakeMemberWith({
@@ -516,6 +517,7 @@ describe("MatrixMemberMetadata", () => {
       }
     }
 
+    // TODO this is a regression, now there the own user is not always in the map. Ask Timo if fine
     it("should use avatar url from room members", () => {
       withTestScheduler(({ behavior, expectObservable }) => {
         fakeMemberWith({

src/state/CallViewModel/remoteMembers/MatrixMemberMetadata.ts

@@ -1,5 +1,5 @@
 /*
-Copyright 2025 Element Creations Ltd.
+Copyright 2025 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.

src/state/ObservableScope.test.ts

@@ -1,14 +1,13 @@
 /*
-Copyright 2025 Element Creations Ltd.
+Copyright 2025 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.
 */
 
-import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";
+import { describe, expect, it } from "vitest";
 import { BehaviorSubject, combineLatest, Subject } from "rxjs";
 import { logger } from "matrix-js-sdk/lib/logger";
-import { sleep } from "matrix-js-sdk/lib/utils";
 
 import {
   Epoch,
@@ -103,137 +102,3 @@ describe("Epoch", () => {
     s$.complete();
   });
 });
-
-describe("Reconcile", () => {
-  beforeEach(() => {
-    vi.useFakeTimers();
-  });
-
-  afterEach(() => {
-    vi.useRealTimers();
-  });
-
-  it("should wait clean up before processing next", async () => {
-    vi.useFakeTimers();
-    const scope = new ObservableScope();
-    const behavior$ = new BehaviorSubject<number>(0);
-
-    const setup = vi.fn().mockImplementation(async () => await sleep(100));
-    const cleanup = vi
-      .fn()
-      .mockImplementation(async (n: number) => await sleep(100));
-    scope.reconcile(behavior$, async (value) => {
-      await setup();
-      return async (): Promise<void> => {
-        await cleanup(value);
-      };
-    });
-    // Let the initial setup process
-    await vi.advanceTimersByTimeAsync(120);
-    expect(setup).toHaveBeenCalledTimes(1);
-    expect(cleanup).toHaveBeenCalledTimes(0);
-
-    // Send next value
-    behavior$.next(1);
-    await vi.advanceTimersByTimeAsync(50);
-    // Should not have started setup for 1 yet
-    expect(setup).toHaveBeenCalledTimes(1);
-    expect(cleanup).toHaveBeenCalledTimes(1);
-    expect(cleanup).toHaveBeenCalledWith(0);
-
-    // Let cleanup finish
-    await vi.advanceTimersByTimeAsync(50);
-    // Now setup for 1 should have started
-    expect(setup).toHaveBeenCalledTimes(2);
-  });
-
-  it("should skip intermediates values that are not setup", async () => {
-    vi.useFakeTimers();
-    const scope = new ObservableScope();
-    const behavior$ = new BehaviorSubject<number>(0);
-
-    const setup = vi
-      .fn()
-      .mockImplementation(async (n: number) => await sleep(100));
-
-    const cleanupLock = Promise.withResolvers();
-    const cleanup = vi
-      .fn()
-      .mockImplementation(async (n: number) => await cleanupLock.promise);
-
-    scope.reconcile(behavior$, async (value) => {
-      await setup(value);
-      return async (): Promise<void> => {
-        await cleanup(value);
-      };
-    });
-    // Let the initial setup process (0)
-    await vi.advanceTimersByTimeAsync(120);
-
-    // Send 4 next values quickly
-    behavior$.next(1);
-    behavior$.next(2);
-    behavior$.next(3);
-    behavior$.next(4);
-
-    await vi.advanceTimersByTimeAsync(3000);
-    // should have only called cleanup for 0
-    expect(cleanup).toHaveBeenCalledTimes(1);
-    expect(cleanup).toHaveBeenCalledWith(0);
-    // Let cleanup finish
-    cleanupLock.resolve(undefined);
-    await vi.advanceTimersByTimeAsync(120);
-
-    // Now setup for 4 should have started, skipping 1,2,3
-    expect(setup).toHaveBeenCalledTimes(2);
-    expect(setup).toHaveBeenCalledWith(4);
-    expect(setup).not.toHaveBeenCalledWith(1);
-    expect(setup).not.toHaveBeenCalledWith(2);
-    expect(setup).not.toHaveBeenCalledWith(3);
-  });
-
-  it("should wait for setup to complete before starting cleanup", async () => {
-    vi.useFakeTimers();
-    const scope = new ObservableScope();
-    const behavior$ = new BehaviorSubject<number>(0);
-
-    const setup = vi
-      .fn()
-      .mockImplementation(async (n: number) => await sleep(3000));
-
-    const cleanupLock = Promise.withResolvers();
-    const cleanup = vi
-      .fn()
-      .mockImplementation(async (n: number) => await cleanupLock.promise);
-
-    scope.reconcile(behavior$, async (value) => {
-      await setup(value);
-      return async (): Promise<void> => {
-        await cleanup(value);
-      };
-    });
-
-    await vi.advanceTimersByTimeAsync(500);
-    // Setup for 0 should be in progress
-    expect(setup).toHaveBeenCalledTimes(1);
-
-    behavior$.next(1);
-    await vi.advanceTimersByTimeAsync(500);
-
-    // Should not have started setup for 1 yet
-    expect(setup).not.toHaveBeenCalledWith(1);
-    // Should not have called cleanup yet, because the setup for 0 is not done
-    expect(cleanup).toHaveBeenCalledTimes(0);
-
-    // Let setup for 0 finish
-    await vi.advanceTimersByTimeAsync(2500 + 100);
-    // Now cleanup for 0 should have started
-    expect(cleanup).toHaveBeenCalledTimes(1);
-    expect(cleanup).toHaveBeenCalledWith(0);
-
-    cleanupLock.resolve(undefined);
-    await vi.advanceTimersByTimeAsync(100);
-    // Now setup for 1 should have started
-    expect(setup).toHaveBeenCalledWith(1);
-  });
-});

src/state/ObservableScope.ts

@@ -123,22 +123,8 @@ export class ObservableScope {
     callback: (value: T) => Promise<(() => Promise<void>) | void>,
   ): void {
     let latestValue: T | typeof nothing = nothing;
-    let reconcilePromise: Promise<void> | undefined = undefined;
+    let reconciledValue: T | typeof nothing = nothing;
     let cleanUp: (() => Promise<void>) | void = undefined;
-    let prevVal: T | typeof nothing = nothing;
-
-    // While this loop runs it will process the latest from `value$` until it caught up with the updates.
-    // It might skip updates from `value$` and only process the newest value after callback has resolved.
-    const reconcileLoop = async (): Promise<void> => {
-      while (latestValue !== prevVal) {
-        await cleanUp?.(); // Call the previous value's clean-up handler
-        prevVal = latestValue;
-
-        if (latestValue !== nothing) cleanUp = await callback(latestValue); // Sync current value...
-        // `latestValue` might have gotten updated during the `await callback`. That is why we loop here
-      }
-    };
-
     value$
       .pipe(
         catchError(() => EMPTY), // Ignore errors
@@ -146,15 +132,23 @@ export class ObservableScope {
         endWith(nothing), // Clean up when the scope ends
       )
       .subscribe((value) => {
-        // Always track the latest value! The `reconcileLoop` will run until it "processed" the "last" `latestValue`.
-        latestValue = value;
-        // There's already an instance of the below 'reconcileLoop' loop running
-        // concurrently. So lets let the loop handle it. NEVER instanciate two `reconcileLoop`s.
-        if (reconcilePromise) return;
-
-        reconcilePromise = reconcileLoop().finally(() => {
-          reconcilePromise = undefined;
-        });
+        void (async (): Promise<void> => {
+          if (latestValue === nothing) {
+            latestValue = value;
+            while (latestValue !== reconciledValue) {
+              await cleanUp?.(); // Call the previous value's clean-up handler
+              reconciledValue = latestValue;
+              if (latestValue !== nothing)
+                cleanUp = await callback(latestValue); // Sync current value
+            }
+            // Reset to signal that reconciliation is done for now
+            latestValue = nothing;
+          } else {
+            // There's already an instance of the above 'while' loop running
+            // concurrently. Just update the latest value and let it be handled.
+            latestValue = value;
+          }
+        })();
       });
   }
 

src/state/SessionBehaviors.ts

@@ -1,5 +1,5 @@
 /*
-Copyright 2025 Element Creations Ltd.
+Copyright 2025 New Vector Ltd.
 
 SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
 Please see LICENSE in the repository root for full details.

src/useBehavior.test.tsx

@@ -0,0 +1,124 @@
+/*
+Copyright 2025 New Vector Ltd.
+
+SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
+Please see LICENSE in the repository root for full details.
+*/
+
+import { render } from "@testing-library/react";
+import { afterEach, beforeEach, describe, expect, it } from "vitest";
+import { catchError, of, tap, Subject, map, BehaviorSubject } from "rxjs";
+
+import { type Behavior } from "./state/Behavior";
+import { useBehavior } from "./useBehavior";
+import { ObservableScope } from "./state/ObservableScope";
+
+function TestComponent({
+  behavior$,
+  shouldThrow = false,
+  children,
+}: {
+  behavior$: Behavior<string>;
+  shouldThrow?: boolean;
+  children: React.ReactNode;
+}): React.ReactNode {
+  if (shouldThrow) throw Error("Test error");
+
+  const value = useBehavior(behavior$);
+
+  return (
+    <div>
+      value: {value}
+      {children}
+    </div>
+  );
+}
+
+describe("useBehavior", () => {
+  let scope: ObservableScope;
+  beforeEach(() => (scope = new ObservableScope()));
+  afterEach(() => scope.end());
+
+  it("reference test", () => {
+    expect(() =>
+      render(
+        <TestComponent behavior$={scope.behavior(of("test"))}>
+          Test
+        </TestComponent>,
+      ),
+    ).not.toThrow();
+  });
+  it("should return the correct behavior", () => {
+    expect(() =>
+      render(
+        <TestComponent
+          shouldThrow={true}
+          behavior$={scope.behavior(of("test"))}
+        >
+          Test
+        </TestComponent>,
+      ),
+    ).toThrow("Test error");
+  });
+
+  it("useBehavior forwards the throw in obs computation", () => {
+    const throwingOperation = (): string => {
+      throw new Error("Test error");
+    };
+
+    expect(() => {
+      const s$ = new Subject<string>();
+      const b$ = scope.behavior(s$, "");
+      s$.next("test");
+      s$.next(throwingOperation());
+      render(<TestComponent behavior$={b$}>Test</TestComponent>);
+    }).toThrow("Test error");
+  });
+
+  function errorOnE(s: string): string {
+    if (s === "E") throw new Error("Test error");
+    return s + "CheckedForE";
+  }
+
+  it("useBehavior does not throw in caught obs computation", () => {
+    console.log("hello");
+    const s$ = new Subject<string>();
+    const b$ = scope.behavior(s$.pipe(map(errorOnE)), "START");
+
+    const inheritForThrowCatch$ = scope.behavior(
+      b$.pipe(
+        tap((v) => console.log("tap-" + v)),
+        catchError((err) => {
+          console.log("caught error" + err);
+          return of("I caught an error and converted it to sth nicer");
+        }),
+      ),
+    );
+
+    s$.next("test");
+    s$.next("E");
+    s$.next("after error");
+
+    expect(() => {
+      render(
+        <TestComponent behavior$={inheritForThrowCatch$}>Test</TestComponent>,
+      );
+    }).not.toThrow();
+    expect(() => {
+      render(<TestComponent behavior$={b$}>Test</TestComponent>);
+    }).toThrow();
+  });
+  it("a playground to test around a little bit", () => {
+    const s$ = new BehaviorSubject("initial");
+    const e = new Error("Test error");
+
+    console.log("hello");
+
+    s$.error(e);
+    // does not help to set the value afterwards if it errord once it cannot recover
+    s$.next("nextval");
+    const s2$ = scope.behavior(s$.pipe(catchError((e) => e.message)));
+    expect(() => s$.value).toThrow(e);
+    expect(() => s2$.value).not.toThrow();
+  });
+});

src/useBehavior.ts

@@ -15,7 +15,12 @@ import { type Behavior } from "./state/Behavior";
 export function useBehavior<T>(behavior: Behavior<T>): T {
   const subscribe = useCallback(
     (onChange: () => void) => {
-      const s = behavior.subscribe(onChange);
+      const s = behavior.subscribe({
+        next: onChange,
+        error: (e) => {
+          throw e;
+        },
+      });
       return (): void => s.unsubscribe();
     },
     [behavior],

src/utils/errors.ts

@@ -13,8 +13,6 @@ export enum ErrorCode {
    */
   MISSING_MATRIX_RTC_TRANSPORT = "MISSING_MATRIX_RTC_TRANSPORT",
   CONNECTION_LOST_ERROR = "CONNECTION_LOST_ERROR",
-  INTERNAL_MEMBERSHIP_MANAGER = "INTERNAL_MEMBERSHIP_MANAGER",
-  FAILED_TO_START_LIVEKIT = "FAILED_TO_START_LIVEKIT",
   /** LiveKit indicates that the server has hit its track limits */
   INSUFFICIENT_CAPACITY_ERROR = "INSUFFICIENT_CAPACITY_ERROR",
   E2EE_NOT_SUPPORTED = "E2EE_NOT_SUPPORTED",
@@ -29,7 +27,6 @@ export enum ErrorCategory {
   NETWORK_CONNECTIVITY = "NETWORK_CONNECTIVITY",
   CLIENT_CONFIGURATION = "CLIENT_CONFIGURATION",
   UNKNOWN = "UNKNOWN",
-  SYSTEM_FAILURE = "SYSTEM_FAILURE",
   // SYSTEM_FAILURE / FEDERATION_FAILURE ..
 }
 
@@ -86,18 +83,6 @@ export class ConnectionLostError extends ElementCallError {
   }
 }
 
-export class MembershipManagerError extends ElementCallError {
-  public constructor(error: Error) {
-    super(
-      t("error.membership_manager"),
-      ErrorCode.INTERNAL_MEMBERSHIP_MANAGER,
-      ErrorCategory.SYSTEM_FAILURE,
-      t("error.membership_manager_description"),
-      error,
-    );
-  }
-}
-
 export class E2EENotSupportedError extends ElementCallError {
   public constructor() {
     super(
@@ -135,17 +120,6 @@ export class FailToGetOpenIdToken extends ElementCallError {
   }
 }
 
-export class FailToStartLivekitConnection extends ElementCallError {
-  public constructor(e?: string) {
-    super(
-      t("error.failed_to_start_livekit"),
-      ErrorCode.FAILED_TO_START_LIVEKIT,
-      ErrorCategory.NETWORK_CONNECTIVITY,
-      e,
-    );
-  }
-}
-
 export class InsufficientCapacityError extends ElementCallError {
   public constructor() {
     super(

src/utils/test.ts

@@ -44,12 +44,12 @@ import {
   Track,
 } from "livekit-client";
 import { randomUUID } from "crypto";
+import {
+  type RoomAndToDeviceEvents,
+  type RoomAndToDeviceEventsHandlerMap,
+} from "matrix-js-sdk/lib/matrixrtc/RoomAndToDeviceKeyTransport";
 import { type TrackReference } from "@livekit/components-core";
 import EventEmitter from "events";
-import {
-  type KeyTransportEvents,
-  type KeyTransportEventsHandlerMap,
-} from "matrix-js-sdk/lib/matrixrtc/IKeyTransport";
 
 import {
   LocalUserMediaViewModel,
@@ -79,13 +79,6 @@ export async function flushPromises(): Promise<void> {
   await new Promise<void>((resolve) => window.setTimeout(resolve));
 }
 
-export type NodeEventHandler = (...args: unknown[]) => void;
-
-export interface NodeStyleEventEmitter {
-  addListener(eventName: string | symbol, handler: NodeEventHandler): this;
-  removeListener(eventName: string | symbol, handler: NodeEventHandler): this;
-}
-
 export interface OurRunHelpers extends RunHelpers {
   /**
    * Schedules a sequence of actions to happen, as described by a marble
@@ -284,8 +277,6 @@ export function mockLivekitRoom(
 ): LivekitRoom {
   const livekitRoom = {
     options: {},
-    setE2EEEnabled: vi.fn(),
-
     ...mockEmitter(),
     ...room,
   } as Partial<LivekitRoom> as LivekitRoom;
@@ -308,9 +299,7 @@ export function mockLocalParticipant(
   return {
     isLocal: true,
     trackPublications: new Map(),
-    publishTrack: vi.fn(),
-    unpublishTracks: vi.fn().mockResolvedValue([]),
-    createTracks: vi.fn(),
+    unpublishTracks: async () => Promise.resolve(),
     getTrackPublication: () =>
       ({}) as Partial<LocalTrackPublication> as LocalTrackPublication,
     ...mockEmitter(),
@@ -398,9 +387,9 @@ export function mockConfig(
 }
 
 export class MockRTCSession extends TypedEventEmitter<
-  MatrixRTCSessionEvent | MembershipManagerEvent | KeyTransportEvents,
-  KeyTransportEventsHandlerMap &
-    MatrixRTCSessionEventHandlerMap &
+  MatrixRTCSessionEvent | RoomAndToDeviceEvents | MembershipManagerEvent,
+  MatrixRTCSessionEventHandlerMap &
+    RoomAndToDeviceEventsHandlerMap &
     MembershipManagerEventHandlerMap
 > {
   public asMockedSession(): MockedObject<MatrixRTCSession> {

yarn.lock

@@ -2731,39 +2731,37 @@ __metadata:
   languageName: node
   linkType: hard
 
-"@livekit/components-core@npm:0.12.11, @livekit/components-core@npm:^0.12.0":
-  version: 0.12.11
-  resolution: "@livekit/components-core@npm:0.12.11"
+"@livekit/components-core@npm:0.12.10, @livekit/components-core@npm:^0.12.0":
+  version: 0.12.10
+  resolution: "@livekit/components-core@npm:0.12.10"
   dependencies:
     "@floating-ui/dom": "npm:1.6.13"
     loglevel: "npm:1.9.1"
     rxjs: "npm:7.8.2"
   peerDependencies:
-    livekit-client: ^2.15.14
+    livekit-client: ^2.13.3
     tslib: ^2.6.2
-  checksum: 10c0/9c2ac3d30bb8cc9067ae0b2049784f81e90e57df9eabf7edbaf3c8ceb65a63f644a4e6abeb6cc38d3ebe52663d8dbb88535e01a965011f365d5ae1f3daf86052
+  checksum: 10c0/bfd84fb950f72dd037bd5329658c1e750a8ac6b8f2953ea673e3e944b8ea9d412ef9c98eb8b690052323e03c675964b162aacb00e60530cdc5187f77d21979bd
   languageName: node
   linkType: hard
 
 "@livekit/components-react@npm:^2.0.0":
-  version: 2.9.16
-  resolution: "@livekit/components-react@npm:2.9.16"
+  version: 2.9.15
+  resolution: "@livekit/components-react@npm:2.9.15"
   dependencies:
-    "@livekit/components-core": "npm:0.12.11"
+    "@livekit/components-core": "npm:0.12.10"
     clsx: "npm:2.1.1"
-    events: "npm:^3.3.0"
-    jose: "npm:^6.0.12"
     usehooks-ts: "npm:3.1.1"
   peerDependencies:
     "@livekit/krisp-noise-filter": ^0.2.12 || ^0.3.0
-    livekit-client: ^2.15.14
+    livekit-client: ^2.13.3
     react: ">=18"
     react-dom: ">=18"
     tslib: ^2.6.2
   peerDependenciesMeta:
     "@livekit/krisp-noise-filter":
       optional: true
-  checksum: 10c0/4ba4ff473c5a29d3107412733a6676a3b708d70684ed463e9b34cda26abb3d2f317c2828a52e730837b756de9df3fc248260d6f390aedebfb6ec96ef63c7b151
+  checksum: 10c0/58a93d85c3b8267d0afd00eceb4f34992ce66124f93450e828a78dd825ecc20e254c3123ed22ec33061a3728f50f4f020ff896769fb3a0ff79656ed8cf452a2b
   languageName: node
   linkType: hard
 
@@ -5249,12 +5247,12 @@ __metadata:
   languageName: node
   linkType: hard
 
-"@types/node@npm:^24.0.0":
-  version: 24.10.0
-  resolution: "@types/node@npm:24.10.0"
+"@types/node@npm:^22.0.0":
+  version: 22.17.0
+  resolution: "@types/node@npm:22.17.0"
   dependencies:
-    undici-types: "npm:~7.16.0"
-  checksum: 10c0/f82ed7194e16f5590ef7afdc20c6d09068c76d50278b485ede8f0c5749683536e3064ffa8def8db76915196afb3724b854aa5723c64d6571b890b14492943b46
+    undici-types: "npm:~6.21.0"
+  checksum: 10c0/e1c603b660d3de3243dfc02ded5d40623ff3f36315ffbdd8cdc81bc2c5a8da172035879d437b72e9fa61ca01827f28e9c2b0c32898f411a8e9ba0a5efac0b4ca
   languageName: node
   linkType: hard
 
@@ -7509,7 +7507,7 @@ __metadata:
     "@types/grecaptcha": "npm:^3.0.9"
     "@types/jsdom": "npm:^21.1.7"
     "@types/lodash-es": "npm:^4.17.12"
-    "@types/node": "npm:^24.0.0"
+    "@types/node": "npm:^22.0.0"
     "@types/pako": "npm:^2.0.3"
     "@types/qrcode": "npm:^1.5.5"
     "@types/react": "npm:^19.0.0"
@@ -7547,8 +7545,8 @@ __metadata:
     livekit-client: "npm:^2.13.0"
     lodash-es: "npm:^4.17.21"
     loglevel: "npm:^1.9.1"
-    matrix-js-sdk: "npm:^39.2.0"
-    matrix-widget-api: "npm:^1.14.0"
+    matrix-js-sdk: "github:matrix-org/matrix-js-sdk#head=toger5/sticky-events&commit=e7f5bec51b6f70501a025b79fe5021c933385b21"
+    matrix-widget-api: "npm:^1.13.0"
     normalize.css: "npm:^8.0.1"
     observable-hooks: "npm:^4.2.3"
     pako: "npm:^2.0.4"
@@ -9830,13 +9828,6 @@ __metadata:
   languageName: node
   linkType: hard
 
-"jose@npm:^6.0.12":
-  version: 6.1.2
-  resolution: "jose@npm:6.1.2"
-  checksum: 10c0/55f79426f43e652ed6d5de938d50f66bb0a10dcae078db81a23f8d3303e889ce226f000e815f3211f9956bb84badce10da892d130d40fe2eca658045a6f1778e
-  languageName: node
-  linkType: hard
-
 "jose@npm:^6.1.0":
   version: 6.1.0
   resolution: "jose@npm:6.1.0"
@@ -10119,8 +10110,8 @@ __metadata:
   linkType: hard
 
 "livekit-client@npm:^2.13.0":
-  version: 2.16.0
-  resolution: "livekit-client@npm:2.16.0"
+  version: 2.15.13
+  resolution: "livekit-client@npm:2.15.13"
   dependencies:
     "@livekit/mutex": "npm:1.1.1"
     "@livekit/protocol": "npm:1.42.2"
@@ -10134,7 +10125,7 @@ __metadata:
     webrtc-adapter: "npm:^9.0.1"
   peerDependencies:
     "@types/dom-mediacapture-record": ^1
-  checksum: 10c0/5d03adc5d09efde343ab894db397529dff26117598e773b23a5df90a4fb166bde12c6bb1f2cfd1d28dbaf93fe9f275026d7abb75f2ffd2ba816393a2d58e6c7e
+  checksum: 10c0/5a061df9000461a6d40ef8aa1e72e8aedc640181cc57fe6f2c48c5c7f90ce96a735b125aede377fc43f4692a685e098f17eeae0f42c5b2fed473305867bf2789
   languageName: node
   linkType: hard
 
@@ -10352,9 +10343,9 @@ __metadata:
   languageName: node
   linkType: hard
 
-"matrix-js-sdk@npm:^39.2.0":
-  version: 39.2.0
-  resolution: "matrix-js-sdk@npm:39.2.0"
+"matrix-js-sdk@github:matrix-org/matrix-js-sdk#head=toger5/sticky-events&commit=e7f5bec51b6f70501a025b79fe5021c933385b21":
+  version: 38.4.0
+  resolution: "matrix-js-sdk@https://github.com/matrix-org/matrix-js-sdk.git#commit=e7f5bec51b6f70501a025b79fe5021c933385b21"
   dependencies:
     "@babel/runtime": "npm:^7.12.5"
     "@matrix-org/matrix-sdk-crypto-wasm": "npm:^15.3.0"
@@ -10364,23 +10355,23 @@ __metadata:
     jwt-decode: "npm:^4.0.0"
     loglevel: "npm:^1.9.2"
     matrix-events-sdk: "npm:0.0.1"
-    matrix-widget-api: "npm:^1.14.0"
+    matrix-widget-api: "npm:^1.10.0"
     oidc-client-ts: "npm:^3.0.1"
     p-retry: "npm:7"
-    sdp-transform: "npm:^3.0.0"
+    sdp-transform: "npm:^2.14.1"
     unhomoglyph: "npm:^1.0.6"
     uuid: "npm:13"
-  checksum: 10c0/f8b5261de2744305330ba3952821ca9303698170bfd3a0ff8a767b9286d4e8d4ed5aaf6fbaf8a1e8ff9dbd859102a2a47d882787e2da3b3078965bec00157959
+  checksum: 10c0/7adffdc183affd2d3ee1e8497cad6ca7904a37f98328ff7bc15aa6c1829dc9f9a92f8e1bd6260432a33626ff2a839644de938270163e73438b7294675cd954e4
   languageName: node
   linkType: hard
 
-"matrix-widget-api@npm:^1.14.0":
-  version: 1.15.0
-  resolution: "matrix-widget-api@npm:1.15.0"
+"matrix-widget-api@npm:^1.10.0, matrix-widget-api@npm:^1.13.0":
+  version: 1.13.1
+  resolution: "matrix-widget-api@npm:1.13.1"
   dependencies:
     "@types/events": "npm:^3.0.0"
     events: "npm:^3.2.0"
-  checksum: 10c0/1c08b5284cd98aed312d95594335e1391d937dfad70ef862a1f90fdbaaa27709e1c44dcda37f8045e4814779d8d5816d240aee396d52cfd9b37fbf243a6baf6a
+  checksum: 10c0/25ded744922755b3eb65f4e171cf6cff1a2e0fe43fc3fecbb13e565e41d8af066daa817dd2c3c7d921b996af399eec3b23df70ab7b682cf422d9cee7ca202512
   languageName: node
   linkType: hard
 
@@ -12553,7 +12544,7 @@ __metadata:
   languageName: node
   linkType: hard
 
-"sdp-transform@npm:^2.15.0":
+"sdp-transform@npm:^2.14.1, sdp-transform@npm:^2.15.0":
   version: 2.15.0
   resolution: "sdp-transform@npm:2.15.0"
   bin:
@@ -12562,15 +12553,6 @@ __metadata:
   languageName: node
   linkType: hard
 
-"sdp-transform@npm:^3.0.0":
-  version: 3.0.0
-  resolution: "sdp-transform@npm:3.0.0"
-  bin:
-    sdp-verify: checker.js
-  checksum: 10c0/828a4595041ba64c86b29075aa4007ab384519b1fa29882db59ccb83b54b2b2a33b60848293f8da537fe151c52f5844fc17c8325396cac309fb19e2e81ec5bf4
-  languageName: node
-  linkType: hard
-
 "sdp@npm:^3.2.0":
   version: 3.2.0
   resolution: "sdp@npm:3.2.0"
@@ -13621,10 +13603,10 @@ __metadata:
   languageName: node
   linkType: hard
 
-"undici-types@npm:~7.16.0":
-  version: 7.16.0
-  resolution: "undici-types@npm:7.16.0"
-  checksum: 10c0/3033e2f2b5c9f1504bdc5934646cb54e37ecaca0f9249c983f7b1fc2e87c6d18399ebb05dc7fd5419e02b2e915f734d872a65da2e3eeed1813951c427d33cc9a
+"undici-types@npm:~6.21.0":
+  version: 6.21.0
+  resolution: "undici-types@npm:6.21.0"
+  checksum: 10c0/c01ed51829b10aa72fc3ce64b747f8e74ae9b60eafa19a7b46ef624403508a54c526ffab06a14a26b3120d055e1104d7abe7c9017e83ced038ea5cf52f8d5e04
   languageName: node
   linkType: hard