0.3.7

chat v3

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