monarch-rs 0.1.0

Advanced Git Management Suite for handling multiple repositories concurrently
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

// src/operations/run.rs
use crate::types::{OperationResult, RepositoryOperation};
use anyhow::{Context, Result};
use std::path::Path;
use tracing::{debug, info};

pub struct RunOperation {
    command: Vec<String>,
}

impl RunOperation {
    pub fn new(command: Vec<String>) -> Self {
        Self { command }
    }
}

impl RepositoryOperation for RunOperation {
    fn name(&self) -> &'static str {
        "Run"
    }

    fn description(&self) -> &'static str {
        "Run arbitrary git command"
    }

    fn execute<'a>(&'a self, repo_path: &'a Path) -> 
        std::pin::Pin<Box<dyn std::future::Future<Output = Result<OperationResult>> + Send + 'a>> {
        Box::pin(async move {
            // Check if it's a valid git repository
            if !repo_path.join(".git").is_dir() {
                return Ok(OperationResult::Skipped(format!(
                    "Not a git repository: {}",
                    repo_path.display()
                )));
            }

            // Create git command
            let mut cmd = tokio::process::Command::new("git");
            cmd.current_dir(repo_path);
            
            // Add all arguments
            for arg in &self.command {
                cmd.arg(arg);
            }

            debug!("Running command in {}: {:?}", repo_path.display(), cmd);
            
            let output = cmd
                .output()
                .await
                .context("Failed to execute git command")?;

            let stdout = String::from_utf8_lossy(&output.stdout).to_string();
            let stderr = String::from_utf8_lossy(&output.stderr).to_string();
            
            if output.status.success() {
                Ok(OperationResult::Success(format!(
                    "Command completed successfully in {}:\n{}{}",
                    repo_path.display(),
                    stdout,
                    if !stderr.is_empty() { format!("\nStderr: {}", stderr) } else { String::new() }
                )))
            } else {
                Ok(OperationResult::Failure(format!(
                    "Command failed in {}:\n{}{}",
                    repo_path.display(),
                    stdout,
                    if !stderr.is_empty() { format!("\nStderr: {}", stderr) } else { String::new() }
                )))
            }
        })
    }
}