Merge pull request #1768 from GavanHub/fix/sse-error-handling

fix: SSE请求增加HTTP错误处理及401自动跳转登录

Author: coltea

web/app/src/components/QaModal/AiQaContent.tsx

@@ -11,7 +11,7 @@ import { postShareV1ChatFeedback } from '@/request/ShareChat';
 import { getShareV1ConversationDetail } from '@/request/ShareConversation';
 import { postShareV1CommonFileUpload } from '@/request/ShareFile';
 import { copyText } from '@/utils';
-import SSEClient from '@/utils/fetch';
+import SSEClient, { SSEHttpError } from '@/utils/fetch';
 import { Image as ImagePreview, message } from '@ctzhian/ui';
 import CloseIcon from '@mui/icons-material/Close';
 import ExpandMoreIcon from '@mui/icons-material/ExpandMore';
@@ -615,6 +615,16 @@ const AiQaContent: React.FC<{
       headers: {
         'Content-Type': 'application/json',
       },
+      onError: error => {
+        setLoading(false);
+        setThinking(4);
+        if (error instanceof SSEHttpError && error.status === 401) {
+          const current = window.location;
+          window.location.href = `${basePath}/auth/login?redirect=${encodeURIComponent(current.pathname + current.search)}`;
+          return;
+        }
+        message.error(error.message || '请求失败');
+      },
       onCancel: () => {
         setLoading(false);
         setThinking(4);

web/app/src/utils/fetch.ts

@@ -2,6 +2,15 @@ type SSECallback<T> = (data: T) => void;
 type SSEErrorCallback = (error: Error) => void;
 type SSECompleteCallback = () => void;
 
+export class SSEHttpError extends Error {
+  status: number;
+  constructor(status: number, message: string) {
+    super(message);
+    this.name = 'SSEHttpError';
+    this.status = status;
+  }
+}
+
 interface SSEClientOptions {
   url: string;
   headers?: Record<string, string>;
@@ -63,7 +72,13 @@ class SSEClient<T> {
       .then(async response => {
         if (!response.ok) {
           clearTimeout(timeoutId);
-          throw new Error(`HTTP error! status: ${response.status}`);
+          let errorMessage = `HTTP error! status: ${response.status}`;
+          try {
+            const body = await response.json();
+            if (body?.message) errorMessage = body.message;
+            else if (body?.error) errorMessage = body.error;
+          } catch {}
+          throw new SSEHttpError(response.status, errorMessage);
         }
         if (!response.body) {
           clearTimeout(timeoutId);