Merge branch 'chat' into 'dev'

Ajout d'un chat intégré

See merge request animath/si/plateforme-tfjm!45

chat/consumers.py

@@ -3,7 +3,7 @@
 
 from channels.generic.websocket import AsyncJsonWebsocketConsumer
 from django.contrib.auth.models import User
-from django.db.models import Count, F, Q
+from django.db.models import Count, Exists, OuterRef, Q
 from registration.models import Registration
 
 from .models import Channel, Message
@@ -93,9 +93,7 @@ class ChatConsumer(AsyncJsonWebsocketConsumer):
                     'unread_messages': channel.unread_messages,
                 }
                 async for channel in self.read_channels.prefetch_related('invited')
-                .annotate(total_messages=Count('messages', distinct=True))
-                .annotate(read_messages=Count('messages', filter=Q(messages__users_read=user), distinct=True))
-                .annotate(unread_messages=F('total_messages') - F('read_messages')).all()
+                .annotate(unread_messages=Count('messages', filter=~Q(messages__users_read=user))).all()
             ]
         }
         await self.send_json(message)
@@ -162,7 +160,8 @@ class ChatConsumer(AsyncJsonWebsocketConsumer):
 
         messages = Message.objects \
             .filter(channel=channel) \
-            .annotate(read=Count('users_read', filter=Q(users_read=self.scope['user']))) \
+            .annotate(read=Exists(User.objects.filter(pk=self.scope['user'].pk)
+                                  .filter(pk=OuterRef('users_read')))) \
             .order_by('-created_at')[offset:offset + limit].all()
         await self.send_json({
             'type': 'fetch_messages',
@@ -174,7 +173,7 @@ class ChatConsumer(AsyncJsonWebsocketConsumer):
                     'author_id': message.author_id,
                     'author': await message.aget_author_name(),
                     'content': message.content,
-                    'read': message.read > 0,
+                    'read': message.read,
                 }
                 async for message in messages
             ]))
@@ -240,6 +239,7 @@ class ChatConsumer(AsyncJsonWebsocketConsumer):
                               'content': message['content']})
 
     async def chat_edit_message(self, message) -> None:
+        print(message)
         await self.send_json({'type': 'edit_message', 'id': message['id'], 'channel_id': message['channel_id'],
                               'content': message['content']})
 

chat/static/chat.js

@@ -157,7 +157,6 @@ function fetchPreviousMessages() {
 }
 
 function receiveFetchedMessages(data) {
-    console.log(data)
     let channel_id = data['channel_id']
     let new_messages = data['messages']
 
@@ -190,6 +189,7 @@ function updateUnreadBadges(unreadMessages) {
 
     for (let channel of Object.values(channels)) {
         let unreadMessagesChannel = unreadMessages[channel['id']] || 0
+        console.log(channel, unreadMessagesChannel)
         channel.unread_messages = unreadMessagesChannel
 
         let unreadBadge = document.getElementById(`unread-messages-${channel['id']}`)