bug fixes

app/api_helpers.py

@@ -365,7 +365,7 @@ async def openai_fake_stream_generator( # Reverted signature: removed thought_ta
         
         # Use the already configured extra_body which includes the thought_tag_marker
         _api_call_task = asyncio.create_task(
-            openai_client.chat.completions.create(**params_for_non_stream_call, extra_body=openai_extra_body['extra_body'])
+            openai_client.chat.completions.create(**params_for_non_stream_call, extra_body=openai_extra_body)
         )
         raw_response = await _api_call_task
         full_content_from_api = ""

app/openai_handler.py

@@ -115,7 +115,7 @@ class OpenAIDirectHandler:
             openai_params_for_stream = {**openai_params, "stream": True}
             stream_response = await openai_client.chat.completions.create(
                 **openai_params_for_stream,
-                extra_body=openai_extra_body['extra_body']
+                extra_body=openai_extra_body
             )
             
             # Create processor for tag-based extraction across chunks
@@ -134,6 +134,7 @@ class OpenAIDirectHandler:
                                 del delta['extra_content']
                             
                             content = delta.get('content', '')
+                            print(content)
                             if content:
                                 # Use the processor to extract reasoning
                                 processed_content, current_reasoning = reasoning_processor.process_chunk(content)
@@ -198,7 +199,7 @@ class OpenAIDirectHandler:
             openai_params_non_stream = {**openai_params, "stream": False}
             response = await openai_client.chat.completions.create(
                 **openai_params_non_stream,
-                extra_body=openai_extra_body['extra_body']
+                extra_body=openai_extra_body
             )
             response_dict = response.model_dump(exclude_unset=True, exclude_none=True)