Update function/agent/pipeline_agent.py

function/agent/pipeline_agent.py

@@ -1,27 +1,20 @@
-import os,sys
-BASE_DIR = os.path.abspath(os.path.join(os.path.dirname(__file__), "../../"))
-sys.path.insert(0, BASE_DIR)
-from  function.file import extract_file as extract_file
-import function.agent.function_call as fc
-import function.function_agent.multi_agent as multi_agent
-import function.function_agent.map_toolcall as map_toolcall
-import function.gemini_response.response_all as response_all
-
-
-async def multi_query_user(user_input:str, user_id:int,role,languages:str,chat_id,token)->str:
-    multi_tasks = await fc.process_user_query(user_input,user_id,role,languages,chat_id)
-    result_multi_task = await multi_agent.process_toolcalls_with_order(multi_tasks,token)
-    map_tool_result = map_toolcall.map_toolcalls_with_results(multi_tasks,result_multi_task)
-    result = await response_all.response_all(user_input,map_tool_result)
-    if result != None:
-        return result
-
-    
-import asyncio
-# if __name__ == "__main__":
-#     token = "eyJhbGciOiJIUzI1NiJ9.eyJVc2VySWQiOiI0IiwiUm9sZXMiOiJDVVNUT01FUiIsInNlc3Npb25JZCI6ImJkM2M5MmNkLTczMzgtNDlmNS04NzIyLTUwMDU0Zjk5MjRhZSIsInN1YiI6ImxpbmgiLCJpYXQiOjE3NDg3NjcwNDUsImV4cCI6MTc0OTY2NzA0NX0.X4d4GcstDhaVC1nbPWWkN3sUEHNUltDtD5KgP_mzPrM"
-#     result = asyncio.run(multi_query_user("Tôi muốn thêm sản phẩm Yogurt Đào size S vào giỏ hàng và tôi quyết định mua sản phẩm này", 4 , "CUSTOMER", "VN","67d009fee0a638763885c195",token=token))
-#     print(result)
-if __name__ == "__main__":
-    result = asyncio.run(multi_query_user("Tôi muốn thêm trà chanh size L vào giỏ", 4, "CUSTOMER", "ADMIN","67d2fc6607b51a01e3beb501",""))
-    print(result)
+import os,sys
+BASE_DIR = os.path.abspath(os.path.join(os.path.dirname(__file__), "../../"))
+sys.path.insert(0, BASE_DIR)
+from  function.file import extract_file as extract_file
+import function.agent.function_call as fc
+import function.function_agent.multi_agent as multi_agent
+import function.function_agent.map_toolcall as map_toolcall
+import function.gemini_response.response_all as response_all
+
+
+async def multi_query_user(user_input:str, user_id:int,role,languages:str,chat_id,token)->str:
+    multi_tasks = await fc.process_user_query(user_input,user_id,role,languages,chat_id)
+    result_multi_task = await multi_agent.process_toolcalls_with_order(multi_tasks,token)
+    map_tool_result = map_toolcall.map_toolcalls_with_results(multi_tasks,result_multi_task)
+    result = await response_all.response_all(user_input,map_tool_result)
+    if result != None:
+        return result
+
+    
+