wip

Author: truemagic-coder

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "solana-agent"
-version = "31.2.2-dev1"
+version = "31.2.2-dev2"
 description = "AI Agents for Solana"
 authors = ["Bevan Hunt <bevan@bevanhunt.com>"]
 license = "MIT"

solana_agent/adapters/openai_realtime_ws.py

@@ -1254,6 +1254,24 @@ def iter_output_transcript(self) -> AsyncGenerator[str, None]:  # pragma: no cov
     def set_tool_executor(self, executor):  # pragma: no cover
         self._tool_executor = executor
 
+    def reset_output_stream(self) -> None:  # pragma: no cover
+        """Drain any queued output audio and clear per-response text buffers.
+        This avoids replaying stale audio if the client failed to consume previous chunks."""
+        try:
+            while True:
+                try:
+                    _ = self._audio_queue.get_nowait()
+                except asyncio.QueueEmpty:
+                    break
+                except Exception:
+                    break
+            try:
+                self._out_text_buffers.clear()
+            except Exception:
+                pass
+        except Exception:
+            pass
+
     # Expose whether a function/tool call is currently pending
     def has_pending_tool_call(self) -> bool:  # pragma: no cover
         try:
@@ -1615,3 +1633,7 @@ async def _empty():
     def set_tool_executor(self, executor):  # pragma: no cover
         # Not applicable for transcription-only
         return
+
+    def reset_output_stream(self) -> None:  # pragma: no cover
+        # No audio output stream to reset
+        return

solana_agent/services/query.py

@@ -669,6 +669,12 @@ async def _exec(tool_name: str, args: Dict[str, Any]) -> Dict[str, Any]:
                     await rt.clear_input()
                 except Exception:
                     pass
+                # Also reset any leftover output audio so new turn doesn't replay old chunks
+                try:
+                    if hasattr(rt, "reset_output_stream"):
+                        rt.reset_output_stream()
+                except Exception:
+                    pass
 
                 # Persist once per turn
                 turn_id = await self.realtime_begin_turn(user_id)

solana_agent/services/realtime.py

@@ -185,6 +185,13 @@ def iter_events(self) -> AsyncGenerator[Dict[str, Any], None]:  # pragma: no cov
     def iter_output_audio(self) -> AsyncGenerator[bytes, None]:  # pragma: no cover
         return self._session.iter_output_audio()
 
+    def reset_output_stream(self) -> None:  # pragma: no cover
+        try:
+            if hasattr(self._session, "reset_output_stream"):
+                self._session.reset_output_stream()
+        except Exception:
+            pass
+
     async def iter_output_audio_encoded(
         self,
     ) -> AsyncGenerator[bytes, None]:  # pragma: no cover
@@ -447,6 +454,13 @@ def iter_events(self) -> AsyncGenerator[Dict[str, Any], None]:  # pragma: no cov
     def iter_output_audio(self) -> AsyncGenerator[bytes, None]:  # pragma: no cover
         return self._conv.iter_output_audio()
 
+    def reset_output_stream(self) -> None:  # pragma: no cover
+        try:
+            if hasattr(self._conv, "reset_output_stream"):
+                self._conv.reset_output_stream()
+        except Exception:
+            pass
+
     async def iter_output_audio_encoded(
         self,
     ) -> AsyncGenerator[bytes, None]:  # pragma: no cover