Define small lib.rs for integration testing.

src/lib.rs

@@ -0,0 +1,2 @@
+mod config;
+pub mod proto;

src/proto/handler.rs

@@ -4,13 +4,14 @@ use std::net;
 use std::net::ToSocketAddrs;
 
 use crossbeam_channel;
+use log::{error, info};
 use mio;
 use slab;
 
 use crate::config;
 
 use super::peer;
-use super::server::*;
+use super::server::{ServerRequest, ServerResponse};
 use super::{Intent, SendPacket, Stream};
 
 /*===========*

src/proto/peer/message.rs

@@ -1,5 +1,7 @@
 use std::io;
 
+use log::warn;
+
 use crate::proto::core::value::{
   ValueDecode, ValueDecodeError, ValueDecoder, ValueEncode, ValueEncodeError,
   ValueEncoder,

src/proto/server/client.rs

@@ -65,7 +65,7 @@ enum RunOnceResult {
 }
 
 impl Client {
-  async fn login(
+  pub async fn login(
     tcp_stream: net::TcpStream,
     options: ClientOptions,
   ) -> Result<Client, ClientLoginError> {
@@ -144,7 +144,7 @@ impl Client {
     )
   }
 
-  fn run<S>(
+  pub fn run<S>(
     mut self,
     mut request_stream: S,
   ) -> impl Stream<Item = Result<ServerResponse, ClientRunError>> + Unpin

src/proto/server/mod.rs

@@ -7,6 +7,7 @@ mod response;
 mod testing;
 mod version;
 
+pub use self::client::{Client, ClientOptions};
 pub use self::credentials::Credentials;
 pub use self::request::*;
 pub use self::response::*;

src/proto/server/response.rs

@@ -1,5 +1,7 @@
 use std::net;
 
+use log::{debug, error, warn};
+
 use crate::proto::core::value::{
   ValueDecode, ValueDecodeError, ValueDecoder, ValueEncode, ValueEncodeError,
   ValueEncoder,

src/proto/server/testing.rs

@@ -5,7 +5,7 @@ use std::io;
 use std::net::{IpAddr, Ipv4Addr, SocketAddr};
 use std::sync::Arc;
 
-use log::{info, warn};
+use log::{debug, info, warn};
 use parking_lot::Mutex;
 use tokio::net::{TcpListener, TcpStream};
 use tokio::sync::mpsc;

src/proto/stream.rs

@@ -4,6 +4,7 @@ use std::fmt;
 use std::io;
 use std::net::ToSocketAddrs;
 
+use log::{error, info};
 use mio;
 
 use super::packet::{MutPacket, Parser, ReadFromPacket, WriteToPacket};