ockam_command 0.146.0

End-to-end encryption and mutual authentication for distributed applications.
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

use crate::util::foreground_args::ForegroundArgs;
use crate::util::{embedded_node_that_is_not_stopped, local_cmd};
use crate::{Command, CommandGlobalOpts};
use async_trait::async_trait;
use clap::Args;
use ockam_node::Context;
use tracing::instrument;

/// Start a Rendezvous server in foreground
#[derive(Clone, Debug, Args)]
pub struct CreateCommand {
    #[command(flatten)]
    pub foreground_args: ForegroundArgs,

    /// The address to bind the UDP listener to.
    #[arg(
        display_order = 900,
        long = "udp",
        id = "UDP_SOCKET_ADDRESS",
        default_value = "0.0.0.0:4000"
    )]
    pub udp_address: String,

    /// The address to bind the TCP listener to support healthcheck.
    #[arg(
        display_order = 900,
        long = "healthcheck",
        id = "TCP_SOCKET_ADDRESS",
        default_value = "0.0.0.0:4001"
    )]
    pub healthcheck_address: String,
}

#[async_trait]
impl Command for CreateCommand {
    const NAME: &'static str = "rendezvous create";

    #[instrument(skip_all)]
    fn run(self, opts: CommandGlobalOpts) -> miette::Result<()> {
        local_cmd(embedded_node_that_is_not_stopped(
            opts.rt.clone(),
            |ctx| async move { self.foreground_mode(&ctx, opts).await },
        ))
    }

    async fn async_run(self, ctx: &Context, opts: CommandGlobalOpts) -> crate::Result<()> {
        self.foreground_mode(ctx, opts).await?;

        Ok(())
    }
}