Method GetLineageMappingByProvider

database/lineage.go:95–120

GetLineageMappingByProvider retrieves a specific lineage mapping for a balance and provider.

(ctx context.Context, balanceID, provider string)

// GetLineageMappingByProvider retrieves a specific lineage mapping for a balance and provider.
func (d Datasource) GetLineageMappingByProvider(ctx context.Context, balanceID, provider string) (*model.LineageMapping, error) {
	row := d.Conn.QueryRowContext(ctx, `
		SELECT id, balance_id, provider, shadow_balance_id, aggregate_balance_id, identity_id, created_at
		FROM ledgerforge.lineage_mappings
		WHERE balance_id = $1 AND provider = $2
	`, balanceID, provider)

	var mapping model.LineageMapping
	err := row.Scan(
		&mapping.ID,
		&mapping.BalanceID,
		&mapping.Provider,
		&mapping.ShadowBalanceID,
		&mapping.AggregateBalanceID,
		&mapping.IdentityID,
		&mapping.CreatedAt,
	)
	if err != nil {
		if err == sql.ErrNoRows {
			return nil, nil
		}
		return nil, apierror.NewAPIError(apierror.ErrInternalServer, "Failed to retrieve lineage mapping", err)
	}

	return &mapping, nil
}

// DeleteLineageMapping deletes a lineage mapping by its ID.
func (d Datasource) DeleteLineageMapping(ctx context.Context, id int64) error {