refactor: move RequestIdGen trait to the sdk crate

Author: hashemix

crates/rust-mcp-sdk/src/mcp_runtimes/client_runtime.rs

@@ -1,21 +1,22 @@
 pub mod mcp_client_runtime;
 pub mod mcp_client_runtime_core;
 
-use crate::schema::{
-    schema_utils::{
-        self, ClientMessage, ClientMessages, FromMessage, MessageFromClient, ServerMessage,
-        ServerMessages,
+use crate::{
+    mcp_traits::{RequestIdGen, RequestIdGenNumeric},
+    schema::{
+        schema_utils::{
+            self, ClientMessage, ClientMessages, FromMessage, MessageFromClient, ServerMessage,
+            ServerMessages,
+        },
+        InitializeRequest, InitializeRequestParams, InitializeResult, InitializedNotification,
+        RequestId, RpcError, ServerResult,
     },
-    InitializeRequest, InitializeRequestParams, InitializeResult, InitializedNotification,
-    RequestId, RpcError, ServerResult,
 };
 use async_trait::async_trait;
 use futures::future::{join_all, try_join_all};
 use futures::StreamExt;
 
-use rust_mcp_transport::{
-    IoStream, McpDispatch, MessageDispatcher, RequestIdGen, RequestIdGenNumeric, Transport,
-};
+use rust_mcp_transport::{IoStream, McpDispatch, MessageDispatcher, Transport};
 use std::{
     sync::{Arc, RwLock},
     time::Duration,

crates/rust-mcp-sdk/src/mcp_runtimes/server_runtime.rs

@@ -3,6 +3,7 @@ pub mod mcp_server_runtime_core;
 use crate::error::SdkResult;
 use crate::mcp_traits::mcp_handler::McpServerHandler;
 use crate::mcp_traits::mcp_server::McpServer;
+use crate::mcp_traits::{RequestIdGen, RequestIdGenNumeric};
 use crate::schema::{
     schema_utils::{
         ClientMessage, ClientMessages, FromMessage, MessageFromServer, SdkError, ServerMessage,
@@ -16,7 +17,7 @@ use futures::future::try_join_all;
 use futures::{StreamExt, TryFutureExt};
 #[cfg(feature = "hyper-server")]
 use rust_mcp_transport::SessionId;
-use rust_mcp_transport::{IoStream, RequestIdGen, RequestIdGenNumeric, TransportDispatcher};
+use rust_mcp_transport::{IoStream, TransportDispatcher};
 use std::collections::HashMap;
 use std::sync::Arc;
 use std::time::Duration;

crates/rust-mcp-sdk/src/mcp_traits.rs

@@ -3,3 +3,6 @@ pub mod mcp_client;
 pub mod mcp_handler;
 #[cfg(feature = "server")]
 pub mod mcp_server;
+mod request_id_gen;
+
+pub use request_id_gen::*;

crates/rust-mcp-transport/src/lib.rs

@@ -6,7 +6,6 @@ mod client_sse;
 pub mod error;
 mod mcp_stream;
 mod message_dispatcher;
-mod request_id_gen;
 mod schema;
 #[cfg(feature = "sse")]
 mod sse;
@@ -17,7 +16,6 @@ mod utils;
 #[cfg(feature = "sse")]
 pub use client_sse::*;
 pub use message_dispatcher::*;
-pub use request_id_gen::*;
 #[cfg(feature = "sse")]
 pub use sse::*;
 pub use stdio::*;