famapp/src/app/api/agent/chat/route.ts

import { z } from "zod";
import { apiError, apiJson } from "@/lib/api-handler";
import { resolveApiAuth } from "@/lib/api-auth";
import { getAssistantPreferences, resolveAssistantSystemPrompt } from "@/lib/assistant-preference";
import { isLlmConfigured } from "@/lib/llm";
import { encodeSseEvent } from "@/modules/agent/server/progress";
import { runAgentChat } from "@/modules/agent/server/run";

const chatInput = z.object({
  stream: z.boolean().optional(),
  messages: z
    .array(
      z.object({
        role: z.enum(["user", "assistant"]),
        content: z.string().trim().min(1).max(8000),
      }),
    )
    .min(1)
    .max(40),
});

export async function POST(request: Request) {
  const auth = await resolveApiAuth(request);
  if (!auth?.userId) {
    return apiError("Unauthorized", 401);
  }

  const assistant = await getAssistantPreferences(auth.userId);
  if (!assistant.enabled) {
    return apiError("Assistant not enabled", 403);
  }

  const systemPrompt = resolveAssistantSystemPrompt(assistant.systemPrompt);

  let body: unknown;
  try {
    body = await request.json();
  } catch {
    return apiError("Invalid JSON body", 400);
  }

  const parsed = chatInput.safeParse(body);
  if (!parsed.success) {
    return apiError(parsed.error.issues[0]?.message ?? "Validation error", 400);
  }

  if (parsed.data.stream) {
    const stream = new ReadableStream<Uint8Array>({
      async start(controller) {
        const encoder = new TextEncoder();
        const send = (event: Parameters<typeof encodeSseEvent>[0]) => {
          controller.enqueue(encoder.encode(encodeSseEvent(event)));
        };

        try {
          const result = await runAgentChat({
            messages: parsed.data.messages,
            request,
            systemPrompt,
            onProgress: send,
          });

          send({
            type: "done",
            message: {
              role: "assistant",
              content: result.message.content,
            },
            toolCalls: result.toolCalls,
          });
        } catch (err) {
          const message = err instanceof Error ? err.message : "Agent request failed";
          send({ type: "error", message });
        } finally {
          controller.close();
        }
      },
    });

    return new Response(stream, {
      headers: {
        "Content-Type": "text/event-stream; charset=utf-8",
        "Cache-Control": "no-cache, no-transform",
        Connection: "keep-alive",
      },
    });
  }

  try {
    const result = await runAgentChat({
      messages: parsed.data.messages,
      request,
      systemPrompt,
    });

    return apiJson({
      ...result,
      configured: isLlmConfigured(),
      provider: isLlmConfigured() ? "openai" : "mock",
    });
  } catch (err) {
    const message = err instanceof Error ? err.message : "Agent request failed";
    return apiError(message, 502);
  }
}