Fix

Author: eabz

bin/snoop.rs

@@ -69,13 +69,17 @@ async fn sync_chain(rpc: &Rpc, db: &Database, config: &Config) {
         let first_block = block_chunk[0];
         let last_block = block_chunk[block_chunk.len() - 1];
 
-        let pair_logs = rpc
+        let pair_logs = match rpc
             .get_factory_logs_batch(
                 first_block as u64,
                 last_block as u64,
                 config,
             )
-            .await;
+            .await
+        {
+            Some(logs) => logs,
+            None => return,
+        };
 
         handle_pairs(pair_logs, db, rpc).await;
 

src/rpc/mod.rs

@@ -61,17 +61,17 @@ impl Rpc {
         first_block: u64,
         last_block: u64,
         config: &Config,
-    ) -> Vec<Log> {
+    ) -> Option<Vec<Log>> {
         let filter = Filter::new()
             .from_block(BlockNumberOrTag::Number(first_block))
             .to_block(BlockNumberOrTag::Number(last_block))
             .address(config.factory.address)
             .event(PairCreated::SIGNATURE);
 
-        self.client
-            .get_logs(&filter)
-            .await
-            .expect("unable to get logs from RPC")
+        match self.client.get_logs(&filter).await {
+            Ok(logs) => logs,
+            Err(_) => None,
+        }
     }
 
     pub async fn get_pairs_logs_batch(