support chat v3 switch to redis
This commit is contained in:
SDE
2023-08-14 17:14:20 +03:00
parent 12213d83c4
commit 11cfcda4fb
3 changed files with 25 additions and 23 deletions

View File

@@ -436,7 +436,9 @@ def create_ticket_ajax(request):
group_name = 'support_managers' group_name = 'support_managers'
Dict = { Dict = {
'type': 'update_chat', '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() channel_layer = get_channel_layer()
async_to_sync(channel_layer.group_send)( async_to_sync(channel_layer.group_send)(

View File

@@ -63,24 +63,24 @@ class ChatConsumer(WebsocketConsumer):
) )
group_name = f'user_{receiver}' group_name = f'user_{receiver}'
if group_name in self.channel_layer.groups.keys(): # if group_name in self.channel_layer.groups.keys():
data.update({ data.update({
'cur_user': receiver, 'cur_user': receiver,
'required_beep': True, 'required_beep': True,
}) })
Dict = update_chat(data) Dict = update_chat(data)
resDict = { resDict = {
'type': 'update_chat', 'type': 'update_chat',
'sender': receiver, 'sender': receiver,
'receiver': sender, 'receiver': sender,
'group_name': group_name, 'group_name': group_name,
} }
resDict.update(Dict) resDict.update(Dict)
async_to_sync(self.channel_layer.group_send)( async_to_sync(self.channel_layer.group_send)(
group_name, group_name,
resDict resDict
) )
def echo(self, data): def echo(self, data):
print('ws echo') print('ws echo')

View File

@@ -93,11 +93,11 @@ ASGI_APPLICATION = 'TWB.asgi.application'
CHANNEL_LAYERS = { CHANNEL_LAYERS = {
'default': { 'default': {
'BACKEND': 'channels.layers.InMemoryChannelLayer' # 'BACKEND': 'channels.layers.InMemoryChannelLayer',
# "BACKEND": "channels_redis.core.RedisChannelLayer", "BACKEND": "channels_redis.core.RedisChannelLayer",
# "CONFIG": { "CONFIG": {
# "hosts": [("127.0.0.1", 6379)], "hosts": [("127.0.0.1", 6379)],
# }, },
} }
} }