Class TelegramWorkerPort<Custom>Abstract

Type Parameters

Hierarchy (View Summary)

Implements

Constructors

constructor

Properties

appConfig changePrimaryDc computeNewPasswordHash computeSrpParams destroy_ disconnect exportSession getApiCredentials getMtprotoMessageId getPoolSize getPrimaryDcId handleClientUpdate importSession log notifyChannelClosed notifyChannelOpened notifyLoggedIn notifyLoggedOut onConnectionState onError onRawUpdate onServerUpdate options platform prepare recreateDc startUpdatesLoop stopSignal stopUpdatesLoop storage timers

Methods

call connect connectToWorker destroy invokeCustom

Constructors

constructor

Properties

ReadonlyappConfig

appConfig: AppConfigManagerProxy

ReadonlychangePrimaryDc

changePrimaryDc: (newDc: number) => Promise<void>

ReadonlycomputeNewPasswordHash

computeNewPasswordHash: (
    algo: TypePasswordKdfAlgo,
    password: string,
) => Promise<Uint8Array>

ReadonlycomputeSrpParams

computeSrpParams: (
    request: RawPassword,
    password: string,
) => Promise<RawInputCheckPasswordSRP>

Readonlydestroy_

destroy_: () => Promise<void>

Readonlydisconnect

disconnect: () => Promise<void>

ReadonlyexportSession

exportSession: () => Promise<string>

ReadonlygetApiCredentials

getApiCredentials: () => Promise<{ hash: string; id: number }>

ReadonlygetMtprotoMessageId

getMtprotoMessageId: () => Promise<Long>

ReadonlygetPoolSize

getPoolSize: (kind: ConnectionKind, dcId?: number) => Promise<number>

ReadonlygetPrimaryDcId

getPrimaryDcId: () => Promise<number>

ReadonlyhandleClientUpdate

handleClientUpdate: (updates: TypeUpdates, noDispatch?: boolean) => void

ReadonlyimportSession

importSession: (
    session: string | InputStringSessionData,
    force?: boolean,
) => Promise<void>

Readonlylog

log: LogManager

ReadonlynotifyChannelClosed

notifyChannelClosed: (channelId: number) => Promise<boolean>

ReadonlynotifyChannelOpened

notifyChannelOpened: (channelId: number, pts?: number) => Promise<boolean>

ReadonlynotifyLoggedIn

notifyLoggedIn: (auth: RawUser | TypeAuthorization) => Promise<RawUser>

ReadonlynotifyLoggedOut

notifyLoggedOut: () => Promise<void>

onConnectionState

onConnectionState: Emitter<ConnectionState> = ...

onError

onError: Emitter<Error> = ...

onRawUpdate

onRawUpdate: Emitter<RawUpdateInfo> = ...

onServerUpdate

onServerUpdate: Emitter<TypeUpdates> = ...

Readonlyoptions

options: TelegramWorkerPortOptions

Readonlyplatform

platform: ICorePlatform

Readonlyprepare

prepare: () => Promise<void>

ReadonlyrecreateDc

recreateDc: (dcId: number) => Promise<void>

ReadonlystartUpdatesLoop

startUpdatesLoop: () => Promise<void>

ReadonlystopSignal

stopSignal: AbortSignal = ...

ReadonlystopUpdatesLoop

stopUpdatesLoop: () => Promise<void>

Readonlystorage

storage: TelegramStorageProxy

Readonlytimers

timers: TimersManager

Methods

call

  • call<T extends RpcMethod>(
        message: MustEqual<T, RpcMethod>,
        params?: RpcCallOptions,
    ): Promise<RpcCallReturn[T["_"]]>

  • Type Parameters

    • T extends RpcMethod

    Parameters

    Returns Promise<RpcCallReturn[T["_"]]>

connect

  • connect(): Promise<void>

  • Returns Promise<void>

AbstractconnectToWorker

destroy

  • destroy(terminate?: boolean): Promise<void>

  • Parameters

    • terminate: boolean = false

    Returns Promise<void>

invokeCustom

  • invokeCustom<T extends string | number | symbol>(
        method: T,
        ...args: Parameters<Custom[T]>,
    ): Promise<ReturnType<Custom[T]>>

  • Type Parameters

    • T extends string | number | symbol

    Parameters

    Returns Promise<ReturnType<Custom[T]>>

Settings

Member Visibility

On This Page

Constructors
Properties
Methods