feat(model): enhance ProtocolVersion with PartialOrd and add utility methods

Author: 4t145

crates/rmcp/src/model.rs

@@ -92,7 +92,7 @@ macro_rules! const_string {
 
 const_string!(JsonRpcVersion2_0 = "2.0");
 
-#[derive(Debug, Clone, Eq, PartialEq, Hash)]
+#[derive(Debug, Clone, Eq, PartialEq, Hash, PartialOrd)]
 pub struct ProtocolVersion(Cow<'static, str>);
 
 impl Default for ProtocolVersion {
@@ -106,23 +106,6 @@ impl ProtocolVersion {
     pub const LATEST: Self = Self::V_2025_03_26;
 }
 
-impl PartialOrd for ProtocolVersion {
-    fn partial_cmp(&self, other: &Self) -> Option<std::cmp::Ordering> {
-        fn parse(s: &str) -> Option<(u16, u16, u16)> {
-            let (s_year, rest) = s.split_once('-')?;
-            let (s_month, rest) = rest.split_once('-')?;
-            let s_day = rest;
-            let year = s_year.parse::<u16>().ok()?;
-            let month = s_month.parse::<u16>().ok()?;
-            let day = s_day.parse::<u16>().ok()?;
-            Some((year, month, day))
-        }
-        let self_date = parse(self.0.as_ref())?;
-        let other_date = parse(other.0.as_ref())?;
-        Some(self_date.cmp(&other_date))
-    }
-}
-
 impl Serialize for ProtocolVersion {
     fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
     where

crates/rmcp/src/model/extension.rs

@@ -1,7 +1,9 @@
-//! Copied from http
+//! A container for those extra data could be carried on request or notification.
 //!
-//! source: <https://github.com/hyperium/http/blob/master/src/extensions.rs>
-
+//! This file is copied and modified from crate [http](https://github.com/hyperium/http).
+//!
+//! - Original code license: <https://github.com/hyperium/http/blob/master/LICENSE-MIT>
+//! - Original code: <https://github.com/hyperium/http/blob/master/src/extensions.rs>
 use std::{
     any::{Any, TypeId},
     collections::HashMap,

crates/rmcp/src/model/tool.rs

@@ -104,6 +104,16 @@ impl ToolAnnotations {
             ..self
         }
     }
+
+    /// If not set, defaults to true.
+    pub fn is_destructive(&self) -> bool {
+        self.destructive_hint.unwrap_or(true)
+    }
+
+    /// If not set, defaults to false.
+    pub fn is_idempotent(&self) -> bool {
+        self.idempotent_hint.unwrap_or(false)
+    }
 }
 
 impl Tool {

crates/rmcp/src/transport/sse_server.rs

@@ -70,16 +70,9 @@ pub struct PostEventQuery {
 async fn post_event_handler(
     State(app): State<App>,
     Query(PostEventQuery { session_id }): Query<PostEventQuery>,
-    Json(message): Json<serde_json::Value>,
+    Json(message): Json<ClientJsonRpcMessage>,
 ) -> Result<StatusCode, StatusCode> {
     tracing::debug!(session_id, ?message, "new client message");
-    let message = match serde_json::from_value(message) {
-        Ok(message) => message,
-        Err(e) => {
-            tracing::error!(error = %e, "failed to parse message");
-            return Err(StatusCode::BAD_REQUEST);
-        }
-    };
     let tx = {
         let rg = app.txs.read().await;
         rg.get(session_id.as_str())