Chore/more payment watcher debug endpoints

common/client-libs/validator-client/src/nyxd/mod.rs

@@ -62,6 +62,7 @@ pub use cw3;
 pub use cw4;
 pub use cw_controllers;
 pub use fee::{gas_price::GasPrice, GasAdjustable, GasAdjustment};
+pub use prost::Name;
 pub use tendermint_rpc::endpoint::block::Response as BlockResponse;
 pub use tendermint_rpc::{
     endpoint::{tx::Response as TxResponse, validators::Response as ValidatorResponse},

common/nyxd-scraper/src/block_processor/mod.rs

@@ -182,9 +182,11 @@ impl BlockProcessor {
             // the ones concerned with individual messages
             for (index, msg) in block_tx.tx.body.messages.iter().enumerate() {
                 for msg_module in &mut self.msg_modules {
-                    msg_module
-                        .handle_msg(index, msg, &block_tx, &mut tx)
-                        .await?
+                    if msg.type_url == msg_module.type_url() {
+                        msg_module
+                            .handle_msg(index, msg, &block_tx, &mut tx)
+                            .await?
+                    }
                 }
             }
         }

common/nyxd-scraper/src/error.rs

@@ -83,6 +83,15 @@ pub enum ScraperError {
         source: cosmrs::ErrorReport,
     },
 
+    #[error("could not parse msg in tx {hash} at index {index} into {type_url}: {source}")]
+    MsgParseFailure {
+        hash: Hash,
+        index: usize,
+        type_url: String,
+        #[source]
+        source: cosmrs::ErrorReport,
+    },
+
     #[error("received an invalid chain subscription event of kind {kind} while we were waiting for new block data (query: '{query}')")]
     InvalidSubscriptionEvent { query: String, kind: String },
 

common/nyxd-scraper/src/modules/msg_module.rs

@@ -9,6 +9,8 @@ use cosmrs::Any;
 
 #[async_trait]
 pub trait MsgModule {
+    fn type_url(&self) -> String;
+
     async fn handle_msg(
         &mut self,
         index: usize,

nyx-chain-watcher/Cargo.toml

@@ -3,7 +3,7 @@
 
 [package]
 name = "nyx-chain-watcher"
-version = "0.1.13"
+version = "0.1.14"
 authors.workspace = true
 repository.workspace = true
 homepage.workspace = true
@@ -23,15 +23,11 @@ nym-config = { path = "../common/config" }
 nym-bin-common = { path = "../common/bin-common", features = ["output_format"] }
 nym-network-defaults = { path = "../common/network-defaults" }
 nym-task = { path = "../common/task" }
-nym-node-requests = { path = "../nym-node/nym-node-requests", features = [
-    "openapi",
-] }
 nym-validator-client = { path = "../common/client-libs/validator-client" }
 nyxd-scraper = { path = "../common/nyxd-scraper" }
 reqwest = { workspace = true, features = ["rustls-tls"] }
 schemars = { workspace = true }
 serde = { workspace = true, features = ["derive"] }
-serde_json = { workspace = true }
 sqlx = { workspace = true, features = ["runtime-tokio-rustls", "sqlite", "time"] }
 thiserror = { workspace = true }
 time = { workspace = true }