gsof_protocol 0.1.23

Software to collect data generated by sources who provide GSOF messages (Trimble)
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

use super::message;
use super::receiver;
use futures::future::{self};
use tokio::sync::broadcast::{self};
use tracing::{span, Instrument, Level};

#[doc = r#"
Create the instance for a socket client (TcpStream) connected with
the data receptor.

Uses data argument from cli to create the parameters.

Server Parameters:
- scheme: http/https
- host: localhost/ip
- port: valid port number

Receptor parameters:
- end-flag: &String

All the parameters must be simple string or numbers, so on the main
function (using clap mayb or args parsing) you can obtain or define
the values.
"#]
#[tracing::instrument(level = "info")]
pub async fn client(
    host: &String,
    port: &u16) {
    let (tx_source, _rx) = broadcast::channel(100);

    let addr =  format!("{}:{}", host, port);
    // couroutine to save the data
    let span_data = span!(Level::TRACE, "DATA");
    // couroutine to be used as client to receive data and
    // send to span_data
    let span_client = span!(Level::TRACE, "CLIENT");

    let recv_tx_source = tx_source.clone();

    let data_task = tokio::spawn(async move {
        message::receive_and_save_data(recv_tx_source)
            .instrument(span_data)
            .await;
    });

    let client_tx_source = tx_source.clone();

    let client_task = tokio::spawn(async move {
        receiver::run_client(&addr, client_tx_source)
            .instrument(span_client)
            .await;
    });

    let v = vec![data_task, client_task];
    let _outputs = future::try_join_all(v).await;
}