fix: roomconsumer bug修改

This commit is contained in:
caoqianming 2023-09-01 10:16:36 +08:00
parent df6fbf500e
commit 46d127758a
1 changed files with 9 additions and 7 deletions

View File

@ -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))