Dependency updates. Improve logging. Bump version.

kukabi · kukabi · commit b72636f00f15 · 2025-10-10T10:22:13.000+01:00
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/_docker/compose/.env.sample b/_docker/compose/.env.sample
@@ -1,4 +1,4 @@
-VERSION=0.24.12
+VERSION=0.24.13
 ENV=production
 LOG_LEVEL=debug
 
diff --git a/subvt-app-service/Cargo.toml b/subvt-app-service/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-app-service"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-block-processor/Cargo.toml b/subvt-block-processor/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-block-processor"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-block-processor/src/lib.rs b/subvt-block-processor/src/lib.rs
@@ -289,6 +289,7 @@ impl BlockProcessor {
         block_number: u64,
         persist_era_reward_points: bool,
     ) -> anyhow::Result<()> {
+        log::info!("Process ASSET_HUB finalized block {}.", block_number);
         let block_hash = substrate_client.get_block_hash(block_number).await?;
         let block_header = substrate_client.get_block_header(&block_hash).await?;
         let runtime_upgrade_info = substrate_client
@@ -319,12 +320,15 @@ impl BlockProcessor {
                 runtime_information.epoch_index,
             )
         };
+        log::info!("Get active validator account ids.");
         let active_validator_account_ids = relay_substrate_client
             .get_active_validator_account_ids(&relay_block_hash)
             .await?;
+        log::info!("Get active era.");
         let active_era = substrate_client
             .get_active_era(&block_hash, &relay_substrate_client.metadata)
             .await?;
+        log::info!("Get current epoch.");
         let current_epoch = relay_substrate_client
             .get_current_epoch(&active_era, &relay_block_hash)
             .await?;
@@ -427,22 +431,6 @@ impl BlockProcessor {
             runtime_information.era_index = active_era.index;
             runtime_information.epoch_index = current_epoch.index;
         }
-
-        if !postgres.era_exists(active_era.index).await? {
-            log::info!("Era doesn't exist - persist.");
-            let total_stake = substrate_client
-                .get_era_total_stake(active_era.index, &block_hash)
-                .await?;
-            let era_stakers = substrate_client
-                .get_era_stakers(&active_era, &block_hash)
-                .await?;
-            postgres
-                .save_era(&active_era, total_stake, &era_stakers)
-                .await?;
-        }
-        let current_epoch = relay_substrate_client
-            .get_current_epoch(&active_era, &relay_block_hash)
-            .await?;
         log::info!("Persist era reward points.");
         if persist_era_reward_points {
             self.persist_era_reward_points(
@@ -469,7 +457,7 @@ impl BlockProcessor {
             block_number
         );
 
-        log::info!("Save block.");
+        log::info!("Save finalized block {}.", block_number);
         let block_timestamp = substrate_client.get_block_timestamp(&block_hash).await?;
         let runtime_version = substrate_client.last_runtime_upgrade_info.spec_version as i16;
         postgres
@@ -483,10 +471,12 @@ impl BlockProcessor {
                 (14, runtime_version),
             )
             .await?;
+        log::info!("Saved finalized block {}.", block_number);
         // process/persist events
         let mut extrinsic_event_map: HashMap<u32, Vec<(usize, SubstrateEvent)>> =
             HashMap::default();
         for (index, event_result) in event_results.iter().enumerate() {
+            log::info!("Process event #{} of block {}.", index, block_number);
             match event_result {
                 Ok(event) => {
                     if let Some(extrinsic_index) = event.get_extrinsic_index() {
@@ -542,8 +532,10 @@ impl BlockProcessor {
                 },
             }
         }
+        log::info!("Processed events in block {}.", block_number);
         // persist extrinsics
         for (index, extrinsic_result) in extrinsic_results.iter().enumerate() {
+            log::info!("Process extrinsic #{} of block {}.", index, block_number);
             match extrinsic_result {
                 Ok(extrinsic) => {
                     // check events for batch & batch_all
diff --git a/subvt-config/Cargo.toml b/subvt-config/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-config"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-governance/Cargo.toml b/subvt-governance/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-governance"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-kline-updater/Cargo.toml b/subvt-kline-updater/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-kline-updater"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-logging/Cargo.toml b/subvt-logging/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-logging"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-metrics/Cargo.toml b/subvt-metrics/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-metrics"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
@@ -10,4 +10,4 @@ once_cell = "1"
 prometheus = "0.14"
 thiserror = { workspace = true }
 tokio = { version = "1.47", features = ["time", "rt-multi-thread"] }
-warp = { version = "0.3", default-features = false }
+warp = { version = "0.4", features = ["server"] }
diff --git a/subvt-metrics/src/server.rs b/subvt-metrics/src/server.rs
@@ -24,15 +24,12 @@ pub async fn start<T: ToSocketAddrs + Debug>(address: T) {
 
     log::info!("Metrics server started on {address:?}");
     let routes = route.with(warp::log("subvt_metrics_server"));
-    warp::serve(routes)
-        .run(
-            address
-                .to_socket_addrs()
-                .expect("Invalid server address.")
-                .next()
-                .unwrap(),
-        )
-        .await;
+    let socket_addr = address
+        .to_socket_addrs()
+        .expect("Invalid server address.")
+        .next()
+        .expect("Could not resolve address.");
+    warp::serve(routes).run(socket_addr).await;
 }
 
 async fn metrics_text_handler(registry: Registry) -> Result<impl Reply, Rejection> {
diff --git a/subvt-network-status-server/Cargo.toml b/subvt-network-status-server/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-network-status-server"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-network-status-updater/Cargo.toml b/subvt-network-status-updater/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-network-status-updater"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-nft/Cargo.toml b/subvt-nft/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-nft"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-notification-generator/Cargo.toml b/subvt-notification-generator/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-notification-generator"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-notification-processor/Cargo.toml b/subvt-notification-processor/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-notification-processor"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-notification-processor/src/sender/telegram.rs b/subvt-notification-processor/src/sender/telegram.rs
@@ -36,11 +36,13 @@ impl TelegramSender {
             disable_notification: None,
             protect_content: None,
             message_effect_id: None,
+            suggested_post_parameters: None,
             reply_parameters: None,
             reply_markup: None,
             message_thread_id: None,
             business_connection_id: None,
             allow_paid_broadcast: None,
+            direct_messages_topic_id: None,
         };
         match self.telegram_client.send_message(&params).await {
             Ok(response) => {
diff --git a/subvt-onekv-updater/Cargo.toml b/subvt-onekv-updater/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-onekv-updater"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-persistence/Cargo.toml b/subvt-persistence/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-persistence"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-plotter/Cargo.toml b/subvt-plotter/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-plotter"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-proc-macro/Cargo.toml b/subvt-proc-macro/Cargo.toml
@@ -3,7 +3,7 @@ proc-macro = true
 
 [package]
 name = "subvt-proc-macro"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-referendum-updater/Cargo.toml b/subvt-referendum-updater/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-referendum-updater"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-report-service/Cargo.toml b/subvt-report-service/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-report-service"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-service-common/Cargo.toml b/subvt-service-common/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-service-common"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-session-validator-performance-updater/Cargo.toml b/subvt-session-validator-performance-updater/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-session-validator-performance-updater"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-substrate-client/Cargo.toml b/subvt-substrate-client/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-substrate-client"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
@@ -14,7 +14,7 @@ log = { workspace = true }
 parity-scale-codec = { version = "3.7", default-features = false, features = ["derive", "full"] }
 rustc-hash = "2.1"
 serde_json = "1.0"
-sp-core = { git = "https://github.com/paritytech/polkadot-sdk.git", tag = "polkadot-v1.19.2" }
+sp-core = { git = "https://github.com/paritytech/polkadot-sdk.git", tag = "polkadot-v1.20.0" }
 subvt-config = { path = "../subvt-config" }
 subvt-types = { path = "../subvt-types" }
 subvt-utility = { path = "../subvt-utility" }
diff --git a/subvt-telegram-bot/Cargo.toml b/subvt-telegram-bot/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-telegram-bot"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
@@ -10,7 +10,7 @@ async-recursion = "1.1"
 async-trait = "0.1"
 chrono = "0.4"
 enum-iterator = "2.3"
-frankenstein = { version = "0.44", default-features = false, features = ["client-reqwest"] }
+frankenstein = { version = "0.45", default-features = false, features = ["client-reqwest"] }
 itertools = { workspace = true }
 lazy_static = { workspace = true }
 log = { workspace = true }
diff --git a/subvt-telegram-bot/src/messenger/mod.rs b/subvt-telegram-bot/src/messenger/mod.rs
@@ -175,11 +175,13 @@ impl Messenger for MessengerImpl {
             disable_notification: None,
             protect_content: None,
             message_effect_id: None,
+            suggested_post_parameters: None,
             reply_parameters: None,
             reply_markup: None,
             message_thread_id: None,
             business_connection_id: None,
             allow_paid_broadcast: None,
+            direct_messages_topic_id: None,
         };
         match self.api.send_photo(&params).await {
             Ok(response) => Ok(response),
@@ -275,11 +277,13 @@ impl Messenger for MessengerImpl {
             disable_notification: None,
             protect_content: None,
             message_effect_id: None,
+            suggested_post_parameters: None,
             reply_parameters: None,
             reply_markup: inline_keyboard,
             message_thread_id: None,
             business_connection_id: None,
             allow_paid_broadcast: None,
+            direct_messages_topic_id: None,
         };
         log::info!(
             "Message to chat {}: {}",
diff --git a/subvt-telemetry-processor/Cargo.toml b/subvt-telemetry-processor/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "subvt-telemetry-processor"
-version = "0.24.12"
+version = "0.24.13"
 edition = "2021"
 rust-version = "1.67.0"
 
diff --git a/subvt-types/Cargo.toml b/subvt-types/Cargo.toml
diff --git a/subvt-types/src/substrate/metadata.rs b/subvt-types/src/substrate/metadata.rs
diff --git a/subvt-utility/Cargo.toml b/subvt-utility/Cargo.toml
diff --git a/subvt-validator-details-server/Cargo.toml b/subvt-validator-details-server/Cargo.toml
diff --git a/subvt-validator-list-server/Cargo.toml b/subvt-validator-list-server/Cargo.toml
diff --git a/subvt-validator-list-updater/Cargo.toml b/subvt-validator-list-updater/Cargo.toml

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-VERSION=0.24.12`
	`1`	`+VERSION=0.24.13`
`2`	`2`	`ENV=production`
`3`	`3`	`LOG_LEVEL=debug`
`4`	`4`