merge

chat/views/ask.py

@@ -0,0 +1,78 @@
+from rest_framework.views import APIView
+from rest_framework.response import Response
+from rest_framework import permissions, status
+from rest_framework.authentication import SessionAuthentication
+
+from django.http import HttpRequest
+from django.contrib.auth import login
+from django.db.models import QuerySet
+from django.core import serializers
+
+from chat.models import AskModel
+from profiles.models import ProfileModel
+
+from ..serializers.ask import AskSerializer
+
+from notice.consumers import notice_manager
+
+from django.contrib.auth.models import User
+
+class AskView(APIView):
+    
+	serializer_class = AskSerializer
+	permission_classes = (permissions.IsAuthenticated,)
+	authentication_classes = (SessionAuthentication,)    
+
+	def post(self, request):
+		data : dict = request.data
+		if (data["asked"] == None):
+			return
+
+		asker_id = request.user.pk
+		asked_id = data["asked"]
+
+		if AskModel().is_asked(asker_id, asked_id):
+			return Response(status=status.HTTP_208_ALREADY_REPORTED)
+		
+		AskModel(asker_id=asker_id, asked_id=asked_id).save()
+		return Response(status=status.HTTP_201_CREATED)
+
+	def delete(self, request):
+		data : dict = request.data
+		if (data["asker"] == None):
+			return
+
+		asker_id = data["asker"]
+		asked_id = request.user.pk
+
+		if not AskModel().is_asked(asker_id, asked_id):
+			return Response(status=status.HTTP_404_NOT_FOUND)
+
+		asker = User.objects.filter(pk=asked_id)[0] 
+		notice_manager.refuse_game(request.user, asker)
+
+		AskModel(asker_id=asker_id, asked_id=asked_id).delete()
+
+		return Response(status=status.HTTP_200_OK)
+
+class AskAccepteView(APIView):
+
+	serializer_class = AskSerializer
+	permission_classes = (permissions.IsAuthenticated,)
+	authentication_classes = (SessionAuthentication,)    
+
+	def post(self, request):
+		data : dict = request.data
+		if (data["asker"] == None):
+			return
+
+		asker_id = data["asker"]
+		asked_id = request.user.pk
+
+		if not AskModel().is_asked(asker_id, asked_id):
+			return Response(status=status.HTTP_404_NOT_FOUND)
+		
+		notice_manager.accept_game(asker=User.objects.filter(pk=asker_id)[0], asked=User.objects.filter(pk=asked_id)[0])
+
+		AskModel(asker_id=asker_id, asked_id=asked_id).delete()
+		return Response(status=status.HTTP_200_OK)

chat/views/chat.py

@@ -0,0 +1,48 @@
+from rest_framework.views import APIView
+from rest_framework.response import Response
+from rest_framework import permissions, status
+from rest_framework.authentication import SessionAuthentication
+
+from django.http import HttpRequest
+from django.contrib.auth import login
+from django.db.models import QuerySet
+from django.core import serializers
+
+
+from ..models import ChatChannelModel, ChatMemberModel, ChatMessageModel
+from ..serializers.chat import ChatChannelSerializer, ChatMessageSerializer
+
+class ChannelView(APIView):
+    
+    queryset = ChatChannelModel.objects
+    serializer_class = ChatChannelSerializer
+    permission_classes = (permissions.IsAuthenticated,)
+    authentication_classes = (SessionAuthentication,)    
+
+    def post(self, request):
+
+        serializer = self.serializer_class(data = request.data)
+        
+        serializer.is_valid(raise_exception=True)
+
+        data: dict = serializer.validated_data
+
+        members_id = data.get("members_id")
+        if members_id == None:
+            return Response({"detail": "members_id is None."}, status = status.HTTP_400_BAD_REQUEST)
+
+        if self.request.user.pk not in members_id:
+            return Response({"detail": "You are trying to create a chat group without you."}, status = status.HTTP_400_BAD_REQUEST)
+
+        for member_channel in ChatMemberModel.objects.filter(member_id = members_id[0]):
+            channel_id: int = member_channel.channel_id
+            if not ChatChannelModel.objects.filter(pk = channel_id).exists():
+                continue
+            channel: ChatChannelModel = ChatChannelModel.objects.get(pk = channel_id)
+            if set(channel.get_members_id()) == set(members_id):
+                messages = ChatMessageModel.objects.filter(channel_id = channel_id).order_by("time")
+                messages = serializers.serialize("json", messages)
+                return Response({'channel_id': channel_id, 'messages': messages}, status=status.HTTP_200_OK)                
+
+        new_channel_id = ChatChannelModel().create(members_id)
+        return Response({'channel_id': new_channel_id}, status=status.HTTP_201_CREATED)