From 0196465da1e6e0f440b7fbd207aba32d712b0f41 Mon Sep 17 00:00:00 2001
From: Mark Sinclair <mmsinclair@users.noreply.github.com>
Date: Tue, 11 Nov 2025 21:50:07 +0000
Subject: [PATCH] add missing things and make clippy happy

---
 common/nyxd-scraper-shared/src/block_processor/types.rs | 2 ++
 common/nyxd-scraper-shared/src/rpc_client.rs            | 3 +++
 nym-data-observatory/src/chain_scraper/webhook.rs       | 5 ++---
 3 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/common/nyxd-scraper-shared/src/block_processor/types.rs b/common/nyxd-scraper-shared/src/block_processor/types.rs
index 00ceeac207..8bf184c0d9 100644
--- a/common/nyxd-scraper-shared/src/block_processor/types.rs
+++ b/common/nyxd-scraper-shared/src/block_processor/types.rs
@@ -30,6 +30,8 @@ pub struct ParsedTransactionResponse {
 
     pub parsed_messages: HashMap<usize, serde_json::Value>,
 
+    pub parsed_message_urls: HashMap<usize, String>,
+
     pub block: Block,
 }
 
diff --git a/common/nyxd-scraper-shared/src/rpc_client.rs b/common/nyxd-scraper-shared/src/rpc_client.rs
index 18af321ece..3f4ee84d26 100644
--- a/common/nyxd-scraper-shared/src/rpc_client.rs
+++ b/common/nyxd-scraper-shared/src/rpc_client.rs
@@ -73,6 +73,7 @@ impl RpcClient {
         let mut transactions = Vec::with_capacity(raw_transactions.len());
         for raw_tx in raw_transactions {
             let mut parsed_messages = HashMap::new();
+            let mut parsed_message_urls = HashMap::new();
             let tx = cosmrs::Tx::from_bytes(&raw_tx.tx).map_err(|source| {
                 ScraperError::TxParseFailure {
                     hash: raw_tx.hash,
@@ -83,6 +84,7 @@ impl RpcClient {
             for (index, msg) in tx.body.messages.iter().enumerate() {
                 if let Some(value) = self.decode_or_skip(msg) {
                     parsed_messages.insert(index, value);
+                    parsed_message_urls.insert(index, msg.type_url.clone());
                 }
             }
 
@@ -94,6 +96,7 @@ impl RpcClient {
                 tx,
                 proof: raw_tx.proof,
                 parsed_messages,
+                parsed_message_urls,
                 block: block.block.clone(),
             })
         }
diff --git a/nym-data-observatory/src/chain_scraper/webhook.rs b/nym-data-observatory/src/chain_scraper/webhook.rs
index fe9a4c088b..641f5741d7 100644
--- a/nym-data-observatory/src/chain_scraper/webhook.rs
+++ b/nym-data-observatory/src/chain_scraper/webhook.rs
@@ -10,7 +10,6 @@ use nyxd_scraper_psql::{
 };
 use reqwest::{Client, Url};
 use tracing::{error, info};
-use utoipa::r#gen::serde_json;
 
 pub struct WebhookModule {
     webhooks: Vec<Webhook>,
@@ -36,10 +35,10 @@ impl TxModule for WebhookModule {
         _: &mut dyn NyxdScraperTransaction,
     ) -> Result<(), ScraperError> {
         for (index, msg) in &tx.parsed_messages {
-            if let Some(parsed_message_type_url) = tx.parsed_message_urls.get(&index) {
+            if let Some(parsed_message_type_url) = tx.parsed_message_urls.get(index) {
                 let payload = WebhookPayload {
                     height: tx.height.value(),
-                    message_index: index.clone() as u64,
+                    message_index: *index as u64,
                     transaction_hash: tx.hash.to_string(),
                     message: Some(msg.clone()),
                 };