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

fix(core): onError not working

Browse source 
i might be fucking retarded actually
This commit is contained in:
alina 🌸 2024-05-30 00:35:52 +03:00
parent e6e5d97a3e
commit 86405fae18
Signed by: teidesu
SSH key fingerprint: SHA256:uNeCpw6aTSU4aIObXLvHfLkDa82HWH9EiOj9AXOIRpI
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
packages/core/src/network/client.ts
View file

@ -24,7 +24,6 @@ import { ConfigManager } from './config-manager.js'
import { NetworkManager, NetworkManagerExtraParams, RpcCallOptions } from './network-manager.js' import { NetworkManager, NetworkManagerExtraParams, RpcCallOptions } from './network-manager.js'
import { PersistentConnectionParams } from './persistent-connection.js' import { PersistentConnectionParams } from './persistent-connection.js'
import { ReconnectionStrategy } from './reconnection.js' import { ReconnectionStrategy } from './reconnection.js'
import { SessionConnection } from './session-connection.js'
import { TransportFactory } from './transports/index.js' import { TransportFactory } from './transports/index.js'
/** Options for {@link MtClient} */ /** Options for {@link MtClient} */
@ -234,7 +233,7 @@ export class MtClient extends EventEmitter {
readonly _config = new ConfigManager(() => this.call({ _: 'help.getConfig' })) readonly _config = new ConfigManager(() => this.call({ _: 'help.getConfig' }))
private _emitError?: (err: unknown, connection?: SessionConnection) => void private _emitError?: (err: unknown) => void
readonly log: Logger readonly log: Logger
readonly network: NetworkManager readonly network: NetworkManager
@ -306,9 +305,9 @@ export class MtClient extends EventEmitter {
) )
} }
emitError(err: unknown, connection?: SessionConnection): void { emitError(err: unknown): void {
if (this._emitError) { if (this._emitError) {
this._emitError(err, connection) this._emitError(err)
} else { } else {
this.log.error('unhandled error:', err) this.log.error('unhandled error:', err)
} }
@ -392,6 +391,6 @@ export class MtClient extends EventEmitter {
* @param handler Error handler. * @param handler Error handler.
*/ */
onError(handler: (err: unknown) => void): void { onError(handler: (err: unknown) => void): void {
this.emitError = handler this._emitError = handler
} }
} }