Improve desktop runtime visibility and session parsing

Author: hwisu

crates/api/migrations/local_0005_lifecycle_cleanup_status.sql

@@ -0,0 +1,14 @@
+-- Desktop lifecycle cleanup progress/status snapshot
+CREATE TABLE IF NOT EXISTS lifecycle_cleanup_jobs (
+    id                INTEGER PRIMARY KEY AUTOINCREMENT,
+    status            TEXT NOT NULL,
+    deleted_sessions  INTEGER NOT NULL DEFAULT 0,
+    deleted_summaries INTEGER NOT NULL DEFAULT 0,
+    message           TEXT,
+    started_at        TEXT,
+    finished_at       TEXT,
+    updated_at        TEXT NOT NULL DEFAULT (datetime('now'))
+);
+
+CREATE INDEX IF NOT EXISTS idx_lifecycle_cleanup_jobs_status
+    ON lifecycle_cleanup_jobs(status, updated_at DESC);

crates/api/src/db/migrations.rs

@@ -31,6 +31,10 @@ pub const LOCAL_MIGRATIONS: &[Migration] = &[
         "local_0004_summary_batch_status",
         include_str!("../../migrations/local_0004_summary_batch_status.sql"),
     ),
+    (
+        "local_0005_lifecycle_cleanup_status",
+        include_str!("../../migrations/local_0005_lifecycle_cleanup_status.sql"),
+    ),
 ];
 
 #[cfg(test)]
@@ -41,11 +45,12 @@ mod tests {
     fn schema_migration_set_is_minimal() {
         assert_eq!(MIGRATIONS.len(), 1);
         assert_eq!(MIGRATIONS[0].0, "0001_schema");
-        assert_eq!(LOCAL_MIGRATIONS.len(), 4);
+        assert_eq!(LOCAL_MIGRATIONS.len(), 5);
         assert_eq!(LOCAL_MIGRATIONS[0].0, "local_0001_schema");
         assert_eq!(LOCAL_MIGRATIONS[1].0, "local_0002_session_summaries");
         assert_eq!(LOCAL_MIGRATIONS[2].0, "local_0003_vector_index");
         assert_eq!(LOCAL_MIGRATIONS[3].0, "local_0004_summary_batch_status");
+        assert_eq!(LOCAL_MIGRATIONS[4].0, "local_0005_lifecycle_cleanup_status");
     }
 
     #[test]

crates/api/src/lib.rs

@@ -876,6 +876,32 @@ pub struct DesktopRuntimeLifecycleSettingsUpdate {
     pub cleanup_interval_secs: u64,
 }
 
+#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
+#[serde(rename_all = "snake_case")]
+#[cfg_attr(feature = "ts", derive(ts_rs::TS))]
+#[cfg_attr(feature = "ts", ts(export))]
+pub enum DesktopLifecycleCleanupState {
+    Idle,
+    Running,
+    Complete,
+    Failed,
+}
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+#[cfg_attr(feature = "ts", derive(ts_rs::TS))]
+#[cfg_attr(feature = "ts", ts(export))]
+pub struct DesktopLifecycleCleanupStatusResponse {
+    pub state: DesktopLifecycleCleanupState,
+    pub deleted_sessions: u32,
+    pub deleted_summaries: u32,
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub message: Option<String>,
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub started_at: Option<String>,
+    #[serde(default, skip_serializing_if = "Option::is_none")]
+    pub finished_at: Option<String>,
+}
+
 #[derive(Debug, Clone, Serialize, Deserialize)]
 #[cfg_attr(feature = "ts", derive(ts_rs::TS))]
 #[cfg_attr(feature = "ts", ts(export))]
@@ -1841,6 +1867,8 @@ mod tests {
             DesktopRuntimeChangeReaderSettingsUpdate,
             DesktopRuntimeLifecycleSettings,
             DesktopRuntimeLifecycleSettingsUpdate,
+            DesktopLifecycleCleanupState,
+            DesktopLifecycleCleanupStatusResponse,
             DesktopVectorPreflightResponse,
             DesktopVectorInstallStatusResponse,
             DesktopVectorIndexStatusResponse,

crates/local-db/src/lib.rs

@@ -145,6 +145,17 @@ pub struct SummaryBatchJobRow {
     pub finished_at: Option<String>,
 }
 
+/// Lifecycle cleanup progress/status snapshot.
+#[derive(Debug, Clone, PartialEq, Eq)]
+pub struct LifecycleCleanupJobRow {
+    pub status: String,
+    pub deleted_sessions: u32,
+    pub deleted_summaries: u32,
+    pub message: Option<String>,
+    pub started_at: Option<String>,
+    pub finished_at: Option<String>,
+}
+
 fn infer_tool_from_source_path(source_path: Option<&str>) -> Option<&'static str> {
     let source_path = source_path.map(|path| path.to_ascii_lowercase())?;
 
@@ -1436,6 +1447,53 @@ impl LocalDb {
         Ok(row)
     }
 
+    pub fn set_lifecycle_cleanup_job(&self, payload: &LifecycleCleanupJobRow) -> Result<()> {
+        self.conn().execute(
+            "INSERT INTO lifecycle_cleanup_jobs \
+             (id, status, deleted_sessions, deleted_summaries, message, started_at, finished_at, updated_at) \
+             VALUES (1, ?1, ?2, ?3, ?4, ?5, ?6, datetime('now')) \
+             ON CONFLICT(id) DO UPDATE SET \
+             status=excluded.status, \
+             deleted_sessions=excluded.deleted_sessions, \
+             deleted_summaries=excluded.deleted_summaries, \
+             message=excluded.message, \
+             started_at=excluded.started_at, \
+             finished_at=excluded.finished_at, \
+             updated_at=datetime('now')",
+            params![
+                payload.status,
+                payload.deleted_sessions as i64,
+                payload.deleted_summaries as i64,
+                payload.message,
+                payload.started_at,
+                payload.finished_at,
+            ],
+        )?;
+        Ok(())
+    }
+
+    pub fn get_lifecycle_cleanup_job(&self) -> Result<Option<LifecycleCleanupJobRow>> {
+        let row = self
+            .conn()
+            .query_row(
+                "SELECT status, deleted_sessions, deleted_summaries, message, started_at, finished_at \
+                 FROM lifecycle_cleanup_jobs WHERE id = 1 LIMIT 1",
+                [],
+                |row| {
+                    Ok(LifecycleCleanupJobRow {
+                        status: row.get(0)?,
+                        deleted_sessions: row.get::<_, i64>(1)?.max(0) as u32,
+                        deleted_summaries: row.get::<_, i64>(2)?.max(0) as u32,
+                        message: row.get(3)?,
+                        started_at: row.get(4)?,
+                        finished_at: row.get(5)?,
+                    })
+                },
+            )
+            .optional()?;
+        Ok(row)
+    }
+
     // ── Sync cursor ────────────────────────────────────────────────────
 
     pub fn get_sync_cursor(&self, team_id: &str) -> Result<Option<String>> {
@@ -2538,10 +2596,14 @@ mod tests {
             migration_names.contains(&"local_0004_summary_batch_status"),
             "expected local_0004_summary_batch_status migration from opensession-api"
         );
+        assert!(
+            migration_names.contains(&"local_0005_lifecycle_cleanup_status"),
+            "expected local_0005_lifecycle_cleanup_status migration from opensession-api"
+        );
         assert_eq!(
             migration_names.len(),
-            4,
-            "local schema should include baseline + summary cache + vector index + summary batch status steps"
+            5,
+            "local schema should include baseline + summary cache + vector index + summary batch status + lifecycle cleanup status steps"
         );
 
         let manifest_dir = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
@@ -3427,6 +3489,30 @@ mod tests {
         assert_eq!(loaded.message.as_deref(), Some("processing summaries"));
     }
 
+    #[test]
+    fn test_lifecycle_cleanup_job_round_trip() {
+        let db = test_db();
+        let payload = LifecycleCleanupJobRow {
+            status: "complete".to_string(),
+            deleted_sessions: 3,
+            deleted_summaries: 7,
+            message: Some("cleanup complete".to_string()),
+            started_at: Some("2026-03-06T01:00:00Z".to_string()),
+            finished_at: Some("2026-03-06T01:00:04Z".to_string()),
+        };
+        db.set_lifecycle_cleanup_job(&payload)
+            .expect("set lifecycle cleanup job snapshot");
+
+        let loaded = db
+            .get_lifecycle_cleanup_job()
+            .expect("read lifecycle cleanup job snapshot")
+            .expect("lifecycle cleanup row should exist");
+        assert_eq!(loaded.status, "complete");
+        assert_eq!(loaded.deleted_sessions, 3);
+        assert_eq!(loaded.deleted_summaries, 7);
+        assert_eq!(loaded.message.as_deref(), Some("cleanup complete"));
+    }
+
     #[test]
     fn test_session_count() {
         let db = test_db();