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

cleanup (still need to pass original request)

Browse Source
This commit is contained in:
Brandon Thomas
2020-06-29 14:56:22 -04:00
parent 663284df87
commit cd68e43389
1 changed files with 3 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main.rs
+3 -60
View File
@@ -155,67 +155,10 @@ fn main() -> AnyhowResult<()> {
return hyper_reverse_proxy::call(remote_addr.ip(), &route_a, new_req) return hyper_reverse_proxy::call(remote_addr.ip(), &route_a, new_req)
} else if req.uri().path().eq("/speak_spectrogram") { } else if req.uri().path().eq("/speak_spectrogram") {
info!("/speak_spectrogram");
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 serde_json::from_slice::<SpeakRequest>(b.as_ref())
// always succeeds, but in general parsing may .unwrap()
// fail (for example, an invalid post of json), so }).and_then(move |speak_request: SpeakRequest| {
// returning early with BadRequest may be
// necessary.
//
// Warning: this is a simplified use case. In
// principle names can appear multiple times in a
// form, and the values should be rolled up into a
// HashMap<String, Vec<String>>. However in this
// example the simpler approach is sufficient.
//let params = form_urlencoded::parse(b.as_ref()).into_owned().collect::<HashMap<String, String>>();
// Validate the request parameters, returning
// early if an invalid input is detected.
/*let name = if let Some(n) = params.get("name") {
n
} else {
return Response::builder()
.status(StatusCode::UNPROCESSABLE_ENTITY)
.body(MISSING.into())
.unwrap();
};
let number = if let Some(n) = params.get("number") {
if let Ok(v) = n.parse::<f64>() {
v
} else {
return Response::builder()
.status(StatusCode::UNPROCESSABLE_ENTITY)
.body(NOTNUMERIC.into())
.unwrap();
}
} else {
return Response::builder()
.status(StatusCode::UNPROCESSABLE_ENTITY)
.body(MISSING.into())
.unwrap();
};*/
//let request : SpeakRequest = serde_json::from_str(&req.body().into()).unwrap();
//let request: SpeakRequest = serde_json::from_slice(&body_bytes).unwrap();
let request : SpeakRequest = serde_json::from_slice(b.as_ref()).unwrap();
info!("Request: {:?}", request);
let name = "asdf";
let number = "asdf";
// Render the response. This will often involve
// calls to a database or web service, which will
// require creating a new stream for the response
// body. Since those may fail, other error
// responses such as InternalServiceError may be
// needed here, too.
let body = format!("Hello {}, your number is {}", name, number);
Response::new(body.into())
}).and_then(move |f: Response<Body>| {
let remote_addr3 = remote_addr2.clone(); let remote_addr3 = remote_addr2.clone();
let new_req = Request::new(Body::empty()); let new_req = Request::new(Body::empty());
hyper_reverse_proxy::call(remote_addr3.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)