Function upsertInboxThreadMessage

desktop/thread-state-db/inbox-writes.ts:79–121

(record: ThreadInboxMessageRecord)

}

export function upsertInboxThreadMessage(record: ThreadInboxMessageRecord) {
  const db = getThreadStateDatabase()
  const serializedContent = JSON.stringify(record.content)

  db.prepare(
    `
      INSERT INTO inbox_items (
        session_path,
        unread,
        last_user_prompt,
        last_assistant_message_json,
        last_assistant_preview,
        last_assistant_at_ms
      )
      VALUES (?, 1, ?, ?, ?, ?)
      ON CONFLICT(session_path) DO UPDATE SET
        unread = 1,
        last_user_prompt = excluded.last_user_prompt,
        last_assistant_message_json = excluded.last_assistant_message_json,
        last_assistant_preview = excluded.last_assistant_preview,
        last_assistant_at_ms = excluded.last_assistant_at_ms,
        updated_at = CURRENT_TIMESTAMP
    `,
  ).run(
    record.sessionPath,
    record.userPrompt,
    serializedContent,
    record.preview,
    record.lastAssistantAtMs,
  )

  db.prepare(
    `
      UPDATE threads
      SET
        last_assistant_message_json = ?,
        last_assistant_preview = ?,
        last_assistant_at_ms = ?,
        updated_at = CURRENT_TIMESTAMP
      WHERE session_path = ?
    `,
  ).run(serializedContent, record.preview, record.lastAssistantAtMs, record.sessionPath)
}