mirror of
https://github.com/vector-im/element-call.git
synced 2026-11-10 01:02:27 +00:00
Robin
b4bd1f81a0
The OpenID flow moves to src/livekit/auth/openID.ts with the SFU config types in a sibling file, takes an options object, and replaces the MatrixRTC mode with the role we take on the transport plus the session's slot ID instead of a hard-coded m.call#ROOM. This changes behaviour: publishers on a livekit_service_url transport always use the legacy /sfu/get endpoint, so that subscribers can predict their user:device participant identity, and subscribers always use the default /get_token endpoint. The MatrixRTC mode no longer influences which endpoint is used. On the SDK this lands as sdk/src/media-backend/livekit/auth/ with the connection map, the discriminated connection state and the client-server API flow of the following commits of element-hq/element-call#4331, which rewrite the same files: - Model ConnectionState as a discriminated union - Show the whole transport in debug UI and logs (SDK part) - Let the publishing Connection authenticate itself - Reduce ConnectionManager to a ConnectionMap - Use the unstable LiveKit transport type - Identify transports by server name as well as URLs - Get SFU tokens and delegate delayed leaves through the MSC4195 CS API - Fall back to get_token as subscriber on widget API errors - Share a connection between homeservers using the same JWT service - Make the auth choice mode independent again Co-authored-by: Johannes Marbach <n0-0ne+github@mailbox.org> (cherry picked from commit adb380cd9ed108856e42d992fc03ced8c44f1e56)
38 lines
1.2 KiB
TypeScript
38 lines
1.2 KiB
TypeScript
/*
|
|
Copyright 2026 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 { calculateRetryBackoff } from "matrix-js-sdk";
|
|
import { sleep } from "matrix-js-sdk/lib/utils";
|
|
|
|
/**
|
|
* Performs a network operation with retries on connection errors, honouring
|
|
* the homeserver's rate limits. Rethrows once the error is not retryable or
|
|
* the retries are used up.
|
|
* @param operation The operation to perform.
|
|
* @param shouldRetry Rules out errors that retrying cannot fix, on top of the
|
|
* standard backoff rule. Retries everything by default.
|
|
*/
|
|
export async function doNetworkOperationWithRetry<T>(
|
|
operation: () => Promise<T>,
|
|
shouldRetry: (e: unknown) => boolean = () => true,
|
|
): Promise<T> {
|
|
let currentRetryCount = 0;
|
|
// eslint-disable-next-line no-constant-condition
|
|
while (true) {
|
|
try {
|
|
return await operation();
|
|
} catch (e) {
|
|
currentRetryCount++;
|
|
const backoff = shouldRetry(e)
|
|
? calculateRetryBackoff(e, currentRetryCount, true)
|
|
: -1;
|
|
if (backoff < 0) throw e;
|
|
await sleep(backoff);
|
|
}
|
|
}
|
|
}
|