Skip to content

Commit 30159ef

Browse files
authored
Merge branch 'main' into sean/tool-annotations
2 parents 0594222 + aa00fc3 commit 30159ef

File tree

2 files changed

+9
-2
lines changed

2 files changed

+9
-2
lines changed

src/commonMain/kotlin/io/modelcontextprotocol/kotlin/sdk/client/SSEClientTransport.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ public class SseClientTransport(
6868

6969
session = urlString?.let {
7070
client.sseSession(
71-
urlString = "$it/sse",
71+
urlString = it,
7272
reconnectionTime = reconnectionTime,
7373
block = requestBuilder,
7474
)

src/commonTest/kotlin/io/modelcontextprotocol/kotlin/sdk/integration/SseIntegrationTest.kt

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,11 @@ package io.modelcontextprotocol.kotlin.sdk.integration
22

33
import io.ktor.client.HttpClient
44
import io.ktor.client.plugins.sse.SSE
5+
import io.ktor.server.application.install
56
import io.ktor.server.cio.CIOApplicationEngine
67
import io.ktor.server.engine.EmbeddedServer
78
import io.ktor.server.engine.embeddedServer
9+
import io.ktor.server.routing.routing
810
import io.modelcontextprotocol.kotlin.sdk.Implementation
911
import io.modelcontextprotocol.kotlin.sdk.ServerCapabilities
1012
import io.modelcontextprotocol.kotlin.sdk.client.Client
@@ -52,7 +54,12 @@ class SseIntegrationTest {
5254
ServerOptions(capabilities = ServerCapabilities()),
5355
)
5456

55-
return embeddedServer(ServerCIO, host = URL, port = PORT) { mcp { server } }.startSuspend(wait = false)
57+
return embeddedServer(ServerCIO, host = URL, port = PORT) {
58+
install(io.ktor.server.sse.SSE)
59+
routing {
60+
mcp { server }
61+
}
62+
}.startSuspend(wait = false)
5663
}
5764

5865
companion object {

0 commit comments

Comments
 (0)