GitHub-Proxy/deer-flow
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/bytedance/deer-flow synced 2025-08-18 01:46:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: enhance mocking data

Browse Source
This commit is contained in:
Li Xin 2025-04-19 11:03:33 +08:00
parent 0fa890746a
commit 9758180e96
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
web/src/core/api/chat.ts
View File

@ -36,18 +36,24 @@ export function chatStream(
async function* chatStreamMock( async function* chatStreamMock(
userMessage: string, userMessage: string,
_: { params: {
thread_id: string; thread_id: string;
max_plan_iterations: number; max_plan_iterations: number;
max_step_num: number; max_step_num: number;
interrupt_feedback?: string;
} = { } = {
thread_id: "__mock__", thread_id: "__mock__",
max_plan_iterations: 3, max_plan_iterations: 3,
max_step_num: 1, max_step_num: 1,
interrupt_feedback: undefined,
}, },
options: { abortSignal?: AbortSignal } = {}, options: { abortSignal?: AbortSignal } = {},
): AsyncIterable<ChatEvent> { ): AsyncIterable<ChatEvent> {
const res = await fetch("/mock.txt", { const mockFile =
params.interrupt_feedback === "accepted"
? "/mock-before-interrupt.txt"
: "/mock-after-interrupt.txt";
const res = await fetch(mockFile, {
signal: options.abortSignal, signal: options.abortSignal,
}); });
await sleep(800); await sleep(800);
@ -58,7 +64,7 @@ async function* chatStreamMock(
const [, event] = eventRaw.split("event: ", 2) as [string, string]; const [, event] = eventRaw.split("event: ", 2) as [string, string];
const [, data] = dataRaw.split("data: ", 2) as [string, string]; const [, data] = dataRaw.split("data: ", 2) as [string, string];
if (event === "message_chunk") { if (event === "message_chunk") {
await sleep(0); await sleep(100);
} else if (event === "tool_call_result") { } else if (event === "tool_call_result") {
await sleep(1500); await sleep(1500);
} }