diff --git a/apps/ws/consumers.py b/apps/ws/consumers.py index cc34f5fd..75788a7a 100644 --- a/apps/ws/consumers.py +++ b/apps/ws/consumers.py @@ -31,14 +31,16 @@ class RoomConsumer(AsyncWebsocketConsumer): self.channel_name ) - async def receive_json(self, content, **kwargs): + async def receive(self, text_data=None, bytes_data=None): sender_user = self.scope["user"] - if content['type'] == 'chat': - content['from'] = sender_user.username - await self.channel_layer.group_send( - self.room_group_name, - content - ) + if text_data: + content = json.loads(text_data) + if content['type'] == 'chat': + content['from'] = sender_user.username + await self.channel_layer.group_send( + self.room_group_name, + content + ) async def chat(self, content): await self.send(json.dumps(content, ensure_ascii=False))