udp-stream 0.0.12

Implementation of UdpSocket same as TcpStream
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

use openssl::ssl::{SslConnector, SslMethod, SslVerifyMode};
use std::error::Error;
use std::pin::Pin;
use std::{io, net::SocketAddr, str::FromStr};

use tokio::io::{AsyncReadExt, AsyncWriteExt};

use udp_stream::UdpStream;

const SERVER_DOMAIN: &str = "pourali.com";

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    let stream = UdpStream::connect(SocketAddr::from_str("127.0.0.1:8080")?).await?;

    let mut connector_builder = SslConnector::builder(SslMethod::dtls())?;
    connector_builder.set_verify(SslVerifyMode::NONE);
    let connector = connector_builder.build().configure()?;
    let ssl = connector.into_ssl(SERVER_DOMAIN)?;
    let mut stream = tokio_openssl::SslStream::new(ssl, stream)?;
    Pin::new(&mut stream).connect().await?;
    let mut buffer = String::new();
    loop {
        io::stdin().read_line(&mut buffer)?;
        stream.write_all(buffer.as_bytes()).await?;
        let mut buf = vec![0u8; 1024];
        let n = stream.read(&mut buf).await?;
        print!("-> {}", String::from_utf8_lossy(&buf[..n]));
        buffer.clear();
    }
}