wash-cli 0.39.0

wasmCloud Shell (wash) CLI tool
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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136

mod common;

use common::TestWashInstance;

use anyhow::{Context, Result};
use serial_test::serial;
use tokio::process::Command;
use wash_lib::cli::output::LinkQueryCommandOutput;

#[tokio::test]
#[serial]
async fn integration_link_serial() -> Result<()> {
    let wash = TestWashInstance::create().await?;

    let output = Command::new(env!("CARGO_BIN_EXE_wash"))
        .args([
            "link",
            "query",
            "--output",
            "json",
            "--ctl-port",
            &wash.nats_port.to_string(),
        ])
        .kill_on_drop(true)
        .output()
        .await
        .context("failed to execute link query")?;

    assert!(output.status.success(), "executed link query");

    let cmd_output: LinkQueryCommandOutput = serde_json::from_slice(&output.stdout)?;
    assert!(cmd_output.success, "command returned success");
    assert_eq!(
        cmd_output.links.len(),
        0,
        "links list is empty without any links"
    );

    Ok(())
}

/// Ensure wash can delete all links
#[tokio::test]
#[serial]
async fn integration_link_del_all_serial() -> Result<()> {
    let wash = TestWashInstance::create().await?;

    let query_links = || async {
        let output = Command::new(env!("CARGO_BIN_EXE_wash"))
            .args([
                "link",
                "query",
                "--output",
                "json",
                "--ctl-port",
                &wash.nats_port.to_string(),
            ])
            .kill_on_drop(true)
            .output()
            .await
            .context("executing query link query")?;
        assert!(output.status.success(), "executed link query");

        let cmd_output: LinkQueryCommandOutput =
            serde_json::from_slice(&output.stdout).context("parsing link query command output")?;
        assert!(cmd_output.success, "command returned success");
        Ok(cmd_output) as Result<LinkQueryCommandOutput>
    };

    let queried_links = query_links().await?;
    assert_eq!(
        queried_links.links.len(),
        0,
        "links list is empty without any links"
    );

    // Create links that will be deleted
    const LINKS: [(&str, &str, &str, &str, &str); 3] = [
        ("src", "dst", "wasi", "http", "incoming-handler"),
        ("src", "dst", "example", "pkg", "call"),
        ("src", "dst", "wasmcloud", "messaging", "consumer"),
    ];
    for (src, dest, ns, pkg, iface) in LINKS {
        let _ = Command::new(env!("CARGO_BIN_EXE_wash"))
            .args([
                "link",
                "put",
                src,
                dest,
                ns,
                pkg,
                "--interface",
                iface,
                "--ctl-port",
                &wash.nats_port.to_string(),
            ])
            .kill_on_drop(true)
            .output()
            .await
            .context("failed to execute link query")?;
    }

    let queried_links = query_links().await?;
    assert_eq!(
        queried_links.links.len(),
        LINKS.len(),
        "queried link list does not match"
    );

    // Delete all the links
    let output = Command::new(env!("CARGO_BIN_EXE_wash"))
        .args([
            "link",
            "delete",
            "--all",
            "--force",
            "--output",
            "json",
            "--ctl-port",
            &wash.nats_port.to_string(),
        ])
        .kill_on_drop(true)
        .output()
        .await
        .context("failed to execute link query")?;
    assert!(output.status.success(), "delete query succeeded");

    let queried_links = query_links().await?;
    assert_eq!(
        queried_links.links.len(),
        0,
        "queried links were unexpectedly present"
    );

    Ok(())
}