hyper-noise 0.0.2

A Noise protocol encryption layer on top of hyper HTTP servers and clients.
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

use hyper::{Body, Request, Response};
use tokio::net::TcpStream;
use tokio_noise::{
    handshakes::{nn_psk2::Initiator, NNpsk2},
    NoiseTcpStream,
};

use std::time::Duration;

use crate::ClientError;

pub async fn send_request(
    tcp_stream: TcpStream,
    initiator: Initiator<'_>,
    request: Request<Body>,
    request_timeout: Option<Duration>,
) -> Result<Response<Body>, ClientError> {
    let handshake = NNpsk2::new(initiator);

    let timeout = request_timeout.unwrap_or(Duration::from_secs(999999999));
    tokio::time::timeout(timeout, async move {
        let noise_stream = NoiseTcpStream::handshake_initiator(tcp_stream, handshake).await?;

        let (mut request_sender, connection) = hyper::client::conn::handshake(noise_stream).await?;
        tokio::spawn(async move {
            if let Err(e) = connection.await {
                log::warn!("Error in hyper HTTP connection driver: {}", e);
            }
        });

        let resp = request_sender.send_request(request).await?;
        Ok(resp)
    })
    .await
    .map_err(|_| ClientError::RequestTimeout)?
}