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
#![allow(dead_code, unused_imports)]
use clap::{CommandFactory, Parser, Subcommand};
use miette::Result;
mod commands;
mod compose;
mod config;
mod context;
mod error;
mod executor;
mod git;
mod mcp;
mod ports;
mod sanitize;
mod sync;
#[derive(Parser)]
#[command(
name = "rft",
version,
about = "Zero-config Docker Compose isolation for git worktrees"
)]
struct Cli {
#[command(subcommand)]
command: Command,
}
#[derive(Subcommand)]
enum Command {
/// Analyze compose file and generate .rftrc.toml
Init,
/// Start Docker Compose stacks for worktrees
Start {
/// Worktree indices to start (1-indexed, all if omitted)
indices: Vec<usize>,
/// Show what would be done without executing
#[arg(long)]
dry_run: bool,
},
/// Stop Docker Compose stacks
Stop {
/// Worktree indices to stop (1-indexed, all if omitted)
indices: Vec<usize>,
},
/// Restart Docker Compose stacks
Restart {
/// Worktree indices to restart (1-indexed, all if omitted)
indices: Vec<usize>,
},
/// List all worktrees with ports and status
List,
/// Promote changes from a worktree to current branch
Promote {
/// Worktree index (1-indexed)
index: usize,
/// Show what would be promoted without executing
#[arg(long)]
dry_run: bool,
/// Only promote files matching glob pattern
#[arg(long)]
files: Option<String>,
},
/// Stop all stacks, remove worktrees, clean up Docker resources
Clean,
/// Show logs for a worktree stack
Logs {
/// Worktree index (1-indexed)
index: usize,
/// Service name (all services if omitted)
service: Option<String>,
/// Don't follow log output
#[arg(long)]
no_follow: bool,
},
/// One-line status for shell prompt integration
Status,
/// Generate shell completions
Completions {
/// Shell to generate completions for
shell: clap_complete::Shell,
},
/// Start stacks and restart on compose/Dockerfile changes
Watch {
/// Worktree indices to watch (1-indexed, all if omitted)
indices: Vec<usize>,
},
/// Start MCP server (stdio transport)
Mcp,
}
#[tokio::main]
async fn main() -> Result<()> {
miette::set_panic_hook();
let cli = Cli::parse();
match cli.command {
Command::Init => commands::init::run().await.map_err(Into::into),
Command::List => commands::list::run().await,
Command::Start { indices, dry_run } => commands::start::run(indices, dry_run)
.await
.map_err(Into::into),
Command::Stop { indices } => commands::stop::run(indices).await.map_err(Into::into),
Command::Restart { indices } => commands::restart::run(indices).await.map_err(Into::into),
Command::Promote {
index,
dry_run,
files,
} => commands::promote::run(index, dry_run, files.as_deref()).await,
Command::Clean => commands::clean::run().await.map_err(Into::into),
Command::Logs {
index,
service,
no_follow,
} => commands::logs::run(index, service, no_follow)
.await
.map_err(Into::into),
Command::Status => commands::status::run().await.map_err(Into::into),
Command::Completions { shell } => {
let mut cmd = Cli::command();
clap_complete::generate(shell, &mut cmd, "rft", &mut std::io::stdout());
Ok(())
}
Command::Watch { indices } => commands::watch::run(indices).await.map_err(Into::into),
Command::Mcp => mcp::server::run_mcp_server().await.map_err(Into::into),
}
}