[client] Standardize pika SSL control flow (#163)

Author: djds

pycti/connector/opencti_connector_helper.py

@@ -565,23 +565,17 @@ def send_stix2_bundle(self, bundle, **kwargs) -> list:
         pika_credentials = pika.PlainCredentials(
             self.config["connection"]["user"], self.config["connection"]["pass"]
         )
-        if self.config["connection"]["use_ssl"]:
-            context = create_ssl_context()
-            ssl_options = pika.SSLOptions(context, self.config["connection"]["host"])
-            pika_parameters = pika.ConnectionParameters(
-                host=self.config["connection"]["host"],
-                port=self.config["connection"]["port"],
-                virtual_host="/",
-                credentials=pika_credentials,
-                ssl_options=ssl_options,
-            )
-        else:
-            pika_parameters = pika.ConnectionParameters(
-                host=self.config["connection"]["host"],
-                port=self.config["connection"]["port"],
-                virtual_host="/",
-                credentials=pika_credentials,
+        pika_parameters = pika.ConnectionParameters(
+            host=self.config["connection"]["host"],
+            port=self.config["connection"]["port"],
+            virtual_host="/",
+            credentials=pika_credentials,
+            ssl_options=pika.SSLOptions(
+                create_ssl_context(), self.config["connection"]["host"]
             )
+            if self.config["connection"]["use_ssl"]
+            else None,
+        )
 
         pika_connection = pika.BlockingConnection(pika_parameters)
         channel = pika_connection.channel()