test(logging): add comprehensive server transport tests

Author: Hendler

crates/rmcp/Cargo.toml

@@ -23,7 +23,6 @@ tracing = { version = "0.1" }
 tokio-util = { version = "0.7" }
 pin-project-lite = "0.2"
 paste = { version = "1", optional = true }
-log = { version = "0.4" }
 # for auto generate schema
 schemars = { version = "0.8", optional = true }
 

crates/rmcp/src/handler/server.rs

@@ -100,7 +100,6 @@ impl<H: ServerHandler> Service<RoleServer> for H {
     fn get_info(&self) -> <RoleServer as ServiceRole>::Info {
         self.get_info()
     }
-
 }
 
 #[allow(unused_variables)]
@@ -230,26 +229,4 @@ pub trait ServerHandler: Sized + Send + Sync + 'static {
     fn get_info(&self) -> ServerInfo {
         ServerInfo::default()
     }
-
-    fn log(
-        &self,
-        level: LoggingLevel,
-        message: &str,
-    ) -> impl Future<Output = ()> + Send + '_ {
-        let peer = self.get_peer();
-        let params = LoggingMessageNotificationParam {
-            level,
-            data: serde_json::json!({
-                "message": message,
-                "timestamp": chrono::Utc::now().to_rfc3339(),
-            }),
-            logger: None,
-        };
-        
-        async move {
-            if let Some(p) = peer {
-                let _ = p.notify_logging_message(params).await;
-            }
-        }
-    }
 }

crates/rmcp/src/model.rs

@@ -611,7 +611,7 @@ const_string!(ToolListChangedNotificationMethod = "notifications/tools/list_chan
 pub type ToolListChangedNotification = NotificationNoParam<ToolListChangedNotificationMethod>;
 // 日志相关
 #[derive(Debug, Serialize, Deserialize, Clone, PartialEq, Copy)]
-#[serde(rename_all = "camelCase")]
+#[serde(rename_all = "lowercase")] //match spec
 pub enum LoggingLevel {
     Debug,
     Info,
@@ -961,17 +961,6 @@ impl From<CancelledNotification> for ClientNotification {
     }
 }
 
-const_string!(LogRequestMethod = "logging/log");
-
-#[derive(Debug, Serialize, Deserialize, Clone, PartialEq)]
-#[serde(rename_all = "camelCase")]
-pub struct LogRequestParam {
-    pub level: LoggingLevel,
-    pub message: String,
-}
-
-pub type LogRequest = Request<LogRequestMethod, LogRequestParam>;
-
 #[cfg(test)]
 mod tests {
     use serde_json::json;

crates/rmcp/src/service/client.rs

@@ -13,7 +13,7 @@ use crate::model::{
     ProgressNotificationParam, ReadResourceRequest, ReadResourceRequestParam, ReadResourceResult,
     RequestId, RootsListChangedNotification, ServerInfo, ServerJsonRpcMessage, ServerNotification,
     ServerRequest, ServerResult, SetLevelRequest, SetLevelRequestParam, SubscribeRequest,
-    SubscribeRequestParam, UnsubscribeRequest, UnsubscribeRequestParam, LogRequest, LogRequestParam,
+    SubscribeRequestParam, UnsubscribeRequest, UnsubscribeRequestParam,
 };
 
 /// It represents the error that may occur when serving the client.

crates/rmcp/src/transport.rs

@@ -36,14 +36,7 @@
 //!     println!("{:?}", tools);
 //!     Ok(())
 //! }
-//!
-/// ```rust,ignore
-/// # use rmcp::ServiceExt;
-/// # async fn example() -> anyhow::Result<()> {
-/// #     let stream = tokio::io::duplex(1024);
-/// #     Ok(())
-/// # }
-/// ```
+//! ```
 
 use futures::{Sink, Stream};