fix(mempool_p2p): pass broadcasted message metadata to gateway (#1795)

starkware-libs · Nov 7, 2024 · 6890308 · 6890308
1 parent 9c57a2c
commit 6890308
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/crates/mempool_p2p/src/runner/mod.rs b/crates/mempool_p2p/src/runner/mod.rs
@@ -56,11 +56,10 @@ impl ComponentStarter for MempoolP2pRunner {
                 Some((message_result, broadcasted_message_metadata)) = self.broadcasted_topic_server.next() => {
                     match message_result {
                         Ok(message) => {
-                            // TODO(eitan): Add message metadata.
                             // TODO(eitan): make this call non blocking by adding this future to a
                             // FuturesUnordered that will be polled in the select.
                             match self.gateway_client.add_tx(
-                                GatewayInput { rpc_tx: message.0, message_metadata: None }
+                                GatewayInput { rpc_tx: message.0, message_metadata: Some(broadcasted_message_metadata.clone()) }
                             ).await {
                                 Ok(_tx_hash) => {}
                                 Err(e) => {