Method prepareDestinationLineageBalances

lineage.go:478–493

prepareDestinationLineageBalances pre-creates destination shadow and aggregate balances for all providers. This is called BEFORE acquiring locks to avoid nested lock acquisition deadlocks. Parameters: - ctx context.Context: The context for the operation. - mappings []model.LineageMapping: The sourc

(ctx context.Context, mappings []model.LineageMapping, destinationBalance *model.Balance)

// - map[string]*destinationLineageInfo: Map of provider to destination lineage balances.
// - error: An error if any balance could not be created.
func (l *LedgerForge) prepareDestinationLineageBalances(ctx context.Context, mappings []model.LineageMapping, destinationBalance *model.Balance) (map[string]*destinationLineageInfo, error) {
	result := make(map[string]*destinationLineageInfo, len(mappings))

	for _, mapping := range mappings {
		shadowBalance, aggBalance, err := l.getOrCreateDestinationLineageBalances(ctx, mapping.Provider, destinationBalance)
		if err != nil {
			return nil, fmt.Errorf("failed to prepare destination lineage for provider %s: %w", mapping.Provider, err)
		}
		result[mapping.Provider] = &destinationLineageInfo{
			shadowBalance:    shadowBalance,
			aggregateBalance: aggBalance,
		}
	}

	return result, nil
}

// acquireLineageLocks acquires distributed locks for multiple shadow balances using MultiLocker.
// MultiLocker handles sorting (prevents deadlock) and deduplication automatically.