Fail asks it whether Victor holds a deposit sweep's book transfer.
Protected ReadonlydbStaticinstanceThe process service, starting transfers on the queue the temporal namespace names.
Writes the memo and adds one to executorClaims while the transfer is
PENDING, answering this attempt's count. One statement, so a claim that
waits on a FAILED write's row lock claims nothing.
OptionaldepositId?: stringOptionalsource?: { accountNumber: string; routingNumber: string }The Victor book-transfer instruction; omit when pairing existing bank rows.
Optionaltarget?: { accountNumber: string; routingNumber: string }Optionaltx?: PgAsyncTransaction<NodePgQueryResultHKT, EmptyRelations>Inside a caller's transaction the caller publishes created after commit.
OptionalwithdrawalId?: stringMarks failed a portal transfer never sent, a FIB transfer whose batch has
no file, or a deposit's Victor sweep Victor has no transfer for, once its
workflow closed SWEEP_SETTLE_TIME ago or, with no run, it is orphaned
(orphanedDepositSweepSql). Each refusal
is decided under the FAILED write's locks, so a transfer whose money may
have left is never failed. A retry by the operator who failed it returns
the transfer and announces FAILED again.
Creates an operator's transfer as PENDING and starts its workflow under the
transfer id. A retry of the same request returns the same transfer with
created: false and starts the workflow again, which Temporal refuses if
it runs.
Records a payout's RouteFusion ticket once on a PENDING transfer and answers
with the ticket that holds the record, transferId or an earlier attempt's.
One statement, so two attempts cannot each record their own, and it waits
on a FAILED write's row lock, so a fail and a record cannot both apply.
The kind and fund class at each end, the executor, and the source's implied balance (null when unmeasured).
Optionalamount?: BigNumberTransfers whose data.amount equals this, compared as numbers.
OptionalcreatedAt?: DbTimestampCriteriaOptionaldepositId?: stringOptionalexecutors?: Executor[]Transfers whose recorded executor is one of these. An empty list matches none.
OptionalhasExecutor?: trueTransfers the operator workflow started; the leg guard leaves the rest alone.
OptionalidempotencyKeys?: string[]Transfers an operator initiated under these idempotency keys.
Optionalids?: string[]OptionalidsIgnoringCase?: string[]Like ids, ignoring case: a rail can upper-case the id it carries in free text.
OptionallegAccount?: Pick<BankTransaction, "type" | "routingNumber" | "accountNumber">Transfers whose end on the side type names (source for a DEBIT, target
for a CREDIT) is this account, as attachLeg checks a leg's account.
OptionallegIds?: string[]Transfers with any leg among these bank transactions.
Optionalnow?: DateThe clock deadline and the stale filter are read at. Defaults to now.
OptionalorderBy?: DbOrderByCriterion<Must name the same table as the dbOrderBy call below.
Optionalpage?: numberDefaults to 1
OptionalpageSize?: numberDefaults to 10
OptionalsourceAccountNumber?: stringTransfers whose recorded source account has this number, matched on the
number alone like bankTransactionSourceAccountTypeSql.
Optionalstale?: trueTransfers whose deadline has passed.
Optionalstatus?: "PENDING" | "COMPLETED" | "FAILED"Optionaltx?: PgAsyncTransaction<NodePgQueryResultHKT, EmptyRelations>OptionalupdatedAt?: DbTimestampCriteriaOptionalwithdrawalId?: stringOptionalwithoutLeg?: "CREDIT" | "DEBIT"Transfers holding no leg on this side yet.
How many transfers the stale filter returns, and the earliest of their deadlines.
Grouped by executor, orphaned sweeps being the group with none. Within a group the
deadline moves only with the clock, so its earliest clock gives its earliest deadline.
On the writer: initiate decides on the register rows it reads.