Class TelegramWorkerPort<T>

Type Parameters

Hierarchy (View Summary)

Constructors

constructor

Properties

appConfig changePrimaryDc close computeNewPasswordHash computeSrpParams 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>

Readonlyclose

close: () => Promise<void>

ReadonlycomputeNewPasswordHash

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

ReadonlycomputeSrpParams

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

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>

connectToWorker

destroy

  • destroy(terminate?: boolean): void

  • Parameters

    • terminate: boolean = false

    Returns void

invokeCustom

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

  • Type Parameters

    • T extends string | number | symbol

    Parameters

    • method: T
    • ...args: Parameters<T[T]>

    Returns Promise<ReturnType<T[T]>>

Settings

Member Visibility

On This Page

Constructors
Properties
Methods