Add 8999999999999999999999

enhanced_websocket_handler.py

@@ -383,11 +383,30 @@ async def handle_voice_message(websocket: WebSocket, data: dict, session_data: d
                 enhanced_message, session_data["context"], config, knowledge_base
             ):
                 response_chunks.append(chunk)
+                # Send each chunk as structured data
                 await websocket.send_json({
                     "type": "streaming_response",
-                    "message": chunk
+                    "clause_text": chunk.get("clause_text", ""),
+                    "summary": chunk.get("summary", ""),
+                    "role_checklist": chunk.get("role_checklist", []),
+                    "source_title": chunk.get("source_title", ""),
+                    "clause_id": chunk.get("clause_id", ""),
+                    "date": chunk.get("date", ""),
+                    "url": chunk.get("url", ""),
+                    "score": chunk.get("score", 1.0),
+                    "scenario_analysis": chunk.get("scenario_analysis", None),
+                    "charts": chunk.get("charts", [])
                 })
-            response_text = "".join(response_chunks)
+            
+            # Create response text for voice synthesis from the chunks
+            response_text_parts = []
+            for chunk in response_chunks:
+                if chunk.get("clause_text"):
+                    response_text_parts.append(chunk.get("clause_text", ""))
+                if chunk.get("summary"):
+                    response_text_parts.append(chunk.get("summary", ""))
+            response_text = " ".join(response_text_parts) if response_text_parts else "I found relevant information about your query."
+            
             provider_used = hybrid_llm_service.choose_llm_provider(enhanced_message)
             provider_used = provider_used.value if provider_used else "unknown"
         else: