bgit 0.4.2

User-friendly Git wrapper for beginners, automating essential tasks like adding, committing, and pushing changes. It includes smart rules to avoid common pitfalls, such as accidentally adding sensitive files or directories and has exclusive support for portable hooks!
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

use log::{debug, info};

use crate::bgit_error::BGitError;
use std::io::{BufRead, BufReader};
use std::process;
use std::thread;

use super::error::create_hook_error;

/// Handles the stdout and stderr of a child process
pub fn handle_process_output(child: &mut process::Child) -> Result<(), Box<BGitError>> {
    // Take ownership of stdout and stderr
    let stdout = child
        .stdout
        .take()
        .ok_or_else(|| create_hook_error("Failed to capture stdout", "", "hook execution"))?;
    let stderr = child
        .stderr
        .take()
        .ok_or_else(|| create_hook_error("Failed to capture stderr", "", "hook execution"))?;

    // Stream stdout
    let stdout_thread = thread::spawn(move || {
        let reader = BufReader::new(stdout);
        for line in reader.lines().map_while(Result::ok) {
            debug!("[hook_executor][stdout] {line}");
        }
    });

    // Stream stderr
    let stderr_thread = thread::spawn(move || {
        let reader = BufReader::new(stderr);
        for line in reader.lines().map_while(Result::ok) {
            info!("[hook_executor][stderr] {line}");
        }
    });

    // Wait for the streaming threads to finish
    stdout_thread
        .join()
        .map_err(|_| create_hook_error("Failed to join stdout thread", "", "hook execution"))?;
    stderr_thread
        .join()
        .map_err(|_| create_hook_error("Failed to join stderr thread", "", "hook execution"))?;

    Ok(())
}