Update app.py

app.py

@@ -24,7 +24,7 @@ async def send_chat_message(LLM_URL, LLM_API, category, file_id):
     payload = {
         "inputs": {},
         "query": category,
-        "response_mode": "streaming",
+        "response_mode": "blocking",  # ⬅️ 改這裡
         "conversation_id": "",
         "user": USER_ID,
         "files": [
@@ -45,26 +45,17 @@ async def send_chat_message(LLM_URL, LLM_API, category, file_id):
             ) as response:
 
                 if response.status != 200:
-                    err = await response.text()
-                    return f"Error: Server returned status {response.status}: {err}"
-
-                last_thought = None
-                async for line in response.content:
-                    if line:
-                        try:
-                            if b"data: " in line:
-                                json_part = line.split(b"data: ")[1].strip()
-                                data = json.loads(json_part.decode("utf-8"))
-                                if data.get("event") == "agent_thought":
-                                    last_thought = data.get("thought")
-                        except Exception as e:
-                            print(f"[stream error] {e} line={line}")
-                            continue
-                return last_thought.strip() if last_thought else "Error: No thought found in response"
-    except aiohttp.ClientPayloadError as e:
-        return f"Error: Incomplete response stream ({str(e)})"
+                    error_text = await response.text()
+                    return f"Error: Server returned status {response.status} - {error_text}"
+
+                try:
+                    data = await response.json()
+                    return data.get("thought", "Error: No thought in response")
+                except Exception as e:
+                    return f"Error: Failed to parse JSON - {e}"
+
     except Exception as e:
-        return f"Error: Unexpected exception - {str(e)}"
+        return f"Error: Unexpected exception - {e}"
 
 async def upload_file(LLM_URL, LLM_API, file_path, user_id):
     if not os.path.exists(file_path):