Method processAllocations

lineage.go:561–582

processAllocations processes fund allocations by queuing release and receive transactions. Parameters: - ctx context.Context: The context for the operation. - txn *model.Transaction: The original transaction. - allocations []Allocation: The calculated allocations. - mappings []model.LineageMapping:

(ctx context.Context, txn *model.Transaction, allocations []Allocation, mappings []model.LineageMapping, sourceBalance, destinationBalance, sourceAggBalance *model.Balance, destLineageBalances map[string]*destinationLineageInfo)

// - sourceAggBalance *model.Balance: The source aggregate balance.
// - destLineageBalances map[string]*destinationLineageInfo: Pre-created destination lineage balances (may be nil).
func (l *LedgerForge) processAllocations(ctx context.Context, txn *model.Transaction, allocations []Allocation, mappings []model.LineageMapping, sourceBalance, destinationBalance, sourceAggBalance *model.Balance, destLineageBalances map[string]*destinationLineageInfo) {
	for i, alloc := range allocations {
		if alloc.Amount.Cmp(big.NewInt(0)) == 0 {
			continue
		}

		mapping := l.findMappingByShadowID(mappings, alloc.BalanceID)
		if mapping == nil {
			continue
		}

		if err := l.queueReleaseTransaction(ctx, txn, alloc, mapping, sourceBalance, sourceAggBalance, i); err != nil {
			logrus.Errorf("failed to queue release transaction: %v", err)
			continue
		}

		if err := l.processDestinationLineage(ctx, txn, alloc, mapping, sourceBalance, destinationBalance, destLineageBalances, i); err != nil {
			logrus.Errorf("failed to process destination lineage: %v", err)
			// Continue processing other allocations even if one fails
		}
	}
}

// queueReleaseTransaction queues a transaction to release funds from the aggregate balance back to a shadow balance.
//