feeless 0.1.11

A Nano (cryptocurrency) node and utilities such as nano addresses, hashing blocks, signing, etc.
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

use crate::network::Network;
use crate::node::controller::{Controller, Packet};
use crate::node::state::ArcState;
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use tokio::net::TcpStream;

pub async fn network_channel(
    network: Network,
    state: ArcState,
    stream: TcpStream,
) -> anyhow::Result<()> {
    // TODO: How would this fail?
    let peer_addr = stream.peer_addr().unwrap();

    let (controller, tx, mut rx) = Controller::new_with_channels(network, state, peer_addr);

    // We don't `await` here since the controller will quit when the incoming channel drops.
    tokio::spawn(controller.run());

    let (mut in_stream, mut out_stream) = stream.into_split();

    // Handle reads in a separate task.
    tokio::spawn(async move {
        let mut buffer: [u8; 10240] = [0; 10240];
        loop {
            let bytes = in_stream
                .read(&mut buffer)
                .await
                .expect("Could not read from peer");

            tx.send(Packet::new(Vec::from(&buffer[0..bytes])))
                .await
                .expect("Could not send to controller");
        }
    });

    // Writing to the socket. Keep it in this task.
    loop {
        let to_send = match rx.recv().await {
            Some(bytes) => bytes,
            None => return Ok(()),
        };

        out_stream.write_all(&to_send.data).await?;
    }
}