From 8643d80b1c250f3f7a207994c90b6754c340a5df Mon Sep 17 00:00:00 2001 From: Brandon Thomas Date: Thu, 10 Sep 2020 03:24:49 -0400 Subject: [PATCH] fix bug --- src/speak_proxy.rs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/speak_proxy.rs b/src/speak_proxy.rs index aa77746..b277f6f 100644 --- a/src/speak_proxy.rs +++ b/src/speak_proxy.rs @@ -56,6 +56,10 @@ pub async fn speak_proxy_with_retry( headers_to_proxy.insert(HeaderName::from_static("x-voder-proxy-for"), upstream_client_ip.clone()); headers_to_proxy.insert(HeaderName::from_static("x-gateway-ip"), gateway_ip); + // We're going to be changing the request body length, so remove the reported value + // so Hyper doesn't choke on any mismatch. + headers_to_proxy.remove(HeaderName::from_static("content-length")); + // The proxy host is a Kubernetes load balancer. We're not doing the round robin magic here, // so it makes sense to reuse the same value for each retry. let load_balancer_hostname = router.get_speaker_host(&external_http_request.speak_request.speaker); @@ -112,6 +116,8 @@ async fn speak_proxy( let json_speak_request = serde_json::to_string(&internal_speak_request).unwrap(); + println!("Request: {:?}", internal_speak_request); + let request = request_builder .body(Body::from(json_speak_request)) .unwrap();