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> = items.iter().map(|i: &Item| i.to_json_value()).collect();
53        let json = serde_json::to_string_pretty(&values)?;
54        println!("{}", json);
55    } else if items.is_empty() {
56        eprintln!("No items found");
57    } else {
58        let pending_ids: HashSet<String> = queue
59            .filter(Some("pending"))
60            .iter()
61            .map(|i| i.id.clone())
62            .collect();
63        for item in &items {
64            formatters::print_item_summary(item, Some(&pending_ids));
65        }
66        eprintln!("{} item(s)", items.len());
67    }
68
69    Ok(0)
70}
71
72/// Run a jq expression on items, returning parsed results or None on error.
73fn jq_filter(items: &[Item], expr: &str) -> Option<Vec<Item>> {
74    let json_values: Vec<serde_json::Value> = items.iter().map(|i: &Item| i.to_json_value()).collect();
75    let json = serde_json::to_string(&json_values).ok()?;
76
77    let mut child = Command::new("jq")
78        .arg("-e")
79        .arg(expr)
80        .stdin(Stdio::piped())
81        .stdout(Stdio::piped())
82        .stderr(Stdio::piped())
83        .spawn()
84        .map_err(|e| {
85            eprintln!("Error: Failed to run jq: {}", e);
86        })
87        .ok()?;
88
89    if let Some(ref mut stdin) = child.stdin {
90        stdin.write_all(json.as_bytes()).ok()?;
91    }
92    // Close stdin
93    drop(child.stdin.take());
94
95    let output = child.wait_with_output().ok()?;
96
97    if !output.status.success() {
98        let stderr = String::from_utf8_lossy(&output.stderr);
99        eprintln!("Error: Filter failed: {}", stderr.trim());
100        return None;
101    }
102
103    let parsed: Vec<serde_json::Value> = serde_json::from_slice(&output.stdout).ok()?;
104    Some(
105        parsed
106            .into_iter()
107            .filter_map(|v| serde_json::from_value::<Item>(v).ok())
108            .collect(),
109    )
110}
sift_queue/cli/commands/list.rs

sift_queue/cli/commands/
list.rs
