mirror of
https://github.com/vector-im/element-call.git
synced 2026-09-07 21:45:18 +00:00
Update remaining variable names for remote Matrix-LiveKit members
This commit is contained in:
@@ -89,7 +89,7 @@ test("should signal participant not yet connected to livekit", async () => {
|
|||||||
mockConnectionManagerData$,
|
mockConnectionManagerData$,
|
||||||
);
|
);
|
||||||
|
|
||||||
const matrixLivekitMember$ = createRemoteMatrixLivekitMembers$({
|
const remoteMatrixLivekitMembers$ = createRemoteMatrixLivekitMembers$({
|
||||||
scope: testScope,
|
scope: testScope,
|
||||||
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
||||||
connectionManager: {
|
connectionManager: {
|
||||||
@@ -99,7 +99,7 @@ test("should signal participant not yet connected to livekit", async () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
await flushPromises();
|
await flushPromises();
|
||||||
expect(matrixLivekitMember$.value.value).toSatisfy(
|
expect(remoteMatrixLivekitMembers$.value.value).toSatisfy(
|
||||||
(data: RemoteMatrixLivekitMember[]) => {
|
(data: RemoteMatrixLivekitMember[]) => {
|
||||||
expect(data.length).toEqual(1);
|
expect(data.length).toEqual(1);
|
||||||
expect(data[0].membership$.value).toBe(bobMembership);
|
expect(data[0].membership$.value).toBe(bobMembership);
|
||||||
@@ -159,7 +159,7 @@ test("should signal participant on a connection that is publishing", async () =>
|
|||||||
constant(dataWithPublisher),
|
constant(dataWithPublisher),
|
||||||
);
|
);
|
||||||
|
|
||||||
const matrixLivekitMember$ = createRemoteMatrixLivekitMembers$({
|
const remoteMatrixLivekitMembers$ = createRemoteMatrixLivekitMembers$({
|
||||||
scope: testScope,
|
scope: testScope,
|
||||||
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
||||||
connectionManager: {
|
connectionManager: {
|
||||||
@@ -169,7 +169,7 @@ test("should signal participant on a connection that is publishing", async () =>
|
|||||||
});
|
});
|
||||||
|
|
||||||
await flushPromises();
|
await flushPromises();
|
||||||
expect(matrixLivekitMember$.value.value).toSatisfy(
|
expect(remoteMatrixLivekitMembers$.value.value).toSatisfy(
|
||||||
(data: RemoteMatrixLivekitMember[]) => {
|
(data: RemoteMatrixLivekitMember[]) => {
|
||||||
expect(data.length).toEqual(1);
|
expect(data.length).toEqual(1);
|
||||||
expect(data[0].membership$.value).toBe(bobMembership);
|
expect(data[0].membership$.value).toBe(bobMembership);
|
||||||
@@ -200,7 +200,7 @@ test("should signal participant on a connection that is not publishing", async (
|
|||||||
constant(dataWithPublisher),
|
constant(dataWithPublisher),
|
||||||
);
|
);
|
||||||
|
|
||||||
const matrixLivekitMember$ = createRemoteMatrixLivekitMembers$({
|
const remoteMatrixLivekitMembers$ = createRemoteMatrixLivekitMembers$({
|
||||||
scope: testScope,
|
scope: testScope,
|
||||||
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
||||||
connectionManager: {
|
connectionManager: {
|
||||||
@@ -209,7 +209,7 @@ test("should signal participant on a connection that is not publishing", async (
|
|||||||
localUser: localRtcMember,
|
localUser: localRtcMember,
|
||||||
});
|
});
|
||||||
await flushPromises();
|
await flushPromises();
|
||||||
expect(matrixLivekitMember$.value.value).toSatisfy(
|
expect(remoteMatrixLivekitMembers$.value.value).toSatisfy(
|
||||||
(data: RemoteMatrixLivekitMember[]) => {
|
(data: RemoteMatrixLivekitMember[]) => {
|
||||||
expect(data.length).toEqual(1);
|
expect(data.length).toEqual(1);
|
||||||
expect(data[0].membership$.value).toBe(bobMembership);
|
expect(data[0].membership$.value).toBe(bobMembership);
|
||||||
@@ -249,7 +249,7 @@ describe("Publication edge case", () => {
|
|||||||
constant(connectionWithPublisher),
|
constant(connectionWithPublisher),
|
||||||
);
|
);
|
||||||
|
|
||||||
const matrixLivekitMembers$ = createRemoteMatrixLivekitMembers$({
|
const remoteMatrixLivekitMembers$ = createRemoteMatrixLivekitMembers$({
|
||||||
scope: testScope,
|
scope: testScope,
|
||||||
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
||||||
connectionManager: {
|
connectionManager: {
|
||||||
@@ -258,7 +258,7 @@ describe("Publication edge case", () => {
|
|||||||
localUser: localRtcMember,
|
localUser: localRtcMember,
|
||||||
});
|
});
|
||||||
await flushPromises();
|
await flushPromises();
|
||||||
expect(matrixLivekitMembers$.value.value).toSatisfy(
|
expect(remoteMatrixLivekitMembers$.value.value).toSatisfy(
|
||||||
(data: RemoteMatrixLivekitMember[]) => {
|
(data: RemoteMatrixLivekitMember[]) => {
|
||||||
expect(data.length).toEqual(2);
|
expect(data.length).toEqual(2);
|
||||||
expect(data[0].membership$.value).toBe(bobMembership);
|
expect(data[0].membership$.value).toBe(bobMembership);
|
||||||
@@ -308,7 +308,7 @@ test("bob is publishing in the wrong connection", async () => {
|
|||||||
connectionsWithPublisher$,
|
connectionsWithPublisher$,
|
||||||
);
|
);
|
||||||
|
|
||||||
const matrixLivekitMember$ = createRemoteMatrixLivekitMembers$({
|
const remoteMatrixLivekitMembers$ = createRemoteMatrixLivekitMembers$({
|
||||||
scope: testScope,
|
scope: testScope,
|
||||||
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
membershipsWithTransport$: testScope.behavior(membershipsWithTransport$),
|
||||||
connectionManager: {
|
connectionManager: {
|
||||||
@@ -318,7 +318,7 @@ test("bob is publishing in the wrong connection", async () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
await flushPromises();
|
await flushPromises();
|
||||||
expect(matrixLivekitMember$.value.value).toSatisfy(
|
expect(remoteMatrixLivekitMembers$.value.value).toSatisfy(
|
||||||
(data: RemoteMatrixLivekitMember[]) => {
|
(data: RemoteMatrixLivekitMember[]) => {
|
||||||
expect(data.length).toEqual(2);
|
expect(data.length).toEqual(2);
|
||||||
expect(data[0].membership$.value).toBe(bobMembership);
|
expect(data[0].membership$.value).toBe(bobMembership);
|
||||||
|
|||||||
@@ -130,7 +130,7 @@ test("bob, carl, then bob joining no tracks yet", () => {
|
|||||||
ownMembershipIdentity: ownMemberMock,
|
ownMembershipIdentity: ownMemberMock,
|
||||||
});
|
});
|
||||||
|
|
||||||
const matrixLivekitMembers$ = createRemoteMatrixLivekitMembers$({
|
const remoteMatrixLivekitMembers$ = createRemoteMatrixLivekitMembers$({
|
||||||
scope: testScope,
|
scope: testScope,
|
||||||
membershipsWithTransport$:
|
membershipsWithTransport$:
|
||||||
membershipsAndTransports.membershipsWithTransport$,
|
membershipsAndTransports.membershipsWithTransport$,
|
||||||
@@ -138,7 +138,7 @@ test("bob, carl, then bob joining no tracks yet", () => {
|
|||||||
localUser: localRtcMember,
|
localUser: localRtcMember,
|
||||||
});
|
});
|
||||||
|
|
||||||
expectObservable(matrixLivekitMembers$).toBe(vMarble, {
|
expectObservable(remoteMatrixLivekitMembers$).toBe(vMarble, {
|
||||||
a: expect.toSatisfy((e: Epoch<RemoteMatrixLivekitMember[]>) => {
|
a: expect.toSatisfy((e: Epoch<RemoteMatrixLivekitMember[]>) => {
|
||||||
const items = e.value;
|
const items = e.value;
|
||||||
expect(items.length).toBe(1);
|
expect(items.length).toBe(1);
|
||||||
|
|||||||
Reference in New Issue
Block a user