From 9afb9ebb7c168608c9862df7f96202803b512936 Mon Sep 17 00:00:00 2001 From: foamyguy Date: Tue, 21 Dec 2021 18:28:48 -0600 Subject: [PATCH] code format --- adafruit_minimqtt/adafruit_minimqtt.py | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/adafruit_minimqtt/adafruit_minimqtt.py b/adafruit_minimqtt/adafruit_minimqtt.py index 93f4d0a2..876f09da 100755 --- a/adafruit_minimqtt/adafruit_minimqtt.py +++ b/adafruit_minimqtt/adafruit_minimqtt.py @@ -450,14 +450,21 @@ def connect(self, clean_session=True, host=None, port=None, keep_alive=None): # Set up variable header and remaining_length remaining_length = 12 + len(self.client_id.encode("utf-8")) if self._username: - remaining_length += 2 + len(self._username.encode("utf-8")) + 2 + len(self._password.encode("utf-8")) + remaining_length += ( + 2 + + len(self._username.encode("utf-8")) + + 2 + + len(self._password.encode("utf-8")) + ) var_header[6] |= 0xC0 if self.keep_alive: assert self.keep_alive < MQTT_TOPIC_LENGTH_LIMIT var_header[7] |= self.keep_alive >> 8 var_header[8] |= self.keep_alive & 0x00FF if self._lw_topic: - remaining_length += 2 + len(self._lw_topic.encode("utf-8")) + 2 + len(self._lw_msg) + remaining_length += ( + 2 + len(self._lw_topic.encode("utf-8")) + 2 + len(self._lw_msg) + ) var_header[6] |= 0x4 | (self._lw_qos & 0x1) << 3 | (self._lw_qos & 0x2) << 3 var_header[6] |= self._lw_retain << 5