prns-core 0.3.4

Pure Reticulum engine and wire contract for Personal Reticulum
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

mod destination;
mod hello;
mod naming;
mod session;
mod stream;

use super::{SamCommand, SamProtocolError, SamReply, SamReplyKind};

pub use destination::{GenerateDestination, I2pGeneratedDestination};
pub use hello::{SamHello, SamV3_1};
pub use naming::ResolveName;
pub use session::{CreateSession, EstablishedSession};
pub use stream::{parse_incoming_peer_destination, AcceptStream, ConnectStream, SamStreamReady};

pub trait SamExchange: private::Sealed {
    type Output;

    fn command(&self) -> SamCommand;
    fn conclude(self, reply: SamReply) -> Result<Self::Output, SamProtocolError>;
}

fn accepted_reply(expected: SamReplyKind, reply: SamReply) -> Result<SamReply, SamProtocolError> {
    if reply.kind() != expected {
        return Err(unexpected(expected, reply));
    }
    if let SamReply::Rejected {
        kind,
        rejection,
        message,
    } = reply
    {
        return Err(SamProtocolError::Rejected {
            kind,
            rejection,
            message,
        });
    }
    Ok(reply)
}

fn unexpected(expected: SamReplyKind, reply: SamReply) -> SamProtocolError {
    SamProtocolError::UnexpectedReply {
        expected,
        actual: reply.kind(),
    }
}

mod private {
    pub trait Sealed {}
}