sources fix

src/components/orchestration/ui_adapters.py

@@ -3,6 +3,7 @@ ChatUI Adapters for LangGraph Workflow Streaming
 """
 import logging
 import asyncio
+import json
 from typing import AsyncGenerator, Dict, Any
 
 from components.utils import build_conversation_context
@@ -138,12 +139,10 @@ async def chatui_adapter(data, compiled_graph, max_turns: int = 3, max_chars: in
                     sources_collected = content
                 elif result_type == "end":
                     if sources_collected:
-                        sources_text = "\n\n**Sources:**\n"
-                        for i, source in enumerate(sources_collected, 1):
-                            title = source.get('title', 'Unknown')
-                            uri = source.get('uri') or '#'  # Handle empty string
-                            sources_text += f"{i}. [{title}]({uri})\n"
-                        yield sources_text
+                        # Send sources as structured JSON for ChatUI to parse
+                        sources_json = json.dumps({"webSources": sources_collected})
+                        logger.info(f"Sending structured sources: {sources_json}")
+                        yield sources_json
                 elif result_type == "error":
                     yield f"Error: {content}"
             else:
@@ -243,15 +242,10 @@ async def chatui_file_adapter(data, compiled_graph, max_turns: int = 3, max_char
                     sources_collected = content
                 elif result_type == "end":
                     if sources_collected:
-                        sources_text = "\n\n**Sources:**\n"
-                        for i, source in enumerate(sources_collected, 1):
-                            if isinstance(source, dict):
-                                title = source.get('title', 'Unknown')
-                                uri = source.get('uri') or '#'  # Handle empty string
-                                sources_text += f"{i}. [{title}]({uri})\n"
-                            else:
-                                sources_text += f"{i}. {str(source)}\n"
-                        yield sources_text
+                        # Send sources as structured JSON for ChatUI to parse
+                        sources_json = json.dumps({"webSources": sources_collected})
+                        logger.info(f"Sending structured sources (file): {sources_json}")
+                        yield sources_json
                 elif result_type == "error":
                     yield f"Error: {content}"
             else: