Method persistQueuedTransactionBatch

transaction.go:949–977

persistQueuedTransactionBatch acquires the balance-set lock, prepares the batch in memory, commits the final state atomically, and dispatches post-commit side effects.

(ctx context.Context, transactions []*model.Transaction)

// persistQueuedTransactionBatch acquires the balance-set lock, prepares the batch in memory,
// commits the final state atomically, and dispatches post-commit side effects.
func (l *LedgerForge) persistQueuedTransactionBatch(ctx context.Context, transactions []*model.Transaction) error {
	ctx, span := tracer.Start(ctx, "RecordQueuedTransactionBatch")
	defer span.End()

	if err := validateQueuedBatchCurrencies(transactions); err != nil {
		return err
	}

	if len(transactions) == 0 {
		return nil
	}

	currency := transactions[0].Currency

	balanceIDs := collectQueuedCoalescingBalanceIDs(transactions)
	locker, err := l.acquireBalanceSetLock(ctx, balanceIDs)
	if err != nil {
		hotpairs.RecordContention(ctx, l.hotPairs, transactions[0].Source, transactions[0].Destination, currency, err)
		return fmt.Errorf("failed to acquire batch lock: %w", err)
	}

	result, err := l.persistQueuedTransactionBatchLocked(ctx, span, locker, balanceIDs, transactions)
	if err != nil {
		return err
	}

	l.runQueuedBatchPostCommitWork(ctx, span, result)
	return nil
}

// validateQueuedBatchCurrencies ensures that every transaction in a coalesced batch uses the
// same currency before any lock or balance work begins.