in leda_python/leda.py [0:0]
def _deviceConnect_relay_cb(self, replyMsg):
syncMsg = {"state": False}
_logger.debug("Device(%s): connect return msg: %s" % (self.cloud_id, replyMsg))
try:
retDict = json.loads(replyMsg)
if (0 == retDict["code"]):
_logger.info("Device(%s): is connected" % (self.cloud_id))
syncMsg["state"] = True
self.deviceCloudId = retDict['params']['deviceCloudId']
if (None == self.deviceMbusObject):
self.deviceMbusObject = self._createMbusDynamicObject()
else:
_logger.warning("Device(%s): connect return code is error: %d, errMsg: %s" % (
self.cloud_id, retDict["code"], retDict["message"]))
except:
_logger.exception("Err")
_logger.warning("replyMsg: %s is invalid", replyMsg)
self.connectSync.set(syncMsg)