diff --git a/src/agents/realtime/openai_realtime.py b/src/agents/realtime/openai_realtime.py index 4485deba8..1b0f2fe35 100644 --- a/src/agents/realtime/openai_realtime.py +++ b/src/agents/realtime/openai_realtime.py @@ -266,7 +266,11 @@ async def _send_raw_message(self, event: OpenAIRealtimeClientEvent) -> None: """Send a raw message to the model.""" assert self._websocket is not None, "Not connected" - await self._websocket.send(event.model_dump_json(exclude_none=True, exclude_unset=True)) + json_str = event.model_dump_json(exclude_none=True, exclude_unset=True) + + logger.debug(f"ZZZZZ Sending raw message of type {event.type}. Length: {len(json_str)}") + + await self._websocket.send(json_str) async def _send_user_input(self, event: RealtimeModelSendUserInput) -> None: converted = _ConversionHelper.convert_user_input_to_item_create(event) @@ -275,6 +279,13 @@ async def _send_user_input(self, event: RealtimeModelSendUserInput) -> None: async def _send_audio(self, event: RealtimeModelSendAudio) -> None: converted = _ConversionHelper.convert_audio_to_input_audio_buffer_append(event) + input_audio_len = len(event.audio) + b64_audio_len = len(base64.b64encode(event.audio).decode("utf-8")) + logger.debug( + f"ZZZZZ Sending audio of length {input_audio_len}. " + f"Base64 encoded length: {b64_audio_len}" + ) + await self._send_raw_message(converted) if event.commit: await self._send_raw_message(