mihomo-rs 2.2.0

A Rust SDK and CLI tool for mihomo proxy management with service lifecycle management, configuration handling, and real-time monitoring
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

use crate::cli::print_info;
use crate::config::ConfigManager;
use crate::core::MihomoClient;

pub async fn handle_logs(level: Option<String>) -> anyhow::Result<()> {
    let cm = ConfigManager::new()?;
    let url = cm.get_external_controller().await?;
    let client = MihomoClient::new(&url, None)?;
    print_info("Streaming logs... (Press Ctrl+C to stop)");

    let mut rx = client.stream_logs(level.as_deref()).await?;
    while let Some(log) = rx.recv().await {
        println!("{}", log);
    }

    Ok(())
}

pub async fn handle_traffic() -> anyhow::Result<()> {
    let cm = ConfigManager::new()?;
    let url = cm.get_external_controller().await?;
    let client = MihomoClient::new(&url, None)?;
    print_info("Streaming traffic... (Press Ctrl+C to stop)");

    let mut rx = client.stream_traffic().await?;
    while let Some(traffic) = rx.recv().await {
        println!(
            "↑ {} KB/s  ↓ {} KB/s",
            traffic.up / 1024,
            traffic.down / 1024
        );
    }

    Ok(())
}

pub async fn handle_memory() -> anyhow::Result<()> {
    let cm = ConfigManager::new()?;
    let url = cm.get_external_controller().await?;
    let client = MihomoClient::new(&url, None)?;

    let memory = client.get_memory().await?;
    println!("Memory Usage:");
    println!("  In Use:   {} MB", memory.in_use / 1024 / 1024);
    println!("  OS Limit: {} MB", memory.os_limit / 1024 / 1024);

    Ok(())
}