net-cli 0.27.0-beta.1

Unified `net-mesh` command-line tool for the Net mesh
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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

//! `--dry-run` smoke tests for the admin + ICE dispatch surface.
//!
//! The admin `--dry-run` path short-circuits before
//! `CliContext::build`, so these tests exercise the clap routing
//! and the JSON envelope shape without paying the substrate-boot
//! cost. The ICE dry-run still simulates (and therefore boots the
//! supervisor), so this file pins only the admin surface; the
//! pre-existing `code_8_on_ice_confirmation_refused_non_tty` test
//! in `tests/exit_codes.rs` already exercises the ICE simulate
//! path on `freeze-cluster`.

use assert_cmd::prelude::*;
use serde_json::Value;
use std::process::{Command, Stdio};

fn json_stdout(args: &[&str]) -> Value {
    let out = Command::cargo_bin("net-mesh")
        .unwrap()
        .args(args)
        .stdin(Stdio::null())
        .output()
        .unwrap();
    assert!(
        out.status.success(),
        "command {args:?} failed: stdout={} stderr={}",
        String::from_utf8_lossy(&out.stdout),
        String::from_utf8_lossy(&out.stderr),
    );
    serde_json::from_slice(&out.stdout).unwrap_or_else(|e| {
        panic!(
            "stdout was not valid JSON: {e}; got: {}",
            String::from_utf8_lossy(&out.stdout)
        )
    })
}

#[test]
fn admin_drain_dry_run() {
    let v = json_stdout(&["admin", "drain", "0x1", "--drain-for", "5m", "--dry-run"]);
    assert_eq!(v["dry_run"], true);
    assert_eq!(v["envelope"]["kind"], "drain");
    assert_eq!(v["envelope"]["node"], 1);
    assert_eq!(v["envelope"]["drain_for_ms"], 5 * 60 * 1000);
}

#[test]
fn admin_enter_maintenance_dry_run() {
    let v = json_stdout(&["admin", "enter-maintenance", "0x1", "--dry-run"]);
    assert_eq!(v["envelope"]["kind"], "enter_maintenance");
}

#[test]
fn admin_exit_maintenance_dry_run() {
    let v = json_stdout(&["admin", "exit-maintenance", "0x1", "--dry-run"]);
    assert_eq!(v["envelope"]["kind"], "exit_maintenance");
}

#[test]
fn admin_cordon_dry_run() {
    let v = json_stdout(&["admin", "cordon", "0x1", "--dry-run"]);
    assert_eq!(v["envelope"]["kind"], "cordon");
}

#[test]
fn admin_uncordon_dry_run() {
    let v = json_stdout(&["admin", "uncordon", "0x1", "--dry-run"]);
    assert_eq!(v["envelope"]["kind"], "uncordon");
}

#[test]
fn admin_drop_replicas_dry_run() {
    let v = json_stdout(&[
        "admin",
        "drop-replicas",
        "0x1",
        "--chain",
        "0xAB",
        "--chain",
        "0xCD",
        "--dry-run",
    ]);
    assert_eq!(v["envelope"]["kind"], "drop_replicas");
    assert_eq!(v["envelope"]["chains"], serde_json::json!([0xAB, 0xCD]));
}

#[test]
fn admin_invalidate_placement_dry_run() {
    let v = json_stdout(&["admin", "invalidate-placement", "0x1", "--dry-run"]);
    assert_eq!(v["envelope"]["kind"], "invalidate_placement");
}

#[test]
fn admin_restart_all_daemons_dry_run() {
    let v = json_stdout(&["admin", "restart-all-daemons", "0x1", "--dry-run"]);
    assert_eq!(v["envelope"]["kind"], "restart_all_daemons");
}

#[test]
fn admin_clear_avoid_list_dry_run() {
    let v = json_stdout(&["admin", "clear-avoid-list", "0x1", "--dry-run"]);
    assert_eq!(v["envelope"]["kind"], "clear_avoid_list");
}