jianguo
/
wx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update: 更新

This commit is contained in:
Lexcubia 2025-04-21 11:01:18 +08:00
parent 226f3ff476
commit 1958abd246
1 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/utils/request.js
View File

@ -41,8 +41,9 @@ service.interceptors.response.use(
export const sseRequest = (config) => { export const sseRequest = (config) => {
return new Promise((resolve) => { return new Promise((resolve) => {
try { try {
const baseURL = isElectron ? process.env.VITE_APP_BASE_API : import.meta.env.VITE_APP_BASE_API const url = new URL(`${config.url}`, window.location.origin)
const url = new URL(`${config.url}`, baseURL) // const baseURL = isElectron ? process.env.VITE_APP_BASE_API : import.meta.env.VITE_APP_BASE_API
// const url = new URL(`${config.url}`, baseURL)
const ctrl = new AbortController() const ctrl = new AbortController()
let messageQueue = [] let messageQueue = []
let resolveQueue = null let resolveQueue = null
@ -54,21 +55,21 @@ export const sseRequest = (config) => {
'Authorization': config.headers?.Authorization || `Bearer ${localStorage.getItem('token')}`, 'Authorization': config.headers?.Authorization || `Bearer ${localStorage.getItem('token')}`,
'Content-Type': 'application/json', 'Content-Type': 'application/json',
'Accept': 'text/event-stream', 'Accept': 'text/event-stream',
'Cache-Control': 'no-cache', // 'Cache-Control': 'no-cache',
'Connection': 'keep-alive' // 'Connection': 'keep-alive'
}, },
body: JSON.stringify(config.params), body: JSON.stringify(config.params),
signal: ctrl.signal, signal: ctrl.signal,
openWhenHidden: true, openWhenHidden: true,
credentials: 'include', // credentials: 'include',
keepalive: true, // keepalive: true,
retry: 1000, // retry: 1000,
onopen(response) { // onopen(response) {
if (response.ok && response.headers.get('content-type')?.includes('text/event-stream')) { // if (response.ok && response.headers.get('content-type')?.includes('text/event-stream')) {
return; // return;
} // }
throw new Error(`Failed to open SSE connection: ${response.status} ${response.statusText}`); // throw new Error(`Failed to open SSE connection: ${response.status} ${response.statusText}`);
}, // },
onmessage: (event) => { onmessage: (event) => {
try { try {
const data = JSON.parse(event.data) const data = JSON.parse(event.data)