Method upsertCreditLineageMapping

lineage.go:324–338

upsertCreditLineageMapping creates or updates the lineage mapping for a credit transaction. Parameters: - ctx context.Context: The context for the operation. - destBalance *model.Balance: The destination balance. - provider string: The fund provider identifier. - shadowBalance *model.Balance: The s

(ctx context.Context, destBalance *model.Balance, provider string, shadowBalance, aggregateBalance *model.Balance, identityID string)

// Returns:
// - error: An error if the mapping could not be created.
func (l *LedgerForge) upsertCreditLineageMapping(ctx context.Context, destBalance *model.Balance, provider string, shadowBalance, aggregateBalance *model.Balance, identityID string) error {
	mapping := model.LineageMapping{
		BalanceID:          destBalance.BalanceID,
		Provider:           provider,
		ShadowBalanceID:    shadowBalance.BalanceID,
		AggregateBalanceID: aggregateBalance.BalanceID,
		IdentityID:         identityID,
	}

	if err := l.datasource.UpsertLineageMapping(ctx, mapping); err != nil {
		return fmt.Errorf("failed to upsert lineage mapping: %w", err)
	}

	return nil
}

// queueShadowCreditTransaction queues a shadow transaction to track credited funds from a provider.
//