支持zerocopy操作，修复keepalive获取hash时候报错

Author: tianxiu2b2t

core/api.py

@@ -257,7 +257,7 @@ def get_hash_content(org, content: io.BytesIO):
         h = hashlib.md5()
     else:
         h = hashlib.sha1()
-    h.update(content)
+    h.update(content.getbuffer())
     return org == h.hexdigest()
 
 

core/certificate.py

@@ -19,7 +19,7 @@
 def _load_cert(cert, key):
     global server_side_ssl, client_side_ssl, _loaded
     if not os.path.exists(cert) or not os.path.exists(key):
-        logger.terror("cert.error.failed.file", cert=cert, key=key)
+        logger.terror("cert.error.failed.file", cert=cert, path=key)
         return False
     try:
         server_side_ssl.load_cert_chain(cert, key)

core/cluster.py

@@ -402,14 +402,14 @@ async def __call__(
             self.start_task()
             return
         with tqdm(
+            desc=locale.t("cluster.tqdm.desc.check_files"),
             total=len(files) * len(storages.get_storages()),
             unit=locale.t("cluster.tqdm.unit.file"),
             unit_scale=True,
         ) as pbar:
             self.pbar = pbar
             self.files = files
             await dashboard.set_status_by_tqdm("files.checking", pbar)
-            pbar.set_description(locale.t("cluster.tqdm.desc.check_files"))
             try:
                 miss_storage: list[list[BMCLAPIFile]] = await asyncio.gather(
                     *[

core/web.py

@@ -19,7 +19,6 @@
 import zlib
 from core.exceptions import (
     WebSocketError,
-    ServerWebSocketError,
     ServerWebSocketUnknownDataError,
 )
 from typing import (
@@ -906,13 +905,10 @@ async def __call__(
                 client.write(content.getbuffer()[start_bytes : end_bytes + 1])
                 await client.drain()
             elif isinstance(content, Path):
-                async with aiofiles.open(content, "rb") as r:
-                    cur_length: int = 0
-                    await r.seek(start_bytes, os.SEEK_SET)
-                    while data := await r.read(max(0, min(IO_BUFFER, length - cur_length))):
-                        cur_length += len(data)
-                        client.write(data)
-                        await client.drain()
+                with open(content, "rb") as r:
+                    await asyncio.get_event_loop().sendfile(
+                        client.writer.transport, r, start_bytes, length
+                    )
             else:
                 cur_length: int = 0
                 bound: bool = False