Method processDestinationLineage

lineage.go:636–670

processDestinationLineage processes lineage tracking for the destination balance when it also tracks fund lineage. Uses pre-created destination balances to avoid nested lock acquisition (locks are already held by caller). Parameters: - ctx context.Context: The context for the operation. - txn *mode

(ctx context.Context, txn *model.Transaction, alloc Allocation, mapping *model.LineageMapping, sourceBalance, destinationBalance *model.Balance, destLineageBalances map[string]*destinationLineageInfo, index int)

// Returns:
// - error: An error if destination lineage processing fails.
func (l *LedgerForge) processDestinationLineage(ctx context.Context, txn *model.Transaction, alloc Allocation, mapping *model.LineageMapping, sourceBalance, destinationBalance *model.Balance, destLineageBalances map[string]*destinationLineageInfo, index int) error {
	if destinationBalance == nil || !destinationBalance.TrackFundLineage || destinationBalance.IdentityID == "" {
		return nil
	}

	// Use pre-created destination balances (locks already held by caller)
	if destLineageBalances == nil {
		return nil
	}

	destInfo, ok := destLineageBalances[mapping.Provider]
	if !ok || destInfo == nil {
		return nil
	}

	destShadowBalance := destInfo.shadowBalance
	destAggBalance := destInfo.aggregateBalance

	if err := l.queueReceiveTransaction(ctx, txn, alloc, mapping, sourceBalance, destinationBalance, destShadowBalance, destAggBalance, index); err != nil {
		return fmt.Errorf("failed to queue receive transaction: %w", err)
	}

	destMapping := model.LineageMapping{
		BalanceID:          destinationBalance.BalanceID,
		Provider:           mapping.Provider,
		ShadowBalanceID:    destShadowBalance.BalanceID,
		AggregateBalanceID: destAggBalance.BalanceID,
		IdentityID:         destinationBalance.IdentityID,
	}
	if err := l.datasource.UpsertLineageMapping(ctx, destMapping); err != nil {
		return fmt.Errorf("failed to upsert destination lineage mapping: %w", err)
	}

	return nil
}

// getOrCreateDestinationLineageBalances retrieves or creates shadow and aggregate balances for the destination.
//