feat : add ai agent api

app.py

@@ -8,7 +8,9 @@ from linebot.exceptions import InvalidSignatureError  # 匯入 Line 簽章無效
 from services.linebot import line_handle
 
 from services.deblur import deblur_image_tiled
+from services.agents import run_agent
 
+import json
 from PIL import Image
 import io
 import os
@@ -69,6 +71,95 @@ async def webhook(
         raise HTTPException(status_code=400, detail="Invalid signature")
     return "ok"
 
+@app.post("/ai_agent")
+async def ai_agent(
+    input_text: Annotated[str, Form(description="輸入文字")],
+    # 將您的 form-data 欄位定義為函數參數，並使用 Form()
+    file_name: Annotated[str, Form(description="檔案名稱")] = None,
+    file_format: Annotated[str, Form(description="檔案格式")] = None,
+    file_url: Annotated[str, Form(description="檔案下載網址")] = None, # 可選參數，有預設值
+    # 對於需要轉換類型 (例如 int) 的欄位，直接在類型提示中指定
+    file_width: Annotated[int, Form(description="檔案寬度")] = 0,
+    file_height: Annotated[int, Form(description="檔案高度")] = 0,
+    file_created_at: Annotated[str, Form(description="檔案建立時間")] = None,
+):
+    out_str = ""
+    image_url = ""
+    text_result = ""
+
+    try:
+
+        agent_input = input_text
+        if file_url:
+            agent_input = f"請根據這張圖片回答問題。圖片的路徑是 {file_url}，我的問題是：{input_text}"
+
+        # 運行 LangChain 代理人
+        response = run_agent(agent_input)
+        # Agent 的輸出是 JSON 字串 (無論成功或失敗)
+        out_str = response["output"]
+        #print(f"out_str:{out_str}")
+        tool_result = out_str.get("tool_result", {})
+        if tool_result is None:
+            tool_result = {}
+        #print(f"tool_result:{tool_result}")
+        final_response = out_str.get("final_response") 
+        #print(f"final_response:{final_response}")
+
+        if "error" in tool_result:
+            # 3A. 處理錯誤情況 (例如：圖片下載失敗、API 錯誤)
+            error_msg = tool_result["error"]
+            reply_text = f"🚫 圖片工具執行失敗：\n{error_msg}"
+            return JSONResponse(
+                {"status": "error", "message": reply_text},
+                status_code=500
+            )
+
+        elif "image_url" in tool_result:
+            # 3B. 處理成功情況 (帶有圖片 URL，例如：圖片生成或去模糊工具)
+            image_url = tool_result["image_url"]
+            text_result = tool_result.get("text_result", "圖片處理完成。")
+            
+            # Line 要求圖片 URL 必須是 HTTPS
+            # 由於 HF_SPACE 預設是 https，這裡做一個保險轉換
+            if image_url.startswith("http://"):
+                image_url = image_url.replace("http://", "https://")
+                
+        elif "text_result" in tool_result:
+                # 3C. 處理純文字結果 (例如：多模態分析工具)
+            text_result = tool_result["text_result"]
+            
+        elif final_response:
+            text_result = final_response
+
+        else:
+                # 3D. 處理意外的 JSON 結構
+            text_result = "代理人回覆格式無法識別，請聯繫管理員。"
+            
+        return JSONResponse(
+            {
+                "status": "success", 
+                "message": text_result,
+                "image_url" : image_url 
+            }, status_code=200
+        )
+
+    except json.JSONDecodeError:
+            # 4. 處理 Agent 返回了無法解析的純文字 (非 JSON)
+            # 這通常發生在 Agent 決定不使用工具，直接回覆純文字，或者推理過程出錯。
+            return JSONResponse(
+                {"status": "error", "message": out_str }, status_code=500
+            )
+
+    except Exception as e:
+            # 處理代理人執行時的錯誤
+            print(f"代理人執行出錯: {e}")
+            out = f"代理人執行出錯!錯誤訊息：{e}"
+            import traceback
+            traceback.print_exc()
+            return JSONResponse(
+                {"status": "error", "message": out }, status_code=500
+            )
+
 @app.post("/predict")
 async def predict(
     request: Request,