Merge branch 'Chatte' into server
This commit is contained in:
@ -2,6 +2,7 @@ import json
|
||||
from channels.generic.websocket import WebsocketConsumer
|
||||
from asgiref.sync import async_to_sync
|
||||
from .models import MemberModel, MessageModel
|
||||
from profiles.models import BlockModel
|
||||
import time
|
||||
|
||||
class ChatConsumer(WebsocketConsumer):
|
||||
@ -34,6 +35,9 @@ class ChatConsumer(WebsocketConsumer):
|
||||
|
||||
text_data_json = json.loads(text_data)
|
||||
message = text_data_json['message']
|
||||
receivers_id = text_data_json['receivers_id']
|
||||
|
||||
print(text_data)
|
||||
|
||||
channel_id : int = int(self.scope['path'].split('/')[3])
|
||||
user = self.scope["user"]
|
||||
@ -46,9 +50,14 @@ class ChatConsumer(WebsocketConsumer):
|
||||
if (self.channel_layer == None):
|
||||
return
|
||||
|
||||
print(message)
|
||||
|
||||
message_time : int = int(time.time() * 1000)
|
||||
|
||||
if (len(receivers_id) == 1 and
|
||||
BlockModel.objects.filter(blocker=user.pk, blocked=receivers_id[0]) or
|
||||
BlockModel.objects.filter(blocker=receivers_id[0], blocked=user.pk)
|
||||
):
|
||||
return
|
||||
|
||||
async_to_sync(self.channel_layer.group_send)(
|
||||
self.room_group_name,
|
||||
{
|
||||
|
Reference in New Issue
Block a user