Class BankInternalTransferReconciliationService

constructor

• new BankInternalTransferReconciliationService(
      args: {
          bankInternalTransferService: BankInternalTransferService;
          bankTransactionService: BankTransactionService;
          db: B2bDatabase;
          internalEventPublisher: InternalEventPublisher;
      },
  ): BankInternalTransferReconciliationService

  Parameters

  • args: {
        bankInternalTransferService: BankInternalTransferService;
        bankTransactionService: BankTransactionService;
        db: B2bDatabase;
        internalEventPublisher: InternalEventPublisher;
    }

  Returns BankInternalTransferReconciliationService

Staticinstance

attachLeg

• attachLeg(
      args: { bankTransactionId: string; id: string },
  ): Promise<
      | {
          ok: true;
          value: { completed: boolean; transfer: BankInternalTransfer };
      }
      | { error: BankInternalTransferLegError
      | AttachLegError; ok: false },
  >

  Record one bank transaction as a leg of a PENDING transfer, on the side its type names, and complete the transfer once both sides total its amount. Attaching a row this transfer already holds is a no-op.

  Parameters

  • args: { bankTransactionId: string; id: string }

  Returns Promise<
      | {
          ok: true;
          value: { completed: boolean; transfer: BankInternalTransfer };
      }
      | { error: BankInternalTransferLegError
      | AttachLegError; ok: false },
  >

createCompletedBankInternalTransfer

• createCompletedBankInternalTransfer(
      args: {
          creditBankTransactionIds: string[];
          debitBankTransactionIds: string[];
          victorTransactionId?: string;
      },
  ): Promise<
      | { ok: true; value: BankInternalTransfer }
      | { error: BankInternalTransferLegError; ok: false },
  >

  Record a COMPLETED internal transfer for bank rows that already posted.

  Parameters

  • args: {
        creditBankTransactionIds: string[];
        debitBankTransactionIds: string[];
        victorTransactionId?: string;
    }

  Returns Promise<
      | { ok: true; value: BankInternalTransfer }
      | { error: BankInternalTransferLegError; ok: false },
  >

failBankInternalTransfer

• failBankInternalTransfer(
      args: { id: string },
  ): Promise<{ ok: true; value: BankInternalTransfer }>

  Fail a PENDING internal transfer.

  Parameters

  • args: { id: string }

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

getLegHolder

• getLegHolder(args: { bankTransactionId: string }): Promise<string | null>

  The transfer that holds this bank transaction as a leg, read under the bank transaction's row lock, so an attach in flight is waited out rather than missed.

  Parameters

  • args: { bankTransactionId: string }

  Returns Promise<string | null>

processBankInternalTransfer

• processBankInternalTransfer(
      args: {
          creditBankTransactionIds: string[];
          debitBankTransactionIds: string[];
          id: string;
          victorTransactionId?: string;
      },
  ): Promise<
      | { ok: true; value: BankInternalTransfer }
      | { error: BankInternalTransferLegError; ok: false },
  >

  Reconcile a PENDING internal transfer to COMPLETED against its legs.

  Parameters

  • args: {
        creditBankTransactionIds: string[];
        debitBankTransactionIds: string[];
        id: string;
        victorTransactionId?: string;
    }

  Returns Promise<
      | { ok: true; value: BankInternalTransfer }
      | { error: BankInternalTransferLegError; ok: false },
  >