translate done

Author: kezhengjie

i18n.py

@@ -31,6 +31,10 @@ def __init__(
         fail: str,
         unable_to_start_grpc_server: str,
         title: str,
+        receiving_file: str,
+        receive_file_successful: str,
+        sending_file: str,
+        syncing_file_to: str,
     ) -> None:
         self.ip_label = ip_label
         self.ip_edit_button = ip_edit_button
@@ -62,6 +66,10 @@ def __init__(
         self.fail = fail
         self.unable_to_start_grpc_server = unable_to_start_grpc_server
         self.title = title
+        self.receiving_file = receiving_file
+        self.receive_file_successful = receive_file_successful
+        self.sending_file = sending_file
+        self.syncing_file_to = syncing_file_to
 
 
 cn = Text(
@@ -95,6 +103,10 @@ def __init__(
     "失败",
     "无法启动grpc服务器",
     "游戏存档同步工具",
+    "正在接收文件",
+    "接收文件成功",
+    "正在发送文件",
+    "同步文件到{}中"
 )
 
 en = Text(
@@ -128,6 +140,10 @@ def __init__(
     "fail",
     "unable to start grpc server",
     "Game Save Sync",
+    "receiving file",
+    "receive file successful",
+    "sending file",
+    "syncing file to {}"
 )
 
 

mainwindow.py

@@ -37,7 +37,7 @@ class Signal(QObject):
 class MainWindow(QWidget):
     def __init__(self):
         super().__init__()
-        self._debug_mode = True
+        self._debug_mode = False
         self._grpc_client = None
         self.config = Config()
         self._text: Text = get_i18n_text(self.config.lang)
@@ -67,6 +67,7 @@ def switch_cn_en(self):
             self.config.lang = "cn"
         self.config.save()
         self._text = get_i18n_text(self.config.lang)
+        self.rpc_service.set_text_source(self._text)
         self.i18n()
 
     def _debug_method(self):
@@ -162,10 +163,12 @@ def moveEvent(self, ev: QMoveEvent):
     def start_grpc_thread(self):
         try:
             self.grpc_server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
+            self.rpc_service = RPCService(
+                get_filepath=self.filepath_line_edit.text, logger=self.print
+            )
+            self.rpc_service.set_text_source(self._text)
             rpc_service_pb2_grpc.add_RpcServicer_to_server(
-                RPCService(
-                    get_filepath=self.filepath_line_edit.text, logger=self.print
-                ),
+                self.rpc_service,
                 self.grpc_server,
             )
             self.grpc_server.add_insecure_port("[::]:" + str(self.config.listen_port))
@@ -223,7 +226,7 @@ def show_ip_edit_dialog(self):
 
     def compress_file(self, filepath: str):
         zip_filepath = "temp.zip"
-        self.print(f"{self._text.compressing}{os.path.basename(filepath)}")
+        self.print(f"{self._text.compressing} {os.path.basename(filepath)}")
         compress_file(filepath, zip_filepath)
         self.print(f"{self._text.compress_done}")
         return zip_filepath

rpc_service.py

@@ -8,6 +8,7 @@
 
 import grpc
 from compress import compress_file, decompress
+from i18n import Text
 import rpc_service_pb2
 import rpc_service_pb2_grpc
 from threading import Thread
@@ -26,6 +27,9 @@ def __init__(self, *args, **kwargs) -> None:
         self._get_filepath = kwargs["get_filepath"]
         self._logger = kwargs["logger"]
 
+    def set_text_source(self, text: Text):
+        self._text = text
+
     def Ping(self, request, context):
         print(request)
         return rpc_service_pb2.PingReply(msg="pong")
@@ -53,34 +57,34 @@ def FileStatus(self, request, context):
 
     def UploadFile(self, it, context):
         filepath = self._get_filepath()
-        self._logger(f"正在接收文件{os.path.basename(filepath)}")
+        self._logger(f"{self._text.receiving_file} {os.path.basename(filepath)}")
         zip_filepath = "temp.zip"
         with open(zip_filepath, "wb") as fd:
             for i in it:
                 fd.write(i.data)
-        self._logger(f"接收文件成功")
-        self._logger(f"正在解压")
+        self._logger(f"{self._text.receive_file_successful}")
+        self._logger(f"{self._text.decompressing}")
         decompress(zip_filepath, os.path.dirname(filepath))
-        self._logger(f"解压成功")
+        self._logger(f"{self._text.decompress_success}")
         return rpc_service_pb2.UploadFileReply(status=True)
 
     def DownloadFile(self, request, context):
         filepath = self._get_filepath()
-        self._logger(f"正在压缩{os.path.basename(filepath)}")
+        self._logger(f"{self._text.compressing} {os.path.basename(filepath)}")
         zip_filepath = "temp.zip"
         compress_file(filepath, zip_filepath)
-        self._logger(f"压缩成功")
-        self._logger(f"发送文件{os.path.basename(filepath)}")
+        self._logger(f"{self._text.compress_done}")
+        self._logger(f"{self._text.sending_file} {os.path.basename(filepath)}")
         with open(zip_filepath, "rb") as fd:
             while True:
                 data = fd.read(BUF_SIZE)
                 if len(data) <= 0:
-                    self._logger(f"发送文件成功")
+                    self._logger(f"{self._text.send_success}")
                     return
                 yield rpc_service_pb2.DownloadFileReply(data=data)
 
     def DownloadDirectory(self, request, context):
-        self._logger("正在发送文件到远端")
+        self._logger(f"{self._text.sending_file_to_remote}")
         directory_path = self._get_filepath()
         with zipfile.ZipFile("temp.zip", "w", zipfile.ZIP_DEFLATED) as zip:
             for file in request.files:
@@ -92,21 +96,21 @@ def DownloadDirectory(self, request, context):
             while True:
                 data = fd.read(BUF_SIZE)
                 if len(data) <= 0:
-                    self._logger(f"发送文件成功")
+                    self._logger(f"{self._text.send_success}")
                     return
                 yield rpc_service_pb2.DownloadDirectoryReply(data=data)
 
     def ReceiveDirectory(self, request, context):
         dir_path = self._get_filepath()
-        self._logger(f"同步文件到{dir_path}中")
+        self._logger(self._text.syncing_file_to.format(dir_path))
         zip_filepath = "temp.zip"
         with open(zip_filepath, "wb") as fd:
             for i in request:
                 fd.write(i.data)
-        self._logger("正在解压")
+        self._logger(f"{self._text.decompressing}")
         decompress("temp.zip", dir_path)
-        self._logger("解压成功")
-        self._logger("同步成功")
+        self._logger(f"{self._text.decompress_success}")
+        self._logger(f"{self._text.sync_success}")
         return rpc_service_pb2.ReceiveDirectoryReply()
 
     def DirectoryStatus(self, request, context):