|
|
|
@ -38,7 +38,7 @@ class TicketRoomConsumer(WebsocketConsumer):
|
|
|
|
|
self.ticket_number, self.channel_name
|
|
|
|
|
)
|
|
|
|
|
self.accept()
|
|
|
|
|
self.modify_online_user()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def disconnect(self, close_code):
|
|
|
|
@ -170,9 +170,11 @@ class TicketRoomConsumer(WebsocketConsumer):
|
|
|
|
|
}))
|
|
|
|
|
|
|
|
|
|
def modify_online_user(self):
|
|
|
|
|
|
|
|
|
|
connections = TicketConnection.objects.filter(ticket=self.ticket, terminated_at__isnull=True)
|
|
|
|
|
event = {
|
|
|
|
|
|
|
|
|
|
'type': 'user_connection_handler',
|
|
|
|
|
'user': self.user,
|
|
|
|
|
'connections': connections,
|
|
|
|
|
}
|
|
|
|
|
async_to_sync(self.channel_layer.group_send)(
|
|
|
|
|
self.ticket_number, event
|
|
|
|
@ -180,7 +182,8 @@ class TicketRoomConsumer(WebsocketConsumer):
|
|
|
|
|
|
|
|
|
|
def user_connection_handler(self, event):
|
|
|
|
|
context = {
|
|
|
|
|
|
|
|
|
|
'connections': event['connections'],
|
|
|
|
|
'user': event['user']
|
|
|
|
|
}
|
|
|
|
|
html = render_to_string("details_templates/partials/ticket-online-users.html", context=context)
|
|
|
|
|
self.send(text_data=json.dumps({
|
|
|
|
|