Invoke request_body_filter of modules for proxies

This commit is contained in:
Yuchen Wu 2024-06-25 16:25:22 -07:00 committed by Yuchen Wu
parent ee7f66082f
commit 65b1d6c733
3 changed files with 11 additions and 1 deletions

2
.bleep
View file

@ -1 +1 @@
9ec5f295aba1ec889914afb8c3cbb44724a516f1
00504ca4d524990b3a1b53bbeb42824c3fbdcfe9

View file

@ -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?;

View file

@ -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?;