[NOTICKET] fixed single source into multiple sources

src/api/v1/chat.py

@@ -63,7 +63,7 @@ def _extract_sources(results: List[Dict[str, Any]]) -> List[Dict[str, Any]]:
     for result in results:
         if "document_id" in result["metadata"]["data"]:
             meta = result["metadata"]
-            key = (meta.get("document_id"), meta.get("page_label"))
+            key = (meta.get("data", {}).get("document_id"), meta.get("data", {}).get("page_label"))
             if key not in seen:
                 seen.add(key)
                 sources.append({
@@ -73,7 +73,7 @@ def _extract_sources(results: List[Dict[str, Any]]) -> List[Dict[str, Any]]:
                 })
         else:
             meta = result["metadata"]
-            key = (meta.get("table_name"), meta.get("column_name"))
+            key = (meta.get("data", {}).get("table_name"), meta.get("data", {}).get("column_name"))
             if key not in seen:
                 seen.add(key)
                 table_name = meta.get("data", {}).get("table_name")
@@ -192,6 +192,7 @@ async def chat_stream(request: ChatRequest, db: AsyncSession = Depends(get_db)):
                         query=search_query,
                         user_id=request.user_id,
                         db=db,
+                        source_hint=intent_result.get("source_hint", "both"),
                     )
                 else:
                     raw_results = await retrieval_task