Method validateLineageProvider

lineage.go:201–224

validateLineageProvider checks if the specified provider exists on the source balance. If the source tracks fund lineage but doesn't have the specified provider, returns empty string (provider should be ignored). If the source doesn't track lineage (e.g., @world), any provider is valid. Parameters:

(ctx context.Context, provider string, sourceBalance *model.Balance)

// - string: The validated provider name (empty if invalid/should be ignored).
// - error: An error if validation fails (database errors only, not for invalid providers).
func (l *LedgerForge) validateLineageProvider(ctx context.Context, provider string, sourceBalance *model.Balance) (string, error) {
	if provider == "" {
		return "", nil
	}

	// Source is nil or doesn't track lineage - provider is valid
	if sourceBalance == nil || !sourceBalance.TrackFundLineage {
		return provider, nil
	}

	// Source tracks lineage - verify provider exists
	mapping, err := l.datasource.GetLineageMappingByProvider(ctx, sourceBalance.BalanceID, provider)
	if err != nil {
		return "", fmt.Errorf("failed to validate provider on source: %w", err)
	}

	if mapping == nil {
		logrus.Warnf("lineage provider validation: provider %q does not exist on source balance %s - ignoring provider",
			provider, sourceBalance.BalanceID)
		return "", nil
	}

	return provider, nil
}

// processLineageCredit processes a credit transaction for fund lineage tracking.
// It creates shadow balances and queues a shadow transaction to track the provider's funds.