feat: Mise en place du Backend-messagerie [#17]

Back-End/GestionMessagerie/models.py

@@ -1,15 +1,15 @@
-from django.contrib.auth.models import AbstractUser
 from django.db import models
-from django.utils.translation import gettext_lazy as _
-from django.conf import settings
 from Auth.models import Profile
-    
+
 class Messagerie(models.Model):
     id = models.AutoField(primary_key=True)
     objet = models.CharField(max_length=200, default="", blank=True)
     emetteur = models.ForeignKey(Profile, on_delete=models.PROTECT, related_name='messages_envoyes')
     destinataire = models.ForeignKey(Profile, on_delete=models.PROTECT, related_name='messages_recus')
     corpus = models.CharField(max_length=200, default="", blank=True)
+    date_envoi = models.DateTimeField(auto_now_add=True)  # Date d'envoi du message
+    is_read = models.BooleanField(default=False)  # Statut lu/non lu
+    conversation_id = models.CharField(max_length=100, blank=True, default="")  # Pour regrouper les messages par conversation
 
     def __str__(self):
-        return 'Messagerie_'+self.id
+        return f'Messagerie_{self.id}'

Back-End/GestionMessagerie/serializers.py

@@ -8,6 +8,7 @@ class MessageSerializer(serializers.ModelSerializer):
     class Meta:
         model = Messagerie
         fields = '__all__'
+        read_only_fields = ['date_envoi']
     
     def get_destinataire_profil(self, obj):
         return obj.destinataire.email

Back-End/GestionMessagerie/urls.py

@@ -1,5 +1,5 @@
 from django.urls import path, re_path
-from .views import SendEmailView, search_recipients
+from .views import SendEmailView, search_recipients, ConversationListView, ConversationMessagesView, MarkAsReadView
 from GestionMessagerie.views import MessagerieView, MessageView, MessageSimpleView
 
 urlpatterns = [
@@ -8,4 +8,8 @@ urlpatterns = [
     re_path(r'^messages/(?P<id>[0-9]+)$', MessageSimpleView.as_view(), name="messages"),
     path('send-email/', SendEmailView.as_view(), name='send_email'),
     path('search-recipients/', search_recipients, name='search_recipients'),
+    # Endpoints pour le chat instantané
+    path('conversations/<int:profile_id>/', ConversationListView.as_view(), name='conversations'),
+    path('conversations/messages/<str:conversation_id>/', ConversationMessagesView.as_view(), name='conversation_messages'),
+    path('conversations/mark-as-read/<str:conversation_id>/', MarkAsReadView.as_view(), name='mark_as_read'),
 ]

Back-End/GestionMessagerie/views.py

@@ -5,16 +5,18 @@ from django.conf import settings
 from rest_framework.response import Response
 from rest_framework import status
 from django.db.models import Q
+from .models import Messagerie
 from Auth.models import Profile, ProfileRole
-
-from .models import *
+from GestionMessagerie.serializers import MessageSerializer
 from School.models import Teacher
 
-from GestionMessagerie.serializers import MessageSerializer
 from School.serializers import TeacherSerializer
 
-from N3wtSchool import bdd
 import N3wtSchool.mailManager as mailer
+from N3wtSchool import bdd
+from drf_yasg.utils import swagger_auto_schema
+from drf_yasg import openapi
+from rest_framework.exceptions import NotFound
 
 class MessagerieView(APIView):
     def get(self, request, profile_id):
@@ -140,3 +142,70 @@ def search_recipients(request):
 
     return JsonResponse(results, safe=False)
 
+class ConversationListView(APIView):
+    """
+    Liste les conversations d'un utilisateur (parent ou enseignant).
+    Retourne la liste des interlocuteurs et le dernier message échangé.
+    """
+    @swagger_auto_schema(
+        operation_description="Liste les conversations d'un utilisateur (parent ou enseignant).",
+        responses={200: openapi.Response('Liste des conversations')}
+    )
+    def get(self, request, profile_id):
+        # Récupérer toutes les conversations où l'utilisateur est émetteur ou destinataire
+        messages = Messagerie.objects.filter(Q(emetteur_id=profile_id) | Q(destinataire_id=profile_id))
+        # Grouper par conversation_id
+        conversations = {}
+        for msg in messages.order_by('-date_envoi'):
+            conv_id = msg.conversation_id or f"{min(msg.emetteur_id, msg.destinataire_id)}_{max(msg.emetteur_id, msg.destinataire_id)}"
+            if conv_id not in conversations:
+                conversations[conv_id] = msg
+        # Préparer la réponse
+        data = []
+        for conv_id, last_msg in conversations.items():
+            interlocuteur = last_msg.emetteur if last_msg.destinataire_id == int(profile_id) else last_msg.destinataire
+            data.append({
+                'conversation_id': conv_id,
+                'last_message': MessageSerializer(last_msg).data,
+                'interlocuteur': {
+                    'id': interlocuteur.id,
+                    'first_name': interlocuteur.first_name,
+                    'last_name': interlocuteur.last_name,
+                    'email': interlocuteur.email,
+                }
+            })
+        return Response(data, status=status.HTTP_200_OK)
+
+class ConversationMessagesView(APIView):
+    """
+    Récupère tous les messages d'une conversation donnée.
+    """
+    @swagger_auto_schema(
+        operation_description="Récupère tous les messages d'une conversation donnée.",
+        responses={200: openapi.Response('Liste des messages')}
+    )
+    def get(self, request, conversation_id):
+        messages = Messagerie.objects.filter(conversation_id=conversation_id).order_by('date_envoi')
+        serializer = MessageSerializer(messages, many=True)
+        return Response(serializer.data, status=status.HTTP_200_OK)
+
+class MarkAsReadView(APIView):
+    """
+    Marque tous les messages reçus dans une conversation comme lus pour l'utilisateur connecté.
+    """
+    @swagger_auto_schema(
+        operation_description="Marque tous les messages reçus dans une conversation comme lus pour l'utilisateur connecté.",
+        request_body=openapi.Schema(
+            type=openapi.TYPE_OBJECT,
+            properties={
+                'profile_id': openapi.Schema(type=openapi.TYPE_INTEGER, description='ID du profil utilisateur')
+            },
+            required=['profile_id']
+        ),
+        responses={200: openapi.Response('Statut OK')}
+    )
+    def post(self, request, conversation_id):
+        profile_id = request.data.get('profile_id')
+        Messagerie.objects.filter(conversation_id=conversation_id, destinataire_id=profile_id, is_read=False).update(is_read=True)
+        return Response({'status': 'ok'}, status=status.HTTP_200_OK)
+