refactor: extract _iter_content_blocks to eliminate duplicated message-content iteration

_apply_assistant and _apply_user both repeated the same five-line
boilerplate (get content from message, guard non-list, yield dicts).
The new generator centralises that logic so each method focuses only
on what it does with the blocks.

Co-authored-by: Ralphify <noreply@ralphify.co>

Author: 2 people

src/ralphify/_console_emitter.py

@@ -10,7 +10,7 @@
 import sys
 import threading
 import time
-from collections.abc import Callable
+from collections.abc import Callable, Iterator
 from dataclasses import dataclass
 from functools import partial
 from pathlib import Path
@@ -307,6 +307,16 @@ def _tool_display(name: str, tool_input: dict[str, Any]) -> tuple[str, str, str]
     return color, category, arg
 
 
+def _iter_content_blocks(raw: dict[str, Any]) -> Iterator[dict[str, Any]]:
+    """Yield each dict block from ``raw["message"]["content"]``."""
+    content = raw.get("message", {}).get("content", [])
+    if not isinstance(content, list):
+        return
+    for block in content:
+        if isinstance(block, dict):
+            yield block
+
+
 class _LivePanelBase:
     """Shared scroll-buffer state for iteration Live renderables.
 
@@ -484,13 +494,7 @@ def _apply_assistant(self, raw: dict[str, Any]) -> None:
                 "cache_read_input_tokens", self._cache_read_tokens
             )
 
-        content = msg.get("content", [])
-        if not isinstance(content, list):
-            return
-
-        for block in content:
-            if not isinstance(block, dict):
-                continue
+        for block in _iter_content_blocks(raw):
             block_type = block.get("type")
 
             if block_type == "thinking":
@@ -534,13 +538,7 @@ def _apply_assistant(self, raw: dict[str, Any]) -> None:
                     self.add_scroll_line(f"[bold {color}]{escape_markup(name)}[/]")
 
     def _apply_user(self, raw: dict[str, Any]) -> None:
-        msg = raw.get("message", {})
-        content = msg.get("content", [])
-        if not isinstance(content, list):
-            return
-        for block in content:
-            if not isinstance(block, dict):
-                continue
+        for block in _iter_content_blocks(raw):
             if block.get("type") == "tool_result" and block.get("is_error"):
                 snippet = _truncate(str(block.get("content", "")), _TRUNCATE_TOOL_ERROR)
                 self.add_scroll_line(