Decode all messages

rakanalh · Feb 26, 2023 · 893361a · 893361a
1 parent ce5e912
commit 893361a
Show file tree

Hide file tree

Showing 6 changed files with 422 additions and 17 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/bin/raiden/src/main.rs b/bin/raiden/src/main.rs
@@ -27,6 +27,7 @@ use raiden_client::{
 		SyncService,
 	},
 };
+use raiden_network_messages::decode::MessageDecoder;
 use raiden_pathfinding::{
 	self,
 	config::PFSConfig,
@@ -222,6 +223,14 @@ async fn main() {
 		},
 	};
 
+	let message_decoder = MessageDecoder {
+		private_key: account.private_key(),
+		our_address: account.address(),
+		proxy_manager: proxy_manager.clone(),
+		secret_registry_address: default_addresses.secret_registry,
+		pathfinding_service_url: cli.services_config.pathfinding_service_address.clone(),
+	};
+
 	// #
 	// # Initialize Raiden
 	// #
@@ -245,7 +254,7 @@ async fn main() {
 		config,
 		contracts_manager,
 		proxy_manager,
-		state_manager,
+		state_manager: state_manager.clone(),
 		transport: transport_sender.clone(),
 	});
 
@@ -280,7 +289,7 @@ async fn main() {
 
 	futures::join!(
 		block_monitor_service.start(),
-		transport_service.run(transitioner),
+		transport_service.run(state_manager, transitioner, message_decoder),
 		http_service.start()
 	);
 }

diff --git a/raiden/network/messages/Cargo.toml b/raiden/network/messages/Cargo.toml
@@ -13,6 +13,7 @@ rust-version = "1.59"
 [dependencies]
 # 3rd-Party
 derive_more = { version = "0.99.11", default-features = false }
+hex = { version = "0.4.3" }
 thiserror = { version = "1.0", default-features = false }
 tiny-keccak = { version = "2.0.0", features = [ "keccak" ] }
 serde = { version = "1.0.136", default-features = false, features = [ "derive" ] }
@@ -21,5 +22,6 @@ web3 = { version = "0.18.0", default-features = false, features = ["signing"] }
 
 # Raiden
 raiden-blockchain = { path = "../../blockchain" }
+raiden-pathfinding = { path = "../../pathfinding" }
 raiden-primitives = { path = "../../primitives" }
 raiden-state-machine = { path = "../../state-machine" }