diff --git a/src/mqtt.py b/src/mqtt.py index c88a0b1..ec28762 100644 --- a/src/mqtt.py +++ b/src/mqtt.py @@ -105,6 +105,7 @@ class Mqtt: name = "" # we will find it next sid = query_sid + isFound = False for current_sid in self._sids: if (current_sid == None): continue @@ -116,11 +117,15 @@ class Mqtt: if (sidname == query_sid and sidmodel == model): sid = current_sid name = sidname + isFound = True break else: _LOGGER.debug(sidmodel + "-" + sidname + " is not " + model + "-" + query_sid + ".") continue + if isFound == False: + return + # fix for rgb format if (param == "rgb" and "," in str(value)): value = self._color_rgb_to_xiaomi(value) diff --git a/src/xiaomihub.py b/src/xiaomihub.py index cbc9ed1..7b70f76 100644 --- a/src/xiaomihub.py +++ b/src/xiaomihub.py @@ -128,7 +128,7 @@ class XiaomiHub: def _send_socket(self, cmd, rtnCmd, ip, port): socket = self._socket try: - _LOGGER.info('Sending to GW {0}'.format(cmd)) + _LOGGER.debug('Sending to GW {0}'.format(cmd)) self._read_unwanted_data() socket.settimeout(30.0) @@ -137,6 +137,7 @@ class XiaomiHub: data, addr = socket.recvfrom(1024) if len(data) is not None: resp = json.loads(data.decode()) + _LOGGER.debug('Recieved from GW {0}'.format(resp)) if resp["cmd"] == rtnCmd: return resp else: