Function POST

notfair-cmo/src/app/api/chat/route.ts:41–221

(request: Request)

};

export async function POST(request: Request) {
  let body: ChatPostBody;
  try {
    body = (await request.json()) as ChatPostBody;
  } catch {
    return NextResponse.json({ error: "Invalid JSON body" }, { status: 400 });
  }
  if (!body?.message?.trim()) {
    return NextResponse.json({ error: "message is required" }, { status: 400 });
  }

  const project = body.project ? getProject(body.project) : await getActiveProject();
  if (!project) {
    return NextResponse.json(
      { error: "No active project. Create one first." },
      { status: 400 },
    );
  }

  const requestedSlug = (body.agent ?? "cmo").trim();
  const resolved = await resolveAgentBySlug(project.slug, requestedSlug);
  if (!resolved) {
    return NextResponse.json(
      { error: `Unknown agent: '${requestedSlug}'` },
      { status: 404 },
    );
  }

  const taskId = body.task_id?.trim();
  if (taskId) {
    const existing = getTask(taskId);
    if (!existing) {
      return NextResponse.json({ error: `Unknown task_id '${taskId}'` }, { status: 404 });
    }
    if (existing.agent_id !== resolved.agent_id) {
      return NextResponse.json(
        {
          error: `Task ${existing.display_id} belongs to ${existing.agent_id}, not ${resolved.agent_id}`,
        },
        { status: 400 },
      );
    }
    const claimed = claimProposedTask(existing.id);
    if (!claimed) {
      return NextResponse.json(
        { error: "task already claimed", status: existing.status, task_id: existing.id },
        { status: 409 },
      );
    }
  }

  const label =
    body.thread?.trim() || body.sessionId?.trim() || "main";
  const session = getOrCreateSession({
    project_slug: project.slug,
    agent_id: resolved.agent_id,
    label,
    harness_adapter: project.harness_adapter,