From a85bdcf019083779ac0622ca9fe9e67ca7803ee7 Mon Sep 17 00:00:00 2001
From: itdominator <1itdominator@gmail.com>
Date: Wed, 18 Oct 2023 21:02:46 -0500
Subject: [PATCH] In effect addeed socket recovery logic; added deubug hook

---
 src/app.py              | 14 +++++++++++---
 src/utils/ipc_server.py | 28 +++++++++++++++++++++++-----
 2 files changed, 34 insertions(+), 8 deletions(-)

diff --git a/src/app.py b/src/app.py
index 9325654..f79e9fa 100644
--- a/src/app.py
+++ b/src/app.py
@@ -25,7 +25,7 @@ class Application(IPCServer):
             try:
                 self.create_ipc_listener()
             except Exception:
-                ...
+                self.socket_realization_check()
 
             if not self.is_ipc_alive:
                 for arg in unknownargs + [args.new_tab,]:
@@ -35,6 +35,16 @@ class Application(IPCServer):
 
                 raise AppLaunchException(f"{app_name} IPC Server Exists: Will send path(s) to it and close...")
 
+        self.setup_debug_hook()
+
+        Window(args, unknownargs)
+
+
+    def socket_realization_check(self):
+        self.send_test_ipc_message()
+        self.create_ipc_listener()
+
+    def setup_debug_hook(self):
         try:
             # kill -SIGUSR2 <pid> from Linux/Unix or SIGBREAK signal from Windows
             signal.signal(
@@ -44,5 +54,3 @@ class Application(IPCServer):
         except ValueError:
             # Typically: ValueError: signal only works in main thread
             ...
-
-        Window(args, unknownargs)
diff --git a/src/utils/ipc_server.py b/src/utils/ipc_server.py
index 5d19ccc..a351b66 100644
--- a/src/utils/ipc_server.py
+++ b/src/utils/ipc_server.py
@@ -62,15 +62,14 @@ class IPCServer(Singleton):
                 start_time = time.perf_counter()
                 self._handle_ipc_message(conn, start_time)
             except Exception as e:
-                ...
+                logger.debug( repr(e) )
 
         listener.close()
 
     def _handle_ipc_message(self, conn, start_time) -> None:
         while True:
             msg = conn.recv()
-            if settings_manager.is_debug():
-                print(msg)
+            logger.debug(msg)
 
             if "FILE|" in msg:
                 file = msg.split("FILE|")[1].strip()
@@ -109,6 +108,25 @@ class IPCServer(Singleton):
             conn.send(message)
             conn.close()
         except ConnectionRefusedError as e:
-            print("Connection refused...")
+            logger.error("Connection refused...")
         except Exception as e:
-            print(repr(e))
+            logger.error( repr(e) )
+
+
+    def send_test_ipc_message(self, message: str = "Empty Data...") -> None:
+        try:
+            if self._conn_type == "socket":
+                conn = Client(address=self._ipc_address, family="AF_UNIX", authkey=self._ipc_authkey)
+            elif "unsecured" not in self._conn_type:
+                conn = Client((self._ipc_address, self._ipc_port), authkey=self._ipc_authkey)
+            else:
+                conn = Client((self._ipc_address, self._ipc_port))
+
+            conn.send(message)
+            conn.close()
+        except ConnectionRefusedError as e:
+            if self._conn_type == "socket":
+                logger.error("IPC Socket no longer valid.... Removing.")
+                os.unlink(self._ipc_address)
+        except Exception as e:
+            logger.error( repr(e) )