|
|
|
@ -46,11 +46,17 @@ class OnlineUserConsumer(WebsocketConsumer):
|
|
|
|
|
offline_connections = connections.filter(online=False, last_seen__isnull=False).order_by('-last_seen')[:5]
|
|
|
|
|
sorted_connections = list(online_connections) + list(offline_connections)
|
|
|
|
|
online_users_ids = [connection.user.id for connection in online_connections]
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
customer_connections = []
|
|
|
|
|
staff_connections = []
|
|
|
|
|
for connection in sorted_connections:
|
|
|
|
|
if hasattr(connection.user, 'customerprofile'):
|
|
|
|
|
customer_connections.append(connection)
|
|
|
|
|
elif hasattr(connection.user, 'staffprofile'):
|
|
|
|
|
staff_connections.append(connection)
|
|
|
|
|
event = {
|
|
|
|
|
'type': 'online_user_connection_handler',
|
|
|
|
|
|
|
|
|
|
'staff_connections': staff_connections,
|
|
|
|
|
'customer_connections': customer_connections,
|
|
|
|
|
'online_users_ids': online_users_ids
|
|
|
|
|
}
|
|
|
|
|
async_to_sync(self.channel_layer.group_send)(
|
|
|
|
@ -59,6 +65,8 @@ class OnlineUserConsumer(WebsocketConsumer):
|
|
|
|
|
|
|
|
|
|
def online_user_connection_handler(self, event):
|
|
|
|
|
context = {
|
|
|
|
|
'staff_connections': event['staff_connections'],
|
|
|
|
|
'customer_connections': event['customer_connections'],
|
|
|
|
|
}
|
|
|
|
|
html = render_to_string("details_templates/partials/recently-online.html", context=context)
|
|
|
|
|
self.send(text_data=json.dumps({
|
|
|
|
|