root/geo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: enable ws proxy in admin-web dev server and log compliance recheck failures

Browse Source 
- 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) <noreply@anthropic.com>
This commit is contained in:
liangxu
2026-05-06 12:57:03 +08:00
parent 68089d065f
commit f6aed87e44
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/admin-web/vite.config.ts
+1
View File
@@ -61,6 +61,7 @@ export default defineConfig(({ mode }) => {
'/api': { '/api': {
target: env.VITE_API_PROXY_TARGET || 'http://localhost:8080', target: env.VITE_API_PROXY_TARGET || 'http://localhost:8080',
changeOrigin: true, changeOrigin: true,
ws: true,
}, },
'/swagger': { '/swagger': {
target: env.VITE_API_PROXY_TARGET || 'http://localhost:8080', target: env.VITE_API_PROXY_TARGET || 'http://localhost:8080',
server/internal/tenant/app/desktop_task_service.go
+4 -1
View File
@@ -255,7 +255,7 @@ func (s *DesktopTaskService) recheckQueuedPublishTasksForClient(ctx context.Cont
return nil return nil
} }
rows, err := s.pool.Query(ctx, ` rows, err := s.pool.Query(ctx, `
SELECT DISTINCT SELECT
j.desktop_id, j.desktop_id,
j.tenant_id, j.tenant_id,
j.workspace_id, j.workspace_id,
@@ -276,6 +276,7 @@ func (s *DesktopTaskService) recheckQueuedPublishTasksForClient(ctx context.Cont
LIMIT 5 LIMIT 5
`, client.ID) `, client.ID)
if err != nil { 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") return response.ErrInternal(50118, "desktop_publish_compliance_recheck_failed", "failed to load publish jobs for compliance recheck")
} }
defer rows.Close() defer rows.Close()
@@ -293,6 +294,7 @@ func (s *DesktopTaskService) recheckQueuedPublishTasksForClient(ctx context.Cont
for rows.Next() { for rows.Next() {
var item candidate var item candidate
if scanErr := rows.Scan(&item.JobID, &item.TenantID, &item.WorkspaceID, &item.CreatedByUserID, &item.ArticleID, &item.ArticleVersionID, &item.Platforms); scanErr != nil { 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") 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 { 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 { 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") return response.ErrInternal(50118, "desktop_publish_compliance_recheck_failed", "failed to iterate publish jobs for compliance recheck")
} }