Method prepareQueuedBatchTransaction

transaction.go:1061–1089

prepareQueuedBatchTransaction performs the per-transaction work inside a coalesced batch: hooks, reference validation, in-memory balance application, and persistence shaping.

(ctx context.Context, span trace.Span, txn *model.Transaction, balancesByID map[string]*model.Balance, preHooks []*ledgerforgehooks.Hook, prefetchedReferences, existingReferences, batchReferences map[string]struct{})

// prepareQueuedBatchTransaction performs the per-transaction work inside a coalesced batch:
// hooks, reference validation, in-memory balance application, and persistence shaping.
func (l *LedgerForge) prepareQueuedBatchTransaction(ctx context.Context, span trace.Span, txn *model.Transaction, balancesByID map[string]*model.Balance, preHooks []*ledgerforgehooks.Hook, prefetchedReferences, existingReferences, batchReferences map[string]struct{}) (queuedBatchPostCommitWork, error) {
	sourceBalance, destinationBalance, err := coalescingBalancesForTransaction(balancesByID, txn)
	if err != nil {
		return queuedBatchPostCommitWork{}, err
	}

	if l.Hooks != nil {
		if err := l.Hooks.ExecuteHooks(ctx, preHooks, ledgerforgehooks.PreTransaction, txn.TransactionID, txn); err != nil {
			span.RecordError(err)
			return queuedBatchPostCommitWork{}, fmt.Errorf("batch pre-transaction hook failed: %w", err)
		}
	}

	if err := l.validateQueuedBatchTransactionReference(ctx, txn, prefetchedReferences, existingReferences, batchReferences); err != nil {
		return queuedBatchPostCommitWork{}, fmt.Errorf("batch transaction validation failed: %w", err)
	}

	finalizedTxn := l.updateTransactionDetails(ctx, txn, sourceBalance, destinationBalance)
	if err := l.processBalances(ctx, finalizedTxn, sourceBalance, destinationBalance); err != nil {
		return queuedBatchPostCommitWork{}, err
	}

	work, skipPersist := l.buildTransactionExecutionWork(ctx, finalizedTxn, sourceBalance, destinationBalance)
	if skipPersist {
		return queuedBatchPostCommitWork{}, fmt.Errorf("batch coalescing does not support zero-amount transactions")
	}

	return work, nil
}

// runQueuedBatchPostCommitWork dispatches the post-commit work for a coalesced batch after
// the balance-set lock has been released.