fix: 修复 /openbmclapi/download 接口给你 warden 了

Author: tianxiu2b2t

core/cluster.py

@@ -165,8 +165,17 @@ async def get_file(self, hash: str):
                 }
             ) as session:
                 async with session.get(
-                    f"/openbmclapi/download/{hash}"
+                    f"/openbmclapi/download/{hash}",
+                    params={
+                        "noopen": str(1)
+                    }
                 ) as resp:
+                    # check hash, if hash is not mismatch.
+                    body = await resp.content.read()
+                    utils.raise_service_error(body)
+                    got_hash = utils.get_hash_hexdigest(hash, body)
+                    if got_hash != hash:
+                        logger.terror("cluster.error.download_hash", got_hash=got_hash, hash=hash, content=body.decode("utf-8", "ignore")[:64])     
                     file = MemoryStorageFile(
                         hash,
                         resp.content_length or -1,

i18n/zh_cn.json

@@ -36,5 +36,6 @@
     "cluster.error.socketio.warden": "[Warden] 节点 [${cluster}] 收到错误消息，原因 [${message}]",
     "utils.error.service_error": "服务出错，状态码 [${code}(${httpCode})] 类型 [${name}] 信息 [${message}]",
     "web.warning.server_down": "当前 [${port}] 端口已重新开启",
-    "web.traceback.check_server": "当前 [${port}] 端口没有通过检查，原因是："
+    "web.traceback.check_server": "当前 [${port}] 端口没有通过检查，原因是：",
+    "cluster.error.download_hash": "通过主控下载文件出错，本来的哈希是 [${hash}]，获取到的哈希是 [${got_hash}]，内容为 [${content}]"
 }