Merge pull request #47 from DUT-Team-21TCLC-DT3/hotfix/law-fix-case-in-non-debug

hotfix: [LAW] Fix case in non debug error

Author: DinhManhAVG

ai_service/app/services/streaming_service.py

@@ -114,10 +114,9 @@ async def generate_streaming_response(question: str, is_debug: bool = False) ->
                     full_response = await asyncio.to_thread(composer.compose, question, search_result, web_context)
                     yield create_content_chunk(full_response)
                 else:
-                    # Yield chunks directly from compose_stream
                     iterator = composer.compose_stream(question, search_result, web_context)
-                    for chunk in iterator:
-                        yield chunk
+                    for chunk_text in iterator:
+                        yield create_content_chunk(chunk_text)
                 return
 
             # 2. Vector Search (for CONSULTATION category)
@@ -153,10 +152,9 @@ async def generate_streaming_response(question: str, is_debug: bool = False) ->
                 content = await asyncio.to_thread(composer.compose, question, search_result, web_context)
                 yield create_content_chunk(content)
             else:
-                # Yield chunks directly - compose_stream already formats them properly
                 iterator = composer.compose_stream(question, search_result, web_context)
-                for chunk in iterator:
-                    yield chunk
+                for chunk_text in iterator:
+                    yield create_content_chunk(chunk_text)
 
         except Exception as e:
             log.error(f"Pipeline Error: {e}", exc_info=True)