Method Start

pkg/mcp/server.go:66–85

Start binds to cfg.Addr() and serves using streamable HTTP transport. It blocks until ctx is cancelled or a fatal error occurs.

(ctx context.Context)

// Start binds to cfg.Addr() and serves using streamable HTTP transport.
// It blocks until ctx is cancelled or a fatal error occurs.
func (s *Server) Start(ctx context.Context) error {
	streamSrv := mcpserver.NewStreamableHTTPServer(s.mcpSrv)
	wrapped := BearerAuthMiddleware(s.cfg, streamSrv)

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

	go func() {
		<-ctx.Done()
		_ = httpSrv.Shutdown(context.Background())
	}()

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

// registerTools adds all 7 GoSQLX tools with their JSON Schema definitions.
func (s *Server) registerTools() {