()
| 34 | } |
| 35 | |
| 36 | func newMCPServer() *MCPServer { |
| 37 | server := mcp.NewServer(&mcp.Implementation{ |
| 38 | Name: "53AIHub MCP", |
| 39 | Version: config.Version, |
| 40 | }, nil) |
| 41 | |
| 42 | handler := mcp.NewStreamableHTTPHandler(func(*http.Request) *mcp.Server { |
| 43 | return server |
| 44 | }, &mcp.StreamableHTTPOptions{ |
| 45 | Stateless: true, |
| 46 | JSONResponse: true, |
| 47 | DisableLocalhostProtection: true, |
| 48 | }) |
| 49 | |
| 50 | mcpServer := &MCPServer{ |
| 51 | server: server, |
| 52 | handler: handler, |
| 53 | } |
| 54 | registerMCPTools(mcpServer) |
| 55 | return mcpServer |
| 56 | } |
| 57 | |
| 58 | // Server exposes the underlying MCP server for tool registration. |
| 59 | func (s *MCPServer) Server() *mcp.Server { |
no test coverage detected