Function POST

tools/debug-console/app/api/chat/route.ts:102–202

(req: NextRequest)

});

export async function POST(req: NextRequest) {
  let body: unknown;
  try {
    body = await req.json();
  } catch {
    return NextResponse.json({ error: "invalid_json" }, { status: 400 });
  }

  const parsed = RequestSchema.safeParse(body);
  if (!parsed.success) {
    return NextResponse.json(
      { error: "invalid_request", details: parsed.error.flatten() },
      { status: 400 },
    );
  }

  const { provider: providerId, model, system, messages, tool_budget, mode, workspace } =
    parsed.data;
  const provider = getProvider(providerId as ProviderId);
  if (!provider) {
    return NextResponse.json({ error: "unknown_provider" }, { status: 400 });
  }
  if (!provider.isAvailable()) {
    return NextResponse.json(
      { error: "provider_unavailable", reason: provider.unavailableReason() },
      { status: 400 },
    );
  }

  // 客户端断开（关浏览器 / abort()）→ 触发 AbortController，
  // agent-loop / providers 监听后 kill subprocess、停止 fetch 流
  const abortController = new AbortController();
  // Next.js Route Handler 的 req.signal 在客户端断连时 fire abort
  req.signal.addEventListener("abort", () => abortController.abort(), { once: true });

  const stream = new ReadableStream({
    async start(controller) {
      let closed = false;
      const safeEnqueue = (chunk: Uint8Array) => {
        if (closed) return;
        try {
          controller.enqueue(chunk);
        } catch {
          // controller 已关闭——忽略
          closed = true;
        }
      };
      // 整段逻辑跑在 workspaceContext 作用域内：root_index 预热 + runAgent 深处的所有
      // executeTool 都会读到 workspace，并在调 web 时带上 kb_workspace cookie。
      await workspaceContext.run(workspace, async () => {
        try {
          const baseSystem = system || DEFAULT_SYSTEM_PROMPT;
          const indexContent = await getRootIndexContent(workspace);
          const augmentedSystem = appendPrewarmedIndex(baseSystem, indexContent);

          for await (const evt of runAgent({
            provider,
            model,