diff --git a/src/backend/interfaces/WebsocketClientInterface.py b/src/backend/interfaces/WebsocketClientInterface.py index d3bd59c..b7810cd 100644 --- a/src/backend/interfaces/WebsocketClientInterface.py +++ b/src/backend/interfaces/WebsocketClientInterface.py @@ -12,7 +12,7 @@ class WebsocketClientInterface(Interface): # TODO: required? DEFAULT_IFAC_SIZE = 16 - RECONNECT_DELAY_MILLIS = 5000 + RECONNECT_DELAY_SECONDS = 5 def __str__(self): return f"WebsocketClientInterface[{self.name}/{self.target_host}:{self.target_port}]" @@ -103,13 +103,15 @@ class WebsocketClientInterface(Interface): # connect to websocket server try: + RNS.log(f"Establishing Websocket connection for {str(self)}...", RNS.LOG_DEBUG) self.websocket = connect(f"{self.target_type}://{self.target_host}:{self.target_port}", max_size=None, compression=None) self.read_loop() except Exception as e: RNS.log(f"{self} failed with error: {e}", RNS.LOG_ERROR) # auto reconnect after delay - time.sleep(self.RECONNECT_DELAY_MILLIS) + RNS.log(f"Websocket disconnected for {str(self)}...", RNS.LOG_DEBUG) + time.sleep(self.RECONNECT_DELAY_SECONDS) self.connect() def read_loop(self): diff --git a/src/backend/interfaces/WebsocketServerInterface.py b/src/backend/interfaces/WebsocketServerInterface.py index ed73c72..19819f5 100644 --- a/src/backend/interfaces/WebsocketServerInterface.py +++ b/src/backend/interfaces/WebsocketServerInterface.py @@ -15,7 +15,7 @@ class WebsocketServerInterface(Interface): # TODO: required? DEFAULT_IFAC_SIZE = 16 - RESTART_DELAY_MILLIS = 5000 + RESTART_DELAY_SECONDS = 5 def __str__(self): return f"WebsocketServerInterface[{self.name}/{self.listen_ip}:{self.listen_port}]" @@ -126,6 +126,7 @@ class WebsocketServerInterface(Interface): # run websocket server try: + RNS.log(f"Starting Websocket server for {str(self)}...", RNS.LOG_DEBUG) with serve(on_websocket_client_connected, self.listen_ip, self.listen_port, compression=None) as server: self.online = True self.server = server @@ -135,7 +136,8 @@ class WebsocketServerInterface(Interface): # websocket server is no longer running, let's restart it self.online = False - time.sleep(self.RESTART_DELAY_MILLIS) + RNS.log(f"Websocket server stopped for {str(self)}...", RNS.LOG_DEBUG) + time.sleep(self.RESTART_DELAY_SECONDS) self.serve() def detach(self):