modelcontextprotocol/kotlin-sdk
Watch
1
0
Fork
You've already forked kotlin-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Remove fixed suffix /sse (#108)

Browse source 
* Simplify URL handling in SSE client transport.

* fix the sse integration test

---------

Co-authored-by: devcrocod <devcrocod@gmail.com>
This commit is contained in:
adamglin0 2025-07-04 18:40:00 +08:00 • committed by GitHub
commit aa00fc3d5e
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 9 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/commonMain/kotlin/io/modelcontextprotocol/kotlin/sdk/client/SSEClientTransport.kt
View file

@ -68,7 +68,7 @@ public class SseClientTransport(
session = urlString?.let { session = urlString?.let {
client.sseSession( client.sseSession(
urlString = "$it/sse", urlString = it,
reconnectionTime = reconnectionTime, reconnectionTime = reconnectionTime,
block = requestBuilder, block = requestBuilder,
) )

9
src/commonTest/kotlin/io/modelcontextprotocol/kotlin/sdk/integration/SseIntegrationTest.kt
View file

@ -2,9 +2,11 @@ package io.modelcontextprotocol.kotlin.sdk.integration
import io.ktor.client.HttpClient import io.ktor.client.HttpClient
import io.ktor.client.plugins.sse.SSE import io.ktor.client.plugins.sse.SSE
import io.ktor.server.application.install
import io.ktor.server.cio.CIOApplicationEngine import io.ktor.server.cio.CIOApplicationEngine
import io.ktor.server.engine.EmbeddedServer import io.ktor.server.engine.EmbeddedServer
import io.ktor.server.engine.embeddedServer import io.ktor.server.engine.embeddedServer
import io.ktor.server.routing.routing
import io.modelcontextprotocol.kotlin.sdk.Implementation import io.modelcontextprotocol.kotlin.sdk.Implementation
import io.modelcontextprotocol.kotlin.sdk.ServerCapabilities import io.modelcontextprotocol.kotlin.sdk.ServerCapabilities
import io.modelcontextprotocol.kotlin.sdk.client.Client import io.modelcontextprotocol.kotlin.sdk.client.Client
@ -52,7 +54,12 @@ class SseIntegrationTest {
ServerOptions(capabilities = ServerCapabilities()), ServerOptions(capabilities = ServerCapabilities()),
) )
return embeddedServer(ServerCIO, host = URL, port = PORT) { mcp { server } }.startSuspend(wait = false) return embeddedServer(ServerCIO, host = URL, port = PORT) {
install(io.ktor.server.sse.SSE)
routing {
mcp { server }
}
}.startSuspend(wait = false)
} }
companion object { companion object {