Class TransactionQueryService

constructor

• new TransactionQueryService(
      args: { db: B2bDatabase; valkeyClient: ValkeyClient | null },
  ): TransactionQueryService

  Parameters

  • args: { db: B2bDatabase; valkeyClient: ValkeyClient | null }

  Returns TransactionQueryService

Staticinstance

aggregateTotalsByMethod

• aggregateTotalsByMethod(
      args: {
          createdAt?: DbTimestampCriteria;
          customerId: string;
          dataSources?: (
              | "deposit"
              | "manual_mint"
              | "withdrawal"
              | "swap"
              | "transfer"
              | "network_transfer"
              | "fee_transfer"
              | "redemption"
              | "card"
              | "escrow_transfer"
              | "reward"
              | "blockchain_deposit"
              | "blockchain_withdrawal"
              | "ledger_account_withdrawal"
          )[];
          methods?: (
              | "ACH_CREDIT"
              | "ACH_DEBIT"
              | "AF_BANK"
              | "AF_MOMO"
              | "BLOCKCHAIN"
              | "CASH"
              | "CFX_NETWORK"
              | "DEPOSIT"
              | "ESCROW"
              | "FEDWIRE"
              | "FEDWIRE_DRAWDOWN"
              | "FEDNOW"
              | "RTP"
              | "INSTANT"
              | "SPEI"
              | "DEBIT_CARD"
              | "REWARD"
              | "SWAP"
              | "SWIFT"
              | "TRANSFER"
              | "VIRTUAL_CARD"
              | "WITHDRAWAL"
          )[];
          statuses?: (
              | "PENDING"
              | "FAILED"
              | "PROCESSING"
              | "COMPLETED"
              | "RETURNED"
              | "CANCELLED"
          )[];
          subtypes?: | (
              | "DEPOSIT"
              | "RETURN"
              | "FEE"
              | "ADJUSTMENT"
              | "POINTS"
              | "LEDGER_ACCOUNT"
              | "PLATFORM_SETTLEMENT"
              | undefined
          )[]
          | null;
      },
  ): Promise<{ ok: true; value: { items: TransactionMethodAggregate[] } }>

  Aggregate transaction totals grouped by (method, type, status).

  Single GROUP BY query against the same UNION used by search, but skips the outer entity / ledger / solana enrichment — aggregation only needs (method, type, status, amount). Use this instead of paging through search when you only need bucketed sums (e.g. the home-page money- movement widget).

  Parameters

  • args: {
        createdAt?: DbTimestampCriteria;
        customerId: string;
        dataSources?: (
            | "deposit"
            | "manual_mint"
            | "withdrawal"
            | "swap"
            | "transfer"
            | "network_transfer"
            | "fee_transfer"
            | "redemption"
            | "card"
            | "escrow_transfer"
            | "reward"
            | "blockchain_deposit"
            | "blockchain_withdrawal"
            | "ledger_account_withdrawal"
        )[];
        methods?: (
            | "ACH_CREDIT"
            | "ACH_DEBIT"
            | "AF_BANK"
            | "AF_MOMO"
            | "BLOCKCHAIN"
            | "CASH"
            | "CFX_NETWORK"
            | "DEPOSIT"
            | "ESCROW"
            | "FEDWIRE"
            | "FEDWIRE_DRAWDOWN"
            | "FEDNOW"
            | "RTP"
            | "INSTANT"
            | "SPEI"
            | "DEBIT_CARD"
            | "REWARD"
            | "SWAP"
            | "SWIFT"
            | "TRANSFER"
            | "VIRTUAL_CARD"
            | "WITHDRAWAL"
        )[];
        statuses?: (
            | "PENDING"
            | "FAILED"
            | "PROCESSING"
            | "COMPLETED"
            | "RETURNED"
            | "CANCELLED"
        )[];
        subtypes?: | (
            | "DEPOSIT"
            | "RETURN"
            | "FEE"
            | "ADJUSTMENT"
            | "POINTS"
            | "LEDGER_ACCOUNT"
            | "PLATFORM_SETTLEMENT"
            | undefined
        )[]
        | null;
    }

    • OptionalcreatedAt?: DbTimestampCriteria

    • customerId: string

    • OptionaldataSources?: (
          | "deposit"
          | "manual_mint"
          | "withdrawal"
          | "swap"
          | "transfer"
          | "network_transfer"
          | "fee_transfer"
          | "redemption"
          | "card"
          | "escrow_transfer"
          | "reward"
          | "blockchain_deposit"
          | "blockchain_withdrawal"
          | "ledger_account_withdrawal"
      )[]

      Filter by the producing arm; prunes the UNION exactly.

    • Optionalmethods?: (
          | "ACH_CREDIT"
          | "ACH_DEBIT"
          | "AF_BANK"
          | "AF_MOMO"
          | "BLOCKCHAIN"
          | "CASH"
          | "CFX_NETWORK"
          | "DEPOSIT"
          | "ESCROW"
          | "FEDWIRE"
          | "FEDWIRE_DRAWDOWN"
          | "FEDNOW"
          | "RTP"
          | "INSTANT"
          | "SPEI"
          | "DEBIT_CARD"
          | "REWARD"
          | "SWAP"
          | "SWIFT"
          | "TRANSFER"
          | "VIRTUAL_CARD"
          | "WITHDRAWAL"
      )[]

    • Optionalstatuses?: ("PENDING" | "FAILED" | "PROCESSING" | "COMPLETED" | "RETURNED" | "CANCELLED")[]

    • Optionalsubtypes?:
          | (
              | "DEPOSIT"
              | "RETURN"
              | "FEE"
              | "ADJUSTMENT"
              | "POINTS"
              | "LEDGER_ACCOUNT"
              | "PLATFORM_SETTLEMENT"
              | undefined
          )[]
          | null

      Pass values to include only those subtypes; pass null to exclude transactions with a subtype

  Returns Promise<{ ok: true; value: { items: TransactionMethodAggregate[] } }>

count

• count(args: TransactionSearchArgs): Promise<{ ok: true; value: number }>

  How many rows the search's filters match, ignoring paging and order; see TransactionAdminQueryService.count. Busted with the customer's listings.

  Parameters

  • args: TransactionSearchArgs

  Returns Promise<{ ok: true; value: number }>

search

• search(
      args: TransactionSearchArgs,
  ): Promise<{ ok: true; value: { hasNext: boolean; items: Transaction[] } }>

  Parameters

  • args: TransactionSearchArgs

  Returns Promise<{ ok: true; value: { hasNext: boolean; items: Transaction[] } }>

searchEntityIds

• searchEntityIds(
      __namedParameters: {
          createdAt?: DbTimestampCriteria;
          customerId: string;
          entityType?: NonNullable<"IDENTITY" | "ORGANIZATION" | null>;
          limit?: number;
      },
  ): Promise<{ ok: true; value: { entityIds: string[] } }>

  Entity external ids the customer has transacted with, ordered by recency (most recently transacted first), optionally filtered by entityType. Uncached.

  Parameters

  • __namedParameters: {
        createdAt?: DbTimestampCriteria;
        customerId: string;
        entityType?: NonNullable<"IDENTITY" | "ORGANIZATION" | null>;
        limit?: number;
    }

  Returns Promise<{ ok: true; value: { entityIds: string[] } }>

searchPages

• searchPages(
      args: TransactionSearchFilters & {
          customerId: string;
          orderBy?: TransactionOrderBy[];
          pageSize?: number;
      },
  ): AsyncGenerator<Transaction[]>

  Every matching transaction, a page at a time, oldest page first.

  For callers that read the whole result set (CSV and XLSX exports, the DART reports, a statement period) rather than one page of it. Walks by keyset, so the cost per page does not grow with how deep the walk has gone the way search's OFFSET paging does. The cache is deliberately not in the path: a full walk would evict every useful entry for a result nobody reads twice.

  Pages rather than rows so a caller can resolve related data for a whole page in one query instead of once per row.

  Parameters

  • args: TransactionSearchFilters & {
        customerId: string;
        orderBy?: TransactionOrderBy[];
        pageSize?: number;
    }

  Returns AsyncGenerator<Transaction[]>

searchPaymentInstrumentIds

• searchPaymentInstrumentIds(
      __namedParameters: {
          createdAt?: DbTimestampCriteria;
          customerId: string;
          dataSources?: (
              | "deposit"
              | "manual_mint"
              | "withdrawal"
              | "swap"
              | "transfer"
              | "network_transfer"
              | "fee_transfer"
              | "redemption"
              | "card"
              | "escrow_transfer"
              | "reward"
              | "blockchain_deposit"
              | "blockchain_withdrawal"
              | "ledger_account_withdrawal"
          )[];
          limit?: number;
          methods?: (
              | "ACH_CREDIT"
              | "ACH_DEBIT"
              | "AF_BANK"
              | "AF_MOMO"
              | "BLOCKCHAIN"
              | "CASH"
              | "CFX_NETWORK"
              | "DEPOSIT"
              | "ESCROW"
              | "FEDWIRE"
              | "FEDWIRE_DRAWDOWN"
              | "FEDNOW"
              | "RTP"
              | "INSTANT"
              | "SPEI"
              | "DEBIT_CARD"
              | "REWARD"
              | "SWAP"
              | "SWIFT"
              | "TRANSFER"
              | "VIRTUAL_CARD"
              | "WITHDRAWAL"
          )[];
      },
  ): Promise<{ ok: true; value: { paymentInstrumentIds: string[] } }>

  Payment-instrument external ids the customer has transacted with, ranked by usage (most-used first). Skips the outer entity / ledger / solana enrichment — ranking only needs (payment_instrument_id, method, created_at). Uncached.

  Parameters

  • __namedParameters: {
        createdAt?: DbTimestampCriteria;
        customerId: string;
        dataSources?: (
            | "deposit"
            | "manual_mint"
            | "withdrawal"
            | "swap"
            | "transfer"
            | "network_transfer"
            | "fee_transfer"
            | "redemption"
            | "card"
            | "escrow_transfer"
            | "reward"
            | "blockchain_deposit"
            | "blockchain_withdrawal"
            | "ledger_account_withdrawal"
        )[];
        limit?: number;
        methods?: (
            | "ACH_CREDIT"
            | "ACH_DEBIT"
            | "AF_BANK"
            | "AF_MOMO"
            | "BLOCKCHAIN"
            | "CASH"
            | "CFX_NETWORK"
            | "DEPOSIT"
            | "ESCROW"
            | "FEDWIRE"
            | "FEDWIRE_DRAWDOWN"
            | "FEDNOW"
            | "RTP"
            | "INSTANT"
            | "SPEI"
            | "DEBIT_CARD"
            | "REWARD"
            | "SWAP"
            | "SWIFT"
            | "TRANSFER"
            | "VIRTUAL_CARD"
            | "WITHDRAWAL"
        )[];
    }

    • OptionalcreatedAt?: DbTimestampCriteria

    • customerId: string

    • OptionaldataSources?: (
          | "deposit"
          | "manual_mint"
          | "withdrawal"
          | "swap"
          | "transfer"
          | "network_transfer"
          | "fee_transfer"
          | "redemption"
          | "card"
          | "escrow_transfer"
          | "reward"
          | "blockchain_deposit"
          | "blockchain_withdrawal"
          | "ledger_account_withdrawal"
      )[]

      Filter by the producing arm; prunes the UNION exactly.

    • Optionallimit?: number

    • Optionalmethods?: (
          | "ACH_CREDIT"
          | "ACH_DEBIT"
          | "AF_BANK"
          | "AF_MOMO"
          | "BLOCKCHAIN"
          | "CASH"
          | "CFX_NETWORK"
          | "DEPOSIT"
          | "ESCROW"
          | "FEDWIRE"
          | "FEDWIRE_DRAWDOWN"
          | "FEDNOW"
          | "RTP"
          | "INSTANT"
          | "SPEI"
          | "DEBIT_CARD"
          | "REWARD"
          | "SWAP"
          | "SWIFT"
          | "TRANSFER"
          | "VIRTUAL_CARD"
          | "WITHDRAWAL"
      )[]

  Returns Promise<{ ok: true; value: { paymentInstrumentIds: string[] } }>