def _deviceConnect_relay_cb()

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)