feat(app): add timeout; fix ai extent not counted for es

src/retk/core/node/node.py

@@ -41,7 +41,7 @@ async def post(
     if from_nid != "":
         from_nids.append(from_nid)
         res = await db_ops.node_add_to_set(from_nid, "toNodeIds", nid)
-        if res.modified_count != 1:
+        if not res.acknowledged:
             return None, const.CodeEnum.OPERATION_FAILED
 
     new_to_node_ids = []

src/retk/core/utils/cos.py

@@ -107,6 +107,7 @@ async def async_put(self, file: BinaryIO, uid: str, filename: str) -> bool:
                     url=f"https://{self.domain}/{key}",
                     headers=self.get_auth_headers("put", key),
                     content=file.read(),
+                    timeout=60,
                 )
             if resp.status_code != 200:
                 logger.error(f"put_cos_object | error: {resp.text}")
@@ -117,7 +118,7 @@ async def async_put(self, file: BinaryIO, uid: str, filename: str) -> bool:
                 httpx.ReadTimeout,
                 httpx.HTTPError
         ) as e:
-            logger.error(f"put_cos_object | error: {e}")
+            logger.error(f"put_cos_object | error: {str(e)}")
             return False
         return True
 

src/retk/models/client.py

@@ -363,7 +363,7 @@ async def try_restore_search(self):
             return
         logger.critical(
             f"restore search index count: {count_search}, mongo count: {count_mongo}."
-            f" They are not equal, tring to restore search index")
+            f" They are not equal, trying to restore search index")
 
         await self.search.drop()
         await self.search.init()