Skip to content

Commit

Permalink
tuya#50 : Fix potential AttributeError for new configurations in case…
Browse files Browse the repository at this point in the history
… of mqtt error
  • Loading branch information
helldog136 committed May 15, 2022
1 parent 20a7c92 commit b435789
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion tuya_iot/openmq.py
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ def __init__(self, api: TuyaOpenAPI) -> None:
self.mq_config = None
self.message_listeners = set()

# https://developer.tuya.com/en/docs/cloud/c2c2630d7c?id=Kb68mozbi3foh
def _get_mqtt_config(self) -> Optional[TuyaMQConfig]:
response = self.api.post(
TO_C_CUSTOM_MQTT_CONFIG_API
Expand Down Expand Up @@ -160,7 +161,6 @@ def run(self):
try:
self.__run_mqtt()
backoff_seconds = 1

# reconnect every 2 hours required.
time.sleep(self.mq_config.expire_time - 60)
except RequestException as e:
Expand All @@ -175,6 +175,8 @@ def __run_mqtt(self):
mq_config = self._get_mqtt_config()
if mq_config is None:
logger.error("error while get mqtt config")
if self.mq_config is None: # if we have no initial mq_config this is a big problem.
raise RequestException()
return

self.mq_config = mq_config
Expand Down

0 comments on commit b435789

Please sign in to comment.