chore: reduce noisy logging

Author: pimeys

crates/rmcp/src/service.rs

@@ -480,9 +480,9 @@ where
     >(SINK_PROXY_BUFFER_SIZE);
 
     if R::IS_CLIENT {
-        tracing::info!(?peer_info, "Service initialized as client");
+        tracing::debug!(?peer_info, "Service initialized as client");
     } else {
-        tracing::info!(?peer_info, "Service initialized as server");
+        tracing::debug!(?peer_info, "Service initialized as server");
     }
 
     let (peer, mut peer_proxy) = <Peer<R>>::new(id_provider, peer_info);
@@ -521,7 +521,7 @@ where
                         Event::PeerMessage(m.into_message())
                     } else {
                         // input stream closed
-                        tracing::info!("input stream terminated");
+                        tracing::debug!("input stream terminated");
                         break QuitReason::Closed
                     }
                 }
@@ -533,7 +533,7 @@ where
                     }
                 }
                 _ = serve_loop_ct.cancelled() => {
-                    tracing::info!("task cancelled");
+                    tracing::debug!("task cancelled");
                     break QuitReason::Cancelled
                 }
             };
@@ -588,7 +588,7 @@ where
                     let _ = responder.send(response);
                     if let Some(param) = cancellation_param {
                         if let Some(responder) = local_responder_pool.remove(&param.request_id) {
-                            tracing::info!(id = %param.request_id, reason = param.reason, "cancelled");
+                            tracing::debug!(id = %param.request_id, reason = param.reason, "cancelled");
                             let _response_result = responder.send(Err(ServiceError::Cancelled {
                                 reason: param.reason.clone(),
                             }));
@@ -612,11 +612,11 @@ where
                             let result = service.handle_request(request, context).await;
                             let response = match result {
                                 Ok(result) => {
-                                    tracing::info!(%id, ?result, "response message");
+                                    tracing::debug!(%id, ?result, "response message");
                                     Message::Response(result, id)
                                 }
                                 Err(error) => {
-                                    tracing::warn!(%id, ?error, "response error");
+                                    tracing::debug!(%id, ?error, "response error");
                                     Message::Error(error, id)
                                 }
                             };
@@ -625,12 +625,12 @@ where
                     }
                 }
                 Event::PeerMessage(Message::Notification(notification)) => {
-                    tracing::info!(?notification, "received notification");
+                    tracing::debug!(?notification, "received notification");
                     // catch cancelled notification
                     let notification = match notification.try_into() {
                         Ok::<CancelledNotification, _>(cancelled) => {
                             if let Some(ct) = local_ct_pool.remove(&cancelled.params.request_id) {
-                                tracing::info!(id = %cancelled.params.request_id, reason = cancelled.params.reason, "cancelled");
+                                tracing::debug!(id = %cancelled.params.request_id, reason = cancelled.params.reason, "cancelled");
                                 ct.cancel();
                             }
                             cancelled.into()
@@ -669,7 +669,7 @@ where
         if let Err(e) = sink_close_result {
             tracing::error!(%e, "fail to close sink");
         }
-        tracing::info!(?quit_reason, "serve finished");
+        tracing::debug!(?quit_reason, "serve finished");
         quit_reason
     });
     Ok(RunningService {

crates/rmcp/src/transport/sse_server.rs

@@ -90,7 +90,7 @@ async fn sse_handler(
     State(app): State<App>,
 ) -> Result<Sse<impl Stream<Item = Result<Event, io::Error>>>, Response<String>> {
     let session = session_id();
-    tracing::info!(%session, "sse connection");
+    tracing::debug!(%session, "sse connection");
     use tokio_stream::{StreamExt, wrappers::ReceiverStream};
     use tokio_util::sync::PollSender;
     let (from_client_tx, from_client_rx) = tokio::sync::mpsc::channel(64);
@@ -232,7 +232,7 @@ impl SseServer {
         let ct = sse_server.config.ct.child_token();
         let server = axum::serve(listener, service).with_graceful_shutdown(async move {
             ct.cancelled().await;
-            tracing::info!("sse server cancelled");
+            tracing::debug!("sse server cancelled");
         });
         tokio::spawn(
             async move {