wruster/*: first version of the http client implementation

wruster/src/http/client/tests.rs

@@ -5,7 +5,7 @@ use crate::http::Response;
 use crate::http::StatusCode;
 use crate::router;
 use crate::router::HttpHandler;
-use crate::*;
+use crate::Server;
 
 #[test]
 fn client_write_run_post_body() {
@@ -17,21 +17,21 @@ fn client_write_run_post_body() {
     let request = Request::from_body(body, HttpMethod::POST, "/");
     let response = c.run(&addr, request).expect("Error running request");
 
-    assert_eq!(response.status, http::StatusCode::OK);
+    assert_eq!(response.status, StatusCode::OK);
 
     server.shutdown().expect("Error shutting down server");
 }
 
 #[test]
-fn client_keep_alive_reuses_connection() {
+fn client_keeps_connection_alive() {
     let handler = handler_from_check_body(|content| String::from_utf8_lossy(&content) == "test");
     let (server, addr) = run_server(handler, HttpMethod::POST, "/");
 
     let c = Client::new();
     let body = Body::from("test", mime::TEXT_PLAIN);
     let request = Request::from_body(body, HttpMethod::POST, "/");
     let response = c.run(&addr, request).expect("Error running request");
-    assert_eq!(response.status, http::StatusCode::OK);
+    assert_eq!(response.status, StatusCode::OK);
 
     // Release the connection.
     drop(response);
@@ -54,7 +54,7 @@ fn client_keep_alive_reuses_connection() {
     assert_eq!(dont_exist, true);
     drop(connection_pool);
 
-    assert_eq!(response.status, http::StatusCode::OK);
+    assert_eq!(response.status, StatusCode::OK);
     drop(response);
 
     // Check the connection is in the connection pool again.

wruster/src/http/errors.rs

@@ -10,11 +10,11 @@ pub enum HttpError {
     /// parsing a Request or a Response. Additional info about the error is
     /// stored in the inner String of the variant.
     Unknown(String),
-    /// It's generated when the connection is closed while reading o writing
+    /// It's generated when the connection is closed while waiting to star
     /// reading a request.
     ConnectionClosed,
-    /// It's generated when the maximum allowed time to read/write a request or
-    /// response has been exceed.
+    /// It's generated when the maximun allowed time to read a request or
+    /// write a response has been exceed.
     Timeout,
     /// It's generated when a syntactic error is found while reading a request.
     InvalidRequest(String),

wruster/src/http/headers.rs

@@ -179,7 +179,11 @@ impl Headers {
                 header.write(to)?
             }
         }
-        to.write_all("\r\n".as_bytes()).map_err(HttpError::from)?;
+
+        let written = to.write_all("\r\n".as_bytes());
+        if let Err(err) = written {
+            return Err(HttpError::Unknown(err.to_string()));
+        };
         Ok(())
     }
 }

wruster/src/http/mod.rs

@@ -14,10 +14,11 @@ pub mod status;
 pub use self::status::StatusCode;
 
 mod version;
+pub use self::version::Version;
+
 use headers::*;
 use mime::Mime;
 
-pub use self::version::Version;
 use crate::errors::HttpError;
 use crate::errors::HttpError::{ConnectionClosed, InvalidRequest, Timeout, Unknown};
 

wruster/src/lib.rs

@@ -81,9 +81,9 @@ mod thread_pool;
 pub const DEFAULT_READ_REQUEST_TIMEOUT: time::Duration = time::Duration::from_secs(30);
 
 /// Defines the default max time for a response to be written
-pub const DEFAULT_WRITE_RESPONSE_TIMEOUT: time::Duration = time::Duration::from_secs(30);
+pub const DEFAULT_WRITE_RESPONSE_TIMEOUT: time::Duration = time::Duration::from_secs(60);
 
-/// Defines the result type returned from the [Server] methods.
+/// Defines the result type returned from the [``Server``] methods.
 pub type ServerResult = Result<(), Box<dyn StdError>>;
 
 /// Defines the timeouts used in [Server::from_timeouts] method.
@@ -95,7 +95,7 @@ pub struct Timeouts {
     pub write_response_timeout: time::Duration,
 }
 
-/// Represents a web server that can be run by passing a [router::Router].
+/// Represents a web server that can be run by passing a [`router::Router`].
 pub struct Server {
     stop: Arc<AtomicBool>,
     addr: Option<String>,