Function runHTTP

cmd/gosqlx-mcp/main.go:80–119

runHTTP serves the MCP protocol over streamable HTTP transport.

()

// runHTTP serves the MCP protocol over streamable HTTP transport.
func runHTTP() error {
	cfg, err := gosqlxmcp.LoadConfig()
	if err != nil {
		return fmt.Errorf("configuration error: %w", err)
	}

	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
	defer stop()

	srv := gosqlxmcp.New(cfg)

	// Build handler chain: MCP → auth → rate limiter
	handler := gosqlxmcp.RateLimitMiddleware(srv.Handler())

	mux := http.NewServeMux()
	mux.Handle("/mcp", handler)
	mux.Handle("/mcp/", handler)
	mux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) {
		w.Header().Set("Content-Type", "application/json")
		fmt.Fprintf(w, `{"status":"ok","version":"%s","tools":7}`, gosqlx.Version)
	})

	httpSrv := &http.Server{
		Addr:    cfg.Addr(),
		Handler: mux,
	}

	go func() {
		<-ctx.Done()
		shutdownCtx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
		defer cancel()
		_ = httpSrv.Shutdown(shutdownCtx)
	}()

	log.Printf("gosqlx-mcp: listening on %s (auth=%v)\n", cfg.Addr(), cfg.AuthEnabled())
	if err := httpSrv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
		return fmt.Errorf("server error: %w", err)
	}
	return nil
}