#hyper #proxy #tokio #ssl

hyper-proxy

A proxy connector for Hyper-based applications

5 releases (3 breaking)

0.4.1 Mar 23, 2018
0.4.0 Dec 21, 2017
0.3.0 Dec 19, 2017
0.2.0 Dec 15, 2017
0.1.0 Dec 14, 2017

#12 in HTTP client

Download history 206/week @ 2018-07-22 268/week @ 2018-07-29 314/week @ 2018-08-05 326/week @ 2018-08-12 245/week @ 2018-08-19 208/week @ 2018-08-26 341/week @ 2018-09-02 331/week @ 2018-09-09 1086/week @ 2018-09-16 1385/week @ 2018-09-23 833/week @ 2018-09-30 710/week @ 2018-10-07 521/week @ 2018-10-14

350 downloads per month
Used in 1 crate

MIT license

26KB
532 lines

hyper-proxy

Travis Build Status MIT licensed crates.io

A proxy connector for hyper based applications.

Documentation

Example

extern crate hyper;
extern crate http;
extern crate hyper_proxy;
extern crate futures;
extern crate tokio;
extern crate typed_headers;

use hyper::{Chunk, Client, Request, Method, Uri};
use hyper::client::HttpConnector;
use futures::{Future, Stream};
use hyper_proxy::{Proxy, ProxyConnector, Intercept};
use tokio::runtime::current_thread::Runtime;
use typed_headers::Credentials;

fn main() {
    let mut core = Runtime::new().unwrap();
    
    let proxy = {
        let proxy_uri = "http://my-proxy:8080".parse().unwrap();
        let mut proxy = Proxy::new(Intercept::All, proxy_uri);
        proxy.set_authorization(Credentials::basic("John Doe", "Agent1234").unwrap());
        let connector = HttpConnector::new(4);
        let proxy_connector = ProxyConnector::from_proxy(connector, proxy).unwrap();
        proxy_connector
    };

    // Connecting to http will trigger regular GETs and POSTs.
    // We need to manually append the relevant headers to the request
    let uri: Uri = "http://my-remote-website.com".parse().unwrap();
    let mut req = Request::get(uri.clone()).body(hyper::Body::from(vec![])).unwrap();
    if let Some(headers) = proxy.http_headers(&uri) {
        req.headers_mut().extend(headers.clone().into_iter());
    }
    let client = Client::builder().build(proxy);
    let fut_http = client.request(req)
        .and_then(|res| res.into_body().concat2())
        .map(move |body: Chunk| ::std::str::from_utf8(&body).unwrap().to_string());

    // Connecting to an https uri is straightforward (uses 'CONNECT' method underneath)
    let uri = "https://my-remote-websitei-secured.com".parse().unwrap();
    let fut_https = client
        .get(uri)
        .and_then(|res| res.into_body().concat2())
        .map(move |body: Chunk| ::std::str::from_utf8(&body).unwrap().to_string());

    let futs = fut_http.join(fut_https);

    let (_http_res, _https_res) = core.block_on(futs).unwrap();
}

Credits

Large part of the code comes from reqwest. The core part as just been extracted and slightly enhanced.

Main changes are:

  • support for authentication
  • add non secured tunneling
  • add the possibility to add additional headers when connecting to the proxy

Dependencies

~5MB
~84K SLoC