qqq-cli 0.7.0

Local-first task queue for coding agent sessions
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

use anyhow::{Result, ensure};
use serde_json::Value;
use std::collections::HashSet;

pub fn normalize(tags: &[String]) -> Result<Vec<String>> {
    let mut seen = HashSet::new();
    let mut normalized = Vec::new();
    for tag in tags {
        let label = tag.trim();
        ensure!(
            !label.is_empty()
                && !tag
                    .chars()
                    .any(|ch| ch.is_control() || matches!(ch, ',' | '[' | ']')),
            crate::errors::Info::invalid_argument(
                "tags",
                "Tags must be nonempty labels without controls, commas or square brackets"
            )
        );
        if seen.insert(label) {
            normalized.push(label.to_owned());
        }
    }
    Ok(normalized)
}

pub fn parse(value: &str) -> Result<Vec<String>> {
    if value.trim().is_empty() {
        return Ok(Vec::new());
    }
    normalize(&value.split(',').map(str::to_owned).collect::<Vec<_>>())
}

pub fn parse_lines(value: &str) -> Result<Vec<String>> {
    let labels = value
        .lines()
        .filter(|line| !line.trim().is_empty() || line.chars().any(char::is_control))
        .flat_map(|line| line.split(','))
        .map(str::to_owned)
        .collect::<Vec<_>>();
    normalize(&labels)
}

pub fn prefix(task: &Value) -> String {
    task["tags"]
        .as_array()
        .into_iter()
        .flatten()
        .filter_map(Value::as_str)
        .map(|tag| format!("[{tag}]"))
        .collect::<Vec<_>>()
        .join(" ")
}

#[cfg(test)]
mod tests {
    #[test]
    fn popup_lines_preserve_order_dedupe_and_comma_compatibility() {
        assert_eq!(
            super::parse_lines("frontend\n界 面\nfrontend\n").unwrap(),
            vec!["frontend", "界 面"]
        );
        assert_eq!(
            super::parse_lines("frontend, bug\r\n\r\nops").unwrap(),
            vec!["frontend", "bug", "ops"]
        );
    }

    #[test]
    fn popup_lines_clear_blank_values_and_skip_blank_rows() {
        for value in ["", " \n\n ", "\r\n\r\n"] {
            assert!(super::parse_lines(value).unwrap().is_empty());
        }
        assert_eq!(
            super::parse_lines("\n frontend\n\n  \n bug \n").unwrap(),
            vec!["frontend", "bug"]
        );
    }

    #[test]
    fn popup_lines_reject_non_separator_controls_and_invalid_labels() {
        for value in [
            "front\tend",
            "front\rend",
            "\t",
            "front\n\t\nend",
            "front\x1bend",
            "[tag]",
            "front,,end",
            "front,\nend",
        ] {
            assert!(super::parse_lines(value).is_err(), "{value:?}");
        }
        // CLI parser retains comma-only syntax and rejects newline labels.
        assert!(super::parse("front\nend").is_err());
    }
}