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

feat(dispatcher): conditional error propagation to client

Browse source
This commit is contained in:
teidesu 2021-06-27 23:59:04 +03:00
parent 80e889d95f
commit 2220371efd
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
packages/dispatcher/src/dispatcher.ts
View file

@ -38,7 +38,7 @@ import { UserStatusUpdate } from './updates/user-status-update'
import { UserTypingUpdate } from './updates/user-typing-update' import { UserTypingUpdate } from './updates/user-typing-update'
import { DeleteMessageUpdate } from './updates/delete-message-update' import { DeleteMessageUpdate } from './updates/delete-message-update'
import { IStateStorage, UpdateState, StateKeyDelegate } from './state' import { IStateStorage, UpdateState, StateKeyDelegate } from './state'
import { defaultStateKeyDelegate } from './state/key' import { defaultStateKeyDelegate } from './state'
import { PropagationAction } from './propagation' import { PropagationAction } from './propagation'
const noop = () => {} const noop = () => {}
@ -171,7 +171,7 @@ export class Dispatcher<State = never, SceneName extends string = string> {
err: Error, err: Error,
update: UpdateInfoForError<T>, update: UpdateInfoForError<T>,
state?: UpdateState<State, SceneName> state?: UpdateState<State, SceneName>
) => MaybeAsync<void> ) => MaybeAsync<boolean>
/** /**
* Create a new dispatcher, that will be used as a child, * Create a new dispatcher, that will be used as a child,
@ -491,11 +491,12 @@ export class Dispatcher<State = never, SceneName extends string = string> {
} }
} catch (e) { } catch (e) {
if (this._errorHandler) { if (this._errorHandler) {
await this._errorHandler( const handled = await this._errorHandler(
e, e,
{ type: parsedType, data: parsed }, { type: parsedType, data: parsed },
parsedState as never parsedState as never
) )
if (!handled) throw e
} else { } else {
throw e throw e
} }
@ -616,7 +617,7 @@ export class Dispatcher<State = never, SceneName extends string = string> {
err: Error, err: Error,
update: UpdateInfoForError<UpdateHandler>, update: UpdateInfoForError<UpdateHandler>,
state?: UpdateState<State, SceneName> state?: UpdateState<State, SceneName>
) => MaybeAsync<void>) ) => MaybeAsync<boolean>)
| null | null
): void { ): void {
if (handler) this._errorHandler = handler if (handler) this._errorHandler = handler
@ -631,7 +632,7 @@ export class Dispatcher<State = never, SceneName extends string = string> {
err: Error, err: Error,
update: UpdateInfoForError<T>, update: UpdateInfoForError<T>,
state?: UpdateState<State, SceneName> state?: UpdateState<State, SceneName>
): MaybeAsync<void> { ): MaybeAsync<boolean> {
if (!this.parent) if (!this.parent)
throw new MtCuteArgumentError('This dispatcher is not a child') throw new MtCuteArgumentError('This dispatcher is not a child')