Help on proxy doing client request inside server request #1636
Comments
Can you instead just change your |
|
Thank you for the pointer @seanmonstar. That helped me move forward. edit here's the full source code of the second (non-working) example: https://gist.github.com/JeanMertz/4278c2cfaebae9c8e57a4c69e5c75435 edit 2 Turns out it was as simple as turning I'm close, but having difficulty wrapping this up: fn main() {
let addr = ([127, 0, 0, 1], 3000).into();
let service = || service_fn(proxy);
let server = Server::bind(&addr)
.serve(service)
.map_err(|e| eprintln!("server error: {}", e));
hyper::rt::run(server);
}
fn proxy(req: Request<Body>) -> impl Future<Item = Response<Body>, Error = Error> {
let client = Client::new();
req.body_mut()
.concat2()
.map(|chunk| chunk.to_vec())
.map(|vec| {
let uri = uri_from_request_body(&vec);
let mut new_request = Request::builder();
new_request.version(req.version()).method(req.method());
for (key, value) in req.headers() {
new_request.header(key, value);
}
new_request
.uri(&uri)
.header(http::header::HOST, uri.host().unwrap())
.body(Body::from(vec))
.unwrap()
}).and_then(|req| client.request(req))
}There's a lot of unwrapping going on (trying to get the happy path to work first), but this example doesn't compile yet, and I'm not sure yet how to tackle this: https://gist.github.com/JeanMertz/a38abfa49ad12f6faa60aca48f8b0fba Any thoughts on the proposed solution and how to handle the I had another solution that made the Future simpler, but caused problems with the borrow checker: req.body_mut()
.concat2()
.map(|chunk| chunk.to_vec())
.map(move |vec| {
let uri = uri_from_request_body(&vec);
new_request
.uri(&uri)
.header(http::header::HOST, uri.host().unwrap())
.body(Body::from(vec))
.unwrap()
}).and_then(move |new_req| client.request(new_req)) |
|
I've found that decomposing 'req' into '.parts()', I can more easily clone/reuse parts of the request for a client connection. Here's a bit of code: let (mut parts, body) = req.into_parts();
// Use and clone at will
let req = Request::from_parts(parts, body);Maybe that helps? |
|
To consume the body, you can use |
I've been at this for a couple of hours, but haven't had any luck so far.
I'm trying to realise the following flow:
wait()I'm especially struggling with reading the body in a future. I (believe I) have to wait for the body to be ready before I can deserialise it, so I have an example using tokio's
core::run, and while it compiled, it panicked, which brought me to this PR:tokio-rs/tokio-core#319 (comment)
@seanmonstar even mentions there that this is a common pitfall for people using something like I'm describing above, but because I need to look inside the payload of the request, I fail to see a solution that doesn't involve either
waitorcore::runat this point.Any help is greatly appreciated.
The text was updated successfully, but these errors were encountered: