@@ -63,31 +63,31 @@ export class LegacyMembershipManager implements IMembershipManager {
63
63
private updateCallMembershipRunning = false ;
64
64
private needCallMembershipUpdate = false ;
65
65
/**
66
- * If the server disallows the configured {@link membershipServerSideExpiryTimeout },
66
+ * If the server disallows the configured {@link delayedLeaveEventDelayMs },
67
67
* this stores a delay that the server does allow.
68
68
*/
69
- private membershipServerSideExpiryTimeoutOverride ?: number ;
69
+ private delayedLeaveEventDelayMsOverride ?: number ;
70
70
private disconnectDelayId : string | undefined ;
71
71
72
- private get callMemberEventRetryDelayMinimum ( ) : number {
72
+ private get networkErrorLocalRetryMs ( ) : number {
73
73
return this . joinConfig ?. networkErrorLocalRetryMs ?? this . joinConfig ?. callMemberEventRetryDelayMinimum ?? 3_000 ;
74
74
}
75
- private get membershipExpiryTimeout ( ) : number {
75
+ private get membershipEventExpiryMs ( ) : number {
76
76
return (
77
77
this . joinConfig ?. membershipEventExpiryMs ??
78
78
this . joinConfig ?. membershipExpiryTimeout ??
79
79
DEFAULT_EXPIRE_DURATION
80
80
) ;
81
81
}
82
- private get membershipServerSideExpiryTimeout ( ) : number {
82
+ private get delayedLeaveEventDelayMs ( ) : number {
83
83
return (
84
- this . membershipServerSideExpiryTimeoutOverride ??
84
+ this . delayedLeaveEventDelayMsOverride ??
85
85
this . joinConfig ?. delayedLeaveEventDelayMs ??
86
86
this . joinConfig ?. membershipServerSideExpiryTimeout ??
87
87
8_000
88
88
) ;
89
89
}
90
- private get membershipKeepAlivePeriod ( ) : number {
90
+ private get delayedLeaveEventRestartMs ( ) : number {
91
91
return this . joinConfig ?. delayedLeaveEventRestartMs ?? this . joinConfig ?. membershipKeepAlivePeriod ?? 5_000 ;
92
92
}
93
93
@@ -138,7 +138,7 @@ export class LegacyMembershipManager implements IMembershipManager {
138
138
public join ( fociPreferred : Focus [ ] , fociActive ?: Focus ) : void {
139
139
this . ownFocusActive = fociActive ;
140
140
this . ownFociPreferred = fociPreferred ;
141
- this . relativeExpiry = this . membershipExpiryTimeout ;
141
+ this . relativeExpiry = this . membershipEventExpiryMs ;
142
142
// We don't wait for this, mostly because it may fail and schedule a retry, so this
143
143
// function returning doesn't really mean anything at all.
144
144
void this . triggerCallMembershipEventUpdate ( ) ;
@@ -262,7 +262,7 @@ export class LegacyMembershipManager implements IMembershipManager {
262
262
this . client . _unstable_sendDelayedStateEvent (
263
263
this . room . roomId ,
264
264
{
265
- delay : this . membershipServerSideExpiryTimeout ,
265
+ delay : this . delayedLeaveEventDelayMs ,
266
266
} ,
267
267
EventType . GroupCallMemberPrefix ,
268
268
{ } , // leave event
@@ -279,9 +279,9 @@ export class LegacyMembershipManager implements IMembershipManager {
279
279
const maxDelayAllowed = e . data [ "org.matrix.msc4140.max_delay" ] ;
280
280
if (
281
281
typeof maxDelayAllowed === "number" &&
282
- this . membershipServerSideExpiryTimeout > maxDelayAllowed
282
+ this . delayedLeaveEventDelayMs > maxDelayAllowed
283
283
) {
284
- this . membershipServerSideExpiryTimeoutOverride = maxDelayAllowed ;
284
+ this . delayedLeaveEventDelayMsOverride = maxDelayAllowed ;
285
285
return prepareDelayedDisconnection ( ) ;
286
286
}
287
287
}
@@ -351,15 +351,15 @@ export class LegacyMembershipManager implements IMembershipManager {
351
351
}
352
352
logger . info ( "Sent updated call member event." ) ;
353
353
} catch ( e ) {
354
- const resendDelay = this . callMemberEventRetryDelayMinimum ;
354
+ const resendDelay = this . networkErrorLocalRetryMs ;
355
355
logger . warn ( `Failed to send call member event (retrying in ${ resendDelay } ): ${ e } ` ) ;
356
356
await sleep ( resendDelay ) ;
357
357
await this . triggerCallMembershipEventUpdate ( ) ;
358
358
}
359
359
}
360
360
361
361
private scheduleDelayDisconnection ( ) : void {
362
- this . memberEventTimeout = setTimeout ( ( ) => void this . delayDisconnection ( ) , this . membershipKeepAlivePeriod ) ;
362
+ this . memberEventTimeout = setTimeout ( ( ) => void this . delayDisconnection ( ) , this . delayedLeaveEventRestartMs ) ;
363
363
}
364
364
365
365
private readonly delayDisconnection = async ( ) : Promise < void > => {
0 commit comments