fix(client): do not mutate SendMessageRequest in BaseClient.send_message

Author: ishymko

src/a2a/client/base_client.py

@@ -66,7 +66,7 @@ async def send_message(
         Yields:
             An async iterator of `StreamResponse`
         """
-        self._apply_client_config(request)
+        request = self._apply_client_config(request)
         if not self._config.streaming or not self._card.capabilities.streaming:
             response = await self._execute_with_interceptors(
                 input_data=request,
@@ -100,7 +100,12 @@ async def send_message(
         ):
             yield event
 
-    def _apply_client_config(self, request: SendMessageRequest) -> None:
+    def _apply_client_config(
+        self, request: SendMessageRequest
+    ) -> SendMessageRequest:
+        request_copy = SendMessageRequest()
+        request_copy.CopyFrom(request)
+        request = request_copy
         request.configuration.return_immediately |= self._config.polling
         if (
             not request.configuration.HasField('task_push_notification_config')
@@ -116,6 +121,7 @@ def _apply_client_config(self, request: SendMessageRequest) -> None:
             request.configuration.accepted_output_modes.extend(
                 self._config.accepted_output_modes
             )
+        return request
 
     async def _process_stream(
         self,

tests/client/test_base_client.py

@@ -208,6 +208,41 @@ async def test_send_message_non_streaming_agent_capability_false(
         response = events[0]
         assert response.task.id == 'task-789'
 
+    @pytest.mark.asyncio
+    async def test_send_message_does_not_mutate_request(
+        self,
+        base_client: BaseClient,
+        mock_transport: MagicMock,
+        sample_message: Message,
+    ):
+        base_client._config.streaming = False
+        base_client._config.polling = True
+        base_client._config.accepted_output_modes = ['application/json']
+        base_client._config.push_notification_configs = [
+            TaskPushNotificationConfig(
+                task_id='task-1',
+            )
+        ]
+
+        task = Task(
+            id='task-no-mutate',
+            context_id='ctx-no-mutate',
+            status=TaskStatus(state=TaskState.TASK_STATE_COMPLETED),
+        )
+        response = SendMessageResponse()
+        response.task.CopyFrom(task)
+        mock_transport.send_message.return_value = response
+
+        request = SendMessageRequest(message=sample_message)
+
+        original = SendMessageRequest()
+        original.CopyFrom(request)
+
+        events = [event async for event in base_client.send_message(request)]
+        assert len(events) == 1
+
+        assert request == original
+
     @pytest.mark.asyncio
     async def test_send_message_callsite_config_overrides_non_streaming(
         self,