fix(open_responses): preserve spec stream details

Author: Komzpa

homeassistant/components/open_responses/entity.py

@@ -256,7 +256,7 @@ async def _transform_stream(
                     "native": {
                         "type": "reasoning",
                         "id": item.get("id"),
-                        "summary": [],
+                        "summary": item.get("summary") or [],
                         "encrypted_content": item.get("encrypted_content"),
                     }
                 }
@@ -324,9 +324,9 @@ async def _transform_stream(
                     reason = error.get("message") or reason
                 raise HomeAssistantError(f"Open Responses response failed: {reason}")
         elif event_type == "response.error":
-            raise HomeAssistantError(
-                f"Open Responses response error: {event['message']}"
-            )
+            error = cast(dict[str, Any], event.get("error") or {})
+            reason = error.get("message") or event.get("message") or "unknown reason"
+            raise HomeAssistantError(f"Open Responses response error: {reason}")
 
 
 class OpenResponsesEntity(Entity):

tests/components/open_responses/test_entity.py

@@ -4,6 +4,7 @@
 from pathlib import Path
 from unittest.mock import Mock
 
+import pytest
 import voluptuous as vol
 
 from homeassistant.components import conversation
@@ -14,6 +15,7 @@
     _transform_stream,
 )
 from homeassistant.core import HomeAssistant
+from homeassistant.exceptions import HomeAssistantError
 from homeassistant.helpers import llm
 
 
@@ -344,7 +346,11 @@ async def stream() -> AsyncGenerator[dict]:
 
 async def test_transform_stream_starts_new_message_for_reasoning_item() -> None:
     """Test each reasoning item starts a separate assistant message."""
-    first_reasoning = {"id": "reasoning_1", "summary": [], "type": "reasoning"}
+    first_reasoning = {
+        "id": "reasoning_1",
+        "summary": [{"type": "summary_text", "text": "Checked the state."}],
+        "type": "reasoning",
+    }
     second_reasoning = {"id": "reasoning_2", "summary": [], "type": "reasoning"}
 
     async def stream() -> AsyncGenerator[dict]:
@@ -387,7 +393,7 @@ async def stream() -> AsyncGenerator[dict]:
             "native": {
                 "encrypted_content": None,
                 "id": "reasoning_1",
-                "summary": [],
+                "summary": [{"type": "summary_text", "text": "Checked the state."}],
                 "type": "reasoning",
             }
         },
@@ -401,3 +407,31 @@ async def stream() -> AsyncGenerator[dict]:
             }
         },
     ]
+
+
+async def test_transform_stream_handles_spec_error_envelope() -> None:
+    """Test streaming error events use the Open Responses error envelope."""
+
+    async def stream() -> AsyncGenerator[dict]:
+        yield {
+            "error": {
+                "code": "invalid_request",
+                "message": "Invalid tool result.",
+                "param": "input",
+                "type": "invalid_request_error",
+            },
+            "sequence_number": 0,
+            "type": "response.error",
+        }
+
+    with pytest.raises(
+        HomeAssistantError,
+        match="Open Responses response error: Invalid tool result.",
+    ):
+        [
+            delta
+            async for delta in _transform_stream(
+                Mock(),
+                stream(),
+            )
+        ]