fixed fontbug

next/src/services/agent/autonomous-agent.ts

@@ -141,10 +141,14 @@ class AutonomousAgent {
         executionMessage.info = "";
       },
       (text) => {
-        executionMessage.info = text.replace(/"/g, "");
-        this.messageService.updateMessage(executionMessage);
+        executionMessage.info += text;
+        if(executionMessage.info){
+          console.log("执行任务信息",executionMessage)
+          this.messageService.updateMessage(executionMessage);
+        }
       },
       (error) => {
+        console.log("执行任务错误",error)
         this.messageService.sendErrorMessage(error);
         this.shutdown();
       },

next/src/services/stream-utils.ts

@@ -47,26 +47,18 @@ async function processStream(
   onError: (error: unknown) => void,
   shouldClose: () => boolean
 ): Promise<void> {
-  try {
-    onStart();
-    while (true) {
-      if (shouldClose()) {
-        await reader.cancel();
-        return;
-      }
-
-      let text = await readStream(reader);
-      if (text === null) break;
-      if(text[text.length-1]=='"'){
-        onText(eval(text));
-      }else{
-        onText(text);
-      }
-
+  onStart();
+  while (true) {
+    if (shouldClose()) {
+      await reader.cancel();
+      return;
     }
-  } catch (error) {
-    onError(error);
+
+    const text = await readStream(reader);
+    if (text === null) break;
+    onText(text);
   }
+
 }
 
 export const streamText = async (

platform/README.md

@@ -5,8 +5,9 @@
 
 这个项目使用poetry作为现代化的依赖管理工具。要运行这个项目，请使用以下命令：
 ```bash
+python3 -m pip install poetry==1.2.0
 poetry install
-poetry run python -m agent_backend
+poetry run python3 -m agent_backend
 ```
 这将在配置的主机上启动服务器。您可以在`/api/docs`处找到Swagger文档。
 您可以在此处阅读有关poetry的更多信息：https://python-poetry.org/

platform/agent_backend/web/api/agent/agent_service/open_ai_agent_service.py

@@ -72,6 +72,7 @@ async def analyze_task_agent(
         )
 
         try:
+            print("====",completion)
             return pydantic_parser.parse(completion)
         except Exception as error:
             return Analysis.get_default_analysis()

platform/agent_backend/web/api/agent/tools/search.py

@@ -27,7 +27,7 @@ async def _google_serper_search_results(
    # 调用serper.dev的API
     async with aiohttp.ClientSession() as session:
         async with session.post(
-            f"https://google.serper.dev/{search_type}", headers=headers, params=params
+            f"https://google.serper.dev/{search_type}", headers=headers, params=params,ssl=False
         ) as response:
             response.raise_for_status()
             search_results = await response.json()
@@ -95,7 +95,9 @@ async def call(
 
         if len(snippets) == 0:
             return stream_string("Google搜索引擎中没有搜索到相关信息", True)
-
+        print("====",snippets)
         # 生成摘要
-        return summarize(self.model_settings, goal, task, snippets)
+        res = summarize(self.model_settings, goal, task, snippets)
+        print(res)
+        return res
 

platform/agent_backend/web/api/agent/tools/tools.py

@@ -6,7 +6,7 @@
 from agent_backend.web.api.agent.tools.reason import Reason
 from agent_backend.web.api.agent.tools.search import Search
 from agent_backend.web.api.agent.tools.tool import Tool
-
+from agent_backend.web.api.agent.tools.wikipedia_search import Wikipedia
 
 def get_user_tools(tool_names: List[str]) -> List[Type[Tool]]:
     return list(map(get_tool_from_name, tool_names)) + get_default_tools()
@@ -22,10 +22,10 @@ def get_available_tools_names() -> List[str]:
 
 def get_external_tools() -> List[Type[Tool]]:
     return [
-        # Wikipedia,  # TODO: Remove if async doesn't work
-        Image,
+        #Wikipedia,  # TODO: Remove if async doesn't work
+        # Image,
         Search,
-        Code,
+        #Code,
     ]
 
 

platform/agent_backend/web/lifetime.py

@@ -44,11 +44,12 @@ def register_startup_event(
 
     @app.on_event("startup")
     async def _startup() -> None:  # noqa: WPS430
-        _setup_db(app)
+        # _setup_db(app)
         # await _create_tables()
         # await init_kafka(app)
 
-    return _startup
+    # return _startup
+      return ""
 
 
 def register_shutdown_event(