sift_queue/cli/commands/
list.rs

1use crate::cli::formatters;
2use crate::queue::{Item, Queue};
3use crate::ListArgs;
4use anyhow::Result;
5use std::collections::HashSet;
6use std::io::Write;
7use std::path::PathBuf;
8use std::process::{Command, Stdio};
9
10/// Execute the `sq list` command.
11pub fn execute(args: &ListArgs, queue_path: PathBuf) -> Result<i32> {
12    let queue = Queue::new(queue_path);
13
14    let mut items: Vec<Item> = if args.ready {
15        queue.ready()
16    } else if let Some(status) = args.status.as_deref() {
17        queue.filter(Some(status))
18    } else if args.all {
19        queue.filter(None)
20    } else {
21        queue
22            .all()
23            .into_iter()
24            .filter(|item| item.status != "closed")
25            .collect()
26    };
27
28    // Apply jq filter
29    if let Some(ref filter_expr) = args.filter {
30        let expr = format!("[.[] | {}]", filter_expr);
31        match jq_filter(&items, &expr) {
32            Some(filtered) => items = filtered,
33            None => return Ok(1),
34        }
35    }
36
37    // Apply jq sort
38    if let Some(ref sort_path) = args.sort {
39        let expr = format!("sort_by({} // infinite)", sort_path);
40        match jq_filter(&items, &expr) {
41            Some(sorted) => items = sorted,
42            None => return Ok(1),
43        }
44    }
45
46    // Apply reverse
47    if args.reverse {
48        items.reverse();
49    }
50
51    if args.json {
52        let values: Vec<serde_json::Value> =
53            items.iter().map(|i: &Item| i.to_json_value()).collect();
54        let json = serde_json::to_string_pretty(&values)?;
55        println!("{}", json);
56    } else if items.is_empty() {
57        eprintln!("No items found");
58    } else {
59        let pending_ids: HashSet<String> = queue
60            .filter(Some("pending"))
61            .iter()
62            .map(|i| i.id.clone())
63            .collect();
64        for item in &items {
65            formatters::print_item_summary(item, Some(&pending_ids));
66        }
67        eprintln!("{} item(s)", items.len());
68    }
69
70    Ok(0)
71}
72
73/// Run a jq expression on items, returning parsed results or None on error.
74fn jq_filter(items: &[Item], expr: &str) -> Option<Vec<Item>> {
75    let json_values: Vec<serde_json::Value> =
76        items.iter().map(|i: &Item| i.to_json_value()).collect();
77    let json = serde_json::to_string(&json_values).ok()?;
78
79    let mut child = Command::new("jq")
80        .arg("-e")
81        .arg(expr)
82        .stdin(Stdio::piped())
83        .stdout(Stdio::piped())
84        .stderr(Stdio::piped())
85        .spawn()
86        .map_err(|e| {
87            eprintln!("Error: Failed to run jq: {}", e);
88        })
89        .ok()?;
90
91    if let Some(ref mut stdin) = child.stdin {
92        stdin.write_all(json.as_bytes()).ok()?;
93    }
94    // Close stdin
95    drop(child.stdin.take());
96
97    let output = child.wait_with_output().ok()?;
98
99    if !output.status.success() {
100        let stderr = String::from_utf8_lossy(&output.stderr);
101        eprintln!("Error: Filter failed: {}", stderr.trim());
102        return None;
103    }
104
105    let parsed: Vec<serde_json::Value> = serde_json::from_slice(&output.stdout).ok()?;
106    Some(
107        parsed
108            .into_iter()
109            .filter_map(|v| serde_json::from_value::<Item>(v).ok())
110            .collect(),
111    )
112}
sift_queue/cli/commands/list.rs

sift_queue/cli/commands/
list.rs
