Use auth credentials if specified in URL

Cargo.toml

@@ -24,6 +24,7 @@ serde = "1.0"
 serde_derive = "1.0"
 serde_json = "1.0"
 tokio-timer = "0.1"
+url = "1.7"
 # Optional deps
 hyper = { version = "0.11", optional = true }
 hyper-tls = { version = "0.1", optional = true }

src/transports/http.rs

@@ -1,6 +1,7 @@
 //! HTTP Transport
 
 extern crate hyper;
+extern crate url;
 
 #[cfg(feature = "tls")]
 extern crate hyper_tls;
@@ -19,6 +20,7 @@ use serde_json;
 use transports::Result;
 use transports::shared::{EventLoopHandle, Response};
 use transports::tokio_core::reactor;
+use self::url::Url;
 use {BatchTransport, Error, ErrorKind, RequestId, Transport};
 
 impl From<hyper::Error> for Error {
@@ -53,6 +55,7 @@ pub type FetchTask<F> = Response<F, hyper::Chunk>;
 pub struct Http {
     id: Arc<AtomicUsize>,
     url: hyper::Uri,
+    basic_auth: Option<hyper::header::Basic>,
     write_sender: mpsc::UnboundedSender<(hyper::client::Request, Pending)>,
 }
 
@@ -109,9 +112,24 @@ impl Http {
                 }),
         );
 
+        let basic_auth = {
+            let url = Url::parse(url)?;
+            let user = url.username();
+
+            if user.len() > 0 {
+                Some(hyper::header::Basic {
+                    username: user.into(),
+                    password: url.password().map(Into::into),
+                })
+            } else {
+                None
+            }
+        };
+
         Ok(Http {
             id: Default::default(),
             url: url.parse()?,
+            basic_auth,
             write_sender,
         })
     }
@@ -133,6 +151,11 @@ impl Http {
             req.headers_mut()
                 .set(hyper::header::ContentLength(len as u64));
         }
+        // Send basic auth header
+        if let Some(ref basic_auth) = self.basic_auth {
+            req.headers_mut()
+                .set(hyper::header::Authorization(basic_auth.clone()));
+        }
         req.set_body(request);
 
         let (tx, rx) = futures::oneshot();