From 1b430c100e9fb05b89ed4d71b7b3daa8fbc868d0 Mon Sep 17 00:00:00 2001
From: Edward Wang <ewang@cloudflare.com>
Date: Mon, 4 Nov 2024 15:08:56 -0800
Subject: Allow errors from upstream_response_body_filter

---
 .bleep                           | 2 +-
 pingora-proxy/src/lib.rs         | 2 +-
 pingora-proxy/src/proxy_trait.rs | 3 ++-
 3 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/.bleep b/.bleep
index 51c1503..1e3b918 100644
--- a/.bleep
+++ b/.bleep
@@ -1 +1 @@
-a76fd1ca898a9518c6aa0c7c8fa5ed845dd1bcbb
\ No newline at end of file
+4a86ea20bc7d70669a7be7b3b316139cbe74e648
\ No newline at end of file
diff --git a/pingora-proxy/src/lib.rs b/pingora-proxy/src/lib.rs
index 5621170..f13a1f7 100644
--- a/pingora-proxy/src/lib.rs
+++ b/pingora-proxy/src/lib.rs
@@ -250,7 +250,7 @@ impl<SV> HttpProxy<SV> {
             }
             HttpTask::Body(data, eos) => self
                 .inner
-                .upstream_response_body_filter(session, data, *eos, ctx),
+                .upstream_response_body_filter(session, data, *eos, ctx)?,
             HttpTask::Trailer(Some(trailers)) => self
                 .inner
                 .upstream_response_trailer_filter(session, trailers, ctx)?,
diff --git a/pingora-proxy/src/proxy_trait.rs b/pingora-proxy/src/proxy_trait.rs
index 4f3f627..4017789 100644
--- a/pingora-proxy/src/proxy_trait.rs
+++ b/pingora-proxy/src/proxy_trait.rs
@@ -267,7 +267,8 @@ pub trait ProxyHttp {
         _body: &mut Option<Bytes>,
         _end_of_stream: bool,
         _ctx: &mut Self::CTX,
-    ) {
+    ) -> Result<()> {
+        Ok(())
     }
 
     /// Similar to [Self::upstream_response_filter()] but for response trailers
-- 
cgit v1.2.3