use std::path::PathBuf;
fn mcp_server_quiet_mode() -> bool {
std::env::var_os("LEAN_CTX_MCP_SERVER").is_some()
}
pub fn refresh_installed_hooks() {
let home = match dirs::home_dir() {
Some(h) => h,
None => return,
};
if home.join(".claude/hooks/lean-ctx-rewrite.sh").exists() {
install_claude_hook_scripts(&home);
}
if home.join(".cursor/hooks/lean-ctx-rewrite.sh").exists() {
install_cursor_hook_scripts(&home);
}
let gemini_rewrite = home.join(".gemini/hooks/lean-ctx-rewrite-gemini.sh");
let gemini_legacy = home.join(".gemini/hooks/lean-ctx-hook-gemini.sh");
if gemini_rewrite.exists() || gemini_legacy.exists() {
install_gemini_hook_scripts(&home);
}
if home.join(".codex/hooks/lean-ctx-rewrite-codex.sh").exists() {
install_codex_hook_scripts(&home);
}
}
fn resolve_binary_path() -> String {
if is_lean_ctx_in_path() {
return "lean-ctx".to_string();
}
std::env::current_exe()
.map(|p| p.to_string_lossy().to_string())
.unwrap_or_else(|_| "lean-ctx".to_string())
}
fn is_lean_ctx_in_path() -> bool {
let which_cmd = if cfg!(windows) { "where" } else { "which" };
std::process::Command::new(which_cmd)
.arg("lean-ctx")
.stdout(std::process::Stdio::null())
.stderr(std::process::Stdio::null())
.status()
.map(|s| s.success())
.unwrap_or(false)
}
fn resolve_binary_path_for_bash() -> String {
let path = resolve_binary_path();
to_bash_compatible_path(&path)
}
pub fn to_bash_compatible_path(path: &str) -> String {
let path = path.replace('\\', "/");
if path.len() >= 2 && path.as_bytes()[1] == b':' {
let drive = (path.as_bytes()[0] as char).to_ascii_lowercase();
format!("/{drive}{}", &path[2..])
} else {
path
}
}
pub fn normalize_tool_path(path: &str) -> String {
let mut p = path.to_string();
if p.len() >= 3
&& p.starts_with('/')
&& p.as_bytes()[1].is_ascii_alphabetic()
&& p.as_bytes()[2] == b'/'
{
let drive = p.as_bytes()[1].to_ascii_uppercase() as char;
p = format!("{drive}:{}", &p[2..]);
}
p = p.replace('\\', "/");
while p.contains("//") && !p.starts_with("//") {
p = p.replace("//", "/");
}
if p.len() > 1 && p.ends_with('/') && !p.ends_with(":/") {
p.pop();
}
p
}
fn generate_rewrite_script(binary: &str) -> String {
format!(
r#"#!/usr/bin/env bash
# lean-ctx PreToolUse hook — rewrites bash commands to lean-ctx equivalents
set -euo pipefail
LEAN_CTX_BIN="{binary}"
INPUT=$(cat)
TOOL=$(echo "$INPUT" | grep -o '"tool_name":"[^"]*"' | head -1 | cut -d'"' -f4)
if [ "$TOOL" != "Bash" ] && [ "$TOOL" != "bash" ]; then
exit 0
fi
CMD=$(echo "$INPUT" | grep -o '"command":"[^"]*"' | head -1 | cut -d'"' -f4)
if echo "$CMD" | grep -qE "^(lean-ctx |$LEAN_CTX_BIN )"; then
exit 0
fi
REWRITE=""
case "$CMD" in
git\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
gh\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
cargo\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
npm\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
pnpm\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
yarn\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
docker\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
kubectl\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
pip\ *|pip3\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
ruff\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
go\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
curl\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
grep\ *|rg\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
find\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
cat\ *|head\ *|tail\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
ls\ *|ls) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
eslint*|prettier*|tsc*) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
pytest*|ruff\ *|mypy*) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
aws\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
helm\ *) REWRITE="$LEAN_CTX_BIN -c $CMD" ;;
*) exit 0 ;;
esac
if [ -n "$REWRITE" ]; then
echo "{{\"hookSpecificOutput\":{{\"hookEventName\":\"PreToolUse\",\"permissionDecision\":\"allow\",\"updatedInput\":{{\"command\":\"$REWRITE\"}}}}}}"
fi
"#
)
}
fn generate_compact_rewrite_script(binary: &str) -> String {
format!(
r#"#!/usr/bin/env bash
# lean-ctx hook — rewrites shell commands
set -euo pipefail
LEAN_CTX_BIN="{binary}"
INPUT=$(cat)
CMD=$(echo "$INPUT" | grep -o '"command":"[^"]*"' | head -1 | cut -d'"' -f4 2>/dev/null || echo "")
if [ -z "$CMD" ] || echo "$CMD" | grep -qE "^(lean-ctx |$LEAN_CTX_BIN )"; then exit 0; fi
case "$CMD" in
git\ *|gh\ *|cargo\ *|npm\ *|pnpm\ *|docker\ *|kubectl\ *|pip\ *|ruff\ *|go\ *|curl\ *|grep\ *|rg\ *|find\ *|ls\ *|ls|cat\ *|aws\ *|helm\ *)
echo "{{\"hookSpecificOutput\":{{\"hookEventName\":\"PreToolUse\",\"permissionDecision\":\"allow\",\"updatedInput\":{{\"command\":\"$LEAN_CTX_BIN -c $CMD\"}}}}}}" ;;
*) exit 0 ;;
esac
"#
)
}
const REDIRECT_SCRIPT_CLAUDE: &str = r#"#!/usr/bin/env bash
# lean-ctx PreToolUse hook — redirects Read/Grep/List to MCP equivalents
set -euo pipefail
INPUT=$(cat)
TOOL=$(echo "$INPUT" | grep -o '"tool_name":"[^"]*"' | head -1 | cut -d'"' -f4 2>/dev/null || echo "")
case "$TOOL" in
Read|read|ReadFile|read_file|View|view)
if pgrep -f "lean-ctx" >/dev/null 2>&1; then
echo '{"hookSpecificOutput":{"hookEventName":"PreToolUse","permissionDecision":"deny","permissionDecisionReason":"STOP. Use ctx_read(path) from the lean-ctx MCP server instead. It saves 60-80% input tokens via caching and compression. Available modes: full, map, signatures, diff, lines:N-M. Never use native Read — always use ctx_read."}}'
fi
;;
Grep|grep|Search|search|RipGrep|ripgrep)
if pgrep -f "lean-ctx" >/dev/null 2>&1; then
echo '{"hookSpecificOutput":{"hookEventName":"PreToolUse","permissionDecision":"deny","permissionDecisionReason":"STOP. Use ctx_search(pattern, path) from the lean-ctx MCP server instead. It provides compact, token-efficient results with .gitignore awareness. Never use native Grep — always use ctx_search."}}'
fi
;;
ListFiles|list_files|ListDirectory|list_directory)
if pgrep -f "lean-ctx" >/dev/null 2>&1; then
echo '{"hookSpecificOutput":{"hookEventName":"PreToolUse","permissionDecision":"deny","permissionDecisionReason":"STOP. Use ctx_tree(path, depth) from the lean-ctx MCP server instead. It provides compact directory maps with file counts. Never use native ListFiles — always use ctx_tree."}}'
fi
;;
esac
"#;
const REDIRECT_SCRIPT_GENERIC: &str = r#"#!/usr/bin/env bash
# lean-ctx hook — redirects Read/Grep to MCP equivalents
set -euo pipefail
INPUT=$(cat)
TOOL=$(echo "$INPUT" | grep -o '"tool_name":"[^"]*"' | head -1 | cut -d'"' -f4 2>/dev/null || echo "")
case "$TOOL" in
Read|read|ReadFile|read_file)
if pgrep -f "lean-ctx" >/dev/null 2>&1; then
echo '{"hookSpecificOutput":{"hookEventName":"PreToolUse","permissionDecision":"deny","permissionDecisionReason":"STOP. Use ctx_read(path) from lean-ctx MCP instead. Saves 60-80% tokens."}}'
fi
;;
Grep|grep|Search|search)
if pgrep -f "lean-ctx" >/dev/null 2>&1; then
echo '{"hookSpecificOutput":{"hookEventName":"PreToolUse","permissionDecision":"deny","permissionDecisionReason":"STOP. Use ctx_search(pattern, path) from lean-ctx MCP instead."}}'
fi
;;
ListFiles|list_files|ListDirectory|list_directory)
if pgrep -f "lean-ctx" >/dev/null 2>&1; then
echo '{"hookSpecificOutput":{"hookEventName":"PreToolUse","permissionDecision":"deny","permissionDecisionReason":"STOP. Use ctx_tree(path, depth) from lean-ctx MCP instead."}}'
fi
;;
esac
"#;
pub fn install_project_rules() {
let cwd = std::env::current_dir().unwrap_or_default();
let agents_md = cwd.join("AGENTS.md");
if !agents_md.exists()
|| !std::fs::read_to_string(&agents_md)
.unwrap_or_default()
.contains("lean-ctx")
{
let content = AGENTS_MD_TEMPLATE;
write_file(&agents_md, content);
println!("Created AGENTS.md in project root.");
}
let cursorrules = cwd.join(".cursorrules");
if !cursorrules.exists()
|| !std::fs::read_to_string(&cursorrules)
.unwrap_or_default()
.contains("lean-ctx")
{
let content = CURSORRULES_TEMPLATE;
if cursorrules.exists() {
let mut existing = std::fs::read_to_string(&cursorrules).unwrap_or_default();
if !existing.ends_with('\n') {
existing.push('\n');
}
existing.push('\n');
existing.push_str(content);
write_file(&cursorrules, &existing);
} else {
write_file(&cursorrules, content);
}
println!("Created/updated .cursorrules in project root.");
}
}
const AGENTS_MD_TEMPLATE: &str = "\
# lean-ctx — Context Engineering Layer
MANDATORY: Use lean-ctx MCP tools for ALL reads, searches, and shell commands.
| FORBIDDEN | USE INSTEAD |
|-----------|-------------|
| Read / cat / head / tail | `ctx_read(path)` — cached, 8 compression modes, re-reads ~13 tokens |
| Shell / bash / terminal | `ctx_shell(command)` — pattern compression for git/npm/cargo output |
| Grep / rg / search | `ctx_search(pattern, path)` — compact, token-efficient results |
| ls / find / tree | `ctx_tree(path, depth)` — compact directory maps |
Keep using Write, StrReplace, Delete, Glob normally (no lean-ctx replacement).
REMINDER: NEVER use native Read, Shell, Grep, or ls. ALWAYS use ctx_read, ctx_shell, ctx_search, ctx_tree.
";
const CURSORRULES_TEMPLATE: &str = "\
# lean-ctx — Context Engineering Layer
CRITICAL: NEVER use native Read, Shell, Grep, or ls tools. ALWAYS use lean-ctx MCP equivalents.
| FORBIDDEN | USE INSTEAD |
|-----------|-------------|
| `Read` | `ctx_read(path)` — cached, 8 compression modes |
| `Shell` | `ctx_shell(command)` — pattern compression |
| `Grep` | `ctx_search(pattern, path)` — compact results |
| `ls` / `find` | `ctx_tree(path, depth)` — directory maps |
Write, StrReplace, Delete, Glob — use normally.
REMINDER: NEVER use native Read, Shell, Grep, or ls. ALWAYS use ctx_read, ctx_shell, ctx_search, ctx_tree.
";
pub fn install_agent_hook(agent: &str, global: bool) {
match agent {
"claude" | "claude-code" => install_claude_hook(global),
"cursor" => install_cursor_hook(global),
"gemini" => install_gemini_hook(),
"codex" => install_codex_hook(),
"windsurf" => install_windsurf_rules(global),
"cline" | "roo" => install_cline_rules(global),
"copilot" => install_copilot_hook(global),
"pi" => install_pi_hook(global),
"qwen" => install_mcp_json_agent(
"Qwen Code",
"~/.qwen/mcp.json",
&dirs::home_dir().unwrap_or_default().join(".qwen/mcp.json"),
),
"trae" => install_mcp_json_agent(
"Trae",
"~/.trae/mcp.json",
&dirs::home_dir().unwrap_or_default().join(".trae/mcp.json"),
),
"amazonq" => install_mcp_json_agent(
"Amazon Q Developer",
"~/.aws/amazonq/mcp.json",
&dirs::home_dir()
.unwrap_or_default()
.join(".aws/amazonq/mcp.json"),
),
"jetbrains" => install_mcp_json_agent(
"JetBrains IDEs",
"~/.jb-mcp.json",
&dirs::home_dir().unwrap_or_default().join(".jb-mcp.json"),
),
"kiro" => install_mcp_json_agent(
"AWS Kiro",
"~/.kiro/settings/mcp.json",
&dirs::home_dir()
.unwrap_or_default()
.join(".kiro/settings/mcp.json"),
),
"verdent" => install_mcp_json_agent(
"Verdent",
"~/.verdent/mcp.json",
&dirs::home_dir()
.unwrap_or_default()
.join(".verdent/mcp.json"),
),
"opencode" => install_mcp_json_agent(
"OpenCode",
"~/.opencode/mcp.json",
&dirs::home_dir()
.unwrap_or_default()
.join(".opencode/mcp.json"),
),
"aider" => install_mcp_json_agent(
"Aider",
"~/.aider/mcp.json",
&dirs::home_dir().unwrap_or_default().join(".aider/mcp.json"),
),
"amp" => install_mcp_json_agent(
"Amp",
"~/.amp/mcp.json",
&dirs::home_dir().unwrap_or_default().join(".amp/mcp.json"),
),
_ => {
eprintln!("Unknown agent: {agent}");
eprintln!(" Supported: claude, cursor, gemini, codex, windsurf, cline, roo, copilot, pi, qwen, trae, amazonq, jetbrains, kiro, verdent, opencode, aider, amp");
std::process::exit(1);
}
}
}
fn install_claude_hook(global: bool) {
let home = match dirs::home_dir() {
Some(h) => h,
None => {
eprintln!("Cannot resolve home directory");
return;
}
};
install_claude_hook_scripts(&home);
install_claude_hook_config(&home);
install_claude_global_md(&home);
if !global {
let claude_md = PathBuf::from("CLAUDE.md");
if !claude_md.exists()
|| !std::fs::read_to_string(&claude_md)
.unwrap_or_default()
.contains("lean-ctx")
{
let content = include_str!("templates/CLAUDE.md");
write_file(&claude_md, content);
println!("Created CLAUDE.md in current project directory.");
} else {
println!("CLAUDE.md already configured.");
}
}
}
fn install_claude_global_md(home: &std::path::Path) {
let claude_dir = home.join(".claude");
let _ = std::fs::create_dir_all(&claude_dir);
let global_md = claude_dir.join("CLAUDE.md");
let existing = std::fs::read_to_string(&global_md).unwrap_or_default();
if existing.contains("lean-ctx") {
println!(" \x1b[32m✓\x1b[0m ~/.claude/CLAUDE.md already configured");
return;
}
let content = include_str!("templates/CLAUDE_GLOBAL.md");
if existing.is_empty() {
write_file(&global_md, content);
} else {
let mut merged = existing;
if !merged.ends_with('\n') {
merged.push('\n');
}
merged.push('\n');
merged.push_str(content);
write_file(&global_md, &merged);
}
println!(" \x1b[32m✓\x1b[0m Installed global ~/.claude/CLAUDE.md");
}
fn install_claude_hook_scripts(home: &std::path::Path) {
let hooks_dir = home.join(".claude").join("hooks");
let _ = std::fs::create_dir_all(&hooks_dir);
let binary = resolve_binary_path_for_bash();
let rewrite_path = hooks_dir.join("lean-ctx-rewrite.sh");
let rewrite_script = generate_rewrite_script(&binary);
write_file(&rewrite_path, &rewrite_script);
make_executable(&rewrite_path);
let redirect_path = hooks_dir.join("lean-ctx-redirect.sh");
write_file(&redirect_path, REDIRECT_SCRIPT_CLAUDE);
make_executable(&redirect_path);
}
fn install_claude_hook_config(home: &std::path::Path) {
let hooks_dir = home.join(".claude").join("hooks");
let rewrite_path = hooks_dir.join("lean-ctx-rewrite.sh");
let redirect_path = hooks_dir.join("lean-ctx-redirect.sh");
let settings_path = home.join(".claude").join("settings.json");
let settings_content = if settings_path.exists() {
std::fs::read_to_string(&settings_path).unwrap_or_default()
} else {
String::new()
};
if settings_content.contains("lean-ctx-rewrite")
&& settings_content.contains("lean-ctx-redirect")
{
return;
}
let hook_entry = serde_json::json!({
"hooks": {
"PreToolUse": [
{
"matcher": "Bash|bash",
"hooks": [{
"type": "command",
"command": rewrite_path.to_string_lossy()
}]
},
{
"matcher": "Read|read|ReadFile|read_file|View|view|Grep|grep|Search|search|ListFiles|list_files|ListDirectory|list_directory",
"hooks": [{
"type": "command",
"command": redirect_path.to_string_lossy()
}]
}
]
}
});
if settings_content.is_empty() {
write_file(
&settings_path,
&serde_json::to_string_pretty(&hook_entry).unwrap(),
);
} else if let Ok(mut existing) = serde_json::from_str::<serde_json::Value>(&settings_content) {
if let Some(obj) = existing.as_object_mut() {
obj.insert("hooks".to_string(), hook_entry["hooks"].clone());
write_file(
&settings_path,
&serde_json::to_string_pretty(&existing).unwrap(),
);
}
}
println!("Installed Claude Code hooks at {}", hooks_dir.display());
}
fn install_cursor_hook(global: bool) {
let home = match dirs::home_dir() {
Some(h) => h,
None => {
eprintln!("Cannot resolve home directory");
return;
}
};
install_cursor_hook_scripts(&home);
install_cursor_hook_config(&home);
if !global {
let rules_dir = PathBuf::from(".cursor").join("rules");
let _ = std::fs::create_dir_all(&rules_dir);
let rule_path = rules_dir.join("lean-ctx.mdc");
if !rule_path.exists() {
let rule_content = include_str!("templates/lean-ctx.mdc");
write_file(&rule_path, rule_content);
println!("Created .cursor/rules/lean-ctx.mdc in current project.");
} else {
println!("Cursor rule already exists.");
}
} else {
println!("Global mode: skipping project-local .cursor/rules/ (use without --global in a project).");
}
println!("Restart Cursor to activate.");
}
fn install_cursor_hook_scripts(home: &std::path::Path) {
let hooks_dir = home.join(".cursor").join("hooks");
let _ = std::fs::create_dir_all(&hooks_dir);
let binary = resolve_binary_path_for_bash();
let rewrite_path = hooks_dir.join("lean-ctx-rewrite.sh");
let rewrite_script = generate_compact_rewrite_script(&binary);
write_file(&rewrite_path, &rewrite_script);
make_executable(&rewrite_path);
let redirect_path = hooks_dir.join("lean-ctx-redirect.sh");
write_file(&redirect_path, REDIRECT_SCRIPT_GENERIC);
make_executable(&redirect_path);
}
fn install_cursor_hook_config(home: &std::path::Path) {
let hooks_dir = home.join(".cursor").join("hooks");
let rewrite_path = hooks_dir.join("lean-ctx-rewrite.sh");
let redirect_path = hooks_dir.join("lean-ctx-redirect.sh");
let hooks_json = home.join(".cursor").join("hooks.json");
let hook_config = serde_json::json!({
"hooks": [
{
"event": "preToolUse",
"matcher": {
"tool": "terminal_command"
},
"command": rewrite_path.to_string_lossy()
},
{
"event": "preToolUse",
"matcher": {
"tool": "read_file|grep|search|list_files|list_directory"
},
"command": redirect_path.to_string_lossy()
}
]
});
let content = if hooks_json.exists() {
std::fs::read_to_string(&hooks_json).unwrap_or_default()
} else {
String::new()
};
if content.contains("lean-ctx-rewrite") && content.contains("lean-ctx-redirect") {
return;
}
write_file(
&hooks_json,
&serde_json::to_string_pretty(&hook_config).unwrap(),
);
println!("Installed Cursor hooks at {}", hooks_json.display());
}
fn install_gemini_hook() {
let home = match dirs::home_dir() {
Some(h) => h,
None => {
eprintln!("Cannot resolve home directory");
return;
}
};
install_gemini_hook_scripts(&home);
install_gemini_hook_config(&home);
}
fn install_gemini_hook_scripts(home: &std::path::Path) {
let hooks_dir = home.join(".gemini").join("hooks");
let _ = std::fs::create_dir_all(&hooks_dir);
let binary = resolve_binary_path_for_bash();
let rewrite_path = hooks_dir.join("lean-ctx-rewrite-gemini.sh");
let rewrite_script = generate_compact_rewrite_script(&binary);
write_file(&rewrite_path, &rewrite_script);
make_executable(&rewrite_path);
let redirect_path = hooks_dir.join("lean-ctx-redirect-gemini.sh");
write_file(&redirect_path, REDIRECT_SCRIPT_GENERIC);
make_executable(&redirect_path);
}
fn install_gemini_hook_config(home: &std::path::Path) {
let hooks_dir = home.join(".gemini").join("hooks");
let rewrite_path = hooks_dir.join("lean-ctx-rewrite-gemini.sh");
let redirect_path = hooks_dir.join("lean-ctx-redirect-gemini.sh");
let settings_path = home.join(".gemini").join("settings.json");
let settings_content = if settings_path.exists() {
std::fs::read_to_string(&settings_path).unwrap_or_default()
} else {
String::new()
};
if settings_content.contains("lean-ctx-rewrite")
&& settings_content.contains("lean-ctx-redirect")
{
return;
}
let hook_config = serde_json::json!({
"hooks": {
"BeforeTool": [
{
"command": rewrite_path.to_string_lossy()
},
{
"command": redirect_path.to_string_lossy()
}
]
}
});
if settings_content.is_empty() {
write_file(
&settings_path,
&serde_json::to_string_pretty(&hook_config).unwrap(),
);
} else if let Ok(mut existing) = serde_json::from_str::<serde_json::Value>(&settings_content) {
if let Some(obj) = existing.as_object_mut() {
obj.insert("hooks".to_string(), hook_config["hooks"].clone());
write_file(
&settings_path,
&serde_json::to_string_pretty(&existing).unwrap(),
);
}
}
println!("Installed Gemini CLI hooks at {}", hooks_dir.display());
}
fn install_codex_hook() {
let home = match dirs::home_dir() {
Some(h) => h,
None => {
eprintln!("Cannot resolve home directory");
return;
}
};
let codex_dir = home.join(".codex");
let _ = std::fs::create_dir_all(&codex_dir);
install_codex_hook_scripts(&home);
let agents_path = codex_dir.join("AGENTS.md");
let agents_content = "# Global Agent Instructions\n\n@LEAN-CTX.md\n";
let lean_ctx_md = codex_dir.join("LEAN-CTX.md");
let binary = resolve_binary_path();
let lean_ctx_content = format!(
r#"# lean-ctx — Token Optimization
Prefix all shell commands with `{binary} -c` for compressed output:
```bash
{binary} -c git status # instead of: git status
{binary} -c cargo test # instead of: cargo test
{binary} -c ls src/ # instead of: ls src/
```
This saves 60-90% tokens per command. Works with: git, cargo, npm, pnpm, docker, kubectl, pip, ruff, go, curl, grep, find, ls, aws, helm, and 90+ more commands.
Use `{binary} -c --raw <cmd>` to skip compression and get full output.
"#
);
if agents_path.exists() {
let content = std::fs::read_to_string(&agents_path).unwrap_or_default();
if content.contains("lean-ctx") || content.contains("LEAN-CTX") {
println!("Codex AGENTS.md already configured.");
return;
}
}
write_file(&agents_path, agents_content);
write_file(&lean_ctx_md, &lean_ctx_content);
println!("Installed Codex instructions at {}", codex_dir.display());
}
fn install_codex_hook_scripts(home: &std::path::Path) {
let hooks_dir = home.join(".codex").join("hooks");
let _ = std::fs::create_dir_all(&hooks_dir);
let binary = resolve_binary_path_for_bash();
let rewrite_path = hooks_dir.join("lean-ctx-rewrite-codex.sh");
let rewrite_script = generate_compact_rewrite_script(&binary);
write_file(&rewrite_path, &rewrite_script);
make_executable(&rewrite_path);
if !mcp_server_quiet_mode() {
println!(
" \x1b[32m✓\x1b[0m Installed Codex hook scripts at {}",
hooks_dir.display()
);
}
}
fn install_windsurf_rules(global: bool) {
if global {
println!("Global mode: skipping project-local .windsurfrules (use without --global in a project).");
return;
}
let rules_path = PathBuf::from(".windsurfrules");
if rules_path.exists() {
let content = std::fs::read_to_string(&rules_path).unwrap_or_default();
if content.contains("lean-ctx") {
println!(".windsurfrules already configured.");
return;
}
}
let rules = include_str!("templates/windsurfrules.txt");
write_file(&rules_path, rules);
println!("Installed .windsurfrules in current project.");
}
fn install_cline_rules(global: bool) {
if global {
println!(
"Global mode: skipping project-local .clinerules (use without --global in a project)."
);
return;
}
let rules_path = PathBuf::from(".clinerules");
if rules_path.exists() {
let content = std::fs::read_to_string(&rules_path).unwrap_or_default();
if content.contains("lean-ctx") {
println!(".clinerules already configured.");
return;
}
}
let binary = resolve_binary_path();
let rules = format!(
r#"# lean-ctx Shell Optimization
# Prefix all shell commands with `{binary} -c` for 60-90% token savings.
When running shell commands, always prefix them with `{binary} -c` to compress output. For example:
- `{binary} -c git status` instead of `git status`
- `{binary} -c cargo test` instead of `cargo test`
- `{binary} -c ls src/` instead of `ls src/`
Supported commands: git, cargo, npm, pnpm, docker, kubectl, pip, ruff, go, curl, grep, find, ls, aws, helm, and 90+ more.
"#
);
write_file(&rules_path, &rules);
println!("Installed .clinerules in current project.");
}
fn install_pi_hook(global: bool) {
let has_pi = std::process::Command::new("pi")
.arg("--version")
.output()
.is_ok();
if !has_pi {
println!("Pi Coding Agent not found in PATH.");
println!("Install Pi first: npm install -g @mariozechner/pi-coding-agent");
println!();
}
println!("Installing pi-lean-ctx Pi Package...");
println!();
let install_result = std::process::Command::new("pi")
.args(["install", "npm:pi-lean-ctx"])
.status();
match install_result {
Ok(status) if status.success() => {
println!("Installed pi-lean-ctx Pi Package.");
}
_ => {
println!("Could not auto-install pi-lean-ctx. Install manually:");
println!(" pi install npm:pi-lean-ctx");
println!();
}
}
if !global {
let agents_md = PathBuf::from("AGENTS.md");
if !agents_md.exists()
|| !std::fs::read_to_string(&agents_md)
.unwrap_or_default()
.contains("lean-ctx")
{
let content = include_str!("templates/PI_AGENTS.md");
write_file(&agents_md, content);
println!("Created AGENTS.md in current project directory.");
} else {
println!("AGENTS.md already contains lean-ctx configuration.");
}
} else {
println!(
"Global mode: skipping project-local AGENTS.md (use without --global in a project)."
);
}
println!();
println!(
"Setup complete. All Pi tools (bash, read, grep, find, ls) now route through lean-ctx."
);
println!("Use /lean-ctx in Pi to verify the binary path.");
}
fn install_copilot_hook(global: bool) {
let binary = resolve_binary_path();
if global {
let mcp_path = copilot_global_mcp_path();
if mcp_path.as_os_str() == "/nonexistent" {
println!(" \x1b[2mVS Code not found — skipping global Copilot config\x1b[0m");
return;
}
write_vscode_mcp_file(&mcp_path, &binary, "global VS Code User MCP");
} else {
let vscode_dir = PathBuf::from(".vscode");
let _ = std::fs::create_dir_all(&vscode_dir);
let mcp_path = vscode_dir.join("mcp.json");
write_vscode_mcp_file(&mcp_path, &binary, ".vscode/mcp.json");
}
}
fn copilot_global_mcp_path() -> PathBuf {
if let Some(home) = dirs::home_dir() {
#[cfg(target_os = "macos")]
{
return home.join("Library/Application Support/Code/User/mcp.json");
}
#[cfg(target_os = "linux")]
{
return home.join(".config/Code/User/mcp.json");
}
#[cfg(target_os = "windows")]
{
if let Ok(appdata) = std::env::var("APPDATA") {
return PathBuf::from(appdata).join("Code/User/mcp.json");
}
}
#[allow(unreachable_code)]
home.join(".config/Code/User/mcp.json")
} else {
PathBuf::from("/nonexistent")
}
}
fn write_vscode_mcp_file(mcp_path: &PathBuf, binary: &str, label: &str) {
if mcp_path.exists() {
let content = std::fs::read_to_string(mcp_path).unwrap_or_default();
if content.contains("lean-ctx") {
println!(" \x1b[32m✓\x1b[0m Copilot already configured in {label}");
return;
}
if let Ok(mut json) = serde_json::from_str::<serde_json::Value>(&content) {
if let Some(obj) = json.as_object_mut() {
let servers = obj
.entry("servers")
.or_insert_with(|| serde_json::json!({}));
if let Some(servers_obj) = servers.as_object_mut() {
servers_obj.insert(
"lean-ctx".to_string(),
serde_json::json!({ "command": binary, "args": [] }),
);
}
write_file(
mcp_path,
&serde_json::to_string_pretty(&json).unwrap_or_default(),
);
println!(" \x1b[32m✓\x1b[0m Added lean-ctx to {label}");
return;
}
}
}
if let Some(parent) = mcp_path.parent() {
let _ = std::fs::create_dir_all(parent);
}
let config = serde_json::json!({
"servers": {
"lean-ctx": {
"command": binary,
"args": []
}
}
});
write_file(
mcp_path,
&serde_json::to_string_pretty(&config).unwrap_or_default(),
);
println!(" \x1b[32m✓\x1b[0m Created {label} with lean-ctx MCP server");
}
fn write_file(path: &PathBuf, content: &str) {
if let Err(e) = std::fs::write(path, content) {
eprintln!("Error writing {}: {e}", path.display());
}
}
#[cfg(unix)]
fn make_executable(path: &PathBuf) {
use std::os::unix::fs::PermissionsExt;
let _ = std::fs::set_permissions(path, std::fs::Permissions::from_mode(0o755));
}
#[cfg(not(unix))]
fn make_executable(_path: &PathBuf) {}
fn install_mcp_json_agent(name: &str, display_path: &str, config_path: &std::path::Path) {
let binary = resolve_binary_path();
if let Some(parent) = config_path.parent() {
let _ = std::fs::create_dir_all(parent);
}
if config_path.exists() {
let content = std::fs::read_to_string(config_path).unwrap_or_default();
if content.contains("lean-ctx") {
println!("{name} MCP already configured at {display_path}");
return;
}
if let Ok(mut json) = serde_json::from_str::<serde_json::Value>(&content) {
if let Some(obj) = json.as_object_mut() {
let servers = obj
.entry("mcpServers")
.or_insert_with(|| serde_json::json!({}));
if let Some(servers_obj) = servers.as_object_mut() {
servers_obj.insert(
"lean-ctx".to_string(),
serde_json::json!({ "command": binary }),
);
}
if let Ok(formatted) = serde_json::to_string_pretty(&json) {
let _ = std::fs::write(config_path, formatted);
println!(" \x1b[32m✓\x1b[0m {name} MCP configured at {display_path}");
return;
}
}
}
}
let content = serde_json::to_string_pretty(&serde_json::json!({
"mcpServers": {
"lean-ctx": {
"command": binary
}
}
}));
if let Ok(json_str) = content {
let _ = std::fs::write(config_path, json_str);
println!(" \x1b[32m✓\x1b[0m {name} MCP configured at {display_path}");
} else {
eprintln!(" \x1b[31m✗\x1b[0m Failed to configure {name}");
}
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn bash_path_unix_unchanged() {
assert_eq!(
to_bash_compatible_path("/usr/local/bin/lean-ctx"),
"/usr/local/bin/lean-ctx"
);
}
#[test]
fn bash_path_home_unchanged() {
assert_eq!(
to_bash_compatible_path("/home/user/.cargo/bin/lean-ctx"),
"/home/user/.cargo/bin/lean-ctx"
);
}
#[test]
fn bash_path_windows_drive_converted() {
assert_eq!(
to_bash_compatible_path("C:\\Users\\Fraser\\bin\\lean-ctx.exe"),
"/c/Users/Fraser/bin/lean-ctx.exe"
);
}
#[test]
fn bash_path_windows_lowercase_drive() {
assert_eq!(
to_bash_compatible_path("D:\\tools\\lean-ctx.exe"),
"/d/tools/lean-ctx.exe"
);
}
#[test]
fn bash_path_windows_forward_slashes() {
assert_eq!(
to_bash_compatible_path("C:/Users/Fraser/bin/lean-ctx.exe"),
"/c/Users/Fraser/bin/lean-ctx.exe"
);
}
#[test]
fn bash_path_bare_name_unchanged() {
assert_eq!(to_bash_compatible_path("lean-ctx"), "lean-ctx");
}
#[test]
fn normalize_msys2_path() {
assert_eq!(
normalize_tool_path("/c/Users/game/Downloads/project"),
"C:/Users/game/Downloads/project"
);
}
#[test]
fn normalize_msys2_drive_d() {
assert_eq!(
normalize_tool_path("/d/Projects/app/src"),
"D:/Projects/app/src"
);
}
#[test]
fn normalize_backslashes() {
assert_eq!(
normalize_tool_path("C:\\Users\\game\\project\\src"),
"C:/Users/game/project/src"
);
}
#[test]
fn normalize_mixed_separators() {
assert_eq!(
normalize_tool_path("C:\\Users/game\\project/src"),
"C:/Users/game/project/src"
);
}
#[test]
fn normalize_double_slashes() {
assert_eq!(
normalize_tool_path("/home/user//project///src"),
"/home/user/project/src"
);
}
#[test]
fn normalize_trailing_slash() {
assert_eq!(
normalize_tool_path("/home/user/project/"),
"/home/user/project"
);
}
#[test]
fn normalize_root_preserved() {
assert_eq!(normalize_tool_path("/"), "/");
}
#[test]
fn normalize_windows_root_preserved() {
assert_eq!(normalize_tool_path("C:/"), "C:/");
}
#[test]
fn normalize_unix_path_unchanged() {
assert_eq!(
normalize_tool_path("/home/user/project/src/main.rs"),
"/home/user/project/src/main.rs"
);
}
#[test]
fn normalize_relative_path_unchanged() {
assert_eq!(normalize_tool_path("src/main.rs"), "src/main.rs");
}
#[test]
fn normalize_dot_unchanged() {
assert_eq!(normalize_tool_path("."), ".");
}
#[test]
fn normalize_unc_path_preserved() {
assert_eq!(
normalize_tool_path("//server/share/file"),
"//server/share/file"
);
}
}