Skip to content

Commit e35e9f2

Browse files
authored
Merge pull request #18 from StacklokLabs/config_transport
Config transport
2 parents 6c24fb3 + fdbf2d4 commit e35e9f2

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ The server can be configured using environment variables:
6565
- If invalid or not set, the server will use port 8080
6666

6767
- `MCP_TRANSPORT`: The transport mode for the server (default: `sse`)
68-
- Supported values: `sse`, `http-stream`
68+
- Supported values: `sse`, `streamable-http`
6969
- If invalid or not set, the server will use SSE transport mode
7070

7171
Example:

cmd/server/main.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ const (
2222
// TransportSSE represents the Server-Sent Events transport mode.
2323
TransportSSE TransportMode = "sse"
2424
// TransportHTTPStream represents the HTTP streaming transport mode.
25-
TransportHTTPStream TransportMode = "http-stream"
25+
TransportHTTPStream TransportMode = "streamable-http"
2626
)
2727

2828
func getTransportMode() (TransportMode, error) {
@@ -35,7 +35,7 @@ func getTransportMode() (TransportMode, error) {
3535
case TransportSSE, TransportHTTPStream:
3636
return TransportMode(mode), nil
3737
default:
38-
return "", fmt.Errorf("invalid MCP_TRANSPORT: %q (allowed: sse, http-stream)", mode)
38+
return "", fmt.Errorf("invalid MCP_TRANSPORT: %q (allowed: sse, streamable-http)", mode)
3939
}
4040
}
4141

pkg/mcp/server.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ func (s *Server) ServeHTTPStream(addr string) error {
164164
log.Printf("Starting OSV MCP server (Streamable HTTP) on %s", addr)
165165

166166
httpSrv := server.NewStreamableHTTPServer(s.mcpServer,
167-
server.WithEndpointPath("/mcp"),
167+
server.WithEndpointPath("/mcp/"),
168168
server.WithStateLess(true), // stateless mode
169169
server.WithHeartbeatInterval(30*time.Second),
170170
)

0 commit comments

Comments
 (0)