arcbox-helper 0.4.23

Privileged helper daemon for host mutations (routes, DNS, sockets)
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

//! tarpc service implementation.
//!
//! Dispatches each RPC to the corresponding operation module.
//! Input validation (parse, don't validate) happens here at the RPC
//! boundary — mutation functions only accept validated types.

use arcbox_helper::HelperService;
use arcbox_helper::validate::{
    BridgeIface, CliName, CliTarget, DnsPort, Domain, SocketTarget, Subnet,
};

use super::mutations;

#[derive(Clone)]
pub struct HelperServer;

impl HelperService for HelperServer {
    async fn route_add(
        self,
        _: tarpc::context::Context,
        subnet: String,
        iface: String,
    ) -> Result<(), String> {
        let subnet: Subnet = subnet.parse()?;
        let iface: BridgeIface = iface.parse()?;
        mutations::route::add(&subnet, &iface)
    }

    async fn route_remove(self, _: tarpc::context::Context, subnet: String) -> Result<(), String> {
        let subnet: Subnet = subnet.parse()?;
        mutations::route::remove(&subnet)
    }

    async fn dns_install(
        self,
        _: tarpc::context::Context,
        domain: String,
        port: u16,
    ) -> Result<(), String> {
        let domain: Domain = domain.parse()?;
        let port = DnsPort::try_from(port)?;
        mutations::dns::install(&domain, port)
    }

    async fn dns_uninstall(self, _: tarpc::context::Context, domain: String) -> Result<(), String> {
        let domain: Domain = domain.parse()?;
        mutations::dns::uninstall(&domain)
    }

    async fn dns_status(self, _: tarpc::context::Context, domain: String) -> Result<bool, String> {
        let domain: Domain = domain.parse()?;
        mutations::dns::status(&domain)
    }

    async fn hosts_alias_install(self, _: tarpc::context::Context) -> Result<(), String> {
        mutations::hosts::install()
    }

    async fn hosts_alias_uninstall(self, _: tarpc::context::Context) -> Result<(), String> {
        mutations::hosts::uninstall()
    }

    async fn hosts_alias_status(self, _: tarpc::context::Context) -> Result<bool, String> {
        mutations::hosts::status()
    }

    async fn socket_link(self, _: tarpc::context::Context, target: String) -> Result<(), String> {
        let target: SocketTarget = target.parse()?;
        mutations::socket::link(&target)
    }

    async fn socket_unlink(self, _: tarpc::context::Context) -> Result<(), String> {
        mutations::socket::unlink()
    }

    async fn cli_link(
        self,
        _: tarpc::context::Context,
        name: String,
        target: String,
    ) -> Result<(), String> {
        let name: CliName = name.parse()?;
        let target: CliTarget = target.parse()?;
        mutations::cli::link(&name, &target)
    }

    async fn cli_unlink(self, _: tarpc::context::Context, name: String) -> Result<(), String> {
        let name: CliName = name.parse()?;
        mutations::cli::unlink(&name)
    }

    async fn version(self, _: tarpc::context::Context) -> String {
        env!("CARGO_PKG_VERSION").to_string()
    }
}