Function deleteThread

packages/core/src/db/thread-queries.ts:120–133

(id: string)

}

export async function deleteThread(id: string): Promise<void> {
  const database = await getDB();
  // Get all message IDs in this thread for tombstones
  const messages = await database.select<{ id: string }>(
    "SELECT id FROM messages WHERE thread_id = ?",
    [id],
  );
  for (const msg of messages) {
    await insertTombstone(database, msg.id, "messages");
  }
  await insertTombstone(database, id, "threads");
  await database.execute("DELETE FROM messages WHERE thread_id = ?", [id]);
  await database.execute("DELETE FROM threads WHERE id = ?", [id]);
}

export async function deleteThreadsByBookId(bookId: string): Promise<void> {
  const database = await getDB();