🚧[WIP/TEST] Controller : 応答値を修正/各セクションでprocess.logに書き出す用に追加

src-python/webui_controller.py

@@ -83,7 +83,7 @@ class MicMessage:
             addSentMessageLog(message)
             translation = ""
             if model.checkKeywords(message):
-                self.action({"status":"error", f"message":"Detected by word filter:{message}"})
+                self.action({"status":"error", "message":f"Detected by word filter:{message}"})
                 return
             elif model.detectRepeatSendMessage(message):
                 return
@@ -416,12 +416,12 @@ def callbackEnableTranslation(*args, **kwargs) -> dict:
     config.ENABLE_TRANSLATION = True
     if model.isLoadedCTranslate2Model() is False:
         model.changeTranslatorCTranslate2Model()
-    return {"status":"success"}
+    return {"status":"success", "data":config.ENABLE_TRANSLATION}
 
 def callbackDisableTranslation(*args, **kwargs) -> dict:
     print("callbackDisableTranslation")
     config.ENABLE_TRANSLATION = False
-    return {"status":"success"}
+    return {"status":"success", "data":config.ENABLE_TRANSLATION}
 
 def callbackEnableTranscriptionSend(data, action, *args, **kwargs) -> dict:
     print("callbackEnableTranscriptionSend")

src-python/webui_mainloop.py

@@ -221,37 +221,49 @@ def main():
     received_data = sys.stdin.readline().strip()
     received_data = json.loads(received_data)
 
-    if received_data is True:
+    with open('process.log', 'a') as f:
-        response_data = {
+        f.write(f"received_data: {received_data}\n")
-            "status": "ok",
-            "id": received_data["id"],
-            "data": received_data["data"],
-        }
-        response = json.dumps(response_data)
-        time.sleep(2)
-        print(response, flush=True)
 
-        # endpoint = received_data.get("endpoint", None)
+    if received_data:
-        # data = received_data.get("data", None)
+        # response_data = {
-
+        #     "status": 200,
-        # match endpoint.split("/")[1]:
+        #     "id": received_data["id"],
-        #     case "config":
+        #     "data": received_data["data"],
-        #         response_data, status = handleConfigRequest(endpoint, data)
-        #     case "controller":
-        #         response_data, status = handleControllerRequest(endpoint, data)
-        #     case _:
-        #         pass
-
-        # response = {
-        #     "status": status,
-        #     "endpoint": endpoint,
-        #     "data": response_data,
         # }
-
+        # response = json.dumps(response_data)
-        # response = json.dumps(response)
         # time.sleep(2)
         # print(response, flush=True)
 
+        endpoint = received_data.get("endpoint", None)
+        data = received_data.get("data", None)
+
+        with open('process.log', 'a') as f:
+            f.write(f"received_data : endpoint: {endpoint}, data:{data}\n")
+
+        try:
+            match endpoint.split("/")[1]:
+                case "config":
+                    result_data, status = handleConfigRequest(endpoint, data)
+                case "controller":
+                    result_data, status = handleControllerRequest(endpoint, data)
+                case _:
+                    pass
+        except Exception as e:
+            result_data = str(e)
+            status = 500
+
+        response = {
+            "status": status,
+            "endpoint": endpoint,
+            "result": result_data,
+        }
+
+        response = json.dumps(response)
+        with open('process.log', 'a') as f:
+            f.write(f"response: {response}\n")
+
+        print(response, flush=True)
+
 if __name__ == "__main__":
     # endpoint = "/controller/list_mic_host"
     # data = None