wasmcloud-test-util 0.19.0

Utilities for testing wasmCloud hosts, providers, and components. 
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

//! Utilities for managing lattice links

use anyhow::{anyhow, Result};
use wasmcloud_control_interface::{CtlResponse, Link};
use wasmcloud_core::KnownConfigName;

#[allow(clippy::too_many_arguments)]
pub async fn assert_advertise_link(
    client: impl Into<&wasmcloud_control_interface::Client>,
    source_id: impl AsRef<str>,
    target: impl AsRef<str>,
    link_name: impl AsRef<str>,
    wit_namespace: impl AsRef<str>,
    wit_package: impl AsRef<str>,
    interfaces: Vec<String>,
    source_config: Vec<KnownConfigName>,
    target_config: Vec<KnownConfigName>,
) -> Result<CtlResponse<()>> {
    let client = client.into();
    let source_id = source_id.as_ref();
    let target = target.as_ref();
    let link_name = link_name.as_ref();
    let wit_namespace = wit_namespace.as_ref();
    let wit_package = wit_package.as_ref();
    client
        .put_link(
            Link::builder()
                .source_id(source_id)
                .target(target)
                .name(link_name)
                .wit_namespace(wit_namespace)
                .wit_package(wit_package)
                .interfaces(interfaces)
                .source_config(source_config)
                .target_config(target_config)
                .build()
                .map_err(|e| anyhow!(e).context("failed to build link"))?,
        )
        .await
        .map_err(|e| anyhow!(e).context("failed to advertise link"))
}

pub async fn assert_remove_link(
    client: impl Into<&wasmcloud_control_interface::Client>,
    component_id: impl AsRef<str>,
    wit_namespace: impl AsRef<str>,
    wit_package: impl AsRef<str>,
    link_name: impl AsRef<str>,
) -> Result<()> {
    let client = client.into();
    let component_id = component_id.as_ref();
    let wit_namespace = wit_namespace.as_ref();
    let wit_package = wit_package.as_ref();
    let link_name = link_name.as_ref();
    client
        .delete_link(component_id, link_name, wit_namespace, wit_package)
        .await
        .map_err(|e| anyhow!(e).context("failed to delete link"))?;
    Ok(())
}