[client] Fix export artifacts

Author: SamuelHassine

pycti/connector/opencti_connector_helper.py

@@ -315,14 +315,17 @@ def run(self) -> None:
                 self.channel.start_consuming()
             except (KeyboardInterrupt, SystemExit):
                 self.channel.stop_consuming()
+                self.pika_connection.close()
                 LOGGER.info("Connector stop")
                 sys.exit(0)
             except Exception as err:  # pylint: disable=broad-except
+                self.pika_connection.close()
                 LOGGER.error("%s", err)
-            self.pika_connection.close()
+                sys.exit(1)
 
     def stop(self):
         self.exit_event.set()
+        self.pika_connection.close()
         if self.thread:
             self.thread.join()
 
@@ -433,7 +436,6 @@ def __init__(
         self.recover_iso_date = recover_iso_date
         self.with_inferences = with_inferences
         self.exit_event = threading.Event()
-        self.exit = False
 
     def run(self) -> None:  # pylint: disable=too-many-branches
         try:
@@ -503,7 +505,7 @@ def run(self) -> None:  # pylint: disable=too-many-branches
             )
             # Iter on stream messages
             for msg in messages:
-                if self.exit:
+                if self.exit_event.is_set():
                     stream_alive.stop()
                     break
                 if msg.id is not None:
@@ -516,7 +518,7 @@ def run(self) -> None:  # pylint: disable=too-many-branches
                         # state can be None if reset from the UI
                         # In this case, default parameters will be used but SSE Client needs to be restarted
                         if state is None:
-                            self.exit = True
+                            self.exit_event.set()
                         else:
                             state["start_from"] = str(msg.id)
                             self.helper.set_state(state)
@@ -533,7 +535,6 @@ def run(self) -> None:  # pylint: disable=too-many-branches
             sys.excepthook(*sys.exc_info())
 
     def stop(self):
-        self.exit = True
         self.exit_event.set()
 
 

pycti/entities/opencti_stix_cyber_observable.py

@@ -155,6 +155,10 @@ def __init__(self, opencti, file):
                             id
                             name
                             size
+                            metaData {
+                                mimetype
+                                version
+                            }
                         }
                     }
                 }