// Copyright 2019 Parity Technologies (UK) Ltd. // // Permission is hereby granted, free of charge, to any person obtaining a // copy of this software and associated documentation files (the "Software"), // to deal in the Software without restriction, including without limitation // the rights to use, copy, modify, merge, publish, distribute, sublicense, // and/or sell copies of the Software, and to permit persons to whom the // Software is furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING // FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER // DEALINGS IN THE SOFTWARE. use futures::io::{AsyncWriteExt, AsyncReadExt}; use futures::stream::TryStreamExt; use tet_libp2p_core::{ identity, multiaddr::Multiaddr, transport::{Transport, ListenerEvent}, upgrade, }; use plaintext::PlainText2Config; use log::debug; use quickcheck::QuickCheck; #[test] fn variable_msg_length() { let _ = env_logger::try_init(); fn prop(msg: Vec) { let mut msg_to_send = msg.clone(); let msg_to_receive = msg; let server_id = identity::Keypair::generate_ed25519(); let server_id_public = server_id.public(); let client_id = identity::Keypair::generate_ed25519(); let client_id_public = client_id.public(); futures::executor::block_on(async { let server_transport = tet_libp2p_core::transport::MemoryTransport{}.and_then( move |output, endpoint| { upgrade::apply( output, PlainText2Config{local_public_key: server_id_public}, endpoint, tet_libp2p_core::upgrade::Version::V1, ) } ); let client_transport = tet_libp2p_core::transport::MemoryTransport{}.and_then( move |output, endpoint| { upgrade::apply( output, PlainText2Config{local_public_key: client_id_public}, endpoint, tet_libp2p_core::upgrade::Version::V1, ) } ); let server_address: Multiaddr = format!( "/memory/{}", std::cmp::Ord::max(1, rand::random::()) ).parse().unwrap(); let mut server = server_transport.listen_on(server_address.clone()).unwrap(); // Ignore server listen address event. let _ = server.try_next() .await .expect("some event") .expect("no error") .into_new_address() .expect("listen address"); let client_fut = async { debug!("dialing {:?}", server_address); let (received_server_id, mut client_channel) = client_transport.dial(server_address).unwrap().await.unwrap(); assert_eq!(received_server_id, server_id.public().into_peer_id()); debug!("Client: writing message."); client_channel.write_all(&mut msg_to_send).await.expect("no error"); debug!("Client: flushing channel."); client_channel.flush().await.expect("no error"); }; let server_fut = async { let mut server_channel = server.try_next() .await .expect("some event") .map(ListenerEvent::into_upgrade) .expect("no error") .map(|client| client.0) .expect("listener upgrade xyz") .await .map(|(_, session)| session) .expect("no error"); let mut server_buffer = vec![0; msg_to_receive.len()]; debug!("Server: reading message."); server_channel.read_exact(&mut server_buffer).await.expect("reading client message"); assert_eq!(server_buffer, msg_to_receive); }; futures::future::join(server_fut, client_fut).await; }) } QuickCheck::new().max_tests(30).quickcheck(prop as fn(Vec)) }