#reverse-proxy #proxy-server #proxy #reverse #warp #filter #http-proxy

warp-reverse-proxy

Warp filter that acts as a reverse proxy, forwarding the request to a proxy address and extracting a response

9 releases (1 stable)

1.0.0 Dec 19, 2022
0.5.0 Mar 18, 2022
0.4.0 Oct 3, 2021
0.3.2 Jun 2, 2021
0.1.0 Aug 17, 2020

#475 in HTTP server

Download history 2793/week @ 2024-06-27 2807/week @ 2024-07-04 2926/week @ 2024-07-11 3374/week @ 2024-07-18 3346/week @ 2024-07-25 3701/week @ 2024-08-01 3486/week @ 2024-08-08 4512/week @ 2024-08-15 4487/week @ 2024-08-22 3764/week @ 2024-08-29 4421/week @ 2024-09-05 4488/week @ 2024-09-12 4548/week @ 2024-09-19 5364/week @ 2024-09-26 5009/week @ 2024-10-03 3494/week @ 2024-10-10

19,256 downloads per month
Used in 21 crates (4 directly)

Custom license

20KB
250 lines

warp-reverse-proxy

MIT licensed GHA Build Status Docs Badge

Fully composable warp filter that can be used as a reverse proxy. It forwards the request to the desired address and replies back the remote address response.

Add the library dependency

[dependencies]
warp = "0.3"
warp-reverse-proxy = "1"

Use it as simple as:

use warp::{hyper::Body, Filter, Rejection, Reply, http::Response};
use warp_reverse_proxy::reverse_proxy_filter;

async fn log_response(response: Response<Body>) -> Result<impl Reply, Rejection> {
    println!("{:?}", response);
    Ok(response)
}

#[tokio::main]
async fn main() {
    let hello = warp::path!("hello" / String).map(|name| format!("Hello, {}!", name));
    // // spawn base server
    tokio::spawn(warp::serve(hello).run(([0, 0, 0, 0], 8080)));
    // Forward request to localhost in other port
    let app = warp::path!("hello" / ..).and(
        reverse_proxy_filter("".to_string(), "http://127.0.0.1:8080/".to_string())
            .and_then(log_response),
    );
    // spawn proxy server
    warp::serve(app).run(([0, 0, 0, 0], 3030)).await;
}

For more control. You can compose inner library filters to help you compose your own reverse proxy:

#[tokio::main]
async fn main() {
    let hello = warp::path!("hello" / String).map(|name| format!("Hello port, {}!", name));

    // // spawn base server
    tokio::spawn(warp::serve(hello).run(([0, 0, 0, 0], 8080)));

    let request_filter = extract_request_data_filter();
    let app = warp::path!("hello" / String)
        // build proxy address and base path data from current filter
        .map(|port| (format!("http://127.0.0.1:{}/", port), "".to_string()))
        .untuple_one()
        // build the request with data from previous filters
        .and(request_filter)
        .and_then(proxy_to_and_forward_response)
        .and_then(log_response);

    // spawn proxy server
    warp::serve(app).run(([0, 0, 0, 0], 3030)).await;
}

Requests client initialization

By default, a simple reqwests::Client is initialized and used. In case some specific client configuration need to be used it can be overridden:

use warp_reverse_proxy::{reverse_proxy_filter, CLIENT as PROXY_CLIENT};

#[tokio::main]
async fn main() {
    let client = reqwest::Client::builder()
        .default_headers(headers)
        .build().expect("client goes boom...");
    PROXY_CLIENT.set(client).expect("client couldn't be set");
    ...
}

Dependencies

~10–24MB
~391K SLoC