From ca1b80503b055faadfc0b737dd79a71c9ccdf006 Mon Sep 17 00:00:00 2001 From: iabdalkader Date: Tue, 5 Mar 2024 17:45:50 +0100 Subject: [PATCH] scripts/libraries: Fix MQTT SSL params. --- scripts/libraries/mqtt.py | 18 +++++------------- 1 file changed, 5 insertions(+), 13 deletions(-) diff --git a/scripts/libraries/mqtt.py b/scripts/libraries/mqtt.py index de20d6d8a..b52e62822 100644 --- a/scripts/libraries/mqtt.py +++ b/scripts/libraries/mqtt.py @@ -91,19 +91,11 @@ class MQTTClient: self.sock.close() self.sock = None - try: - self.sock = socket.socket() - self.sock.settimeout(timeout) - if self.ssl_params is not None: - self.sock = ssl.wrap_socket(self.sock, self.ssl_params) - self.sock.connect(addr) - except Exception: - self.sock.close() - self.sock = socket.socket() - self.sock.settimeout(timeout) - self.sock.connect(addr) - if self.ssl_params is not None: - self.sock = ssl.wrap_socket(self.sock, self.ssl_params) + self.sock = socket.socket() + self.sock.settimeout(timeout) + self.sock.connect(addr) + if self.ssl_params is not None: + self.sock = ssl.wrap_socket(self.sock, **self.ssl_params) premsg = bytearray(b"\x10\0\0\0\0\0") msg = bytearray(b"\x04MQTT\x04\x02\0\0")