aries-cli 0.1.1

A simple Aries Cloudagent Controller
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

use super::register::Module;
use crate::agent::agents::Agent;
use async_trait::async_trait;
use clap::ArgMatches;
use colored::Colorize;

/// Type of the message configuration as received by the cli
pub struct MessageConfig {
    /// connection id to send the message to
    pub connection_id: String,

    /// The message to send
    pub message: String,
}

/// Messages module for the agent
pub struct MessagesModule;

/// Implementation of a module for messages
#[async_trait(?Send)]
impl Module<MessageConfig> for MessagesModule {
    async fn run(agent: &dyn Agent, config: MessageConfig) {
        agent.send_message(&config).await;

        agent.logger().log(&format!(
            "Sent \"{}\" to {}!",
            config.message.bright_purple(),
            config.connection_id.cyan()
        ));
    }

    async fn register<'a>(agent: &dyn Agent, matches: &ArgMatches<'a>) {
        if let Some(matches_connections) = matches.subcommand_matches("message") {
            // We can use unwrap here because these values are required by the cli
            let connection_id = matches_connections
                .value_of("connection-id")
                .unwrap()
                .to_string();
            let message = matches_connections.value_of("message").unwrap().to_string();

            let config = MessageConfig {
                connection_id,
                message,
            };

            MessagesModule::run(agent, config).await;
        }
    }
}