asimov-protocol 25.3.2

ASIMOV Software Development Kit (SDK) for Rust
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

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

#![allow(dead_code)]

use crate::{
    AcceptError, Message, MessageRecv, MessageSend, PeerConnection, PeerHello, RecvError,
    SendError, peer_accept_state::*,
};

#[derive(Debug)]
pub struct PeerAccept<State = Accepted>(State);

impl From<iroh::endpoint::Connection> for PeerAccept {
    fn from(inner: iroh::endpoint::Connection) -> Self {
        Self(Accepted { inner })
    }
}

impl PeerAccept<Accepted> {
    pub async fn recv_hello(self) -> Result<PeerAccept<HelloReceived>, AcceptError> {
        let Accepted { inner } = self.0;
        let (send, recv) = inner.accept_bi().await?;
        let connection = PeerAccept(HelloExpected { inner, send, recv });
        Ok(connection.recv_hello().await?)
    }
}

impl PeerAccept<HelloExpected> {
    pub async fn recv_hello(mut self) -> Result<PeerAccept<HelloReceived>, AcceptError> {
        let response = self.recv().await?;
        let HelloExpected { inner, send, recv } = self.0;
        let Message::Hello(hello) = response else {
            return Err(AcceptError::InvalidMessage(response));
        };
        Ok(PeerAccept(HelloReceived {
            inner,
            send,
            recv,
            hello,
        }))
    }
}

impl PeerAccept<HelloReceived> {
    pub async fn send_hello(mut self) -> Result<PeerAccept<HelloSent>, AcceptError> {
        let HelloReceived { hello, .. } = &self.0;
        let request = Message::Hello(hello.clone()); // TODO
        let _ = self.send(request).await?;
        let HelloReceived {
            inner,
            send,
            recv,
            hello,
        } = self.0;
        Ok(PeerAccept(HelloSent {
            inner,
            send,
            recv,
            hello,
        }))
    }
}

impl PeerAccept<HelloSent> {
    pub fn hello(&self) -> &PeerHello {
        return &self.0.hello;
    }

    pub fn into_connection(self) -> PeerConnection {
        let HelloSent {
            inner,
            send,
            recv,
            hello,
        } = self.0;
        PeerConnection {
            inner,
            send,
            recv,
            hello,
        }
    }
}

impl MessageRecv for PeerAccept<HelloExpected> {
    async fn read_exact(&mut self, buffer: &mut [u8]) -> Result<(), RecvError> {
        Ok(self.0.recv.read_exact(buffer).await?)
    }
}

impl MessageRecv for PeerAccept<HelloReceived> {
    async fn read_exact(&mut self, buffer: &mut [u8]) -> Result<(), RecvError> {
        Ok(self.0.recv.read_exact(buffer).await?)
    }
}

impl MessageRecv for PeerAccept<HelloSent> {
    async fn read_exact(&mut self, buffer: &mut [u8]) -> Result<(), RecvError> {
        Ok(self.0.recv.read_exact(buffer).await?)
    }
}

impl MessageSend for PeerAccept<HelloReceived> {
    async fn write_all(&mut self, buffer: &[u8]) -> Result<(), SendError> {
        Ok(self.0.send.write_all(buffer).await?)
    }
}

impl MessageSend for PeerAccept<HelloSent> {
    async fn write_all(&mut self, buffer: &[u8]) -> Result<(), SendError> {
        Ok(self.0.send.write_all(buffer).await?)
    }
}