Class WalletMessageHandler

constructor

• new WalletMessageHandler(
      options?: { messageTag?: string },
  ): WalletMessageHandler

  Instantiate a new WalletUpdater. Can override the default messageTag allowing more than one updater to run in parallel. Note that the default ServiceWorkerWallet sends messages to the default WalletUpdater tag.

  Parameters

  • Optionaloptions: { messageTag?: string }

  Returns WalletMessageHandler

ReadonlymessageTag

handleMessage

• handleMessage(message: WalletUpdaterRequest): Promise<WalletUpdaterResponse>

  Handle routed messages from the clients

  Parameters

  • message: WalletUpdaterRequest

  Returns Promise<WalletUpdaterResponse>

isLongRunning

• isLongRunning(message: WalletUpdaterRequest): boolean

  Optional opt-out from the bus-level message timeout.

  Long-running flows (e.g. settlement) surrender control to remote peers and can legitimately sit idle for longer than messageTimeoutMs. When this returns true, the bus awaits handleMessage without a deadline. Defaults to false.

  Parameters

  • message: WalletUpdaterRequest

  Returns boolean

start

• start(
      ...params: [
          services: {
              arkProvider: ArkProvider;
              readonlyWallet: ReadonlyWallet;
              wallet?: Wallet;
          },
          repositories: { walletRepository: WalletRepository },
      ],
  ): Promise<void>

  Called once when the SW is starting up

  Parameters

  • ...params: [
        services: {
            arkProvider: ArkProvider;
            readonlyWallet: ReadonlyWallet;
            wallet?: Wallet;
        },
        repositories: { walletRepository: WalletRepository },
    ]

  Returns Promise<void>

stop

• stop(): Promise<void>

  Called once when the SW is shutting down

  Returns Promise<void>

tick

• tick(_now: number): Promise<WalletUpdaterResponse[]>

  Called by the scheduler to perform a tick. Can be used by the updater to perform periodic tasks or return delayed responses (eg: subscriptions).

  Parameters

  • _now: number

  Returns Promise<WalletUpdaterResponse[]>