Class WalletHistoryBackfillAdminService

constructor

• new WalletHistoryBackfillAdminService(
      __namedParameters: {
          db: B2bDatabase;
          temporalClient: TemporalClient;
          testnet: boolean;
      },
  ): WalletHistoryBackfillAdminService

  Parameters

  • __namedParameters: { db: B2bDatabase; temporalClient: TemporalClient; testnet: boolean }

    • db: B2bDatabase

    • temporalClient: TemporalClient

    • testnet: boolean

      The stage's networks: testnets on dev, mainnets on prod.

  Returns WalletHistoryBackfillAdminService

Staticinstance

search

• search(
      __namedParameters: {
          after?: Pair;
          covered?: boolean;
          ledgerAccountIds?: string[];
          maxBatches?: number;
          onProgress?: () => void;
          pageSize: number;
          walletAddressIds?: number[];
          withRuns?: boolean;
      },
  ): Promise<
      {
          ok: true;
          value: {
              hasNext: boolean;
              items: WalletHistoryBackfillPair[];
              next: Pair
              | null;
              runsRead: boolean;
          };
      },
  >

  The pairs after after, by address id then network, as watchedPairs lists them for this stage. next is the last pair read, to pass as after; null once no address is left. With withRuns, each pair carries its latest run from one Temporal visibility list per page; runsRead is false when that read failed, and every run is then null though a run may exist.

  Parameters

  • __namedParameters: {
        after?: Pair;
        covered?: boolean;
        ledgerAccountIds?: string[];
        maxBatches?: number;
        onProgress?: () => void;
        pageSize: number;
        walletAddressIds?: number[];
        withRuns?: boolean;
    }

    • Optionalafter?: Pair

    • Optionalcovered?: boolean

    • OptionalledgerAccountIds?: string[]

      The addresses of these ledger accounts' wallets (external ids).

    • OptionalmaxBatches?: number

      Stops after reading this many batches of ADDRESS_BATCH addresses.

    • OptionalonProgress?: () => void

      Called after each batch read.

    • pageSize: number

    • OptionalwalletAddressIds?: number[]

    • OptionalwithRuns?: boolean

      Reads each pair's latest run from Temporal.

  Returns Promise<
      {
          ok: true;
          value: {
              hasNext: boolean;
              items: WalletHistoryBackfillPair[];
              next: Pair
              | null;
              runsRead: boolean;
          };
      },
  >

start

• start(
      __namedParameters: Pair & {
          endpoints?: readonly WalletHistoryEndpoint[];
      },
  ): Promise<
      | { ok: true; value: { runId: string; workflowId: string } }
      | {
          error:
              | ServiceError<"WORKFLOW_ALREADY_STARTED">
              | ServiceError<"WALLET_HISTORY_PAIR_NOT_WATCHED">;
          ok: false;
      },
  >

  Starts the backfill of one pair on endpoints, by default every one, or joins the one running under its id. WALLET_HISTORY_PAIR_NOT_WATCHED when no such pair is watched here.

  Parameters

  • __namedParameters: Pair & { endpoints?: readonly WalletHistoryEndpoint[] }

    • Optionalendpoints?: readonly WalletHistoryEndpoint[]

      A pair's missing, so a launch re-run pages only a new endpoint.

  Returns Promise<
      | { ok: true; value: { runId: string; workflowId: string } }
      | {
          error:
              | ServiceError<"WORKFLOW_ALREADY_STARTED">
              | ServiceError<"WALLET_HISTORY_PAIR_NOT_WATCHED">;
          ok: false;
      },
  >