Function getThread

packages/core/src/db/thread-queries.ts:47–74

(id: string)

}

export async function getThread(id: string): Promise<Thread | null> {
  const database = await getDB();
  const rows = 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 id = ?", [id]);
  if (rows.length === 0) return null;

  const row = rows[0];
  const messages = await getMessages(row.id);
  return {
    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,
  };
}

export async function insertThread(thread: Thread): Promise<void> {
  const database = await getDB();