fix(test): fix port conflict in test with js

Author: 4t145

crates/rmcp/tests/test_with_js.rs

@@ -6,7 +6,8 @@ use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 mod common;
 use common::calculator::Calculator;
 
-const BIND_ADDRESS: &str = "127.0.0.1:8000";
+const SSE_BIND_ADDRESS: &str = "127.0.0.1:8000";
+const STREAMABLE_HTTP_BIND_ADDRESS: &str = "127.0.0.1:8001";
 
 #[tokio::test]
 async fn test_with_js_client() -> anyhow::Result<()> {
@@ -24,7 +25,7 @@ async fn test_with_js_client() -> anyhow::Result<()> {
         .wait()
         .await?;
 
-    let ct = SseServer::serve(BIND_ADDRESS.parse()?)
+    let ct = SseServer::serve(SSE_BIND_ADDRESS.parse()?)
         .await?
         .with_service(Calculator::default);
 
@@ -83,7 +84,7 @@ async fn test_with_js_streamable_http_client() -> anyhow::Result<()> {
         .wait()
         .await?;
 
-    let ct = StreamableHttpServer::serve(BIND_ADDRESS.parse()?)
+    let ct = StreamableHttpServer::serve(STREAMABLE_HTTP_BIND_ADDRESS.parse()?)
         .await?
         .with_service(Calculator::default);
 

crates/rmcp/tests/test_with_js/streamable_client.js

@@ -1,7 +1,7 @@
 import { Client } from "@modelcontextprotocol/sdk/client/index.js";
 import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";
 
-const transport = new StreamableHTTPClientTransport(new URL(`http://127.0.0.1:8000/`));
+const transport = new StreamableHTTPClientTransport(new URL(`http://127.0.0.1:8001/`));
 
 const client = new Client(
   {