refactor(llm): extract controllers from routes + human review

- Create dedicated controllers in /src/adapters/controllers/llm/
  - stream-completion.controller.ts
  - send-chat-message.controller.ts
  - get-conversation.controller.ts
  - list-conversations.controller.ts
  - delete-conversation.controller.ts
  - list-messages.controller.ts
  - get-usage-stats.controller.ts
  - check-budget.controller.ts

- Create thin route delegation in /app/api/llm/
  - conversations/route.ts (GET, POST)
  - conversations/[id]/route.ts (GET, DELETE)
  - conversations/[id]/messages/route.ts (GET)
  - usage/route.ts (GET)
  - budget/route.ts (GET)

- Fix transaction handling in deleteConversationAction
- Add ITransactionManagerService to DI_SYMBOLS
- Human review and refactoring pass

Author: axelhamil

apps/nextjs/app/(protected)/_components/sidebar.tsx

@@ -8,7 +8,6 @@ import {
   LayoutDashboard,
   MessageSquare,
   Settings,
-  Users,
 } from "lucide-react";
 import Link from "next/link";
 import { usePathname } from "next/navigation";
@@ -18,7 +17,6 @@ const navigation = [
   { name: "Chat", href: "/chat", icon: MessageSquare },
   { name: "Prompts", href: "/admin/prompts", icon: FileText },
   { name: "Usage", href: "/admin/usage", icon: BarChart3 },
-  { name: "Team", href: "/team", icon: Users },
   { name: "Billing", href: "/settings/billing", icon: CreditCard },
   { name: "Settings", href: "/settings", icon: Settings },
 ];

apps/nextjs/app/api/llm/budget/route.ts

@@ -0,0 +1,5 @@
+import { checkBudgetController } from "@/adapters/controllers/llm/check-budget.controller";
+
+export async function GET(request: Request) {
+  return checkBudgetController(request);
+}

apps/nextjs/app/api/llm/chat/route.ts

@@ -1,43 +1,5 @@
-import { NextResponse } from "next/server";
-import { authGuard } from "@/adapters/guards/auth.guard";
-import { streamCompletionInputDtoSchema } from "@/application/dto/llm/stream-completion.dto";
-import { getInjection } from "@/common/di/container";
+import { streamCompletionController } from "@/adapters/controllers/llm/stream-completion.controller";
 
 export async function POST(request: Request) {
-  const guardResult = await authGuard();
-
-  if (!guardResult.authenticated) {
-    return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
-  }
-
-  const body = await request.json();
-  const parseResult = streamCompletionInputDtoSchema.safeParse(body);
-
-  if (!parseResult.success) {
-    return NextResponse.json(
-      { error: parseResult.error.issues[0]?.message ?? "Invalid input" },
-      { status: 400 },
-    );
-  }
-
-  const useCase = getInjection("StreamCompletionUseCase");
-  const result = await useCase.execute({
-    ...parseResult.data,
-    userId: guardResult.session.user.id,
-  });
-
-  if (result.isFailure) {
-    return NextResponse.json({ error: result.getError() }, { status: 400 });
-  }
-
-  const { stream, model, provider } = result.getValue();
-
-  return new Response(stream, {
-    headers: {
-      "Content-Type": "text/plain; charset=utf-8",
-      "Transfer-Encoding": "chunked",
-      "X-LLM-Model": model,
-      "X-LLM-Provider": provider,
-    },
-  });
+  return streamCompletionController(request);
 }

apps/nextjs/app/api/llm/conversations/[id]/messages/route.ts

@@ -0,0 +1,10 @@
+import { listMessagesController } from "@/adapters/controllers/llm/list-messages.controller";
+
+interface RouteParams {
+  params: Promise<{ id: string }>;
+}
+
+export async function GET(request: Request, { params }: RouteParams) {
+  const { id } = await params;
+  return listMessagesController(request, id);
+}

apps/nextjs/app/api/llm/conversations/[id]/route.ts

@@ -0,0 +1,16 @@
+import { deleteConversationController } from "@/adapters/controllers/llm/delete-conversation.controller";
+import { getConversationController } from "@/adapters/controllers/llm/get-conversation.controller";
+
+interface RouteParams {
+  params: Promise<{ id: string }>;
+}
+
+export async function GET(request: Request, { params }: RouteParams) {
+  const { id } = await params;
+  return getConversationController(request, id);
+}
+
+export async function DELETE(request: Request, { params }: RouteParams) {
+  const { id } = await params;
+  return deleteConversationController(request, id);
+}

apps/nextjs/app/api/llm/conversations/route.ts

@@ -0,0 +1,10 @@
+import { listConversationsController } from "@/adapters/controllers/llm/list-conversations.controller";
+import { sendChatMessageController } from "@/adapters/controllers/llm/send-chat-message.controller";
+
+export async function GET(request: Request) {
+  return listConversationsController(request);
+}
+
+export async function POST(request: Request) {
+  return sendChatMessageController(request);
+}

apps/nextjs/app/api/llm/usage/route.ts

@@ -0,0 +1,5 @@
+import { getUsageStatsController } from "@/adapters/controllers/llm/get-usage-stats.controller";
+
+export async function GET(request: Request) {
+  return getUsageStatsController(request);
+}

apps/nextjs/common/di/modules/transaction.module.ts

@@ -0,0 +1,16 @@
+import { createModule } from "@evyweb/ioctopus";
+import { TransactionService } from "@packages/drizzle";
+import { env } from "@/common/env";
+import { DI_SYMBOLS } from "../types";
+
+export const createTransactionModule = () => {
+  const transactionModule = createModule();
+  if (env.NODE_ENV === "test") {
+  } else {
+    transactionModule
+      .bind(DI_SYMBOLS.ITransactionManagerService)
+      .toClass(TransactionService);
+  }
+
+  return transactionModule;
+};

apps/nextjs/common/di/types.ts

@@ -1,3 +1,4 @@
+import type { ITransactionManagerService } from "@packages/drizzle/services/transaction-manager.type";
 import type { IAuthProvider } from "@/application/ports/auth.service.port";
 import type { IConversationRepository } from "@/application/ports/conversation.repository.port";
 import type { IEmailService } from "@/application/ports/email.service.port";
@@ -74,6 +75,7 @@ export const DI_SYMBOLS = {
   EstimateCostUseCase: Symbol.for("EstimateCostUseCase"),
   GetUsageStatsUseCase: Symbol.for("GetUsageStatsUseCase"),
   CheckBudgetUseCase: Symbol.for("CheckBudgetUseCase"),
+  ITransactionManagerService: Symbol.for("ITransactionManagerService"),
 };
 
 export interface DI_RETURN_TYPES {
@@ -114,4 +116,5 @@ export interface DI_RETURN_TYPES {
   EstimateCostUseCase: EstimateCostUseCase;
   GetUsageStatsUseCase: GetUsageStatsUseCase;
   CheckBudgetUseCase: CheckBudgetUseCase;
+  ITransactionManagerService: ITransactionManagerService;
 }

apps/nextjs/src/__TESTS__/application/llm/delete-conversation-use-case.test.ts

@@ -6,6 +6,7 @@ import type { IEventDispatcher } from "@/application/ports/event-dispatcher.port
 import { DeleteConversationUseCase } from "@/application/use-cases/llm/delete-conversation.use-case";
 import { Conversation } from "@/domain/llm/conversation/conversation.aggregate";
 import { ConversationDeletedEvent } from "@/domain/llm/conversation/events/conversation-deleted.event";
+import { UserId } from "@/domain/user/user-id";
 
 describe("DeleteConversationUseCase", () => {
   let useCase: DeleteConversationUseCase;
@@ -23,7 +24,7 @@ describe("DeleteConversationUseCase", () => {
   const createMockConversation = (ownerId: string = userId): Conversation => {
     return Conversation.create(
       {
-        userId: ownerId,
+        userId: UserId.create(new UUID(ownerId)),
         title: Option.none(),
         metadata: Option.none(),
       },