[WEB-2383] feat: Inbox Settings v2

apiserver/plane/app/serializers/__init__.py

@@ -115,7 +115,10 @@
 
 from .analytic import AnalyticViewSerializer
 
-from .notification import NotificationSerializer, UserNotificationPreferenceSerializer
+from .notification import (
+    NotificationSerializer,
+    UserNotificationPreferenceSerializer
+)
 
 from .exporter import ExporterHistorySerializer
 

apiserver/plane/app/urls/notification.py

@@ -6,6 +6,7 @@
     UnreadNotificationEndpoint,
     MarkAllReadNotificationViewSet,
     UserNotificationPreferenceEndpoint,
+    WorkspaceUserNotificationPreferenceEndpoint,
 )
 
 
@@ -47,4 +48,14 @@
         UserNotificationPreferenceEndpoint.as_view(),
         name="user-notification-preferences",
     ),
+    path(
+        "workspaces/<str:slug>/user-notification-preferences/<str:transport>/",
+        WorkspaceUserNotificationPreferenceEndpoint.as_view(),
+        name="workspace-user-notification-preference",
+    ),
+    path(
+        "workspaces/<str:slug>/user-notification-preferences/",
+        WorkspaceUserNotificationPreferenceEndpoint.as_view(),
+        name="workspace-user-notification-preference",
+    ),
 ]

apiserver/plane/app/views/__init__.py

@@ -199,6 +199,7 @@
     NotificationViewSet,
     UnreadNotificationEndpoint,
     UserNotificationPreferenceEndpoint,
+    WorkspaceUserNotificationPreferenceEndpoint,
 )
 
 from .exporter.base import ExportIssuesEndpoint

apiserver/plane/app/views/notification/base.py

@@ -8,7 +8,7 @@
 
 from plane.app.serializers import (
     NotificationSerializer,
-    UserNotificationPreferenceSerializer,
+    UserNotificationPreferenceSerializer
 )
 from plane.db.models import (
     Issue,
@@ -17,6 +17,8 @@
     Notification,
     UserNotificationPreference,
     WorkspaceMember,
+    Workspace,
+    NotificationTransportChoices
 )
 from plane.utils.paginator import BasePaginator
 from plane.app.permissions import allow_permission, ROLE
@@ -360,3 +362,81 @@ def patch(self, request):
             serializer.save()
             return Response(serializer.data, status=status.HTTP_200_OK)
         return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
+
+
+
+class WorkspaceUserNotificationPreferenceEndpoint(BaseAPIView):
+    model = UserNotificationPreference
+    serializer_class = UserNotificationPreferenceSerializer
+
+    @allow_permission(
+        allowed_roles=[ROLE.ADMIN, ROLE.MEMBER, ROLE.GUEST], level="WORKSPACE"
+    )
+    def get(self, request, slug):
+        workspace = Workspace.objects.get(slug=slug)
+        get_notification_preferences = (
+            UserNotificationPreference.objects.filter(
+                workspace=workspace, user=request.user
+            )
+        )
+
+        create_transports = []
+
+        transports = [
+            transport
+            for transport, _ in NotificationTransportChoices.choices
+        ]
+
+        for transport in transports:
+            if transport not in get_notification_preferences.values_list(
+                "transport", flat=True
+            ):
+                create_transports.append(transport)
+
+
+        notification_preferences = (
+            UserNotificationPreference.objects.bulk_create(
+                [
+                    UserNotificationPreference(
+                        workspace=workspace,
+                        user=request.user,
+                        transport=transport,
+                    )
+                    for transport in create_transports
+                ]
+            )
+        )
+
+        notification_preferences = UserNotificationPreference.objects.filter(
+            workspace=workspace, user=request.user
+        )
+
+        return Response(
+            UserNotificationPreferenceSerializer(
+                notification_preferences, many=True
+            ).data,
+            status=status.HTTP_200_OK,
+        )
+
+    @allow_permission(
+        allowed_roles=[ROLE.ADMIN, ROLE.MEMBER, ROLE.GUEST], level="WORKSPACE"
+    )
+    def patch(self, request, slug, transport):
+        notification_preference = UserNotificationPreference.objects.filter(
+            transport=transport, workspace__slug=slug, user=request.user
+        ).first()
+
+        if notification_preference:
+            serializer = UserNotificationPreferenceSerializer(
+                notification_preference, data=request.data, partial=True
+            )
+
+            if serializer.is_valid():
+                serializer.save()
+                return Response(serializer.data, status=status.HTTP_200_OK)
+            return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
+
+        return Response(
+            {"detail": "Workspace notification preference not found"},
+            status=status.HTTP_404_NOT_FOUND,
+        )

apiserver/plane/app/views/workspace/home.py

@@ -2,7 +2,7 @@
 from ..base import BaseAPIView
 from plane.db.models.workspace import WorkspaceHomePreference
 from plane.app.permissions import allow_permission, ROLE
-from plane.db.models import Workspace
+from plane.db.models import Workspace, UserNotificationPreference, NotificationTransportChoices
 from plane.app.serializers.workspace import WorkspaceHomePreferenceSerializer
 
 # Third party imports
@@ -59,6 +59,37 @@ def get(self, request, slug):
             user=request.user, workspace_id=workspace.id
         )
 
+        # Notification preference get or create
+        workspace = Workspace.objects.get(slug=slug)
+        get_notification_preferences = (
+            UserNotificationPreference.objects.filter(
+                workspace=workspace, user=request.user
+            )
+        )
+
+        create_transports = []
+
+        transports = [
+            transport
+            for transport, _ in NotificationTransportChoices.choices
+        ]
+
+
+        for transport in transports:
+            if transport not in get_notification_preferences.values_list(
+                "transport", flat=True
+            ):
+                create_transports.append(transport)
+
+        _ = UserNotificationPreference.objects.bulk_create(
+            [
+                UserNotificationPreference(
+                    workspace=workspace, user=request.user, transport=transport
+                )
+                for transport in create_transports
+            ]
+        )
+
         return Response(
             preference.values("key", "is_enabled", "config", "sort_order"),
             status=status.HTTP_200_OK,