TTB-Network
diff --git a/‎core/cluster.py‎
Lines changed: 14 additions & 1 deletion b/‎core/cluster.py‎
Lines changed: 14 additions & 1 deletion
diff --git a/‎locale/zh_cn.json‎
Lines changed: 1 addition & 1 deletion b/‎locale/zh_cn.json‎
Lines changed: 1 addition & 1 deletion
@@ -100,6 +100,7 @@ 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:
@@ -592,6 +593,8 @@ def __init__(
         self._task_group = None
         self._certificate_type: Optional[CertificateType] = None
         self._cluster_name = False
+        self._zero_bytes_files: set[BMCLAPIFile] = set()
+        self._zero_bytes_hash: set[str] = set()
 
     def add_cluster(
         self,
@@ -640,12 +643,18 @@ async def _(msg: Any):
 
     async def get_files(self) -> set[BMCLAPIFile]:
         # 批量获取 files
-        return set().union(
+        files = set().union(
             *await concurrency.gather(*[
                 cluster.get_files() for cluster in self.clusters
             ])
         )
 
+        # filter 0 bytes
+        zero_bytes = set(filter(lambda x: x.size == 0, files))
+        self._zero_bytes_files = zero_bytes
+        self._zero_bytes_hash = set([f.hash for f in zero_bytes])
+        return files - zero_bytes
+
     async def sync(self):
         assert self._task_group is not None
 
@@ -713,6 +722,10 @@ def hit(self, cluster_id: str, bytes: int):
         self._clusters[cluster_id].counter.bytes += bytes
 
     async def get_response_file(self, hash: str) -> ResponseFile:
+        if hash in self._zero_bytes_hash:
+            return ResponseFile(
+                0
+            )
         storage = self.storages.get_weight_storage()
         if storage is None:
             logger.twarning("cluster.get_response_file.no_storage")
 
@@ -29,7 +29,7 @@
     "info.cluster.want_enable": "节点 [${name} (${id})] 上线",
     "info.core.exit": "已退出",
     "info.core.initialize": "初始化中...",
-    "info.core.initialize.cluster": "加载节点 [${name} (${id})]",
+    "info.core.initialize.cluster": "加载节点 [${id}]",
     "info.core.initialize.platform": "操作平台 [${os} ${arch}] Python 版本 [${python}]",
     "info.core.initialize.storage": "加载存储 [${name} (${type})]",
     "info.core.initialize.version": "API 版本: [${api_version}] Python OpenBMCLAPI 版本 [${version}]",