Merge pull request #65 from Glirido/main

Upload WMP protocol specification

Author: jbergler

custom_components/intesisbox/climate.py

@@ -238,12 +238,12 @@ def set_hvac_mode(self, operation_mode):
             if self._target_temperature:
                 self._controller.set_temperature(self._target_temperature)
 
-        self.hass.async_add_job(self.schedule_update_ha_state, False)
+        self.schedule_update_ha_state(False)
 
     def turn_on(self):
         """Turn thermostat on."""
         self._controller.set_power_on()
-        self.hass.async_add_job(self.schedule_update_ha_state, False)
+        self.schedule_update_ha_state(False)
 
     def turn_off(self):
         """Turn thermostat off."""
@@ -276,8 +276,8 @@ async def async_update(self):
         """Copy values from controller dictionary to climate device."""
         if not self._controller.is_connected:
             await asyncio.sleep(
-                60
-            )  # per device specs, wait min 1 sec before re-connecting
+                5
+            )  # per device specs, wait minimum 1 second before re-connecting
             await self.hass.async_add_executor_job(self._controller.connect)
             self._connection_retries += 1
         else:
@@ -326,7 +326,7 @@ def update_callback(self):
         """Let HA know there has been an update from the controller."""
         _LOGGER.debug("Intesisbox sent a status update.")
         if self.hass:
-            self.hass.async_add_job(self.schedule_update_ha_state, True)
+            self.schedule_update_ha_state(True)
 
     @property
     def min_temp(self):

custom_components/intesisbox/intesisbox.py

@@ -207,8 +207,15 @@ def connect(self):
             except Exception as e:
                 _LOGGER.error("%s Exception. %s / %s", type(e), repr(e.args), e)
                 self._connectionStatus = API_DISCONNECTED
-        else:
+        elif self._connectionStatus == API_CONNECTING:
             _LOGGER.debug("connect() called but already connecting")
+            if self._transport.is_closing():
+                _LOGGER.debug(
+                    "Socket is closing while trying to connect. Force reconnection"
+                )
+                self._connectionStatus = API_DISCONNECTED
+                self._transport.close()
+                self._send_update_callback()
 
     def stop(self):
         """Public method for shutting down connectivity with the envisalink."""