asimov-cli 25.1.1

ASIMOV Command-Line Interface (CLI)
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

// This is free and unencumbered software released into the public domain.

use crate::StandardOptions;
use asimov_protocol::{EndpointTicket, Node, Ticket, Topic};
use color_print::ceprintln;
use core::error::Error;

pub async fn publish(
    topic: &Topic,
    message: &String,
    ticket: &Option<String>,
    _flags: &StandardOptions,
) -> Result<(), Box<dyn Error>> {
    // Start a node and accept connections from peers:
    let mut node = Node::default().bind().await?.start().await?;
    node.online().await;

    // If a peer ticket was provided, use it for bootstrap:
    if let Some(ticket) = ticket {
        let peer_ticket = EndpointTicket::decode_string(ticket.as_ref()).unwrap();
        node.add_peer(peer_ticket.endpoint_addr().id);
    }

    // Subscribe to the given topic and wait for a peer:
    let mut topic_subscription = node.subscribe_and_join(topic).await?;
    ceprintln!("<s,g>✓</> Topic=<s>{:?}</>", topic_subscription);

    // Publish the given message to the topic:
    topic_subscription.publish(message.clone()).await?;

    // Wait until the user presses Ctrl-C to terminate the program:
    tokio::signal::ctrl_c().await?;

    // Close the connection and shut down the node:
    node.terminate().await?;

    Ok(())
}