From fa1f27bad5e60eb649adc2a807bef0339144c86e Mon Sep 17 00:00:00 2001
From: Joey Yakimowich-Payne <jyapayne@pm.me>
Date: Fri, 13 Mar 2026 12:40:18 -0600
Subject: [PATCH] fix: remove YuyayStreamFilter so pichay can receive
 yuyay-response blocks

---
 src/mnemosyne/gateway.py | 11 +----------
 1 file changed, 1 insertion(+), 10 deletions(-)

diff --git a/src/mnemosyne/gateway.py b/src/mnemosyne/gateway.py
index a44893a..e30253e 100644
--- a/src/mnemosyne/gateway.py
+++ b/src/mnemosyne/gateway.py
@@ -2035,7 +2035,6 @@ def create_app(
                 stream_error = False
                 sse_buffer = bytearray()
                 usage: dict[str, Any] = {}
-                yuyay_filter = YuyayStreamFilter()
                 try:
                     with client.stream(
                         "POST", upstream_path, json=outgoing_body, headers=headers
@@ -2049,7 +2048,6 @@ def create_app(
                             for chunk in resp.iter_bytes():
                                 bytes_out += len(chunk)
                                 chunk_count += 1
-                                # Inspect raw chunk for metrics (before filtering)
                                 _inspect_sse_chunk(
                                     chunk,
                                     buffer=sse_buffer,
@@ -2059,14 +2057,7 @@ def create_app(
                                     provider=provider,
                                     usage_accumulator=usage,
                                 )
-                                # Filter yuyay protocol tags before forwarding
-                                filtered = yuyay_filter.feed(chunk)
-                                if filtered:
-                                    yield filtered
-                            # Flush any remaining buffered bytes
-                            tail = yuyay_filter.flush()
-                            if tail:
-                                yield tail
+                                yield chunk
                 except Exception as e:
                     stream_error = True
                     emit_event(