From 2b44ac5bcb8e0335e3c72800426c1e308ee5033f Mon Sep 17 00:00:00 2001 From: yusing Date: Sun, 13 Apr 2025 05:56:25 +0800 Subject: [PATCH] chore(api): remove debug task list endpoint --- internal/api/v1/list.go | 4 ---- internal/api/v1/query/query.go | 4 ---- internal/task/utils.go | 8 +------- 3 files changed, 1 insertion(+), 15 deletions(-) diff --git a/internal/api/v1/list.go b/internal/api/v1/list.go index ef6f95f..b727846 100644 --- a/internal/api/v1/list.go +++ b/internal/api/v1/list.go @@ -13,7 +13,6 @@ import ( "github.com/yusing/go-proxy/internal/net/gphttp/middleware" "github.com/yusing/go-proxy/internal/route/routes/routequery" route "github.com/yusing/go-proxy/internal/route/types" - "github.com/yusing/go-proxy/internal/task" "github.com/yusing/go-proxy/internal/utils" ) @@ -28,7 +27,6 @@ const ( ListRouteProviders = "route_providers" ListHomepageCategories = "homepage_categories" ListIcons = "icons" - ListTasks = "tasks" ) func List(cfg config.ConfigInstance, w http.ResponseWriter, r *http.Request) { @@ -76,8 +74,6 @@ func List(cfg config.ConfigInstance, w http.ResponseWriter, r *http.Request) { icons = []string{} } gphttp.RespondJSON(w, r, icons) - case ListTasks: - gphttp.RespondJSON(w, r, task.DebugTaskList()) default: gphttp.BadRequest(w, fmt.Sprintf("invalid what: %s", what)) } diff --git a/internal/api/v1/query/query.go b/internal/api/v1/query/query.go index 0a1d576..4463834 100644 --- a/internal/api/v1/query/query.go +++ b/internal/api/v1/query/query.go @@ -58,7 +58,3 @@ func ListRoutes() (map[string]map[string]any, gperr.Error) { func ListMiddlewareTraces() (middleware.Traces, gperr.Error) { return List[middleware.Traces](v1.ListMiddlewareTraces) } - -func DebugListTasks() (map[string]any, gperr.Error) { - return List[map[string]any](v1.ListTasks) -} diff --git a/internal/task/utils.go b/internal/task/utils.go index da0bc36..5e8a803 100644 --- a/internal/task/utils.go +++ b/internal/task/utils.go @@ -2,7 +2,6 @@ package task import ( "context" - "encoding/json" "errors" "os" "os/signal" @@ -66,12 +65,7 @@ func GracefulShutdown(timeout time.Duration) (err error) { case <-root.finished: return case <-after: - b, err := json.Marshal(DebugTaskList()) - if err != nil { - logging.Warn().Err(err).Msg("failed to marshal tasks") - return context.DeadlineExceeded - } - logging.Warn().RawJSON("tasks", b).Msgf("Timeout waiting for these %d tasks to finish", allTasks.Size()) + logging.Warn().Msgf("Timeout waiting for %d tasks to finish", allTasks.Size()) return context.DeadlineExceeded } }