Merge pull request #253 from anoma/add-latest-processed-height

crawler: add latest processed block height

Author: Fraccaman

swagger.yml

@@ -815,6 +815,8 @@ paths:
                         ]
                     timestamp:
                       type: number
+                    last_processed_block_height: 
+                      type: number
   /api/v1/chain/history:
     get:
       summary: Get a paginated list of transaction for a list of addresses

webserver/src/handler/crawler_state.rs

@@ -41,6 +41,7 @@ pub async fn get_crawlers_timestamps(
                     || CrawlersTimestamps {
                         name: variant.to_string(),
                         timestamp: 0,
+                        last_processed_block_height: 1,
                     },
                     |ct| ct.clone(),
                 )

webserver/src/response/crawler_state.rs

@@ -5,4 +5,5 @@ use serde::{Deserialize, Serialize};
 pub struct CrawlersTimestamps {
     pub name: String,
     pub timestamp: i64,
+    pub last_processed_block_height: i32,
 }

webserver/src/service/crawler_state.rs

@@ -49,6 +49,9 @@ impl CrawlerStateService {
                 .map(|crawler| CrawlersTimestamps {
                     name: crawler.name.to_string(),
                     timestamp: crawler.timestamp.and_utc().timestamp(),
+                    last_processed_block_height: crawler
+                        .last_processed_block
+                        .unwrap_or(1),
                 })
                 .collect::<Vec<CrawlersTimestamps>>()
         })