From 11cfcda4fbbf828395d19cf87d7d38d837742142 Mon Sep 17 00:00:00 2001 From: SDE Date: Mon, 14 Aug 2023 17:14:20 +0300 Subject: [PATCH] 0.3.14 support chat v3 switch to redis --- ChatServiceApp/js_views.py | 4 +++- ChatServiceApp/websocket_views.py | 34 +++++++++++++++---------------- TWB/settings.py | 10 ++++----- 3 files changed, 25 insertions(+), 23 deletions(-) diff --git a/ChatServiceApp/js_views.py b/ChatServiceApp/js_views.py index c2cd982..a2650b9 100644 --- a/ChatServiceApp/js_views.py +++ b/ChatServiceApp/js_views.py @@ -436,7 +436,9 @@ def create_ticket_ajax(request): group_name = 'support_managers' Dict = { 'type': 'update_chat', - 'tickets_wo_manager_html': tickets_wo_manager_html + 'tickets_wo_manager_html': tickets_wo_manager_html, + 'required_beep': True, + 'group_name': group_name, } channel_layer = get_channel_layer() async_to_sync(channel_layer.group_send)( diff --git a/ChatServiceApp/websocket_views.py b/ChatServiceApp/websocket_views.py index 4f2f9dc..a4a86bd 100644 --- a/ChatServiceApp/websocket_views.py +++ b/ChatServiceApp/websocket_views.py @@ -63,24 +63,24 @@ class ChatConsumer(WebsocketConsumer): ) group_name = f'user_{receiver}' - if group_name in self.channel_layer.groups.keys(): - data.update({ - 'cur_user': receiver, - 'required_beep': True, - }) - Dict = update_chat(data) + # if group_name in self.channel_layer.groups.keys(): + data.update({ + 'cur_user': receiver, + 'required_beep': True, + }) + Dict = update_chat(data) - resDict = { - 'type': 'update_chat', - 'sender': receiver, - 'receiver': sender, - 'group_name': group_name, - } - resDict.update(Dict) - async_to_sync(self.channel_layer.group_send)( - group_name, - resDict - ) + resDict = { + 'type': 'update_chat', + 'sender': receiver, + 'receiver': sender, + 'group_name': group_name, + } + resDict.update(Dict) + async_to_sync(self.channel_layer.group_send)( + group_name, + resDict + ) def echo(self, data): print('ws echo') diff --git a/TWB/settings.py b/TWB/settings.py index 837e851..94b2053 100644 --- a/TWB/settings.py +++ b/TWB/settings.py @@ -93,11 +93,11 @@ ASGI_APPLICATION = 'TWB.asgi.application' CHANNEL_LAYERS = { 'default': { - 'BACKEND': 'channels.layers.InMemoryChannelLayer' - # "BACKEND": "channels_redis.core.RedisChannelLayer", - # "CONFIG": { - # "hosts": [("127.0.0.1", 6379)], - # }, + # 'BACKEND': 'channels.layers.InMemoryChannelLayer', + "BACKEND": "channels_redis.core.RedisChannelLayer", + "CONFIG": { + "hosts": [("127.0.0.1", 6379)], + }, } }