jarvy 0.0.5

Jarvy is a fast, cross-platform CLI that installs and manages developer tools across macOS and Linux.
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
146
147
148
149
150
151
152
153
154
155
156
157
158
159

//! Tilt service backend

use super::{
    ServiceBackend, ServiceBackendOps, ServiceError, ServiceResult, ServiceStatus, command_exists,
    run_command,
};
use crate::telemetry;
use std::path::{Path, PathBuf};

/// Tilt backend implementation
pub struct TiltBackend;

impl ServiceBackendOps for TiltBackend {
    fn is_installed(&self) -> bool {
        command_exists("tilt")
    }

    fn find_config(&self, dir: &Path) -> Option<PathBuf> {
        for filename in ServiceBackend::Tilt.config_files() {
            let path = dir.join(filename);
            if path.exists() {
                return Some(path);
            }
        }
        None
    }

    fn start(&self, config_path: &Path, _detach: bool) -> Result<ServiceResult, ServiceError> {
        if !self.is_installed() {
            return Err(ServiceError::BackendNotInstalled(ServiceBackend::Tilt));
        }

        let working_dir = config_path.parent().unwrap_or(Path::new("."));
        let config_file = config_path
            .file_name()
            .and_then(|f| f.to_str())
            .unwrap_or("Tiltfile");

        // tilt up with --stream=false runs in background mode
        let args = ["up", "-f", config_file, "--stream=false"];

        let output = run_command("tilt", &args, working_dir)?;

        if output.status.success() {
            telemetry::service_operation("tilt", "start", true);
            Ok(ServiceResult {
                success: true,
                message: "Tilt services started. Access dashboard at http://localhost:10350"
                    .to_string(),
                backend: ServiceBackend::Tilt,
            })
        } else {
            telemetry::service_operation("tilt", "start", false);
            Err(ServiceError::CommandFailed {
                backend: ServiceBackend::Tilt,
                operation: "start",
                stderr: String::from_utf8_lossy(&output.stderr).to_string(),
                exit_code: output.status.code(),
            })
        }
    }

    fn stop(&self, config_path: &Path) -> Result<ServiceResult, ServiceError> {
        if !self.is_installed() {
            return Err(ServiceError::BackendNotInstalled(ServiceBackend::Tilt));
        }

        let working_dir = config_path.parent().unwrap_or(Path::new("."));
        let config_file = config_path
            .file_name()
            .and_then(|f| f.to_str())
            .unwrap_or("Tiltfile");

        let args = ["down", "-f", config_file];

        let output = run_command("tilt", &args, working_dir)?;

        if output.status.success() {
            telemetry::service_operation("tilt", "stop", true);
            Ok(ServiceResult {
                success: true,
                message: "Tilt services stopped".to_string(),
                backend: ServiceBackend::Tilt,
            })
        } else {
            telemetry::service_operation("tilt", "stop", false);
            Err(ServiceError::CommandFailed {
                backend: ServiceBackend::Tilt,
                operation: "stop",
                stderr: String::from_utf8_lossy(&output.stderr).to_string(),
                exit_code: output.status.code(),
            })
        }
    }

    fn status(&self, config_path: &Path) -> Result<ServiceStatus, ServiceError> {
        if !self.is_installed() {
            return Ok(ServiceStatus {
                backend: ServiceBackend::Tilt,
                installed: false,
                running: false,
                details: "Tilt is not installed".to_string(),
            });
        }

        let working_dir = config_path.parent().unwrap_or(Path::new("."));

        // tilt status shows resource status
        let output = run_command("tilt", &["status"], working_dir)?;

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

        // If tilt status fails or returns empty, services are not running
        let running = output.status.success() && !stdout.trim().is_empty();

        Ok(ServiceStatus {
            backend: ServiceBackend::Tilt,
            installed: true,
            running,
            details: if running {
                stdout
            } else if !stderr.is_empty() {
                format!("Tilt not running: {}", stderr.trim())
            } else {
                "Tilt services not running".to_string()
            },
        })
    }
}

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

    #[test]
    fn test_find_tiltfile() {
        use std::fs::File;
        use tempfile::TempDir;

        let temp = TempDir::new().unwrap();
        File::create(temp.path().join("Tiltfile")).unwrap();

        let backend = TiltBackend;
        let result = backend.find_config(temp.path());
        assert!(result.is_some());
        assert!(result.unwrap().ends_with("Tiltfile"));
    }

    #[test]
    fn test_find_tiltfile_not_found() {
        use tempfile::TempDir;

        let temp = TempDir::new().unwrap();
        let backend = TiltBackend;
        let result = backend.find_config(temp.path());
        assert!(result.is_none());
    }
}