teidesu/mtcute
1
0
Fork 0
Code Issues 15 Pull requests 1 Projects Releases Packages Wiki Activity Actions

Connection state #22

Merged
teidesu merged 3 commits from connection-state into master 2024-03-15 03:45:03 +03:00
Conversation 1 Commits 3 Files changed 15 +4 -4
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit c9a4558e5c - Show all commits

2
packages/core/src/network/persistent-connection.ts
View file

@ -35,7 +35,7 @@ export abstract class PersistentConnection extends EventEmitter {
private _previousWait: number | null = null private _previousWait: number | null = null
private _reconnectionTimeout: NodeJS.Timeout | null = null private _reconnectionTimeout: NodeJS.Timeout | null = null
private _shouldReconnectImmediately = false private _shouldReconnectImmediately = false
private _disconnectedManually = false protected _disconnectedManually = false
// inactivity timeout // inactivity timeout
private _inactivityTimeout: NodeJS.Timeout | null = null private _inactivityTimeout: NodeJS.Timeout | null = null

6
packages/core/src/network/session-connection.ts
View file

@ -1524,14 +1524,14 @@ export class SessionConnection extends PersistentConnection {
private _flush(): void { private _flush(): void {
if ( if (
!this.isConnected || this._disconnectedManually ||
!this._session._authKey.ready || !this._session._authKey.ready ||
this._isPfsBindingPending || this._isPfsBindingPending ||
this._session.current429Timeout this._session.current429Timeout
) { ) {
this.log.debug( this.log.debug(
'skipping flush, connection is not usable (connected = %b, auth key ready = %b, pfs binding pending = %b, 429 timeout = %b)', 'skipping flush, connection is not usable (offline = %b, auth key ready = %b, pfs binding pending = %b, 429 timeout = %b)',
this.isConnected, this._disconnectedManually,
this._session._authKey.ready, this._session._authKey.ready,
this._isPfsBindingPending, this._isPfsBindingPending,
this._session.current429Timeout, this._session.current429Timeout,