running-process 4.2.0

Subprocess and PTY runtime for the running-process project
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

#![cfg(feature = "client")]

use running_process::broker::protocol::{BrokerIsolation, ServiceDefinition};
use running_process::broker::server::BrokerInstanceKey;

const USER_HASH: &str = "0123456789abcdef";

fn definition(isolation: BrokerIsolation) -> ServiceDefinition {
    ServiceDefinition {
        service_name: "zccache".into(),
        binary_path: "/usr/bin/zccache".into(),
        isolation: isolation as i32,
        explicit_instance: String::new(),
        per_version_binary_dir: String::new(),
        min_version: "1.11.20".into(),
        version_allow_list: vec!["1.11.20".into()],
        labels: Default::default(),
    }
}

fn pick_path(path: running_process::broker::lifecycle::PipePath) -> String {
    path.windows
        .or_else(|| path.unix.map(|p| p.to_string_lossy().into_owned()))
        .unwrap()
}

fn assert_instance_path_contains_identity(path: &str, identity: &str) {
    #[cfg(target_os = "macos")]
    {
        let _ = identity;
        assert!(path.ends_with(".sock"));
    }
    #[cfg(not(target_os = "macos"))]
    assert!(path.contains(identity));
}

#[test]
fn shared_service_uses_shared_instance() {
    let key =
        BrokerInstanceKey::from_service_definition(&definition(BrokerIsolation::SharedBroker))
            .unwrap();

    assert_eq!(key, BrokerInstanceKey::Shared);
    assert_eq!(key.id(), "shared");
    let path = pick_path(key.pipe_path(USER_HASH).unwrap());
    assert_instance_path_contains_identity(&path, "shared");
}

#[test]
fn private_service_uses_service_scoped_instance() {
    let key =
        BrokerInstanceKey::from_service_definition(&definition(BrokerIsolation::PrivateBroker))
            .unwrap();

    assert_eq!(
        key,
        BrokerInstanceKey::Private {
            service_name: "zccache".into()
        }
    );
    assert_eq!(key.id(), "private:zccache");
    let path = pick_path(key.pipe_path(USER_HASH).unwrap());
    assert_instance_path_contains_identity(&path, "zccache");
}

#[test]
fn explicit_service_uses_named_instance() {
    let mut definition = definition(BrokerIsolation::ExplicitInstance);
    definition.explicit_instance = "ci-trusted".into();
    let key = BrokerInstanceKey::from_service_definition(&definition).unwrap();

    assert_eq!(
        key,
        BrokerInstanceKey::Explicit {
            name: "ci-trusted".into()
        }
    );
    assert_eq!(key.id(), "explicit:ci-trusted");
    let path = pick_path(key.pipe_path(USER_HASH).unwrap());
    assert_instance_path_contains_identity(&path, "ci-trusted");
}

#[test]
fn explicit_service_requires_instance_name() {
    let err =
        BrokerInstanceKey::from_service_definition(&definition(BrokerIsolation::ExplicitInstance))
            .unwrap_err();

    assert!(err.to_string().contains("requires explicit_instance"));
}