Function upsertThreadSummary

desktop/thread-state-db/session-writes.ts:84–129

(session: SessionSummaryRecord)

}

export function upsertThreadSummary(session: SessionSummaryRecord) {
  const db = getThreadStateDatabase()
  ensureProject(session.cwd)

  const storedThreadForPath = db
    .prepare(
      `
        SELECT id, session_path AS sessionPath
        FROM threads
        WHERE session_path = ?
      `,
    )
    .get(session.sessionPath) as ThreadIdPathRow | undefined
  const storedDuplicateIdRows = db
    .prepare(
      `
        SELECT id, session_path AS sessionPath
        FROM threads
        WHERE (id = ? OR id LIKE ? ESCAPE '\\')
          AND session_path != ?
      `,
    )
    .all(session.id, `${escapeLikePattern(session.id)}:%`, session.sessionPath) as ThreadIdPathRow[]

  const threadId =
    storedThreadForPath?.id && storedThreadForPath.id !== session.id
      ? storedThreadForPath.id
      : storedDuplicateIdRows.length > 0
        ? getDisambiguatedThreadId(session)
        : session.id

  db.prepare(
    `
      INSERT INTO threads (id, cwd, session_path, title, last_modified_ms)
      VALUES (?, ?, ?, ?, ?)
      ON CONFLICT(session_path) DO UPDATE SET
        id = excluded.id,
        cwd = excluded.cwd,
        title = excluded.title,
        last_modified_ms = excluded.last_modified_ms,
        updated_at = CURRENT_TIMESTAMP
    `,
  ).run(threadId, session.cwd, session.sessionPath, session.title, session.lastModifiedMs)

  return threadId
}

export function setSessionNativeExtensions(sessionPath: string, enabled: string[]) {
  const db = getThreadStateDatabase()