Update app.py

app.py

@@ -21,6 +21,10 @@ LLM_URL = os.environ.get("LLM_URL")
 USER_ID = "HuggingFace Space"
 
 async def send_chat_message(LLM_URL, LLM_API, category, file_url):
+    print(f"--- 開始請求 ---")
+    print(f"URL: {LLM_URL}/chat-messages")
+    print(f"File URL: {file_url}") # 檢查這裡產生的 URL 是否真的公開可讀取
+
     payload = {
         "inputs": {},
         "query": category,
@@ -37,61 +41,54 @@ async def send_chat_message(LLM_URL, LLM_API, category, file_url):
     }
 
     answer = ""
-    async with aiohttp.ClientSession() as session:
-        async with session.post(
-            f"{LLM_URL}/chat-messages",
-            headers={
-                "Authorization": f"Bearer {LLM_API}",
-                "Content-Type": "application/json"
-            },
-            json=payload
-        ) as response:
-            async for line_bytes in response.content:
-                line = line_bytes.decode("utf-8").strip()
-                if line.startswith("data: "):
-                    try:
-                        data = json.loads(line[6:])
-                        if "answer" in data:
-                            answer += data["answer"]
-                    except:
-                        continue
-    return answer or "No answer returned"
-            
-# async def send_chat_message(LLM_URL, LLM_API, category, file_id):
-#     payload = {
-#         "inputs": {},
-#         "query": category,
-#         "conversation_id": "",
-#         "user": USER_ID,
-#         "files": [
-#             {
-#                 "type": "image",
-#                 "transfer_method": "remote_url",
-#                 "upload_file_id": file_id
-#             }
-#         ]
-#     }
-
-#     try:
-#         async with aiohttp.ClientSession() as session:
-#             async with session.post(
-#                 f"{LLM_URL}/chat-messages",
-#                 headers={"Authorization": f"Bearer {LLM_API}"},
-#                 json=payload
-#             ) as response:
-
-#                 if response.status != 200:
-#                     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 - {e}"
+    try:
+        async with aiohttp.ClientSession() as session:
+            async with session.post(
+                f"{LLM_URL}/chat-messages",
+                headers={
+                    "Authorization": f"Bearer {LLM_API}",
+                    "Content-Type": "application/json"
+                },
+                json=payload
+            ) as response:
+                
+                # [DEBUG 1] 檢查狀態碼
+                print(f"HTTP Status: {response.status}")
+                
+                if response.status != 200:
+                    # 如果出錯，讀取錯誤訊息並回傳
+                    error_text = await response.text()
+                    print(f"API Error Response: {error_text}")
+                    return f"API Error {response.status}: {error_text}"
+
+                # [DEBUG 2] 逐行監看回傳內容
+                async for line_bytes in response.content:
+                    line = line_bytes.decode("utf-8").strip()
+                    
+                    # 印出原始資料 (Debug 用，確認有東西回來)
+                    if line: 
+                        print(f"Raw Line: {line}") 
+
+                    if line.startswith("data: "):
+                        try:
+                            data = json.loads(line[6:])
+                            if "answer" in data:
+                                answer += data["answer"]
+                                # print(f"Current Answer chunk: {data['answer']}") # 選用：即時看片段
+                            if "error" in data:
+                                print(f"Data Error: {data}") # Dify 有時會在 data 裡回傳 error
+                        except Exception as e:
+                            print(f"JSON Parse Error: {e} | Content: {line}")
+                            continue
+                            
+    except Exception as e:
+        print(f"Request Exception: {e}")
+        return f"System Error: {str(e)}"
+
+    if not answer:
+        print("警告: 請求結束但 answer 為空")
+        
+    return answer or "No answer returned (Empty Response)"
 
 async def upload_file(LLM_URL, LLM_API, file_path, user_id):
     if not os.path.exists(file_path):