eznet 0.2.0

a simple net lib
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

use crate::socket::Socket;
use futures::StreamExt;
use quinn::{Endpoint, Incoming, ServerConfig};
use rustls::Certificate;
use std::net::SocketAddr;

//

pub struct Listener {
    endpoint: Endpoint,
    incoming: Incoming,
}

//

impl Listener {
    pub fn bind(addr: SocketAddr) -> Self {
        let config = Self::default_config();
        Self::from_config(config, addr)
    }

    /// Self signed certificate
    pub fn default_config() -> ServerConfig {
        let cert = rcgen::generate_simple_self_signed(vec!["localhost".into()]).unwrap();
        let cert_der = cert.serialize_der().unwrap();
        let priv_key = cert.serialize_private_key_der();
        let priv_key = rustls::PrivateKey(priv_key);
        let cert_chain = vec![Certificate(cert_der)];

        ServerConfig::with_single_cert(cert_chain, priv_key).unwrap()
    }

    pub fn from_config(config: ServerConfig, addr: SocketAddr) -> Self {
        let (endpoint, incoming) = Endpoint::server(config, addr).unwrap();
        Self { endpoint, incoming }
    }

    pub async fn next(&mut self) -> Option<Socket> {
        let connecting = self.incoming.next().await?;
        let connection = connecting.await.ok()?;
        Some(Socket::new(connection, self.endpoint.clone()))
    }
}