Добавлен API CRUD для kanban board

Author: Toksi86

kanban/serializers.py

@@ -0,0 +1,47 @@
+from django.db import transaction
+from rest_framework import serializers
+
+from kanban.models import Board, BoardColumn
+from projects.models import Collaborator, Project
+
+
+class BoardSerializer(serializers.ModelSerializer):
+    project = serializers.PrimaryKeyRelatedField(queryset=Project.objects.all())
+
+    class Meta:
+        model = Board
+        fields = (
+            "id",
+            "project",
+            "name",
+            "color",
+            "icon",
+            "description",
+            "created_at",
+            "updated_at",
+        )
+        read_only_fields = ("id", "created_at", "updated_at")
+
+    def validate_project(self, project: Project):
+        request = self.context.get("request")
+        user = getattr(request, "user", None)
+        if not user or not user.is_authenticated:
+            raise serializers.ValidationError("Требуется аутентификация")
+
+        if project.leader_id == user.id:
+            return project
+
+        is_member = Collaborator.objects.filter(
+            project_id=project.id,
+            user_id=user.id,
+        ).exists()
+        if not is_member:
+            raise serializers.ValidationError("Пользователь не является участником проекта")
+        return project
+
+    def create(self, validated_data):
+        with transaction.atomic():
+            board = super().create(validated_data)
+            if not board.columns.exists():
+                BoardColumn.objects.create(board=board, name="Бэклог", order=1)
+        return board

kanban/tests/test_board_api.py

@@ -0,0 +1,57 @@
+from django.urls import reverse
+from rest_framework import status
+from rest_framework.test import APIClient
+
+from kanban.models import Board
+from kanban.tests.base import BaseKanbanTestCase
+from projects.models import Project
+from users.models import CustomUser
+
+
+class BoardAPITests(BaseKanbanTestCase):
+    def setUp(self):
+        super().setUp()
+        self.client = APIClient()
+        self.client.force_authenticate(user=self.user)
+        self.url = reverse("kanban:kanban-board-list")
+
+    def test_list_boards_returns_user_project_boards(self):
+        response = self.client.get(self.url)
+        self.assertEqual(response.status_code, status.HTTP_200_OK)
+        self.assertGreaterEqual(len(response.data), 1)
+        self.assertEqual(response.data[0]["project"], self.project.id)
+
+    def test_create_board_creates_backlog_column(self):
+        payload = {
+            "project": self.project.id,
+            "name": "New Board",
+            "color": "blue",
+            "icon": "rocket",
+            "description": "",
+        }
+        response = self.client.post(self.url, payload, format="json")
+        self.assertEqual(response.status_code, status.HTTP_201_CREATED)
+        board_id = response.data["id"]
+        board = Board.objects.get(id=board_id)
+        backlog = board.columns.first()
+        self.assertIsNotNone(backlog)
+        self.assertEqual(backlog.name, "Бэклог")
+
+    def test_cannot_create_board_for_foreign_project(self):
+        foreign_leader = CustomUser.objects.create(
+            email="foreign@example.com",
+            first_name="Foreign",
+            last_name="Leader",
+            password="pass1234",
+            birthday=self.user.birthday,
+        )
+        foreign_project = Project.objects.create(name="Foreign", leader=foreign_leader)
+        payload = {
+            "project": foreign_project.id,
+            "name": "Forbidden",
+            "color": "blue",
+            "icon": "rocket",
+            "description": "",
+        }
+        response = self.client.post(self.url, payload, format="json")
+        self.assertEqual(response.status_code, status.HTTP_400_BAD_REQUEST)

kanban/urls.py

@@ -0,0 +1,11 @@
+from django.urls import include, path
+from rest_framework.routers import DefaultRouter
+
+from kanban.views import BoardViewSet
+
+app_name = "kanban"
+
+router = DefaultRouter()
+router.register(r"boards", BoardViewSet, basename="kanban-board")
+
+urlpatterns = [path("", include(router.urls))]

kanban/views.py

@@ -0,0 +1,54 @@
+from django.db.models import Q
+from drf_yasg.utils import swagger_auto_schema
+from rest_framework import permissions, viewsets
+
+from kanban.models import Board
+from kanban.serializers import BoardSerializer
+from projects.models import Collaborator
+
+
+class BoardViewSet(viewsets.ModelViewSet):
+    serializer_class = BoardSerializer
+    permission_classes = [permissions.IsAuthenticated]
+
+    def get_queryset(self):
+        user = self.request.user
+        collaborator_projects = Collaborator.objects.filter(user=user).values(
+            "project_id"
+        )
+        return (
+            Board.objects.select_related("project")
+            .prefetch_related("columns")
+            .filter(
+                Q(project__leader_id=user.id) | Q(project_id__in=collaborator_projects)
+            )
+            .distinct()
+        )
+
+    def perform_destroy(self, instance):
+        # TODO: в будущем реализовать проверку прав на удаление досок
+        return super().perform_destroy(instance)
+
+    @swagger_auto_schema(tags=["Kanban Boards"])
+    def create(self, request, *args, **kwargs):
+        return super().create(request, *args, **kwargs)
+
+    @swagger_auto_schema(tags=["Kanban Boards"])
+    def list(self, request, *args, **kwargs):
+        return super().list(request, *args, **kwargs)
+
+    @swagger_auto_schema(tags=["Kanban Boards"])
+    def retrieve(self, request, *args, **kwargs):
+        return super().retrieve(request, *args, **kwargs)
+
+    @swagger_auto_schema(tags=["Kanban Boards"])
+    def partial_update(self, request, *args, **kwargs):
+        return super().partial_update(request, *args, **kwargs)
+
+    @swagger_auto_schema(tags=["Kanban Boards"])
+    def update(self, request, *args, **kwargs):
+        return super().update(request, *args, **kwargs)
+
+    @swagger_auto_schema(tags=["Kanban Boards"])
+    def destroy(self, request, *args, **kwargs):
+        return super().destroy(request, *args, **kwargs)

procollab/urls.py

@@ -50,6 +50,7 @@
     path("programs/", include("partner_programs.urls", namespace="partner_programs")),
     path("rate-project/", include(("project_rates.urls", "rate_projects"))),
     path("feed/", include("feed.urls", namespace="feed")),
+    path("kanban/", include("kanban.urls", namespace="kanban")),
     path("api/token/", TokenObtainPairView.as_view(), name="token_obtain_pair"),
     path("api/token/refresh/", TokenRefreshView.as_view(), name="token_refresh"),
     path("api/token/verify/", TokenVerifyView.as_view(), name="token_verify"),