0.3.9
chat v3
This commit is contained in:
@@ -34,13 +34,14 @@ class ChatConsumer(WebsocketConsumer):
|
||||
receiver = data['receiver']
|
||||
|
||||
from .funcs import send_msg, update_chat
|
||||
data.update({'cur_user': sender})
|
||||
send_msg(data)
|
||||
Dict = update_chat(data)
|
||||
|
||||
resDict = {
|
||||
'type': 'update_chat',
|
||||
# 'message': Dict,
|
||||
# 'sender': resDict['sender']
|
||||
'sender': sender,
|
||||
'receiver': receiver,
|
||||
}
|
||||
resDict.update(Dict)
|
||||
group_name = f'user_{sender}'
|
||||
@@ -49,15 +50,14 @@ class ChatConsumer(WebsocketConsumer):
|
||||
resDict
|
||||
)
|
||||
|
||||
data['sender'] = receiver
|
||||
data['receiver'] = sender
|
||||
data.update({'cur_user': receiver})
|
||||
Dict = update_chat(data)
|
||||
|
||||
group_name = f'user_{receiver}'
|
||||
resDict = {
|
||||
'type': 'update_chat',
|
||||
# 'message': Dict,
|
||||
# 'sender': resDict['sender']
|
||||
'sender': receiver,
|
||||
'receiver': sender,
|
||||
}
|
||||
resDict.update(Dict)
|
||||
async_to_sync(self.channel_layer.group_send)(
|
||||
@@ -71,7 +71,7 @@ class ChatConsumer(WebsocketConsumer):
|
||||
self.send(text_data=json.dumps(data))
|
||||
|
||||
def update_chat(self, data):
|
||||
print('ws update_chat')
|
||||
print(f'ws update_chat {str(self.channel_layer.groups)}')
|
||||
|
||||
self.send(text_data=json.dumps(data))
|
||||
|
||||
|
||||
Reference in New Issue
Block a user