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

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

pub struct PullOperation;

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

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

    fn description(&self) -> &'static str {
        "Pull latest changes for 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 pull command
            let mut cmd = tokio::process::Command::new("git");
            cmd.current_dir(repo_path).arg("pull");

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

            if output.status.success() {
                let message = String::from_utf8_lossy(&output.stdout).to_string();
                if message.contains("Already up to date") {
                    Ok(OperationResult::Skipped(format!(
                        "Already up to date: {}",
                        repo_path.display()
                    )))
                } else {
                    Ok(OperationResult::Success(format!(
                        "Pulled changes for {}",
                        repo_path.display()
                    )))
                }
            } else {
                let error = String::from_utf8_lossy(&output.stderr).to_string();
                Ok(OperationResult::Failure(format!(
                    "Failed to pull {}: {}",
                    repo_path.display(),
                    error
                )))
            }
        })
    }
}