emile 10 months ago
parent 65b853718c
commit 39cb25a62b

@ -37,7 +37,7 @@ class TicketRoomConsumer(WebsocketConsumer):
self.ticket_number, self.channel_name self.ticket_number, self.channel_name
) )
self.accept() self.accept()
self.modify_online_user() self.ok_modify_online_user()
def disconnect(self, close_code): def disconnect(self, close_code):
@ -168,26 +168,18 @@ class TicketRoomConsumer(WebsocketConsumer):
'reaction': new_reaction.reaction if new_reaction else None 'reaction': new_reaction.reaction if new_reaction else None
})) }))
def modify_online_user(self): def ok_modify_online_user(self):
connections = TicketConnection.objects.filter(ticket=self.ticket, terminated_at__isnull=True) connections = TicketConnection.objects.filter(ticket=self.ticket, terminated_at__isnull=True)
sorted_connections = list(connections)
online_connections = []
for connection in sorted_connections:
connection_data = {
'first_name': connection.user.first_name,
'last_name': connection.user.last_name,
}
online_connections.append(connection_data)
event = { event = {
'type': 'online_user_connection_handler', 'type': 'user_connection_handler',
'user': self.user, 'user': self.user,
'connections': online_connections, 'connections': connections,
} }
async_to_sync(self.channel_layer.group_send)( async_to_sync(self.channel_layer.group_send)(
self.ticket_number, event self.ticket_number, event
) )
def online_user_connection_handler(self, event): def user_connection_handler(self, event):
context = { context = {
'connections': event['connections'], 'connections': event['connections'],
'user': event['user'] 'user': event['user']

Loading…
Cancel
Save