chore: 增加 Token 刷新失败后，重新获取

Author: tianxiu2b2t

core/cluster.py

@@ -98,24 +98,28 @@ async def _schedule_refresh_token(self, ttl: float):
             logger.ttraceback("cluster.refresh_token", id=self._id, name=self.display_name)
 
     async def refresh_token(self):
-        async with aiohttp.ClientSession(
-            base_url=cfg.base_url,
-            headers={
-                "Authorization": f"Bearer {self._token}",
-                "User-Agent": USER_AGENT,
-            }
-        ) as session:
-            async with session.post(
-                "/openbmclapi-agent/token",
-                json={
-                    "clusterId": self._id,
-                    "token": self._token
+        try:
+            async with aiohttp.ClientSession(
+                base_url=cfg.base_url,
+                headers={
+                    "Authorization": f"Bearer {self._token}",
+                    "User-Agent": USER_AGENT,
                 }
-            ) as resp:
-                data = await resp.json()
-                self._token = data['token']
-                ttl = data['ttl'] / 1000.0
-                self.schedule_refresh_token(ttl)
+            ) as session:
+                async with session.post(
+                    "/openbmclapi-agent/token",
+                    json={
+                        "clusterId": self._id,
+                        "token": self._token
+                    }
+                ) as resp:
+                    data = await resp.json()
+                    self._token = data['token']
+                    ttl = data['ttl'] / 1000.0
+                    self.schedule_refresh_token(ttl)
+        except:
+            logger.ttraceback("cluster.refresh_token", id=self._id, name=self.display_name)
+            await self.fetch_token()
 
     async def get_socketio_token(self):
         return {

locale/zh_cn.json

@@ -5,6 +5,7 @@
     "debug.web.uvicorn.port": "Web 服务器监听端口 [${port}]",
     "error.cluster.enable": "节点 [${name} (${id})] 上线失败 [${err}]",
     "traceback.cluster.enable.timeout": "节点 [${name} (${id})] 注册超时",
+    "traceback.cluster.refresh_token": "节点 [${name} (${id})] Token 刷新失败",
     "error.cluster.exception": "节点 [${name} (${id})] 异常：[${msg}]",
     "error.cluster.kicked": "节点 [${name} (${id})] 被主控踢出下线",
     "error.cluster.refresh_token": "刷新节点 [${name} (${id})] Token 失败",