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/status.rs
use crate::types::{OperationResult, RepositoryOperation};
use anyhow::{Context, Result};
use std::path::Path;
use tracing::{debug, info};

pub struct StatusOperation;

impl StatusOperation {
    pub fn new() -> Self {
        Self
    }
}

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

    fn description(&self) -> &'static str {
        "Show status of repositories"
    }

    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()
                )));
            }

            // Run git status command
            let mut cmd = tokio::process::Command::new("git");
            cmd.current_dir(repo_path).arg("status").arg("--porcelain");

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

            if output.status.success() {
                let status_output = String::from_utf8_lossy(&output.stdout).to_string();
                
                if status_output.is_empty() {
                    // Clean repository
                    Ok(OperationResult::Success(format!(
                        "Clean repository: {}",
                        repo_path.display()
                    )))
                } else {
                    // Repository has uncommitted changes
                    Ok(OperationResult::Success(format!(
                        "Uncommitted changes in {}: \n{}",
                        repo_path.display(),
                        status_output
                    )))
                }
            } else {
                let error = String::from_utf8_lossy(&output.stderr).to_string();
                Ok(OperationResult::Failure(format!(
                    "Failed to get status for {}: {}",
                    repo_path.display(),
                    error
                )))
            }
        })
    }
}