tsp_sdk 0.9.0-alpha2

Rust implementation of the Trust Spanning Protocol
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

use crate::definitions::TSPStream;
use bytes::BytesMut;
use url::Url;

pub mod error;

mod http;
mod quic;
mod tcp;
mod tls;

pub use error::TransportError;

pub async fn send_message(transport: &Url, tsp_message: &[u8]) -> Result<(), TransportError> {
    if tracing::enabled!(tracing::Level::TRACE) {
        println!(
            "CESR-encoded message: {}",
            crate::cesr::color_format(tsp_message)
                .map_err(|_| TransportError::InvalidMessageReceived("DecodeError".to_string()))?
        );
    }

    match transport.scheme() {
        tcp::SCHEME => tcp::send_message(tsp_message, transport).await,
        tls::SCHEME => tls::send_message(tsp_message, transport).await,
        quic::SCHEME => quic::send_message(tsp_message, transport).await,
        http::SCHEME_HTTP => http::send_message(tsp_message, transport).await,
        http::SCHEME_HTTPS => http::send_message(tsp_message, transport).await,
        _ => Err(TransportError::InvalidTransportScheme(
            transport.scheme().to_string(),
        )),
    }
}

pub async fn receive_messages(
    transport: &Url,
) -> Result<TSPStream<BytesMut, TransportError>, TransportError> {
    match transport.scheme() {
        tcp::SCHEME => tcp::receive_messages(transport).await,
        tls::SCHEME => tls::receive_messages(transport).await,
        quic::SCHEME => quic::receive_messages(transport).await,
        http::SCHEME_HTTP => http::receive_messages(transport).await,
        http::SCHEME_HTTPS => http::receive_messages(transport).await,
        _ => Err(TransportError::InvalidTransportScheme(
            transport.scheme().to_string(),
        )),
    }
}