aranya-daemon 6.0.0

Daemon process for syncing with Aranya peers and maintaining the DAG
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

//! This module contains the QUIC transport code to allow syncing with other clients.

mod connections;
mod connector;
mod listener;
mod psk;
mod stream;

use self::{
    super::{SyncConnector, SyncListener, SyncStream},
    stream::QuicStream,
};
pub(crate) use self::{
    connections::ConnectionPool,
    connector::QuicConnector,
    listener::QuicListener,
    psk::{PskSeed, PskStore},
};

/// ALPN protocol identifier for Aranya QUIC sync.
const ALPN_QUIC_SYNC: &[u8] = b"quic-sync-unstable";

/// Errors specific to the QUIC transport.
#[derive(Debug, thiserror::Error)]
pub(crate) enum Error {
    /// An error occurred when trying to use a QUIC connection.
    #[error(transparent)]
    QuicConnection(#[from] s2n_quic::connection::Error),

    /// An error occurred when trying to use a QUIC stream.
    #[error(transparent)]
    QuicStream(#[from] s2n_quic::stream::Error),

    /// Unable to start a new QUIC client.
    #[error("could not start QUIC client")]
    ClientStart(#[source] s2n_quic::provider::StartError),

    /// Unable to start a new QUIC server.
    #[error("could not start QUIC server")]
    ServerStart(#[source] s2n_quic::provider::StartError),

    /// Failed to send data on a QUIC stream.
    #[error(transparent)]
    Send(s2n_quic::stream::Error),

    /// Failed to receive data from a QUIC stream.
    #[error(transparent)]
    Receive(std::io::Error),

    /// Unable to communicate that the connection is finished.
    #[error(transparent)]
    Finish(s2n_quic::stream::Error),

    /// A peer tried to send a message that was larger than we can handle.
    #[error("message exceeds buffer capacity")]
    MessageTooLarge,

    /// Encountered a bug in the program.
    #[error(transparent)]
    Bug(#[from] buggy::Bug),

    /// Something has gone wrong.
    #[error(transparent)]
    Other(#[from] anyhow::Error),
}

impl From<std::convert::Infallible> for Error {
    fn from(err: std::convert::Infallible) -> Self {
        match err {}
    }
}