feat: bulk update estimate endpoint (#755)

apiserver/plane/api/urls.py

@@ -83,7 +83,7 @@
     EstimateViewSet,
     EstimatePointViewSet,
     ProjectEstimatePointEndpoint,
-    BulkCreateEstimatePointEndpoint,
+    BulkEstimatePointEndpoint,
     ## End Estimates
     # Shortcuts
     ShortCutViewSet,
@@ -536,8 +536,8 @@
         name="project-estimate-points",
     ),
     path(
-        "workspaces/<str:slug>/projects/<uuid:project_id>/estimates/<uuid:estimate_id>/bulk-create-estimate-points/",
-        BulkCreateEstimatePointEndpoint.as_view(),
+        "workspaces/<str:slug>/projects/<uuid:project_id>/estimates/<uuid:estimate_id>/bulk-estimate-points/",
+        BulkEstimatePointEndpoint.as_view(),
         name="bulk-create-estimate-points",
     ),
     # End States ##

apiserver/plane/api/views/__init__.py

@@ -135,5 +135,5 @@
     EstimateViewSet,
     EstimatePointViewSet,
     ProjectEstimatePointEndpoint,
-    BulkCreateEstimatePointEndpoint,
+    BulkEstimatePointEndpoint,
 )

apiserver/plane/api/views/estimate.py

@@ -117,6 +117,10 @@ def partial_update(self, request, slug, project_id, estimate_id, pk):
 
 
 class ProjectEstimatePointEndpoint(BaseAPIView):
+    permission_classes = [
+        ProjectEntityPermission,
+    ]
+
     def get(self, request, slug, project_id):
         try:
             project = Project.objects.get(workspace__slug=slug, pk=project_id)
@@ -137,7 +141,11 @@ def get(self, request, slug, project_id):
             )
 
 
-class BulkCreateEstimatePointEndpoint(BaseAPIView):
+class BulkEstimatePointEndpoint(BaseAPIView):
+    permission_classes = [
+        ProjectEntityPermission,
+    ]
+
     def post(self, request, slug, project_id, estimate_id):
         try:
             estimate = Estimate.objects.get(
@@ -161,6 +169,8 @@ def post(self, request, slug, project_id, estimate_id):
                         description=estimate_point.get("description", ""),
                         project_id=project_id,
                         workspace_id=estimate.workspace_id,
+                        created_by=request.user,
+                        updated_by=request.user,
                     )
                     for estimate_point in estimate_points
                 ],
@@ -182,3 +192,54 @@ def post(self, request, slug, project_id, estimate_id):
                 {"error": "Something went wrong please try again later"},
                 status=status.HTTP_400_BAD_REQUEST,
             )
+
+    def patch(self, request, slug, project_id, estimate_id):
+        try:
+            if not len(request.data.get("estimate_points", [])):
+                return Response(
+                    {"error": "Estimate points are required"},
+                    status=status.HTTP_400_BAD_REQUEST,
+                )
+
+            estimate_points_data = request.data.get("estimate_points", [])
+
+            estimate_points = EstimatePoint.objects.filter(
+                pk__in=[
+                    estimate_point.get("id") for estimate_point in estimate_points_data
+                ],
+                workspace__slug=slug,
+                project_id=project_id,
+                estimate_id=estimate_id,
+            )
+
+            print(estimate_points)
+            updated_estimate_points = []
+            for estimate_point in estimate_points:
+                # Find the data for that estimate point
+                estimate_point_data = [
+                    point
+                    for point in estimate_points_data
+                    if point.get("id") == str(estimate_point.id)
+                ]
+                print(estimate_point_data)
+                if len(estimate_point_data):
+                    estimate_point.value = estimate_point_data[0].get(
+                        "value", estimate_point.value
+                    )
+                    updated_estimate_points.append(estimate_point)
+
+            EstimatePoint.objects.bulk_update(
+                updated_estimate_points, ["value"], batch_size=10
+            )
+            serializer = EstimatePointSerializer(estimate_points, many=True)
+            return Response(serializer.data, status=status.HTTP_200_OK)
+        except Estimate.DoesNotExist:
+            return Response(
+                {"error": "Estimate does not exist"}, status=status.HTTP_400_BAD_REQUEST
+            )
+        except Exception as e:
+            print(e)
+            return Response(
+                {"error": "Something went wrong please try again later"},
+                status=status.HTTP_400_BAD_REQUEST,
+            )