looprs 0.4.0

Concise coding assistant REPL — core library
Documentation 
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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145

use serde::{Deserialize, Serialize};
use std::ffi::OsString;

use crate::plugins::NamedTool;
use crate::plugins::binaries::Jj;

/// Represents jujutsu repository status
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct JjStatus {
    pub branch: String,
    pub commit: String,
    pub description: String,
}

/// Get jujutsu repository status if available
pub fn get_status() -> Option<JjStatus> {
    if !is_jj_repo() {
        return None;
    }

    let branch = get_branch()?;
    let commit = get_current_commit()?;
    let description = get_current_description()?;

    Some(JjStatus {
        branch,
        commit,
        description,
    })
}

/// Get recent commits from jujutsu repo
pub fn get_recent_commits(count: usize) -> Option<Vec<String>> {
    if !is_jj_repo() {
        return None;
    }

    let args: Vec<OsString> = vec![
        "log".into(),
        "--no-pager".into(),
        "-r".into(),
        "main..".into(),
        "-n".into(),
        count.to_string().into(),
        "-T".into(),
        r#"description.first_line()"#.into(),
    ];
    let output = Jj::system().output_if_available(args)?;

    if !output.status.success() {
        return None;
    }

    let output_str = String::from_utf8_lossy(&output.stdout);
    let commits: Vec<String> = output_str
        .lines()
        .filter(|line| !line.is_empty())
        .map(|line| line.trim().to_string())
        .collect();

    if commits.is_empty() {
        None
    } else {
        Some(commits)
    }
}

/// Check if current directory is a jujutsu repository
fn is_jj_repo() -> bool {
    std::path::Path::new(".jj").exists()
}

/// Get current branch name from jj
fn get_branch() -> Option<String> {
    let output =
        Jj::system().output_if_available(vec!["branch".into(), "list".into(), "-q".into()])?;

    if !output.status.success() {
        return None;
    }

    let branch = String::from_utf8_lossy(&output.stdout).trim().to_string();

    if branch.is_empty() {
        None
    } else {
        Some(branch)
    }
}

/// Query the current jj revision with a template string.
fn jj_log_current(template: &str) -> Option<String> {
    let args: Vec<OsString> = vec![
        "log".into(),
        "-r".into(),
        "@".into(),
        "--no-pager".into(),
        "-T".into(),
        template.into(),
    ];
    let output = Jj::system().output_if_available(args)?;

    if !output.status.success() {
        return None;
    }

    let text = String::from_utf8_lossy(&output.stdout).trim().to_string();

    if text.is_empty() { None } else { Some(text) }
}

/// Get current commit ID from jj
fn get_current_commit() -> Option<String> {
    jj_log_current(r#"{change_id.short()}"#)
}

/// Get current commit description from jj
fn get_current_description() -> Option<String> {
    jj_log_current(r#"{description}"#)
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_jj_repo_detection() {
        // This will be false in current git repo
        assert!(!is_jj_repo());
    }

    #[test]
    fn test_get_status_no_jj_repo() {
        // Should return None when not in jj repo
        let status = get_status();
        assert!(status.is_none());
    }

    #[test]
    fn test_get_recent_commits_no_jj_repo() {
        // Should return None when not in jj repo
        let commits = get_recent_commits(5);
        assert!(commits.is_none());
    }
}