storytold/voder-proxy
2
0
Fork 0
mirror of https://github.com/storytold/voder-proxy.git synced 2026-10-19 07:43:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

This compiles, but isn't logical

Browse Source
This commit is contained in:
Brandon Thomas
2020-06-29 07:03:11 -04:00
parent 09ed0163af
commit 0e2990ee2c
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main.rs
+9 -5
View File
@@ -157,7 +157,7 @@ fn main() -> AnyhowResult<()> {
} else if req.uri().path().eq("/speak_spectrogram") { } else if req.uri().path().eq("/speak_spectrogram") {
info!("/speak_spectrogram"); info!("/speak_spectrogram");
let boxed = Box::new(req.into_body().concat2().map(move |b| { // Builds a BoxedFut to return Box::new(req.into_body().concat2().map(move |b| { // Builds a BoxedFut to return
// Parse the request body. form_urlencoded::parse // Parse the request body. form_urlencoded::parse
// always succeeds, but in general parsing may // always succeeds, but in general parsing may
// fail (for example, an invalid post of json), so // fail (for example, an invalid post of json), so
@@ -210,13 +210,17 @@ fn main() -> AnyhowResult<()> {
let body = format!("Hello {}, your number is {}", name, number); let body = format!("Hello {}, your number is {}", name, number);
Response::new(body.into()) Response::new(body.into())
})); }).and_then(move |f: Response<Body>| {
let remote_addr3 = remote_addr2.clone();
Box::new(boxed.then( |b : Result<Response<Body>, Error> | {
let new_req = Request::new(Body::empty()); let new_req = Request::new(Body::empty());
hyper_reverse_proxy::call(remote_addr2.ip(), "http://127.0.0.1:12345/speak_request", new_req) hyper_reverse_proxy::call(remote_addr3.ip(), "http://127.0.0.1:12345/speak_request", new_req)
})) }))
//Box::new(boxed.then( |b : Result<Response<Body>, Error> | {
// let new_req = Request::new(Body::empty());
// hyper_reverse_proxy::call(remote_addr2.ip(), "http://127.0.0.1:12345/speak_request", new_req)
//}))
//let new_req = Request::new(Body::empty()); //let new_req = Request::new(Body::empty());
//return hyper_reverse_proxy::call(remote_addr.ip(), &route_b, new_req) //return hyper_reverse_proxy::call(remote_addr.ip(), &route_b, new_req)