feat: add pinned PRs feature

- Add 'pinned' column to SQLite schema for persistence
- Add toggle_pin() function to toggle pin state
- Add 'p' keybind in list view to toggle pin on selected PR
- Show dedicated 'PINNED' section at the top of the list
- Show 📌 indicator next to pinned PRs
- Pinned PRs are sorted first, then by score/updated
- Pin state persists across sessions via SQLite
- Update help text and footer with new keybind

Author: cesarferreira

src/db.rs

@@ -28,6 +28,7 @@ pub struct DbPrRow {
 
     pub last_seen_at: Option<i64>,
     pub last_opened_at: Option<i64>,
+    pub pinned: Option<i64>,
 }
 
 pub fn now_unix() -> i64 {
@@ -118,6 +119,7 @@ fn migrate_schema(conn: &Connection) -> Result<(), String> {
     add_if_missing(conn, &existing, "mergeable", "TEXT")?;
     add_if_missing(conn, &existing, "merge_state_status", "TEXT")?;
     add_if_missing(conn, &existing, "author_is_viewer", "INTEGER")?;
+    add_if_missing(conn, &existing, "pinned", "INTEGER")?;
 
     Ok(())
 }
@@ -146,7 +148,7 @@ SELECT
   pr_key, owner, repo, number, title, url, author, updated_at_unix,
   last_commit_sha, last_ci_state, last_review_state,
   ci_checks_json, is_draft, mergeable, merge_state_status, author_is_viewer,
-  last_seen_at, last_opened_at
+  last_seen_at, last_opened_at, pinned
 FROM prs
 "#,
         )
@@ -180,25 +182,28 @@ FROM prs
             author_is_viewer: row.get(15).map_err(|e| format!("Row decode: {e}"))?,
             last_seen_at: row.get(16).map_err(|e| format!("Row decode: {e}"))?,
             last_opened_at: row.get(17).map_err(|e| format!("Row decode: {e}"))?,
+            pinned: row.get(18).map_err(|e| format!("Row decode: {e}"))?,
         };
         out.insert(pr.pr_key.clone(), pr);
     }
     Ok(out)
 }
 
 pub fn upsert_pr(conn: &Connection, pr: &DbPrRow, last_seen_at: i64) -> Result<(), String> {
+    // Note: pinned is intentionally NOT updated here to preserve user's pin state.
+    // Use toggle_pin() to change the pinned state.
     conn.execute(
         r#"
 INSERT INTO prs (
   pr_key, owner, repo, number, title, url, author, updated_at_unix,
   last_commit_sha, last_ci_state, last_review_state,
   ci_checks_json, is_draft, mergeable, merge_state_status,
-  author_is_viewer, last_seen_at, last_opened_at
+  author_is_viewer, last_seen_at, last_opened_at, pinned
 ) VALUES (
   ?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8,
   ?9, ?10, ?11,
   ?12, ?13, ?14, ?15,
-  ?16, ?17, ?18
+  ?16, ?17, ?18, ?19
 )
 ON CONFLICT(pr_key) DO UPDATE SET
   owner = excluded.owner,
@@ -236,13 +241,37 @@ ON CONFLICT(pr_key) DO UPDATE SET
             pr.merge_state_status,
             pr.author_is_viewer,
             last_seen_at,
-            pr.last_opened_at
+            pr.last_opened_at,
+            pr.pinned
         ],
     )
     .map_err(|e| format!("Failed to upsert pr: {e}"))?;
     Ok(())
 }
 
+/// Toggle the pinned state of a PR. Returns the new pinned state.
+pub fn toggle_pin(conn: &Connection, pr_key: &str) -> Result<bool, String> {
+    // Get current state
+    let current: Option<i64> = conn
+        .query_row(
+            "SELECT pinned FROM prs WHERE pr_key = ?1",
+            params![pr_key],
+            |row| row.get(0),
+        )
+        .map_err(|e| format!("Failed to query pin state: {e}"))?;
+
+    let new_state = if current.unwrap_or(0) == 0 { 1 } else { 0 };
+
+    conn.execute(
+        "UPDATE prs SET pinned = ?1 WHERE pr_key = ?2",
+        params![new_state, pr_key],
+    )
+    .map_err(|e| format!("Failed to toggle pin: {e}"))?;
+
+    Ok(new_state == 1)
+}
+
+
 pub fn delete_prs_not_in(conn: &Connection, keep_pr_keys: &[String]) -> Result<(), String> {
     if keep_pr_keys.is_empty() {
         conn.execute("DELETE FROM prs", [])

src/refresh.rs

@@ -59,6 +59,7 @@ pub struct UiPr {
     pub display_status: String,
     pub is_new_review_request: bool,
     pub is_new_ci_failure: bool,
+    pub is_pinned: bool,
 }
 
 fn parse_ci_state(s: Option<&str>) -> CiState {
@@ -125,6 +126,7 @@ pub fn load_cached(
 
         let is_new_review = false;
         let is_new_ci_failure = false;
+        let is_pinned = row.pinned.unwrap_or(0) != 0;
         let score = score_pr(&pr, None, now, is_new_ci_failure);
         let category = category_for(&pr, score);
         let display_status = status_text(&pr, now, is_new_ci_failure, is_new_review);
@@ -136,12 +138,15 @@ pub fn load_cached(
             display_status,
             is_new_review_request: is_new_review,
             is_new_ci_failure,
+            is_pinned,
         });
     }
 
+    // Sort: pinned first, then by score desc, then by updated_at desc
     out.sort_by(|a, b| {
-        b.score
-            .cmp(&a.score)
+        b.is_pinned
+            .cmp(&a.is_pinned)
+            .then_with(|| b.score.cmp(&a.score))
             .then_with(|| b.pr.updated_at_unix.cmp(&a.pr.updated_at_unix))
     });
     Ok(out)
@@ -357,6 +362,7 @@ pub async fn refresh(
         let old = existing.get(&pr.pr_key);
         let new_review = is_new_review_request(&pr, old);
         let new_ci_failure = is_new_ci_failure(&pr, old);
+        let is_pinned = old.and_then(|r| r.pinned).unwrap_or(0) != 0;
 
         let db_row = DbPrRow {
             pr_key: pr.pr_key.clone(),
@@ -377,6 +383,7 @@ pub async fn refresh(
             author_is_viewer: Some(viewer_author_to_db(pr.is_viewer_author)),
             last_seen_at: Some(now),
             last_opened_at: old.and_then(|r| r.last_opened_at),
+            pinned: old.and_then(|r| r.pinned),
         };
         upsert_pr(conn, &db_row, now)?;
 
@@ -391,15 +398,18 @@ pub async fn refresh(
             display_status,
             is_new_review_request: new_review,
             is_new_ci_failure: new_ci_failure,
+            is_pinned,
         });
     }
 
     // Keep cache consistent with the current attention set so cached startup doesn't show stale/irrelevant PRs.
     delete_prs_not_in(conn, &keep_keys)?;
 
+    // Sort: pinned first, then by score desc, then by updated_at desc
     out.sort_by(|a, b| {
-        b.score
-            .cmp(&a.score)
+        b.is_pinned
+            .cmp(&a.is_pinned)
+            .then_with(|| b.score.cmp(&a.score))
             .then_with(|| b.pr.updated_at_unix.cmp(&a.pr.updated_at_unix))
     });
 
@@ -430,6 +440,7 @@ pub fn refresh_demo(
         let old = existing.get(&pr.pr_key);
         let new_review = is_new_review_request(&pr, old);
         let new_ci_failure = is_new_ci_failure(&pr, old);
+        let is_pinned = old.and_then(|r| r.pinned).unwrap_or(0) != 0;
 
         let db_row = DbPrRow {
             pr_key: pr.pr_key.clone(),
@@ -450,6 +461,7 @@ pub fn refresh_demo(
             author_is_viewer: Some(viewer_author_to_db(pr.is_viewer_author)),
             last_seen_at: Some(now),
             last_opened_at: old.and_then(|r| r.last_opened_at),
+            pinned: old.and_then(|r| r.pinned),
         };
         upsert_pr(conn, &db_row, now)?;
 
@@ -464,14 +476,17 @@ pub fn refresh_demo(
             display_status,
             is_new_review_request: new_review,
             is_new_ci_failure: new_ci_failure,
+            is_pinned,
         });
     }
 
     delete_prs_not_in(conn, &keep_keys)?;
 
+    // Sort: pinned first, then by score desc, then by updated_at desc
     out.sort_by(|a, b| {
-        b.score
-            .cmp(&a.score)
+        b.is_pinned
+            .cmp(&a.is_pinned)
+            .then_with(|| b.score.cmp(&a.score))
             .then_with(|| b.pr.updated_at_unix.cmp(&a.pr.updated_at_unix))
     });
     Ok(out)
@@ -588,6 +603,7 @@ mod tests {
             author_is_viewer: None,
             last_seen_at: Some(now - 10),
             last_opened_at: None,
+            pinned: None,
         };
 
         assert!(is_new_ci_failure(&pr, Some(&old)));