ockam_api 0.93.0

Ockam's request-response API
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

use crate::authority_node::{Authority, Configuration};
use ockam_core::Result;
use ockam_node::Context;
use tracing::info;

/// Start all the necessary services for an authority node
pub async fn start_node(
    ctx: &Context,
    configuration: &Configuration,
    authority: Authority,
) -> Result<()> {
    debug!("starting authority node");

    debug!("starting services");
    // start a secure channel listener (this also starts a TCP transport)
    let secure_channel_flow_control_id = authority
        .start_secure_channel_listener(ctx, configuration)
        .await?;
    debug!("secure channel listener started");

    // start the authenticator services
    authority.start_direct_authenticator(ctx, &secure_channel_flow_control_id, configuration)?;
    debug!("direct authenticator started");

    authority.start_enrollment_services(ctx, &secure_channel_flow_control_id, configuration)?;
    debug!("enrollment services started");

    authority.start_credential_issuer(ctx, &secure_channel_flow_control_id, configuration)?;
    debug!("credential issuer started");

    // start the Okta service (if the optional configuration has been provided)
    authority.start_okta(ctx, &secure_channel_flow_control_id, configuration)?;
    debug!("okta service started");

    // start an echo service so that the node can be queried as healthy
    authority.start_echo_service(ctx, &secure_channel_flow_control_id)?;
    debug!("echo service started");

    // start the grpc forwarder for telemetry traces
    authority
        .start_grpc_forwarder(ctx, &secure_channel_flow_control_id, configuration)
        .await?;
    debug!("grpc forwarder started");

    info!("authority node started");

    Ok(())
}