Skip to content

Commit 3d60f53

Browse files
committed
comments and rename networkErrorLocalRetryMs -> networkErrorRetryMs
1 parent e2e1305 commit 3d60f53

File tree

4 files changed

+23
-17
lines changed

4 files changed

+23
-17
lines changed

spec/unit/matrixrtc/MembershipManager.spec.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -733,7 +733,7 @@ describe.each([
733733
const unrecoverableError = jest.fn();
734734
(client._unstable_sendDelayedStateEvent as Mock<any>).mockRejectedValue(new HTTPError("unknown", 501));
735735
const manager = new TestMembershipManager(
736-
{ networkErrorLocalRetryMs: 1000, maximumNetworkErrorRetryCount: 7 },
736+
{ networkErrorRetryMs: 1000, maximumNetworkErrorRetryCount: 7 },
737737
room,
738738
client,
739739
() => undefined,

src/matrixrtc/LegacyMembershipManager.ts

+3-3
Original file line numberDiff line numberDiff line change
@@ -69,8 +69,8 @@ export class LegacyMembershipManager implements IMembershipManager {
6969
private delayedLeaveEventDelayMsOverride?: number;
7070
private disconnectDelayId: string | undefined;
7171

72-
private get networkErrorLocalRetryMs(): number {
73-
return this.joinConfig?.networkErrorLocalRetryMs ?? this.joinConfig?.callMemberEventRetryDelayMinimum ?? 3_000;
72+
private get networkErrorRetryMs(): number {
73+
return this.joinConfig?.networkErrorRetryMs ?? this.joinConfig?.callMemberEventRetryDelayMinimum ?? 3_000;
7474
}
7575
private get membershipEventExpiryMs(): number {
7676
return (
@@ -351,7 +351,7 @@ export class LegacyMembershipManager implements IMembershipManager {
351351
}
352352
logger.info("Sent updated call member event.");
353353
} catch (e) {
354-
const resendDelay = this.networkErrorLocalRetryMs;
354+
const resendDelay = this.networkErrorRetryMs;
355355
logger.warn(`Failed to send call member event (retrying in ${resendDelay}): ${e}`);
356356
await sleep(resendDelay);
357357
await this.triggerCallMembershipEventUpdate();

src/matrixrtc/MatrixRTCSession.ts

+15-9
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,13 @@ export type MatrixRTCSessionEventHandlerMap = {
5959
) => void;
6060
[MatrixRTCSessionEvent.MembershipManagerError]: (error: unknown) => void;
6161
};
62-
62+
// The names follow these principles:
63+
// - we use the tehcnical term delay if the option is related to delayed events.
64+
// - we use delayedLeaveEvent if the option is related to the delayed leave event.
65+
// - we use membershipEvent if the option is related to the rtc member state event.
66+
// - we use the technical term expiry if the option is related to the expiry field of the membership state event.
67+
// - we use a `MS` postfix if the option is a duration to avoid using words like:
68+
// `time`, `duration`, `delay`, `timeout`... that might be mistaken/confused with technical terms.
6369
export interface MembershipConfig {
6470
/**
6571
* Use the new Manager.
@@ -93,14 +99,6 @@ export interface MembershipConfig {
9399
/** @deprecated renamed to `membershipEventExpiryHeadroomMs`*/
94100
membershipExpiryTimeoutHeadroom?: number;
95101

96-
/**
97-
* The minimum delay (in milliseconds) after which we will retry sending the membership event if it
98-
* failed to send.
99-
*/
100-
networkErrorLocalRetryMs?: number;
101-
/** @deprecated renamed to `networkErrorLocalRetryMs`*/
102-
callMemberEventRetryDelayMinimum?: number;
103-
104102
/**
105103
* The timeout (in milliseconds) with which the deleayed leave event on the server is configured.
106104
* After this time the server will set the event to the disconnected stat if it has not received a keep-alive from the client.
@@ -125,6 +123,14 @@ export interface MembershipConfig {
125123
* The maximum number of retries that the manager will do for delayed event sending/updating and state event sending when a network error occurs.
126124
*/
127125
maximumNetworkErrorRetryCount?: number;
126+
127+
/**
128+
* The time (in milliseconds) after which we will retry a http request if it
129+
* failed to send due to a network error. (send membership event, send delayed event, restart delayed event...)
130+
*/
131+
networkErrorRetryMs?: number;
132+
/** @deprecated renamed to `networkErrorRetryMs`*/
133+
callMemberEventRetryDelayMinimum?: number;
128134
}
129135

130136
export interface EncryptionConfig {

src/matrixrtc/NewMembershipManager.ts

+4-4
Original file line numberDiff line numberDiff line change
@@ -314,8 +314,8 @@ export class MembershipManager
314314
// Config:
315315
private delayedLeaveEventDelayMsOverride?: number;
316316

317-
private get networkErrorLocalRetryMs(): number {
318-
return this.joinConfig?.networkErrorLocalRetryMs ?? this.joinConfig?.callMemberEventRetryDelayMinimum ?? 3_000;
317+
private get networkErrorRetryMs(): number {
318+
return this.joinConfig?.networkErrorRetryMs ?? this.joinConfig?.callMemberEventRetryDelayMinimum ?? 3_000;
319319
}
320320
private get membershipEventExpiryMs(): number {
321321
return (
@@ -770,7 +770,7 @@ export class MembershipManager
770770
private actionUpdateFromNetworkErrorRetry(error: unknown, type: MembershipActionType): ActionUpdate | undefined {
771771
// "Is a network error"-boundary
772772
const retries = this.state.networkErrorRetries.get(type) ?? 0;
773-
const retryDurationString = this.networkErrorLocalRetryMs / 1000 + "s";
773+
const retryDurationString = this.networkErrorRetryMs / 1000 + "s";
774774
const retryCounterString = "(" + retries + "/" + this.maximumNetworkErrorRetryCount + ")";
775775
if (error instanceof Error && error.name === "AbortError") {
776776
logger.warn(
@@ -820,7 +820,7 @@ export class MembershipManager
820820
// retry boundary
821821
if (retries < this.maximumNetworkErrorRetryCount) {
822822
this.state.networkErrorRetries.set(type, retries + 1);
823-
return createInsertActionUpdate(type, this.networkErrorLocalRetryMs);
823+
return createInsertActionUpdate(type, this.networkErrorRetryMs);
824824
}
825825

826826
// Failure

0 commit comments

Comments
 (0)