fix scanning. (#230)

FindoraNetwork · Feb 27, 2024 · a15dccd · a15dccd
1 parent fc8affc
commit a15dccd
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 7 deletions.
diff --git a/prismer/src/commands.rs b/prismer/src/commands.rs
@@ -147,7 +147,7 @@ impl Subscribe {
 
         let itv = env::var("INTERVAL")
             .ok()
-            .unwrap_or(String::from("12"))
+            .unwrap_or(String::from("15"))
             .parse::<u64>()?;
         let interval = Duration::from_secs(itv);
         info!("interval={:?}", interval);
@@ -162,7 +162,7 @@ impl Subscribe {
         } else if let Ok(h) = db::load_last_height(&pool).await {
             h + 1
         } else {
-            let prism_start = std::env::var("PRISM_START").unwrap_or(String::from("1"));
+            let prism_start = env::var("PRISM_START").unwrap_or("4004430".to_string());
             prism_start.parse::<i64>().unwrap()
         };
 
@@ -192,7 +192,9 @@ impl Subscribe {
                 Ok(_) => {
                     info!("Block at {} loaded.", cursor);
                 }
-                Err(Error::NotFound) => (),
+                Err(Error::NotFound) => {
+                    error!("Block {} not found.", cursor);
+                }
                 Err(e) => return Err(e),
             };
             tokio::time::sleep(interval).await;

diff --git a/prismer/src/rpc.rs b/prismer/src/rpc.rs
@@ -86,8 +86,13 @@ impl TendermintRPC {
         let resp = self.client.get(url).send().await?;
         let status = resp.status();
         if !status.is_success() {
-            return Err(resp.text().await?.into());
+            let resp_text = resp.text().await?;
+            if resp_text.contains("less than or equal to") {
+                return Err(Error::NotFound);
+            }
+            return Err(resp_text.into());
         }
+
         let bytes = resp.bytes().await?;
         if let Ok(r) = serde_json::from_slice::<'_, JsonRpcResponse<T>>(&bytes) {
             Ok(r.result)

diff --git a/scanner/src/commands.rs b/scanner/src/commands.rs
@@ -166,7 +166,7 @@ impl Subscribe {
 
         let itv = env::var("INTERVAL")
             .ok()
-            .unwrap_or(String::from("12"))
+            .unwrap_or(String::from("15"))
             .parse::<u64>()?;
         let interval = Duration::from_secs(itv);
         info!("interval={:?}", interval);
@@ -210,7 +210,9 @@ impl Subscribe {
                 Ok(_) => {
                     info!("Block at {} loaded.", cursor);
                 }
-                Err(Error::NotFound) => (),
+                Err(Error::NotFound) => {
+                    error!("Block {} not found.", cursor);
+                }
                 Err(e) => return Err(e),
             };
             tokio::time::sleep(interval).await;

diff --git a/scanner/src/rpc.rs b/scanner/src/rpc.rs
@@ -132,8 +132,13 @@ impl TendermintRPC {
         let resp = self.client.get(url).send().await?;
         let status = resp.status();
         if !status.is_success() {
-            return Err(resp.text().await?.into());
+            let resp_text = resp.text().await?;
+            if resp_text.contains("less than or equal to") {
+                return Err(Error::NotFound);
+            }
+            return Err(resp_text.into());
         }
+
         let bytes = resp.bytes().await?;
         if let Ok(r) = serde_json::from_slice::<'_, JsonRpcResponse<T>>(&bytes) {
             Ok(r.result)