Function start

notfair-cmo/src/app/api/chat/route.ts:107–211

(controller)

  const stream = new ReadableStream({
    async start(controller) {
      let clientOpen = true;
      const send = (event: string, data: unknown) => {
        if (!clientOpen) return;
        try {
          controller.enqueue(
            encoder.encode(`event: ${event}\ndata: ${JSON.stringify(data)}\n\n`),
          );
        } catch {
          clientOpen = false;
        }
      };

      // Disconnect != cancel: the harness keeps running and persisting events
      // to the transcript. The user sees them on next attach.
      const noAbort = new AbortController();

      try {
        send("meta", {
          project_slug: project.slug,
          agent: resolved.agent_id,
          session_id: session.id,
          harness_adapter: project.harness_adapter,
          message_chars: body.message.length,
          is_kickoff: Boolean(taskId),
        });

        for await (const evt of adapter.execute({
          projectSlug: project.slug,
          agentId: resolved.agent_id,
          workspaceDir: workspaceDirFor(resolved.agent_id),
          message: body.message,
          threadId: session.id,
          harnessSessionId: session.harness_session_id,
          signal: noAbort.signal,
        })) {
          if (evt.kind === "session") {
            // Remember the harness's own session id so the next turn can
            // pass it back via --resume / `exec resume`. Don't persist as
            // a transcript event — it's metadata, not chat content.
            touchSession(session.id, evt.harnessSessionId);
            continue;
          }
          try {
            appendTranscriptEvent(session.id, evt.kind, evt);
          } catch (err) {
            console.error("[api/chat] transcript persist failed:", err);
          }

          if (evt.kind === "delta") {
            send("text", { chunk: evt.text });
          } else if (evt.kind === "tool") {
            send("tool", {
              phase: evt.phase,
              tool_call_id: evt.toolCallId,
              name: evt.name,
              label: evt.label,
            });