Function NewServer

api/server.go:20–85

NewServer 创建新的 API 服务器

(ctx context.Context)

// NewServer 创建新的 API 服务器
func NewServer(ctx context.Context) *Server {
	cfg := config.C().API

	factory := NewTaskFactory(ctx)
	handlers := NewHandlers(factory)

	// 设置路由
	mux := http.NewServeMux()

	// 健康检查
	mux.HandleFunc("/health", handlers.HealthCheckHandler)

	// API v1 路由
	mux.HandleFunc("/api/v1/tasks", func(w http.ResponseWriter, r *http.Request) {
		switch r.Method {
		case http.MethodGet:
			handlers.ListTasksHandler(w, r)
		case http.MethodPost:
			handlers.CreateTaskHandler(w, r)
		default:
			MethodNotAllowedHandler(w, r)
		}
	})
	mux.HandleFunc("/api/v1/tasks/", func(w http.ResponseWriter, r *http.Request) {
		// 根据方法和路径分发
		switch r.Method {
		case http.MethodGet:
			handlers.GetTaskHandler(w, r)
		case http.MethodDelete:
			handlers.CancelTaskHandler(w, r)
		default:
			MethodNotAllowedHandler(w, r)
		}
	})
	mux.HandleFunc("/api/v1/storages", handlers.ListStoragesHandler)
	mux.HandleFunc("/api/v1/task-types", handlers.GetTaskTypesHandler)

	// 404 处理
	mux.HandleFunc("/", NotFoundHandler)

	// Apply middleware chain.
	var handler http.Handler = mux

	// Apply auth middleware when a token is configured.
	token := cfg.Token
	if token != "" {
		handler = AuthMiddleware()(handler)
	}

	// Add logging middleware.
	handler = loggingMiddleware(handler)

	// Add recovery middleware.
	handler = recoveryMiddleware(handler)

	return &Server{
		httpServer: &http.Server{
			Addr:         fmt.Sprintf("%s:%d", cfg.Host, cfg.Port),