decisions: added to endpoint to resolve

backoffice/backoffice/workflows/api/views.py

@@ -43,6 +43,16 @@
 logger = logging.getLogger(__name__)
 
 
+def add_decision(workflow_id, user, action):
+    serializer_class = DecisionSerializer
+    data = {"workflow": workflow_id, "user": user, "action": action}
+
+    serializer = serializer_class(data=data)
+    if serializer.is_valid(raise_exception=True):
+        serializer.save()
+        return Response(serializer.data, status=status.HTTP_201_CREATED)
+
+
 class WorkflowViewSet(viewsets.ModelViewSet):
     queryset = Workflow.objects.all()
     serializer_class = WorkflowSerializer
@@ -103,25 +113,11 @@ def create(self, request, *args, **kwargs):
 
 class DecisionViewSet(viewsets.ModelViewSet):
     queryset = Decision.objects.all()
-    serializer_class = DecisionSerializer
-
-    def get_queryset(self):
-        status = self.request.query_params.get("status")
-        if status:
-            return self.queryset.filter(status__status=status)
-        return self.queryset
 
     def create(self, request, *args, **kwargs):
-        data = {
-            "workflow": request.data["workflow_id"],
-            "user": request.user,
-            "action": request.data["action"],
-        }
-
-        serializer = self.serializer_class(data=data)
-        if serializer.is_valid(raise_exception=True):
-            serializer.save()
-            return Response(serializer.data, status=status.HTTP_201_CREATED)
+        return add_decision(
+            request.data["workflow_id"], request.user, request.data["action"]
+        )
 
 
 class AuthorWorkflowViewSet(viewsets.ViewSet):
@@ -190,6 +186,7 @@ def resolve(self, request, pk=None):
                 ResolutionDags[serializer.validated_data["value"]],
                 pk,
             )
+            add_decision(pk, request.user, serializer.validated_data["value"])
 
             return airflow_utils.trigger_airflow_dag(
                 ResolutionDags[serializer.validated_data["value"]].label, pk, extra_data