exposed some internal functions and structures to the public API

Author: Ben-Lichtman

src/client/decode.rs

@@ -16,7 +16,6 @@ const CR: u8 = b'\r';
 const LF: u8 = b'\n';
 
 /// Decode an HTTP response on the client.
-#[doc(hidden)]
 pub async fn decode<R>(reader: R) -> http_types::Result<Response>
 where
     R: Read + Unpin + Send + Sync + 'static,

src/lib.rs

@@ -106,9 +106,8 @@ const MAX_HEAD_LENGTH: usize = 8 * 1024;
 
 mod chunked;
 mod date;
-mod server;
+pub mod server;
 
-#[doc(hidden)]
 pub mod client;
 
 pub use client::connect;

src/server/decode.rs

@@ -17,7 +17,7 @@ const LF: u8 = b'\n';
 const HTTP_1_1_VERSION: u8 = 1;
 
 /// Decode an HTTP request on the server.
-pub(crate) async fn decode<IO>(mut io: IO) -> http_types::Result<Option<Request>>
+pub async fn decode<IO>(mut io: IO) -> http_types::Result<Option<Request>>
 where
     IO: Read + Write + Clone + Send + Sync + Unpin + 'static,
 {
@@ -116,13 +116,17 @@ fn set_url_and_port_from_host_header(req: &mut Request) -> http_types::Result<()
         .ok_or_else(|| format_err!("Mandatory Host header missing"))? //  https://tools.ietf.org/html/rfc7230#section-5.4
         .to_string();
 
-    if let Some(colon) = host.find(":") {
-        req.url_mut().set_host(Some(&host[0..colon]))?;
-        req.url_mut()
-            .set_port(host[colon + 1..].parse().ok())
-            .unwrap();
-    } else {
-        req.url_mut().set_host(Some(&host))?;
+    if !req.url().cannot_be_a_base() {
+        if let Some(colon) = host.find(":") {
+            println!("AAAA");
+            req.url_mut().set_host(Some(&host[0..colon]))?;
+            println!("AAAA");
+            req.url_mut()
+                .set_port(host[colon + 1..].parse().ok())
+                .unwrap();
+        } else {
+            req.url_mut().set_host(Some(&host))?;
+        }
     }
 
     Ok(())

src/server/encode.rs

@@ -15,7 +15,7 @@ use crate::date::fmt_http_date;
 ///
 /// This is returned from [`encode`].
 #[derive(Debug)]
-pub(crate) struct Encoder {
+pub struct Encoder {
     /// The current level of recursion the encoder is in.
     depth: u16,
     /// HTTP headers to be sent.
@@ -69,7 +69,7 @@ impl Read for Encoder {
 
 impl Encoder {
     /// Create a new instance of Encoder.
-    pub(crate) fn new(res: Response) -> Self {
+    pub fn new(res: Response) -> Self {
         Self {
             res,
             depth: 0,

src/server/mod.rs

@@ -10,8 +10,8 @@ use http_types::{Request, Response};
 mod decode;
 mod encode;
 
-use decode::decode;
-use encode::Encoder;
+pub use decode::decode;
+pub use encode::Encoder;
 
 /// Configure the server.
 #[derive(Debug, Clone)]