diff options
Diffstat (limited to 'pingora-proxy')
| -rw-r--r-- | pingora-proxy/src/proxy_h1.rs | 5 | ||||
| -rw-r--r-- | pingora-proxy/src/proxy_h2.rs | 5 |
2 files changed, 10 insertions, 0 deletions
diff --git a/pingora-proxy/src/proxy_h1.rs b/pingora-proxy/src/proxy_h1.rs index de49c03..1dbb561 100644 --- a/pingora-proxy/src/proxy_h1.rs +++ b/pingora-proxy/src/proxy_h1.rs @@ -546,6 +546,11 @@ impl<SV> HttpProxy<SV> { // affected by the request_body_filter let end_of_body = end_of_body || data.is_none(); + session + .downstream_modules_ctx + .request_body_filter(&mut data, end_of_body) + .await?; + self.inner .request_body_filter(session, &mut data, end_of_body, ctx) .await?; diff --git a/pingora-proxy/src/proxy_h2.rs b/pingora-proxy/src/proxy_h2.rs index c213857..5216ee9 100644 --- a/pingora-proxy/src/proxy_h2.rs +++ b/pingora-proxy/src/proxy_h2.rs @@ -525,6 +525,11 @@ impl<SV> HttpProxy<SV> { SV: ProxyHttp + Send + Sync, SV::CTX: Send + Sync, { + session + .downstream_modules_ctx + .request_body_filter(&mut data, end_of_body) + .await?; + self.inner .request_body_filter(session, &mut data, end_of_body, ctx) .await?; |