From f6aed87e44ecbc9414034a59214fd4440cc93f99 Mon Sep 17 00:00:00 2001 From: liangxu Date: Wed, 6 May 2026 12:57:03 +0800 Subject: [PATCH] chore: enable ws proxy in admin-web dev server and log compliance recheck failures - admin-web vite dev server now proxies websockets on /api so live features (e.g. SSE/WS) work in development. - Tenant desktop publish compliance recheck now logs warnings when the query, scan or row iteration fails so the silent 50118 errors can be diagnosed. Co-Authored-By: Claude Opus 4.7 (1M context) --- apps/admin-web/vite.config.ts | 1 + server/internal/tenant/app/desktop_task_service.go | 5 ++++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/apps/admin-web/vite.config.ts b/apps/admin-web/vite.config.ts index 8499319..da8c35c 100644 --- a/apps/admin-web/vite.config.ts +++ b/apps/admin-web/vite.config.ts @@ -61,6 +61,7 @@ export default defineConfig(({ mode }) => { '/api': { target: env.VITE_API_PROXY_TARGET || 'http://localhost:8080', changeOrigin: true, + ws: true, }, '/swagger': { target: env.VITE_API_PROXY_TARGET || 'http://localhost:8080', diff --git a/server/internal/tenant/app/desktop_task_service.go b/server/internal/tenant/app/desktop_task_service.go index 9abeb14..1a1922f 100644 --- a/server/internal/tenant/app/desktop_task_service.go +++ b/server/internal/tenant/app/desktop_task_service.go @@ -255,7 +255,7 @@ func (s *DesktopTaskService) recheckQueuedPublishTasksForClient(ctx context.Cont return nil } rows, err := s.pool.Query(ctx, ` - SELECT DISTINCT + SELECT j.desktop_id, j.tenant_id, j.workspace_id, @@ -276,6 +276,7 @@ func (s *DesktopTaskService) recheckQueuedPublishTasksForClient(ctx context.Cont LIMIT 5 `, client.ID) if err != nil { + s.logWarn("desktop publish compliance recheck query failed", err, zap.String("client_id", client.ID.String())) return response.ErrInternal(50118, "desktop_publish_compliance_recheck_failed", "failed to load publish jobs for compliance recheck") } defer rows.Close() @@ -293,6 +294,7 @@ func (s *DesktopTaskService) recheckQueuedPublishTasksForClient(ctx context.Cont for rows.Next() { var item candidate if scanErr := rows.Scan(&item.JobID, &item.TenantID, &item.WorkspaceID, &item.CreatedByUserID, &item.ArticleID, &item.ArticleVersionID, &item.Platforms); scanErr != nil { + s.logWarn("desktop publish compliance recheck scan failed", scanErr, zap.String("client_id", client.ID.String())) return response.ErrInternal(50118, "desktop_publish_compliance_recheck_failed", "failed to scan publish job for compliance recheck") } if item.WorkspaceID == client.WorkspaceID && item.TenantID == client.TenantID { @@ -300,6 +302,7 @@ func (s *DesktopTaskService) recheckQueuedPublishTasksForClient(ctx context.Cont } } if err := rows.Err(); err != nil { + s.logWarn("desktop publish compliance recheck rows failed", err, zap.String("client_id", client.ID.String())) return response.ErrInternal(50118, "desktop_publish_compliance_recheck_failed", "failed to iterate publish jobs for compliance recheck") }