diff --git a/packages/core/src/network/client.ts b/packages/core/src/network/client.ts index 42d42a36..e4de2706 100644 --- a/packages/core/src/network/client.ts +++ b/packages/core/src/network/client.ts @@ -360,6 +360,8 @@ export class MtClient extends EventEmitter { * Close all connections and finalize the client. */ async close(): Promise { + this.log.debug('closing client') + this._config.destroy() await this.network.destroy() @@ -369,6 +371,8 @@ export class MtClient extends EventEmitter { this._prepare.reset() this._connect.reset() this._abortController.abort() + + this.log.debug('client closed successfully') } /** diff --git a/packages/core/src/network/mtproto-session.ts b/packages/core/src/network/mtproto-session.ts index 5fc4e0e0..731cc502 100644 --- a/packages/core/src/network/mtproto-session.ts +++ b/packages/core/src/network/mtproto-session.ts @@ -200,6 +200,7 @@ export class MtprotoSession { if (!keepPending) { for (const info of this.pendingMessages.values()) { if (info._ === 'rpc') { + this.log.debug('rejecting pending rpc %s', info.rpc.method) info.rpc.promise.reject(new MtcuteError('Session is reset')) } } @@ -214,6 +215,7 @@ export class MtprotoSession { const rpc = this.queuedRpc.popFront()! if (rpc.sent === false) { + this.log.debug('rejecting pending rpc %s', rpc.method) rpc.promise.reject(new MtcuteError('Session is reset')) } }