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/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};