feat: Log block stream requests

coordinator/Cargo.toml

@@ -9,6 +9,7 @@ redis = { version = "0.24", features = ["tokio-comp", "connection-manager"] }
 tokio = "1.28"
 tonic = "0.10.2"
 tracing = "0.1.40"
+tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 serde_json = "1.0.108"
 
 block-streamer = { path = "../block-streamer" }

coordinator/src/block_streams_handler.rs

@@ -35,10 +35,11 @@ impl BlockStreamsHandlerImpl {
     }
 
     pub async fn stop(&mut self, stream_id: String) -> anyhow::Result<()> {
-        let _ = self
-            .client
-            .stop_stream(Request::new(StopStreamRequest { stream_id }))
-            .await?;
+        let request = Request::new(StopStreamRequest { stream_id });
+
+        tracing::debug!("Sending stop stream request: {:#?}", request);
+
+        let _ = self.client.stop_stream(request).await?;
 
         Ok(())
     }
@@ -85,16 +86,17 @@ impl BlockStreamsHandlerImpl {
             }
         };
 
-        let _ = self
-            .client
-            .start_stream(Request::new(StartStreamRequest {
-                start_block_height,
-                account_id,
-                function_name,
-                version,
-                rule: Some(rule),
-            }))
-            .await?;
+        let request = Request::new(StartStreamRequest {
+            start_block_height,
+            account_id,
+            function_name,
+            version,
+            rule: Some(rule),
+        });
+
+        tracing::debug!("Sending start stream request: {:#?}", request);
+
+        let _ = self.client.start_stream(request).await?;
 
         Ok(())
     }

coordinator/src/main.rs

@@ -1,3 +1,5 @@
+use tracing_subscriber::prelude::*;
+
 use crate::block_streams_handler::BlockStreamsHandler;
 use crate::redis::RedisClient;
 use crate::registry::Registry;
@@ -8,7 +10,11 @@ mod registry;
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
-    let registry = Registry::connect("https://rpc.mainnet.near.org");
+    tracing_subscriber::registry()
+        .with(tracing_subscriber::fmt::layer())
+        .with(tracing_subscriber::EnvFilter::from_default_env())
+        .init();
+
     let redis_client = RedisClient::connect("redis://127.0.0.1").await?;
     let mut block_stream_handler = BlockStreamsHandler::connect().await?;