Function StartHTTPServer

pkg/mcp/server.go:57–101

StartHTTPServer starts a streaming HTTP MCP server on the given listener

(ctx context.Context, agentFilename, agentName string, runConfig *config.RuntimeConfig, ln net.Listener)

// StartHTTPServer starts a streaming HTTP MCP server on the given listener
func StartHTTPServer(ctx context.Context, agentFilename, agentName string, runConfig *config.RuntimeConfig, ln net.Listener) error {
	slog.DebugContext(ctx, "Starting HTTP MCP server", "agent", agentFilename, "addr", ln.Addr())

	server, cleanup, err := createMCPServer(ctx, agentFilename, agentName, runConfig)
	if err != nil {
		return err
	}
	defer cleanup()

	fmt.Printf("MCP HTTP server listening on http://%s\n", ln.Addr())

	// Wrap with otelhttp so the MCP-over-HTTP transport extracts
	// `traceparent` / `baggage` from incoming requests just like the
	// stdio transport extracts them from `params._meta`. Without this
	// HTTP-mode MCP clients lose trace context at the boundary.
	httpServer := &http.Server{
		Handler: otelhttp.NewHandler(
			mcp.NewStreamableHTTPHandler(func(_ *http.Request) *mcp.Server {
				return server
			}, nil),
			"mcp.http",
		),
		ReadHeaderTimeout: 10 * time.Second,
	}

	errCh := make(chan error, 1)
	go func() {
		errCh <- httpServer.Serve(ln)
	}()

	select {
	case <-ctx.Done():
		// ctx is done; detach from its cancellation but keep its trace
		// context so the graceful shutdown can still run. Bound it so a
		// hung client connection can't block shutdown indefinitely.
		shutdownCtx, cancel := context.WithTimeout(context.WithoutCancel(ctx), 5*time.Second)
		defer cancel()
		return httpServer.Shutdown(shutdownCtx)
	case err := <-errCh:
		if errors.Is(err, http.ErrServerClosed) {
			return nil
		}
		return err
	}
}

func createMCPServer(ctx context.Context, agentFilename, agentName string, runConfig *config.RuntimeConfig) (*mcp.Server, func(), error) {
	agentSource, err := config.Resolve(agentFilename, nil)