chore(api): move raydium api url to consts.rs

metaplex-foundation · Jan 28, 2025 · ed93329 · ed93329
1 parent 39c0457
commit ed93329
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 7 deletions.
diff --git a/nft_ingester/src/api/service.rs b/nft_ingester/src/api/service.rs
@@ -112,7 +112,7 @@ pub async fn start_api(
 
     let addr = SocketAddr::from(([0, 0, 0, 0], port));
     let token_price_fetcher = Arc::new(RaydiumTokenPriceFetcher::new(
-        "https://api-v3.raydium.io".to_string(),
+        crate::consts::RAYDIUM_API_HOST.to_string(),
         crate::raydium_price_fetcher::CACHE_TTL,
         red_metrics,
     ));

diff --git a/nft_ingester/src/lib.rs b/nft_ingester/src/lib.rs
@@ -5,6 +5,7 @@ pub mod batch_mint;
 pub mod buffer;
 pub mod cleaners;
 pub mod config;
+pub mod consts;
 pub mod error;
 pub mod flatbuffer_mapper;
 pub mod gapfiller;

diff --git a/nft_ingester/src/raydium_price_fetcher.rs b/nft_ingester/src/raydium_price_fetcher.rs
@@ -18,7 +18,7 @@ pub struct RaydiumTokenPriceFetcher {
 
 impl Default for RaydiumTokenPriceFetcher {
     fn default() -> Self {
-        Self::new("https://api-v3.raydium.io".to_string(), CACHE_TTL, None)
+        Self::new(crate::consts::RAYDIUM_API_HOST.to_string(), CACHE_TTL, None)
     }
 }
 
@@ -138,11 +138,9 @@ impl TokenPriceFetcher for RaydiumTokenPriceFetcher {
                     ))
                 })?;
 
-            for maybe_token_data in tokens_data {
-                if let Some(MintIdsItem { address, symbol }) = maybe_token_data {
-                    self.symbol_cache.insert(address.clone(), symbol.clone()).await;
-                    result.insert(address, symbol);
-                }
+            for MintIdsItem { address, symbol } in tokens_data.into_iter().flatten() {
+                self.symbol_cache.insert(address.clone(), symbol.clone()).await;
+                result.insert(address, symbol);
             }
         }