Method RegisterRoute

pkg/zen/server.go:281–328

RegisterRoute adds an HTTP route to the server with the specified middleware chain. Routes are matched by both method and path, unless the method is CATCHALL (empty string) which matches all methods. Middleware is applied in the order provided, with each middleware wrapping the next. The innermost

(middlewares []Middleware, route Route)

//	    zen.NewRoute(zen.CATCHALL, "/{path...}", proxyHandler),
//	)
func (s *Server) RegisterRoute(middlewares []Middleware, route Route) {
	path := route.Path()
	method := route.Method()
	logger.Info("registering", "method", method, "path", path)

	// Determine the pattern based on whether this is a catch-all route
	// Empty method means match all HTTP methods
	pattern := path
	if method != "" {
		pattern = method + " " + path
	}

	s.mux.HandleFunc(
		pattern,
		func(w http.ResponseWriter, r *http.Request) {
			sess, ok := s.getSession().(*Session)
			if !ok {
				panic("Unable to cast session")
			}

			defer func() {
				sess.reset()
				s.returnSession(sess)
			}()

			handleFn := route.Handle

			err := sess.Init(w, r, s.config.MaxRequestBodySize)
			if err != nil {
				logger.Error("failed to init session", "error", err)
				handleFn = func(_ context.Context, _ *Session) error {
					return err // Return the session init error
				}
			}

			// Reverses the middlewares to run in the desired order.
			// If middlewares are [A, B, C], this writes [C, B, A] to s.middlewares.
			for i := len(middlewares) - 1; i >= 0; i-- {
				handleFn = middlewares[i](handleFn)
			}

			err = handleFn(WithSession(r.Context(), sess), sess)

			if err != nil {
				panic(err)
			}
		})
}

// Shutdown gracefully stops the HTTP server, allowing in-flight requests
// to complete before returning or the context is canceled.