feat: DPSN provider

config/config.go

@@ -69,6 +69,13 @@ type (
 		Quote       string                `mapstructure:"quote" validate:"required"`
 		PairAddress []PairAddressProvider `mapstructure:"pair_address_providers" validate:"dive"`
 		Providers   []types.ProviderName  `mapstructure:"providers" validate:"required,gt=0,dive,required"`
+		DPSNTopics  *DPSNTopics           `mapstructure:"dpsn_topics"`
+	}
+
+	// DPSNTopics defines DPSN-specific configuration for a currency pair.
+	DPSNTopics struct {
+		TopicID string `mapstructure:"topic_id" validate:"required"`
+		AssetID string `mapstructure:"asset_id" validate:"required"`
 	}
 
 	PairAddressProvider struct {
@@ -240,18 +247,34 @@ func (c Config) ProviderPairs() map[types.ProviderName][]types.CurrencyPair {
 			if len(pair.PairAddress) > 0 {
 				for _, uniPair := range pair.PairAddress {
 					if (uniPair.Provider == provider) && (uniPair.Address != "") {
-						providerPairs[uniPair.Provider] = append(providerPairs[uniPair.Provider], types.CurrencyPair{
+						currencyPair := types.CurrencyPair{
 							Base:    pair.Base,
 							Quote:   pair.Quote,
 							Address: uniPair.Address,
-						})
+						}
+						// Add DPSN topics if this is a DPSN provider and topics are configured
+						if provider == types.ProviderName("dpsn") && pair.DPSNTopics != nil {
+							currencyPair.DPSNTopics = &types.DPSNTopics{
+								TopicID: pair.DPSNTopics.TopicID,
+								AssetID: pair.DPSNTopics.AssetID,
+							}
+						}
+						providerPairs[uniPair.Provider] = append(providerPairs[uniPair.Provider], currencyPair)
 					}
 				}
 			} else {
-				providerPairs[provider] = append(providerPairs[provider], types.CurrencyPair{
+				currencyPair := types.CurrencyPair{
 					Base:  pair.Base,
 					Quote: pair.Quote,
-				})
+				}
+				// Add DPSN topics if this is a DPSN provider and topics are configured
+				if provider == types.ProviderName("dpsn") && pair.DPSNTopics != nil {
+					currencyPair.DPSNTopics = &types.DPSNTopics{
+						TopicID: pair.DPSNTopics.TopicID,
+						AssetID: pair.DPSNTopics.AssetID,
+					}
+				}
+				providerPairs[provider] = append(providerPairs[provider], currencyPair)
 			}
 		}
 	}

config/supported_assets.go

@@ -30,6 +30,7 @@ var (
 		provider.ProviderEthCurve:    false,
 		provider.ProviderKujira:      false,
 		provider.ProviderAstroport:   false,
+		provider.ProviderDPSN:        true,
 		provider.ProviderMock:        false,
 	}
 

ojo-provider-config/currency-pairs.toml

@@ -237,3 +237,13 @@ providers = [
   "astroport",
 ]
 quote = "INJ"
+
+[[currency_pairs]]
+base = "WHITE"
+providers = [
+  "dpsn",
+]
+quote = "USDC"
+[dpsn_topics]
+topic_id = "0xcaa7f02362c7a2f1d5d7a1b40c46b4c92acf20eb84231adda6a1a6903adbf7cb"
+asset_id = "0x6Ec94F50cAdcc79984463688dE42A0Ca696EC2db"

ojo-provider-config/endpoints.toml

@@ -1,6 +1,6 @@
 [[provider_endpoints]]
-name = "binance"
-rest = "https://api1.binance.com"
+name = "dpsn"
+rest = "https://data.streams.dpsn.org"
 websocket = "stream.binance.com:9443"
 
 ## If you observe the following error: "ERR failed to initialize binance provider" then most likely

oracle/oracle.go

@@ -487,6 +487,9 @@ func NewProvider(
 
 	case provider.ProviderAstroport:
 		return provider.NewAstroportProvider(ctx, logger, endpoint, providerPairs...)
+
+	case provider.ProviderDPSN:
+		return provider.NewDPSNProvider(ctx, logger, endpoint, providerPairs...)
 	}
 
 	return nil, fmt.Errorf("provider %s not found", providerName)