This commit is contained in:
@@ -81,7 +81,12 @@ export async function createSSEConnection(
|
|||||||
if (msg.trim()) {
|
if (msg.trim()) {
|
||||||
const { eventName, data } = parseSSEMessage(msg);
|
const { eventName, data } = parseSSEMessage(msg);
|
||||||
if (eventName && data) {
|
if (eventName && data) {
|
||||||
onEvent(eventName, data);
|
// 适配后端返回的嵌套数据格式
|
||||||
|
// 后端返回格式: { type: "chat", event: "start", data: {...}, timestamp: "..." }
|
||||||
|
// 实际事件类型在 data.event,实际数据在 data.data
|
||||||
|
const actualEventName = data.event || eventName;
|
||||||
|
const actualData = data.data || data;
|
||||||
|
onEvent(actualEventName, actualData);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user