@@ -63,31 +63,31 @@ export class LegacyMembershipManager implements IMembershipManager {
6363 private updateCallMembershipRunning = false ;
6464 private needCallMembershipUpdate = false ;
6565 /**
66- * If the server disallows the configured {@link membershipServerSideExpiryTimeout },
66+ * If the server disallows the configured {@link delayedLeaveEventDelayMs },
6767 * this stores a delay that the server does allow.
6868 */
69- private membershipServerSideExpiryTimeoutOverride ?: number ;
69+ private delayedLeaveEventDelayMsOverride ?: number ;
7070 private disconnectDelayId : string | undefined ;
7171
72- private get callMemberEventRetryDelayMinimum ( ) : number {
72+ private get networkErrorLocalRetryMs ( ) : number {
7373 return this . joinConfig ?. networkErrorLocalRetryMs ?? this . joinConfig ?. callMemberEventRetryDelayMinimum ?? 3_000 ;
7474 }
75- private get membershipExpiryTimeout ( ) : number {
75+ private get membershipEventExpiryMs ( ) : number {
7676 return (
7777 this . joinConfig ?. membershipEventExpiryMs ??
7878 this . joinConfig ?. membershipExpiryTimeout ??
7979 DEFAULT_EXPIRE_DURATION
8080 ) ;
8181 }
82- private get membershipServerSideExpiryTimeout ( ) : number {
82+ private get delayedLeaveEventDelayMs ( ) : number {
8383 return (
84- this . membershipServerSideExpiryTimeoutOverride ??
84+ this . delayedLeaveEventDelayMsOverride ??
8585 this . joinConfig ?. delayedLeaveEventDelayMs ??
8686 this . joinConfig ?. membershipServerSideExpiryTimeout ??
8787 8_000
8888 ) ;
8989 }
90- private get membershipKeepAlivePeriod ( ) : number {
90+ private get delayedLeaveEventRestartMs ( ) : number {
9191 return this . joinConfig ?. delayedLeaveEventRestartMs ?? this . joinConfig ?. membershipKeepAlivePeriod ?? 5_000 ;
9292 }
9393
@@ -138,7 +138,7 @@ export class LegacyMembershipManager implements IMembershipManager {
138138 public join ( fociPreferred : Focus [ ] , fociActive ?: Focus ) : void {
139139 this . ownFocusActive = fociActive ;
140140 this . ownFociPreferred = fociPreferred ;
141- this . relativeExpiry = this . membershipExpiryTimeout ;
141+ this . relativeExpiry = this . membershipEventExpiryMs ;
142142 // We don't wait for this, mostly because it may fail and schedule a retry, so this
143143 // function returning doesn't really mean anything at all.
144144 void this . triggerCallMembershipEventUpdate ( ) ;
@@ -262,7 +262,7 @@ export class LegacyMembershipManager implements IMembershipManager {
262262 this . client . _unstable_sendDelayedStateEvent (
263263 this . room . roomId ,
264264 {
265- delay : this . membershipServerSideExpiryTimeout ,
265+ delay : this . delayedLeaveEventDelayMs ,
266266 } ,
267267 EventType . GroupCallMemberPrefix ,
268268 { } , // leave event
@@ -279,9 +279,9 @@ export class LegacyMembershipManager implements IMembershipManager {
279279 const maxDelayAllowed = e . data [ "org.matrix.msc4140.max_delay" ] ;
280280 if (
281281 typeof maxDelayAllowed === "number" &&
282- this . membershipServerSideExpiryTimeout > maxDelayAllowed
282+ this . delayedLeaveEventDelayMs > maxDelayAllowed
283283 ) {
284- this . membershipServerSideExpiryTimeoutOverride = maxDelayAllowed ;
284+ this . delayedLeaveEventDelayMsOverride = maxDelayAllowed ;
285285 return prepareDelayedDisconnection ( ) ;
286286 }
287287 }
@@ -351,15 +351,15 @@ export class LegacyMembershipManager implements IMembershipManager {
351351 }
352352 logger . info ( "Sent updated call member event." ) ;
353353 } catch ( e ) {
354- const resendDelay = this . callMemberEventRetryDelayMinimum ;
354+ const resendDelay = this . networkErrorLocalRetryMs ;
355355 logger . warn ( `Failed to send call member event (retrying in ${ resendDelay } ): ${ e } ` ) ;
356356 await sleep ( resendDelay ) ;
357357 await this . triggerCallMembershipEventUpdate ( ) ;
358358 }
359359 }
360360
361361 private scheduleDelayDisconnection ( ) : void {
362- this . memberEventTimeout = setTimeout ( ( ) => void this . delayDisconnection ( ) , this . membershipKeepAlivePeriod ) ;
362+ this . memberEventTimeout = setTimeout ( ( ) => void this . delayDisconnection ( ) , this . delayedLeaveEventRestartMs ) ;
363363 }
364364
365365 private readonly delayDisconnection = async ( ) : Promise < void > => {
0 commit comments