use AccountFetcherDelegate

blockworks-foundation · Oct 19, 2023 · ca3b6ca · ca3b6ca
1 parent a250788
commit ca3b6ca
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/bin/service-mango-pnl/src/main.rs b/bin/service-mango-pnl/src/main.rs
@@ -162,6 +162,8 @@ use jsonrpsee::http_server::HttpServerHandle;
 use mango_feeds_connector::{
     grpc_plugin_source, metrics, EntityFilter, FilterConfig, MetricsConfig, SourceConfig,
 };
+use mango_feeds_connector::feeds_chain_data_fetcher::FeedsAccountFetcher;
+use mango_v4_client::chain_data_fetcher::AccountFetcherDelegate;
 
 fn start_jsonrpc_server(
     config: JsonRpcConfig,
@@ -272,8 +274,8 @@ async fn main() -> anyhow::Result<()> {
         .await?,
     );
     let chain_data = Arc::new(RwLock::new(chain_data::ChainData::new()));
-    let account_fetcher = Arc::new(chain_data_fetcher::AccountFetcherDelegate {
-        chain_data: chain_data.clone(),
+    let account_fetcher = Arc::new(AccountFetcherDelegate {
+        base_fetcher: FeedsAccountFetcher { chain_data: chain_data.clone() },
         rpc: client.rpc_async(),
     });
 

diff --git a/bin/settler/src/main.rs b/bin/settler/src/main.rs
@@ -15,6 +15,8 @@ use itertools::Itertools;
 use solana_sdk::commitment_config::CommitmentConfig;
 use solana_sdk::pubkey::Pubkey;
 use std::collections::HashSet;
+use mango_v4_client::chain_data::FeedsAccountFetcher;
+use mango_v4_client::chain_data_fetcher::AccountFetcherDelegate;
 
 pub mod metrics;
 pub mod settle;
@@ -110,8 +112,10 @@ async fn main() -> anyhow::Result<()> {
     // The representation of current on-chain account data
     let chain_data = Arc::new(RwLock::new(chain_data::ChainData::new()));
     // Reading accounts from chain_data
-    let account_fetcher = Arc::new(chain_data_fetcher::AccountFetcherDelegate {
-        chain_data: chain_data.clone(),
+    let account_fetcher = Arc::new(AccountFetcherDelegate {
+        base_fetcher: FeedsAccountFetcher {
+            chain_data: chain_data.clone()
+        },
         rpc: client.rpc_async(),
     });