Fix syntax

app.py

@@ -46,7 +46,7 @@ async def ask_openai(query: str, history: List[Dict[str, str]]) -> AsyncGenerato
         async with httpx.AsyncClient() as client:
             async with client.stream("POST", "https://api.openai.com/v1/chat/completions", headers=headers, json=payload) as response:
                 response.raise_for_status()
-                async for chunk in response.intro_text():
+                async for chunk in response.aiter_text():
                     if chunk:
                         # Parse the streaming chunk (JSON lines)
                         lines = chunk.splitlines()
@@ -177,14 +177,29 @@ async def query_model(query: str, provider: str, history: List[Dict[str, str]])
 
 async def submit_query(query: str, provider: str, history: List[Dict[str, str]]) -> AsyncGenerator[Tuple[str, List[Dict[str, str]], List[Dict[str, str]]], None]:
     if not query.strip():
-        yield "", history, history
+        yield "", [{"role": "assistant", "content": "Please enter a query."}], history
         return
     
     response = ""
     async for response_chunk, updated_history in query_model(query, provider, history):
         response += response_chunk
-        yield "", updated_history, updated_history  # Yield intermediate updates for streaming
-    yield "", updated_history, updated_history  # Final yield with cleared query
+        # Convert history to chatbot messages format
+        chatbot_messages = []
+        for msg in updated_history:
+            chatbot_messages.append({"role": "user", "content": msg["user"]})
+            if msg["bot"]:
+                chatbot_messages.append({"role": "assistant", "content": msg["bot"]})
+        if response and provider == "openai":
+            # For streaming, show partial response
+            chatbot_messages[-1] = {"role": "assistant", "content": response}
+        yield "", chatbot_messages, updated_history  # Yield intermediate updates
+    # Final yield with complete response
+    chatbot_messages = []
+    for msg in updated_history:
+        chatbot_messages.append({"role": "user", "content": msg["user"]})
+        if msg["bot"]:
+            chatbot_messages.append({"role": "assistant", "content": msg["bot"]})
+    yield "", chatbot_messages, updated_history
 
 # Gradio interface
 def clear_history():