rft-cli 0.4.0

Zero-config Docker Compose isolation for git worktrees
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

use std::path::PathBuf;

use crate::compose::ComposeFile;
use crate::config::RftConfig;
use crate::error::Result;
use crate::git::WorktreeInfo;
use crate::ports::PortMapping;

#[derive(Debug)]
pub struct RftContext {
    pub repo_root: PathBuf,
    pub repo_name: String,
    pub compose_file: ComposeFile,
    pub port_mappings: Vec<PortMapping>,
    pub config: RftConfig,
    pub worktrees: Vec<WorktreeInfo>,
}

pub async fn build_context() -> Result<RftContext> {
    let cwd = std::env::current_dir()?;
    build_context_from(&cwd).await
}

pub async fn build_context_from(cwd: &std::path::Path) -> Result<RftContext> {
    let repo_root = crate::git::get_repo_root(cwd).await?;
    let repo_name = crate::git::get_repo_name(&repo_root);

    let compose_path = crate::compose::detect_compose_file(&repo_root).ok_or_else(|| {
        crate::error::RftError::ComposeNotFound {
            path: repo_root.clone(),
        }
    })?;
    let compose_path_clone = compose_path.clone();
    let compose_file = tokio::task::spawn_blocking(move || {
        crate::compose::parse_compose_file(&compose_path_clone)
    })
    .await
    .map_err(|e| crate::error::RftError::TaskPanicked(e.to_string()))??;

    let port_mappings = crate::ports::extract_port_mappings(&compose_file.services);
    let repo_root_clone = repo_root.clone();
    let config = tokio::task::spawn_blocking(move || crate::config::load_config(&repo_root_clone))
        .await
        .map_err(|e| crate::error::RftError::TaskPanicked(e.to_string()))?;
    let worktrees = crate::git::get_worktrees(&repo_root, config.main_branch.as_deref()).await?;

    Ok(RftContext {
        repo_root,
        repo_name,
        compose_file,
        port_mappings,
        config,
        worktrees,
    })
}

pub fn filter_worktrees<'a>(
    worktrees: &'a [WorktreeInfo],
    indices: &[usize],
) -> Vec<&'a WorktreeInfo> {
    if indices.is_empty() {
        return worktrees.iter().filter(|wt| !wt.is_main).collect();
    }

    worktrees
        .iter()
        .filter(|wt| !wt.is_main && indices.contains(&wt.index))
        .collect()
}

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

    fn sample_worktrees() -> Vec<WorktreeInfo> {
        vec![
            WorktreeInfo {
                path: PathBuf::from("/repo"),
                branch: "main".to_string(),
                is_main: true,
                index: 0, // main always 0
            },
            WorktreeInfo {
                path: PathBuf::from("/repo-wt-1"),
                branch: "feature-a".to_string(),
                is_main: false,
                index: 1, // 1-indexed for non-main
            },
            WorktreeInfo {
                path: PathBuf::from("/repo-wt-2"),
                branch: "feature-b".to_string(),
                is_main: false,
                index: 2,
            },
        ]
    }

    #[test]
    fn filter_returns_all_non_main_when_indices_empty() {
        let worktrees = sample_worktrees();
        let filtered = filter_worktrees(&worktrees, &[]);
        assert_eq!(filtered.len(), 2);
        assert_eq!(filtered[0].branch, "feature-a");
        assert_eq!(filtered[1].branch, "feature-b");
    }

    #[test]
    fn filter_returns_specific_1_indexed() {
        let worktrees = sample_worktrees();
        let filtered = filter_worktrees(&worktrees, &[1]);
        assert_eq!(filtered.len(), 1);
        assert_eq!(filtered[0].branch, "feature-a");
    }

    #[test]
    fn filter_returns_multiple_indices() {
        let worktrees = sample_worktrees();
        let filtered = filter_worktrees(&worktrees, &[1, 2]);
        assert_eq!(filtered.len(), 2);
    }

    #[test]
    fn filter_ignores_invalid_indices() {
        let worktrees = sample_worktrees();
        let filtered = filter_worktrees(&worktrees, &[99]);
        assert!(filtered.is_empty());
    }

    #[test]
    fn filter_skips_main_even_if_requested() {
        let worktrees = sample_worktrees();
        let filtered = filter_worktrees(&worktrees, &[0]);
        assert!(filtered.is_empty());
    }
}