fixup: update integration tests

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

@@ -12,7 +12,6 @@ import EventEmitter from "events";
 import fetchMock from "fetch-mock";
 import { type LivekitTransport } from "matrix-js-sdk/lib/matrixrtc";
 import { type Room as MatrixRoom, type RoomMember } from "matrix-js-sdk";
-import { logger } from "matrix-js-sdk/lib/logger";
 
 import {
   type Epoch,
@@ -150,14 +149,22 @@ test("bob, carl, then bob joining no tracks yet", () => {
         const items = e.value;
         expect(items.length).toBe(1);
         const item = items[0]!;
-        expect(item.membership).toStrictEqual(bobMembership);
+        expectObservable(item.membership$).toBe("a", {
-        expect(
+          a: bobMembership,
-          areLivekitTransportsEqual(
+        });
-            item.connection!.transport,
+        expectObservable(item.connection$).toBe("a", {
-            bobMembership.transports[0]! as LivekitTransport,
+          a: expect.toSatisfy((co) => {
-          ),
+            expect(
-        ).toBe(true);
+              areLivekitTransportsEqual(
-        expect(item.participant).toBeUndefined();
+                co.transport,
+                bobMembership.transports[0]! as LivekitTransport,
+              ),
+            );
+          }),
+        });
+        expectObservable(item.participant$).toBe("a", {
+          a: null,
+        });
         return true;
       }),
       b: expect.toSatisfy((e: Epoch<MatrixLivekitMember[]>) => {
@@ -166,51 +173,67 @@ test("bob, carl, then bob joining no tracks yet", () => {
 
         {
           const item = items[0]!;
-          expect(item.membership).toStrictEqual(bobMembership);
+          expectObservable(item.membership$).toBe("a", {
-          expect(item.participant).toBeUndefined();
+            a: bobMembership,
+          });
+          expectObservable(item.participant$).toBe("a", {
+            a: null,
+          });
         }
 
         {
           const item = items[1]!;
-          expect(item.membership).toStrictEqual(carlMembership);
+
-          expect(item.participantId).toStrictEqual(
+          expectObservable(item.membership$).toBe("a", {
-            `${carlMembership.userId}:${carlMembership.deviceId}`,
+            a: carlMembership,
-          );
+          });
-          expect(
+          expectObservable(item.participant$).toBe("a", {
-            areLivekitTransportsEqual(
+            a: null,
-              item.connection!.transport,
+          });
-              carlMembership.transports[0]! as LivekitTransport,
+          expectObservable(item.connection$).toBe("a", {
-            ),
+            a: expect.toSatisfy((connection) => {
-          ).toBe(true);
+              expect(
-          expect(item.participant).toBeUndefined();
+                areLivekitTransportsEqual(
+                  connection.transport,
+                  carlMembership.transports[0]! as LivekitTransport,
+                ),
+              ).toBe(true);
+              return true;
+            }),
+          });
         }
         return true;
       }),
       c: expect.toSatisfy((e: Epoch<MatrixLivekitMember[]>) => {
         const items = e.value;
-        logger.info(`E Items length: ${items.length}`);
         expect(items.length).toBe(3);
-        {
-          expect(items[0]!.membership).toStrictEqual(bobMembership);
-        }
 
-        {
+        expectObservable(items[0].membership$).toBe("a", {
-          expect(items[1]!.membership).toStrictEqual(carlMembership);
+          a: bobMembership,
-        }
+        });
+        expectObservable(items[1].membership$).toBe("b", {
+          a: carlMembership,
+        });
 
         {
           const item = items[2]!;
-          expect(item.membership).toStrictEqual(daveMembership);
+          expectObservable(item.membership$).toBe("a", {
-          expect(item.participantId).toStrictEqual(
+            a: daveMembership,
-            `${daveMembership.userId}:${daveMembership.deviceId}`,
+          });
-          );
+          expectObservable(item.connection$).toBe("a", {
-          expect(
+            a: expect.toSatisfy((connection) => {
-            areLivekitTransportsEqual(
+              expect(
-              item.connection!.transport,
+                areLivekitTransportsEqual(
-              daveMembership.transports[0]! as LivekitTransport,
+                  connection.transport,
-            ),
+                  daveMembership.transports[0]! as LivekitTransport,
-          ).toBe(true);
+                ),
-          expect(item.participant).toBeUndefined();
+              ).toBe(true);
+              return true;
+            }),
+          });
+          expectObservable(item.participant$).toBe("a", {
+            a: null,
+          });
         }
         return true;
       }),