Fix chat list by project (#128)

Add proper filtering per project

Author: SferaDev

apps/dbagent/src/app/api/chat/route.ts

@@ -5,7 +5,7 @@ import { generateTitleFromUserMessage } from '~/app/(main)/projects/[project]/ch
 import { generateUUID } from '~/components/chat/utils';
 import { getChatSystemPrompt, getModelInstance } from '~/lib/ai/agent';
 import { getTools } from '~/lib/ai/tools';
-import { deleteChatById, getChatById, getChats, saveMessages, updateChat } from '~/lib/db/chats';
+import { deleteChatById, getChatById, getChatsByProject, saveMessages, updateChat } from '~/lib/db/chats';
 import { getConnection } from '~/lib/db/connections';
 import { getUserSessionDBAccess } from '~/lib/db/db';
 import { getProjectById } from '~/lib/db/projects';
@@ -16,11 +16,18 @@ export const maxDuration = 60;
 
 export async function GET(request: NextRequest) {
   const { searchParams } = new URL(request.url);
+
+  const project = searchParams.get('project');
+  if (!project) {
+    return new Response('Project is required', { status: 400 });
+  }
+
   const limit = parseInt(searchParams.get('limit') || '10', 10);
+  const offset = parseInt(searchParams.get('offset') || '0', 10);
 
   const dbAccess = await getUserSessionDBAccess();
 
-  const chats = await getChats(dbAccess, { limit });
+  const chats = await getChatsByProject(dbAccess, { project, limit, offset });
 
   return Response.json({ chats });
 }

apps/dbagent/src/components/ui/side-nav.tsx

@@ -72,7 +72,7 @@ export function SideNav({ className, project, onboardingComplete }: SideNavProps
   const queryClient = useQueryClient();
   const { data: { chats = [] } = {} } = useQuery<{ chats: Chat[] }>({
     queryKey: ['chats'],
-    queryFn: () => fetcher('/api/chat')
+    queryFn: () => fetcher(`/api/chat?project=${project.id}`)
   });
 
   const isActive = (path: string) => {

apps/dbagent/src/lib/db/chats.ts

@@ -41,9 +41,26 @@ export async function deleteChatById(dbAccess: DBAccess, { id }: { id: string })
   });
 }
 
-export async function getChats(dbAccess: DBAccess, { limit = 100, offset = 0 }: { limit?: number; offset?: number }) {
+export async function getChatsByProject(
+  dbAccess: DBAccess,
+  {
+    project,
+    limit = 100,
+    offset = 0
+  }: {
+    project: string;
+    limit?: number;
+    offset?: number;
+  }
+) {
   return dbAccess.query(async ({ db }) => {
-    return await db.select().from(chats).orderBy(desc(chats.createdAt)).limit(limit).offset(offset);
+    return await db
+      .select()
+      .from(chats)
+      .where(eq(chats.projectId, project))
+      .orderBy(desc(chats.createdAt))
+      .limit(limit)
+      .offset(offset);
   });
 }