路由器

use lager::LagerBox;

let lager = LagerBox::from_env()?;
let router = lager.router("router1");

pub struct RouterSystemInfo {
    pub name: Option<String>,          // identity
    pub version: Option<String>,       // RouterOS version
    pub board: Option<String>,
    pub architecture: Option<String>,
    pub uptime: Option<String>,        // e.g. "1w2d3h"
    pub cpu_load: Option<i64>,         // percent
    pub free_memory: Option<i64>,      // bytes
    pub total_memory: Option<i64>,
    pub free_hdd_space: Option<i64>,
}

use serde_json::json;

router.command("block_dns", json!({}))?;
router.command("block_port", json!({ "port": 8883, "protocol": "tcp" }))?;
router.command("add_bandwidth_limit", json!({
    "target": "192.168.88.0/24",
    "max_limit": "1M/1M",
}))?;

use lager::LagerBox;
use std::time::Duration;

let lager = LagerBox::from_env()?;
let router = lager.router("router1");
let mut uart = lager.uart("uart1")?;

router.connect()?;

let outcome = (|| -> lager::Result<()> {
    router.block_internet()?;
    // The DUT stays on the AP; only routing is gone.
    let log = uart.wait_for(b"retry", Duration::from_secs(60))?;
    assert!(!String::from_utf8_lossy(&log).contains("rebooting"),
            "firmware rebooted instead of retrying");
    Ok(())
})();

router.remove_firewall_rules()?;   // always, even if the assertion failed
outcome?;

use serde_json::json;

router.command("add_bandwidth_limit", json!({
    "target": "192.168.88.50",
    "max_limit": "256k/256k",
}))?;

// ... trigger the OTA and wait for it ...

router.command("remove_bandwidth_limits", json!({}))?;