Crate hyper_proxy[−][src]
A Proxy Connector crate for Hyper based applications
Example
use hyper::{Client, Request, Uri, body::HttpBody}; use hyper::client::HttpConnector; use futures::{TryFutureExt, TryStreamExt}; use hyper_proxy::{Proxy, ProxyConnector, Intercept}; use headers::Authorization; use std::error::Error; use tokio::io::{stdout, AsyncWriteExt as _}; #[tokio::main] async fn main() -> Result<(), Box<dyn Error>> { let proxy = { let proxy_uri = "http://my-proxy:8080".parse().unwrap(); let mut proxy = Proxy::new(Intercept::All, proxy_uri); proxy.set_authorization(Authorization::basic("John Doe", "Agent1234")); let connector = HttpConnector::new(); 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::empty()).unwrap(); if let Some(headers) = proxy.http_headers(&uri) { req.headers_mut().extend(headers.clone().into_iter()); } let client = Client::builder().build(proxy); let mut resp = client.request(req).await?; println!("Response: {}", resp.status()); while let Some(chunk) = resp.body_mut().data().await { stdout().write_all(&chunk?).await?; } // Connecting to an https uri is straightforward (uses 'CONNECT' method underneath) let uri = "https://my-remote-websitei-secured.com".parse().unwrap(); let mut resp = client.get(uri).await?; println!("Response: {}", resp.status()); while let Some(chunk) = resp.body_mut().data().await { stdout().write_all(&chunk?).await?; } Ok(()) }
Structs
Custom | A Custom struct to proxy custom uris |
Proxy | A Proxy strcut |
ProxyConnector | A wrapper around |
Enums
Intercept | The Intercept enum to filter connections |
ProxyStream | A Proxy Stream wrapper |
Traits
Dst | A trait for matching between Destination and Uri |