hyperlane-cli 0.1.16

A command-line tool for Hyperlane framework.
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

use crate::*;

/// Execute cargo run command and capture output through log.
///
/// # Returns
///
/// - `Result<(), io::Error>`: Success or error
async fn run_cargo_run() -> Result<(), io::Error> {
    let output: std::process::Output = Command::new("cargo")
        .arg("run")
        .stdout(Stdio::piped())
        .stderr(Stdio::piped())
        .output()
        .await?;
    let stdout: String = String::from_utf8_lossy(&output.stdout).trim().to_string();
    let stderr: String = String::from_utf8_lossy(&output.stderr).trim().to_string();
    if !stdout.is_empty() {
        for line in stdout.lines() {
            log::info!("{line}");
        }
    }
    if !stderr.is_empty() {
        if output.status.success() {
            for line in stderr.lines() {
                if line.is_empty() {
                    continue;
                }
                log::info!("{line}");
            }
        } else {
            for line in stderr.lines() {
                if line.is_empty() {
                    continue;
                }
                log::error!("{line}");
            }
            log::error!("cargo run failed");
        }
    }
    Ok(())
}

/// Execute watch command using notify crate to monitor file changes
/// and re-run cargo run when source files are modified.
///
/// # Returns
///
/// - `Result<(), io::Error>`: Success or error
pub async fn execute_watch() -> Result<(), io::Error> {
    let src_path: PathBuf = PathBuf::from("src");
    if !src_path.exists() {
        return Err(io::Error::other(
            "src directory not found in current directory",
        ));
    }
    run_cargo_run().await?;
    let (tx, mut rx): (Sender<Event>, Receiver<Event>) = channel(Event::new(EventKind::Any));
    let mut watcher: RecommendedWatcher =
        recommended_watcher(move |result: Result<Event, notify::Error>| {
            if let Ok(event) = result {
                let _ = tx.send(event);
            }
        })
        .map_err(|error: notify::Error| io::Error::other(error.to_string()))?;
    watcher
        .watch(&src_path, RecursiveMode::Recursive)
        .map_err(|error: notify::Error| io::Error::other(error.to_string()))?;
    log::info!("Watching src/ for changes...");
    let mut debounce: Interval = interval(Duration::from_millis(500));
    debounce.tick().await;
    while rx.changed().await.is_ok() {
        let event: Event = rx.borrow().clone();
        let has_rust_change: bool = event.paths.iter().any(|path: &PathBuf| {
            path.extension()
                .is_some_and(|ext: &std::ffi::OsStr| ext == "rs")
        });
        if !has_rust_change {
            continue;
        }
        log::warn!("File change detected: {}", event.paths[0].display());
        debounce.reset();
        sleep(Duration::from_millis(300)).await;
        run_cargo_run().await?;
    }
    Ok(())
}