diff --git a/ChatServiceApp/websocket_views.py b/ChatServiceApp/websocket_views.py index 8eb1323..78c35c9 100644 --- a/ChatServiceApp/websocket_views.py +++ b/ChatServiceApp/websocket_views.py @@ -22,6 +22,18 @@ class ChatConsumer(WebsocketConsumer): print(f'self.channel_name = {self.channel_name}') self.accept() + def ws_send_msg(self, msg_type, group_name, msg): + msgDict = { + 'type': msg_type, + 'message': msg, + # 'sender': resDict['sender'] + } + async_to_sync(self.channel_layer.group_send)( + group_name, + msgDict + ) + + def receive(self, text_data): print(f'ws receive text_data = {text_data}') @@ -30,9 +42,6 @@ class ChatConsumer(WebsocketConsumer): from .funcs import send_msg Dict = send_msg(text_data) - # print(f'send_msg res = {len(resDict)}') - - # self.send(text_data='!!!!') group_name = f'user_{data["receiver"]}' resDict = { 'type': 'echo', @@ -55,6 +64,11 @@ class ChatConsumer(WebsocketConsumer): resDict ) + def echo(self, data): + print('ws echo') + + self.send(text_data=json.dumps(data)) + def ws_send_msg(self, data): print('ws ws_send_msg')