From 09955ee8ea28d632519f3c6563bf7fdf916ddfee Mon Sep 17 00:00:00 2001
From: Gianmarco Fraccaroli <gianmarco.fraccaroli@gmail.com>
Date: Wed, 27 Nov 2024 13:14:20 +0100
Subject: [PATCH] return latest processed block

---
 swagger.yml                             | 2 ++
 webserver/src/handler/crawler_state.rs  | 1 +
 webserver/src/response/crawler_state.rs | 1 +
 webserver/src/service/crawler_state.rs  | 2 ++
 4 files changed, 6 insertions(+)

diff --git a/swagger.yml b/swagger.yml
index 801721f8..3a0f01bf 100644
--- a/swagger.yml
+++ b/swagger.yml
@@ -635,6 +635,8 @@ paths:
                       enum: [chain, governance, parameters, pos, rewards, transactions]
                     timestamp:
                       type: number
+                    last_processed_block:
+                      type: number
 
 components:
   schemas:
diff --git a/webserver/src/handler/crawler_state.rs b/webserver/src/handler/crawler_state.rs
index eecbf5bf..8490bc2d 100644
--- a/webserver/src/handler/crawler_state.rs
+++ b/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: None
                     },
                     |ct| ct.clone(),
                 )
diff --git a/webserver/src/response/crawler_state.rs b/webserver/src/response/crawler_state.rs
index d12fe51d..d7f44571 100644
--- a/webserver/src/response/crawler_state.rs
+++ b/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: Option<i32>
 }
diff --git a/webserver/src/service/crawler_state.rs b/webserver/src/service/crawler_state.rs
index 0ca9c805..661ec4ad 100644
--- a/webserver/src/service/crawler_state.rs
+++ b/webserver/src/service/crawler_state.rs
@@ -49,6 +49,8 @@ impl CrawlerStateService {
                 .map(|crawler| CrawlersTimestamps {
                     name: crawler.name.to_string(),
                     timestamp: crawler.timestamp.and_utc().timestamp(),
+                    last_processed_block: crawler.last_processed_block
+                    
                 })
                 .collect::<Vec<CrawlersTimestamps>>()
         })