Function beginInboxThreadTurn

desktop/thread-state-db/inbox-writes.ts:18–56

(sessionPath: string, prompt: string | null)

}

export function beginInboxThreadTurn(sessionPath: string, prompt: string | null) {
  const db = getThreadStateDatabase()
  const resetInboxItem = db.prepare(
    `
      INSERT INTO inbox_items (
        session_path,
        unread,
        last_user_prompt,
        last_assistant_message_json,
        last_assistant_preview,
        last_assistant_at_ms
      )
      VALUES (?, 0, ?, NULL, NULL, NULL)
      ON CONFLICT(session_path) DO UPDATE SET
        unread = 0,
        last_user_prompt = excluded.last_user_prompt,
        last_assistant_message_json = NULL,
        last_assistant_preview = NULL,
        last_assistant_at_ms = NULL,
        updated_at = CURRENT_TIMESTAMP
    `,
  )
  const resetThreadAssistantSnapshot = db.prepare(
    `
      UPDATE threads
      SET
        last_assistant_message_json = NULL,
        last_assistant_preview = NULL,
        last_assistant_at_ms = NULL,
        updated_at = CURRENT_TIMESTAMP
      WHERE session_path = ?
    `,
  )

  runInTransaction(db, () => {
    resetInboxItem.run(sessionPath, prompt)
    resetThreadAssistantSnapshot.run(sessionPath)
  })
}

export function markInboxThreadRead(sessionPath: string) {
  const db = getThreadStateDatabase()