Function syncSessionSummaries

desktop/thread-state-db/session-writes.ts:42–82

(cwd: string, sessions: SessionSummaryRecord[])

}

export function syncSessionSummaries(cwd: string, sessions: SessionSummaryRecord[]) {
  const db = getThreadStateDatabase()
  const insertProject = db.prepare(
    `
      INSERT INTO projects (cwd, name, collapsed, hidden)
      VALUES (?, ?, 1, 0)
      ON CONFLICT(cwd) DO UPDATE SET
        name = excluded.name,
        updated_at = CURRENT_TIMESTAMP
    `,
  )
  const insertThread = 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
    `,
  )
  ensureProject(cwd)
  runInTransaction(db, () => {
    const duplicateSessionIds = getDuplicateSessionIds(sessions)

    for (const session of sessions) {
      insertProject.run(session.cwd, path.basename(session.cwd) || session.cwd)
      const threadId = getSessionThreadId(session, duplicateSessionIds)

      insertThread.run(
        threadId,
        session.cwd,
        session.sessionPath,
        session.title,
        session.lastModifiedMs,
      )
    }
  })
}

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