Load certificate chain only if a certificate was specified

Closes #79.
eht16 · Jul 30, 2023 · 3f07caa · 3f07caa
1 parent 527483e
commit 3f07caa
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/logstash_async/transport.py b/logstash_async/transport.py
@@ -176,9 +176,10 @@ def _create_socket(self):
                 else:
                     cert_reqs = ssl.CERT_NONE
 
-            ssl_context.verify_mode = cert_reqs
             ssl_context.check_hostname = False
-            ssl_context.load_cert_chain(self._certfile, self._keyfile)
+            ssl_context.verify_mode = cert_reqs
+            if self._certfile and self._keyfile:
+                ssl_context.load_cert_chain(self._certfile, self._keyfile)
             self._sock = ssl_context.wrap_socket(self._sock, server_side=False)
         except socket.error:
             self._close()