From 23f846a308792a9ab21b0c486329015aa72eaec0 Mon Sep 17 00:00:00 2001 From: Valere Date: Thu, 2 Apr 2026 14:47:34 +0200 Subject: [PATCH] fixup: test prettier --- .../localMember/LocalTransport.test.ts | 115 +++++++++--------- 1 file changed, 56 insertions(+), 59 deletions(-) diff --git a/src/state/CallViewModel/localMember/LocalTransport.test.ts b/src/state/CallViewModel/localMember/LocalTransport.test.ts index 165db7dd..aa6228c9 100644 --- a/src/state/CallViewModel/localMember/LocalTransport.test.ts +++ b/src/state/CallViewModel/localMember/LocalTransport.test.ts @@ -544,71 +544,68 @@ describe("LocalTransport", () => { }); }); - it( - "should not update advertised transport on delayID changes, but active should update", - async () => { - // For simplicity, we'll just use the config livekit - customLivekitUrl.setValue("https://lk.example.org"); + it("should not update advertised transport on delayID changes, but active should update", async () => { + // For simplicity, we'll just use the config livekit + customLivekitUrl.setValue("https://lk.example.org"); - vi.spyOn(openIDSFU, "getSFUConfigWithOpenID").mockResolvedValue( - openIdResponse, - ); + vi.spyOn(openIDSFU, "getSFUConfigWithOpenID").mockResolvedValue( + openIdResponse, + ); - const delayId$ = new BehaviorSubject(null); + const delayId$ = new BehaviorSubject(null); - const { advertised$, active$ } = createLocalTransport$({ - scope, - ownMembershipIdentity: ownMemberMock, - roomId: "!example_room_id", - // We want multi-sdu - useOldestMember: false, - forceJwtEndpoint: JwtEndpointVersion.Legacy, - delayId$: delayId$, - memberships$: constant(new Epoch([])), - client: { - getDomain: () => "", - baseUrl: "https://example.org", - // eslint-disable-next-line @typescript-eslint/naming-convention - _unstable_getRTCTransports: async () => Promise.resolve([]), - getAccessToken: vi.fn().mockReturnValue("access_token"), - // These won't be called in this error path but satisfy the type - getOpenIdToken: vi.fn(), - getDeviceId: vi.fn(), - }, - }); + const { advertised$, active$ } = createLocalTransport$({ + scope, + ownMembershipIdentity: ownMemberMock, + roomId: "!example_room_id", + // We want multi-sdu + useOldestMember: false, + forceJwtEndpoint: JwtEndpointVersion.Legacy, + delayId$: delayId$, + memberships$: constant(new Epoch([])), + client: { + getDomain: () => "", + baseUrl: "https://example.org", + // eslint-disable-next-line @typescript-eslint/naming-convention + _unstable_getRTCTransports: async () => Promise.resolve([]), + getAccessToken: vi.fn().mockReturnValue("access_token"), + // These won't be called in this error path but satisfy the type + getOpenIdToken: vi.fn(), + getDeviceId: vi.fn(), + }, + }); - const advertisedValues: LivekitTransportConfig[] = []; - const activeValues: LocalTransportWithSFUConfig[] = []; - advertised$ - .pipe(filter((v) => v !== null)) - .subscribe((t) => advertisedValues.push(t)); - active$ - .pipe(filter((v) => v !== null)) - .subscribe((t) => activeValues.push(t)); + const advertisedValues: LivekitTransportConfig[] = []; + const activeValues: LocalTransportWithSFUConfig[] = []; + advertised$ + .pipe(filter((v) => v !== null)) + .subscribe((t) => advertisedValues.push(t)); + active$ + .pipe(filter((v) => v !== null)) + .subscribe((t) => activeValues.push(t)); - await flushPromises(); + await flushPromises(); - // we have now an active and an advertised - expect(advertisedValues.length).toEqual(1); - expect(activeValues.length).toEqual(1); - expect(advertisedValues[0]!.livekit_service_url).toEqual( - "https://lk.example.org", - ); - expect(activeValues[0]!.transport.livekit_service_url).toEqual( - "https://lk.example.org", - ); + // we have now an active and an advertised + expect(advertisedValues.length).toEqual(1); + expect(activeValues.length).toEqual(1); + expect(advertisedValues[0]!.livekit_service_url).toEqual( + "https://lk.example.org", + ); + expect(activeValues[0]!.transport.livekit_service_url).toEqual( + "https://lk.example.org", + ); - // Now emits 3 new delays id - delayId$.next("delay_id_1"); - await flushPromises(); - delayId$.next("delay_id_2"); - await flushPromises(); - delayId$.next("delay_id_3"); - await flushPromises(); + // Now emits 3 new delays id + delayId$.next("delay_id_1"); + await flushPromises(); + delayId$.next("delay_id_2"); + await flushPromises(); + delayId$.next("delay_id_3"); + await flushPromises(); - // No new emissions should've happened, it is the same transport. only auth and delegation of delay has changed - expect(advertisedValues.length).toEqual(1); - expect(activeValues.length).toEqual(4); - }, - ); + // No new emissions should've happened, it is the same transport. only auth and delegation of delay has changed + expect(advertisedValues.length).toEqual(1); + expect(activeValues.length).toEqual(4); + }); });