supertunnel 0.1.0

Build stateful proxy tunnels that resist network disruptions.
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

//! Session resumption protocol module.
//!
//! Provides the handshake and state management required to seamlessly reconnect
//! dropped streams without tearing down the logical session.

mod client;
mod codec;
mod message;
mod server;

pub use client::{ResumptionClient, ResumptionHandle};
pub use codec::ResumptionCodec;
use message::{Command, ResumptionMessage};
pub use server::{ResumptionMap, ResumptionServer};

#[cfg(test)]
pub mod tests {
    use tokio_test::assert_ok;

    use crate::proto::resumption::{ResumptionClient, ResumptionServer};
    use crate::test::{TestIoProtocol, TestNetwork, TestPayload};

    #[tokio::test]
    async fn valid_io_flow() {
        for (c_io, s_io, len) in TestPayload::iter() {
            let client = ResumptionClient::new(TestIoProtocol::from_mock(c_io));
            let server = ResumptionServer::new(TestIoProtocol::from_mock(s_io));

            let network = TestNetwork::new(client, server);
            let (c_to_s_result, s_to_c_result) = network.run().await;

            assert_ok!(c_to_s_result);
            assert_ok!(s_to_c_result);
            assert!(c_to_s_result.unwrap() >= len);
            assert!(s_to_c_result.unwrap() >= len);
        }
    }
}