Function getThreads

packages/core/src/db/thread-queries.ts:5–45

(bookId?: string)

import { getMessages } from "./message-queries";

export async function getThreads(bookId?: string): Promise<Thread[]> {
  const database = await getDB();
  const rows = bookId
    ? await database.select<{
        id: string;
        book_id: string | null;
        title: string;
        memory_summary: string | null;
        memory_updated_at: number | null;
        memory_message_count: number | null;
        created_at: number;
        updated_at: number;
      }>("SELECT * FROM threads WHERE book_id = ? ORDER BY updated_at DESC", [bookId])
    : await database.select<{
        id: string;
        book_id: string | null;
        title: string;
        memory_summary: string | null;
        memory_updated_at: number | null;
        memory_message_count: number | null;
        created_at: number;
        updated_at: number;
      }>("SELECT * FROM threads ORDER BY updated_at DESC");

  const threads: Thread[] = [];
  for (const row of rows) {
    const messages = await getMessages(row.id);
    threads.push({
      id: row.id,
      bookId: row.book_id || undefined,
      title: row.title,
      messages,
      memorySummary: row.memory_summary || undefined,
      memoryUpdatedAt: row.memory_updated_at || undefined,
      memoryMessageCount: row.memory_message_count || 0,
      createdAt: row.created_at,
      updatedAt: row.updated_at,
    });
  }
  return threads;
}

export async function getThread(id: string): Promise<Thread | null> {
  const database = await getDB();