|
|
@ -170,17 +170,17 @@ class TicketRoomConsumer(WebsocketConsumer):
|
|
|
|
|
|
|
|
|
|
|
|
def modify_online_user(self):
|
|
|
|
def 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)
|
|
|
|
connections_serial = []
|
|
|
|
my_connections = []
|
|
|
|
for connection in connections:
|
|
|
|
for connection in connections:
|
|
|
|
connection_data = {
|
|
|
|
connection_data = {
|
|
|
|
'first_name': connection.user.first_name,
|
|
|
|
'first_name': connection.user.first_name,
|
|
|
|
'last_name': connection.user.last_name,
|
|
|
|
'last_name': connection.user.last_name,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
connections_serial.append(connection_data)
|
|
|
|
my_connections.append(connection_data)
|
|
|
|
event = {
|
|
|
|
event = {
|
|
|
|
'type': 'user_connection_handler',
|
|
|
|
'type': 'user_connection_handler',
|
|
|
|
'user': self.user,
|
|
|
|
'user': self.user,
|
|
|
|
'connections': connections_serial,
|
|
|
|
'connections': my_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
|
|
|
|