Crude reconnection attempt after no responce

superrob · Jul 19, 2024 · 6f05183 · 6f05183
1 parent 2f9d690
commit 6f05183
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/src/genvexnabto/const.py b/src/genvexnabto/const.py
@@ -2,4 +2,5 @@
 SOCKET_MAXSIZE = 512
 DATAPOINT_UPDATEINTERVAL = 10 # Seconds since last datapoint update to trigger new update
 SETPOINT_UPDATEINTERVAL = 180 # Seconds since last setpoint update to trigger new update
+SECONDS_UNTILRECONNECT = 20 # Seconds with no responce to try reconnecting
 DISCOVERY_PORT = 5570
diff --git a/src/genvexnabto/genvexnabto.py b/src/genvexnabto/genvexnabto.py
@@ -11,7 +11,7 @@
                        GenvexPayloadCP_ID,  GenvexPacket, GenvexPacketKeepAlive, GenvexCommandDatapointReadList, 
                        GenvexCommandSetpointReadList, GenvexCommandPing, GenvexCommandSetpointWriteList)
 
-from .const import ( SOCKET_TIMEOUT, SOCKET_MAXSIZE, DATAPOINT_UPDATEINTERVAL, SETPOINT_UPDATEINTERVAL, DISCOVERY_PORT)
+from .const import ( SOCKET_TIMEOUT, SOCKET_MAXSIZE, DATAPOINT_UPDATEINTERVAL, SETPOINT_UPDATEINTERVAL, SECONDS_UNTILRECONNECT, DISCOVERY_PORT)
 
 class GenvexNabtoConnectionErrorType:
     TIMEOUT = "timeout"
@@ -221,9 +221,10 @@ def processReceivedMessage(self, message, address):
         if (packetType == GenvexPacketType.U_CONNECT):
             print("U_CONNECT responce packet")
             if (message[20:24] == b'\x00\x00\x00\x01'):
-                print('Connected, pinging to get model number')
                 self._server_id = message[24:28]
-                self.sendPing()
+                print('Connected, pinging to get model number')
+                if not self._is_connected:
+                    self.sendPing()
             else:
                 print("Received unsucessfull response")
                 self._connection_error = GenvexNabtoConnectionErrorType.AUTHENTICATION_ERROR
@@ -308,4 +309,6 @@ def receiveThread(self):
                     self.sendDataStateRequest(100)
                 if time.time() - self._last_setpointupdate > SETPOINT_UPDATEINTERVAL:                    
                     self.sendSetpointStateRequest(200)
+                if time.time() - self._last_responce > SECONDS_UNTILRECONNECT:
+                    self.connectToDevice()