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

fix: correctly reset session

Browse source
This commit is contained in:
alina 🌸 2024-03-28 18:59:21 +03:00
parent d577f0ed9b
commit fa267eef03
Signed by: teidesu
SSH key fingerprint: SHA256:uNeCpw6aTSU4aIObXLvHfLkDa82HWH9EiOj9AXOIRpI
3 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/bun/src/utils/tcp.ts
View file

@ -79,12 +79,12 @@ export abstract class BaseTcpTransport extends EventEmitter implements ITelegram
if (this._state === TransportState.Idle) return if (this._state === TransportState.Idle) return
this.log.info('connection closed') this.log.info('connection closed')
this.emit('close')
this._state = TransportState.Idle this._state = TransportState.Idle
this._socket?.end() this._socket?.end()
this._socket = null this._socket = null
this._currentDc = null this._currentDc = null
this._packetCodec.reset() this._packetCodec.reset()
this.emit('close')
} }
handleError(socket: unknown, error: Error): void { handleError(socket: unknown, error: Error): void {

2
packages/node/src/utils/tcp.ts
View file

@ -73,13 +73,13 @@ export abstract class BaseTcpTransport extends EventEmitter implements ITelegram
if (this._state === TransportState.Idle) return if (this._state === TransportState.Idle) return
this.log.info('connection closed') this.log.info('connection closed')
this.emit('close')
this._state = TransportState.Idle this._state = TransportState.Idle
this._socket!.removeAllListeners() this._socket!.removeAllListeners()
this._socket!.destroy() this._socket!.destroy()
this._socket = null this._socket = null
this._currentDc = null this._currentDc = null
this._packetCodec.reset() this._packetCodec.reset()
this.emit('close')
} }
handleError(error: Error): void { handleError(error: Error): void {

2
packages/web/src/websocket.ts
View file

@ -130,13 +130,13 @@ export abstract class BaseWebSocketTransport extends EventEmitter implements ITe
if (this._state === TransportState.Idle) return if (this._state === TransportState.Idle) return
this.log.info('connection closed') this.log.info('connection closed')
this.emit('close')
this._state = TransportState.Idle this._state = TransportState.Idle
this._socket!.removeEventListener('close', this.close) this._socket!.removeEventListener('close', this.close)
this._socket!.close() this._socket!.close()
this._socket = null this._socket = null
this._currentDc = null this._currentDc = null
this._packetCodec.reset() this._packetCodec.reset()
this.emit('close')
} }
handleError(event: Event | { error: Error }): void { handleError(event: Event | { error: Error }): void {