Method processBalances

transaction.go:1243–1255

processBalances processes the source and destination balances by applying the transaction in-memory. It starts a tracing span, applies the transaction to the balances, and records relevant events and errors. Note: The actual database update of balances is done atomically with the transaction persist

(ctx context.Context, transaction *model.Transaction, sourceBalance, destinationBalance *model.Balance)

// Returns:
// - error: An error if the transaction could not be applied to the balances.
func (l *LedgerForge) processBalances(ctx context.Context, transaction *model.Transaction, sourceBalance, destinationBalance *model.Balance) error {
	ctx, span := tracer.Start(ctx, "ProcessBalances")
	defer span.End()

	// Apply the transaction to the source and destination balances (in-memory only)
	if err := l.applyTransactionToBalances(ctx, []*model.Balance{sourceBalance, destinationBalance}, transaction); err != nil {
		span.RecordError(err)
		return l.logAndRecordError(span, "failed to apply transaction to balances", err)
	}

	span.AddEvent("Balances calculated")
	return nil
}

// buildTransactionExecutionWork converts an in-memory-applied transaction into the shared
// persistence and post-commit work shape used by both single and batched execution paths.