Delete actions after deleting IntegratedFeature

nexus/usecases/projects/delete.py

@@ -1,15 +1,34 @@
-from nexus.usecases.projects.retrieve import get_integrated_feature
-
 from nexus.projects.models import IntegratedFeature
+from nexus.usecases.actions.delete import DeleteFlowDTO, DeleteFlowsUseCase
+from nexus.usecases.projects.get_by_uuid import get_project_by_uuid
+from nexus.usecases.projects.retrieve import get_integrated_feature
 
 
 def delete_integrated_feature(
         project_uuid: str,
-        feature_uuid: str
+        feature_uuid: str,
+        delete_actions: bool = True
 ) -> bool:
     try:
         integrated_feature = get_integrated_feature(project_uuid, feature_uuid)
+        if delete_actions:
+            for action in integrated_feature.current_version_setup:
+                delete_integrated_action(
+                    project_uuid=project_uuid,
+                    action_uuid=action.get("root_flow_uuid")
+                )
         integrated_feature.delete()
         return True
     except IntegratedFeature.DoesNotExist:
         raise ValueError("IntegratedFeature does not exists")
+
+
+def delete_integrated_action(project_uuid: str, action_uuid: str):
+    dto = DeleteFlowDTO(flow_uuid=action_uuid)
+
+    project = get_project_by_uuid(project_uuid)
+    usecase = DeleteFlowsUseCase()
+    usecase.hard_delete_flow(
+        flow_dto=dto,
+        project=project,
+    )

nexus/usecases/projects/tests/test_delete.py

@@ -4,12 +4,31 @@
 
 from nexus.usecases.projects.tests.project_factory import IntegratedFeatureFactory
 from nexus.usecases.projects.delete import delete_integrated_feature
+from nexus.usecases.intelligences.create import create_base_brain_structure
+
+from nexus.usecases.intelligences.get_by_uuid import get_default_content_base_by_project
+from nexus.actions.models import Flow
 
 
 class TestDeleteIntegratedFeature(TestCase):
 
     def setUp(self) -> None:
         self.integrated_feature = IntegratedFeatureFactory()
+        self.project = self.integrated_feature.project
+        self.integrated_intelligence = create_base_brain_structure(self.project)
+        self.content_base = get_default_content_base_by_project(str(self.project.uuid))
+        actions = self.integrated_feature.current_version_setup
+
+        self.flow_list = []
+        for action in actions:
+            self.flow_list.append(
+                Flow.objects.create(
+                    uuid=str(action.get("root_flow_uuid")),
+                    name=action.get("name"),
+                    prompt=action.get("prompt"),
+                    content_base=self.content_base,
+                )
+            )
 
     def test_delete_integrated_feature(self):
         self.assertTrue(
@@ -18,6 +37,9 @@ def test_delete_integrated_feature(self):
                 feature_uuid=self.integrated_feature.feature_uuid
             )
         )
+        with self.assertRaises(Flow.DoesNotExist):
+            for flow in self.flow_list:
+                Flow.objects.get(uuid=flow.uuid)
 
     def test_integrated_feature_does_not_exists(self):
         with self.assertRaises(ValueError):