[backend] WIP background tasks on user

Author: JeremyCloarec

pycti/utils/opencti_stix2.py

@@ -2595,10 +2595,13 @@ def element_add_organizations(self, item):
             organization_ids = item["organization_ids"]
         if item["type"] == "user":
             for organization_id in organization_ids:
-                self.opencti.user.add_organization(id=item["id"], organization_id=organization_id)
+                self.opencti.user.add_organization(
+                    id=item["id"], organization_id=organization_id
+                )
         else:
             raise ValueError(
-                "Add organizations operation not compatible with type", {"type": item["type"]}
+                "Add organizations operation not compatible with type",
+                {"type": item["type"]},
             )
 
     def element_remove_organizations(self, item):
@@ -2609,16 +2612,17 @@ def element_remove_organizations(self, item):
             organization_ids = item["organization_ids"]
         if item["type"] == "user":
             for organization_id in organization_ids:
-                self.opencti.user.delete_organization(id=item["id"], organization_id=organization_id)
+                self.opencti.user.delete_organization(
+                    id=item["id"], organization_id=organization_id
+                )
         else:
             raise ValueError(
-                "Remove organizations operation not compatible with type", {"type": item["type"]}
+                "Remove organizations operation not compatible with type",
+                {"type": item["type"]},
             )
 
     def element_add_groups(self, item):
-        group_ids = self.opencti.get_attribute_in_extension(
-            "group_ids", item
-        )
+        group_ids = self.opencti.get_attribute_in_extension("group_ids", item)
         if group_ids is None:
             group_ids = item["group_ids"]
         if item["type"] == "user":
@@ -2630,17 +2634,16 @@ def element_add_groups(self, item):
             )
 
     def element_remove_groups(self, item):
-        group_ids = self.opencti.get_attribute_in_extension(
-            "group_ids", item
-        )
+        group_ids = self.opencti.get_attribute_in_extension("group_ids", item)
         if group_ids is None:
             group_ids = item["group_ids"]
         if item["type"] == "user":
             for group_id in group_ids:
                 self.opencti.user.delete_membership(id=item["id"], group_id=group_id)
         else:
             raise ValueError(
-                "Remove groups operation not compatible with type", {"type": item["type"]}
+                "Remove groups operation not compatible with type",
+                {"type": item["type"]},
             )
 
     def element_operation_delete(self, item, operation):