From eb6b760981daaf674e90a49fcc4bc99f4c84fefe Mon Sep 17 00:00:00 2001
From: Teknium <127238744+teknium1@users.noreply.github.com>
Date: Wed, 2 Sep 2026 22:59:19 -0700
Subject: [PATCH] =?UTF-8?q?refactor(plugins/google=5Fmeet):=20RealtimeSess?=
 =?UTF-8?q?ion.speak=20=E2=80=94=20ExitStack=20for=20the=20optional=20sink?=
 =?UTF-8?q?=20file?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 plugins/google_meet/realtime/openai_client.py | 17 ++++++-----------
 1 file changed, 6 insertions(+), 11 deletions(-)

diff --git a/plugins/google_meet/realtime/openai_client.py b/plugins/google_meet/realtime/openai_client.py
index 0eb8cc94bb..de0e58def4 100644
--- a/plugins/google_meet/realtime/openai_client.py
+++ b/plugins/google_meet/realtime/openai_client.py
@@ -86,18 +86,16 @@ class RealtimeSession:
         })
         self._send_json({"type": "response.create", "response": {"modalities": ["audio"]}})
         bytes_written = 0
-        sink_fp = None
-        if self.audio_sink_path is not None:
-            self.audio_sink_path.parent.mkdir(parents=True, exist_ok=True)
-            sink_fp = open(self.audio_sink_path, "ab")
-        try:
+        with contextlib.ExitStack() as stack:
+            sink_fp = None
+            if self.audio_sink_path is not None:
+                self.audio_sink_path.parent.mkdir(parents=True, exist_ok=True)
+                sink_fp = stack.enter_context(open(self.audio_sink_path, "ab"))
             while True:
                 frame = self._recv_frame(start + timeout, timeout)
-                if frame is None:  # connection closed by peer
+                if frame is None or frame.get("type") in _TERMINAL_FRAMES:  # peer closed / response done
                     break
                 ftype = frame.get("type")
-                if ftype in _TERMINAL_FRAMES:
-                    break
                 if ftype == "error":
                     raise RuntimeError(f"realtime error: {frame.get('error') or frame}")
                 if ftype == "response.audio.delta" and sink_fp is not None:
@@ -108,9 +106,6 @@ class RealtimeSession:
                         bytes_written += len(chunk)
                         self.audio_bytes_out += len(chunk)
                         self.last_audio_out_at = time.time()
-        finally:
-            if sink_fp is not None:
-                sink_fp.close()
         return {"ok": True, "bytes_written": bytes_written, "duration_ms": (time.monotonic() - start) * 1000.0}
 
     def cancel_response(self) -> bool: