<gh_stars>10-100
'''AI--------------------------------------------------------------------------
    Django Imports
--------------------------------------------------------------------------AI'''
from django.contrib.auth import get_user_model
from django.db import connection


'''AI--------------------------------------------------------------------------
    Third-party Imports
--------------------------------------------------------------------------AI'''
from channels.generic.websocket import AsyncJsonWebsocketConsumer
from channels.db import database_sync_to_async
import bleach


'''AI--------------------------------------------------------------------------
    App Imports
--------------------------------------------------------------------------AI'''
from .models import Room, Message


'''AI--------------------------------------------------------------------------
    Python Imports
--------------------------------------------------------------------------AI'''
import json
from uuid import UUID


'''
AI-------------------------------------------------------------------
    Database Access methods below
-------------------------------------------------------------------AI
'''
@database_sync_to_async
def get_room(room_id, multitenant=False, schema_name=None):
    if multitenant:
        if not schema_name:
            raise AttributeError("Multitenancy support error: \
                scope does not have multitenancy details added. \
                did you forget to add ChatterMTMiddlewareStack to your routing?")
        else:
            from django_tenants.utils import schema_context
            with schema_context(schema_name):
                return Room.objects.get(id=room_id)
    else:
        return Room.objects.get(id=room_id)


'''
AI-------------------------------------------------------------------
    1. Select the Room
    2. Select the user who sent the message
    3. Select the message to be saved
    4. Save message
    5. Set room update time to message date_modified
-------------------------------------------------------------------AI
'''
@database_sync_to_async
def save_message(room, sender, text, multitenant=False, schema_name=None):
    if multitenant:
        if not schema_name:
            raise AttributeError("Multitenancy support error: \
                scope does not have multitenancy details added. \
                did you forget to add ChatterMTMiddlewareStack to your routing?")
        else:
            from django_tenants.utils import schema_context
            with schema_context(schema_name):
                new_message = Message(room=room, sender=sender, text=text)
                new_message.save()
                new_message.recipients.add(sender)
                new_message.save()
                room.date_modified = new_message.date_modified
                room.save()
                return new_message.date_created
    else:
        new_message = Message(room=room, sender=sender, text=text)
        new_message.save()
        new_message.recipients.add(sender)
        new_message.save()
        room.date_modified = new_message.date_modified
        room.save()
        return new_message.date_created


class ChatConsumer(AsyncJsonWebsocketConsumer):

    '''
    AI-------------------------------------------------------------------
        WebSocket methods below
    -------------------------------------------------------------------AI
    '''
    async def connect(self):
        self.user = self.scope['user']

        self.room_username_list = [] # Cache room usernames to send alerts

        self.schema_name = self.scope.get('schema_name', None)
        self.multitenant = self.scope.get('multitenant', False)
        for param in self.scope['path'].split('/'):
            try:
                room_id = UUID(param, version=4)
                break
            except ValueError:
                pass

        # Check if the user connecting to the room's websocket belongs in the room
        try:
            self.room = await get_room(room_id, self.multitenant, self.schema_name)
            if self.multitenant:
                from django_tenants.utils import schema_context
                with schema_context(self.schema_name):
                    if self.user in self.room.members.all():
                        self.room_group_name = 'chat_%s' % self.room.id
                        await self.channel_layer.group_add(
                            self.room_group_name,
                            self.channel_name
                        )
                        await self.accept()

                        for user in self.room.members.all():
                            self.room_username_list.append(user.username)
                    else:
                        await self.disconnect(403)
            else:
                if self.user in self.room.members.all():
                    self.room_group_name = 'chat_%s' % self.room.id
                    await self.channel_layer.group_add(
                        self.room_group_name,
                        self.channel_name
                    )
                    await self.accept()

                    for user in self.room.members.all():
                        self.room_username_list.append(user.username)
                else:
                    await self.disconnect(403)
        except Exception as ex:
            raise ex
            await self.disconnect(500)

    async def disconnect(self, close_code):
        await self.channel_layer.group_discard(
            self.room_group_name,
            self.channel_name
        )

    async def receive_json(self, data):
        if (data['sender'] != self.user.username)\
            or data['room_id'] != str(self.room.id):
            await self.disconnect(403)

        message_type = data['message_type']
        if message_type == "text":
            message = data['message']
            room_id = data['room_id']

            # Clean code off message if message contains code
            self.message_safe = bleach.clean(message)

            # try:
            #     # room = await self.get_room(room_id)
            #     room_group_name = 'chat_%s' % room_id
            # except Exception as ex:
            #     raise ex
            #     await self.disconnect(500)

            time = await save_message(self.room,
                                    self.user,
                                    self.message_safe,
                                    self.multitenant,
                                    self.schema_name
                                    )
            time = time.strftime("%d %b %Y %H:%M:%S %Z")
            await self.channel_layer.group_send(
                self.room_group_name,
                {
                    'type': 'send_to_websocket',
                    'message_type': 'text',
                    'message': self.message_safe,
                    'date_created': time,
                    'sender': self.user.username,
                    'room_id': room_id,
                }
            )

            for username in self.room_username_list:
                if username != self.user.username:
                    await self.channel_layer.group_send(
                        f'user_{username}',
                        {
                            'type': 'receive_json',
                            'message_type': 'text',
                            'message': self.message_safe,
                            'date_created': time,
                            'sender': self.user.username,
                            'room_id': room_id,
                        }
                    )

    async def send_to_websocket(self, event):
        await self.send_json(event)


class AlertConsumer(AsyncJsonWebsocketConsumer):
    '''
    AI-------------------------------------------------------------------
        WebSocket methods below
    -------------------------------------------------------------------AI
    '''
    async def connect(self):
        self.user = self.scope['user']
        self.user_group_name = f'user_{self.user.username}'
        await self.channel_layer.group_add(
            self.user_group_name,
            self.channel_name
        )
        await self.accept()

    async def disconnect(self, close_code):
        await self.channel_layer.group_discard(
            self.user_group_name,
            self.channel_name
        )

    async def receive_json(self, data):

        # Check if the data has been sent to this consumer by the currently
        # logged in user

        data['type'] = 'send_to_websocket'
        await self.channel_layer.group_send(self.user_group_name, data)

    async def send_to_websocket(self, event):
        await self.send_json(event)

'''AI--------------------------------------------------------------------------
    Django Imports
--------------------------------------------------------------------------AI'''
from django.contrib.auth import get_user_model
from django.db import connection


'''AI--------------------------------------------------------------------------
    Third-party Imports
--------------------------------------------------------------------------AI'''
from channels.generic.websocket import AsyncJsonWebsocketConsumer
from channels.db import database_sync_to_async
import bleach


'''AI--------------------------------------------------------------------------
    App Imports
--------------------------------------------------------------------------AI'''
from .models import Room, Message


'''AI--------------------------------------------------------------------------
    Python Imports
--------------------------------------------------------------------------AI'''
import json
from uuid import UUID


'''
AI-------------------------------------------------------------------
    Database Access methods below
-------------------------------------------------------------------AI
'''
@database_sync_to_async
def get_room(room_id, multitenant=False, schema_name=None):
    if multitenant:
        if not schema_name:
            raise AttributeError("Multitenancy support error: \
                scope does not have multitenancy details added. \
                did you forget to add ChatterMTMiddlewareStack to your routing?")
        else:
            from django_tenants.utils import schema_context
            with schema_context(schema_name):
                return Room.objects.get(id=room_id)
    else:
        return Room.objects.get(id=room_id)


'''
AI-------------------------------------------------------------------
    1. Select the Room
    2. Select the user who sent the message
    3. Select the message to be saved
    4. Save message
    5. Set room update time to message date_modified
-------------------------------------------------------------------AI
'''
@database_sync_to_async
def save_message(room, sender, text, multitenant=False, schema_name=None):
    if multitenant:
        if not schema_name:
            raise AttributeError("Multitenancy support error: \
                scope does not have multitenancy details added. \
                did you forget to add ChatterMTMiddlewareStack to your routing?")
        else:
            from django_tenants.utils import schema_context
            with schema_context(schema_name):
                new_message = Message(room=room, sender=sender, text=text)
                new_message.save()
                new_message.recipients.add(sender)
                new_message.save()
                room.date_modified = new_message.date_modified
                room.save()
                return new_message.date_created
    else:
        new_message = Message(room=room, sender=sender, text=text)
        new_message.save()
        new_message.recipients.add(sender)
        new_message.save()
        room.date_modified = new_message.date_modified
        room.save()
        return new_message.date_created


class ChatConsumer(AsyncJsonWebsocketConsumer):

    '''
    AI-------------------------------------------------------------------
        WebSocket methods below
    -------------------------------------------------------------------AI
    '''
    async def connect(self):
        self.user = self.scope['user']

        self.room_username_list = [] # Cache room usernames to send alerts

        self.schema_name = self.scope.get('schema_name', None)
        self.multitenant = self.scope.get('multitenant', False)
        for param in self.scope['path'].split('/'):
            try:
                room_id = UUID(param, version=4)
                break
            except ValueError:
                pass

        # Check if the user connecting to the room's websocket belongs in the room
        try:
            self.room = await get_room(room_id, self.multitenant, self.schema_name)
            if self.multitenant:
                from django_tenants.utils import schema_context
                with schema_context(self.schema_name):
                    if self.user in self.room.members.all():
                        self.room_group_name = 'chat_%s' % self.room.id
                        await self.channel_layer.group_add(
                            self.room_group_name,
                            self.channel_name
                        )
                        await self.accept()

                        for user in self.room.members.all():
                            self.room_username_list.append(user.username)
                    else:
                        await self.disconnect(403)
            else:
                if self.user in self.room.members.all():
                    self.room_group_name = 'chat_%s' % self.room.id
                    await self.channel_layer.group_add(
                        self.room_group_name,
                        self.channel_name
                    )
                    await self.accept()

                    for user in self.room.members.all():
                        self.room_username_list.append(user.username)
                else:
                    await self.disconnect(403)
        except Exception as ex:
            raise ex
            await self.disconnect(500)

    async def disconnect(self, close_code):
        await self.channel_layer.group_discard(
            self.room_group_name,
            self.channel_name
        )

    async def receive_json(self, data):
        if (data['sender'] != self.user.username)\
            or data['room_id'] != str(self.room.id):
            await self.disconnect(403)

        message_type = data['message_type']
        if message_type == "text":
            message = data['message']
            room_id = data['room_id']

            # Clean code off message if message contains code
            self.message_safe = bleach.clean(message)

            # try:
            #     # room = await self.get_room(room_id)
            #     room_group_name = 'chat_%s' % room_id
            # except Exception as ex:
            #     raise ex
            #     await self.disconnect(500)

            time = await save_message(self.room,
                                    self.user,
                                    self.message_safe,
                                    self.multitenant,
                                    self.schema_name
                                    )
            time = time.strftime("%d %b %Y %H:%M:%S %Z")
            await self.channel_layer.group_send(
                self.room_group_name,
                {
                    'type': 'send_to_websocket',
                    'message_type': 'text',
                    'message': self.message_safe,
                    'date_created': time,
                    'sender': self.user.username,
                    'room_id': room_id,
                }
            )

            for username in self.room_username_list:
                if username != self.user.username:
                    await self.channel_layer.group_send(
                        f'user_{username}',
                        {
                            'type': 'receive_json',
                            'message_type': 'text',
                            'message': self.message_safe,
                            'date_created': time,
                            'sender': self.user.username,
                            'room_id': room_id,
                        }
                    )

    async def send_to_websocket(self, event):
        await self.send_json(event)


class AlertConsumer(AsyncJsonWebsocketConsumer):
    '''
    AI-------------------------------------------------------------------
        WebSocket methods below
    -------------------------------------------------------------------AI
    '''
    async def connect(self):
        self.user = self.scope['user']
        self.user_group_name = f'user_{self.user.username}'
        await self.channel_layer.group_add(
            self.user_group_name,
            self.channel_name
        )
        await self.accept()

    async def disconnect(self, close_code):
        await self.channel_layer.group_discard(
            self.user_group_name,
            self.channel_name
        )

    async def receive_json(self, data):

        # Check if the data has been sent to this consumer by the currently
        # logged in user

        data['type'] = 'send_to_websocket'
        await self.channel_layer.group_send(self.user_group_name, data)

    async def send_to_websocket(self, event):
        await self.send_json(event)
AI--------------------------------------------------------------------------     Django Imports --------------------------------------------------------------------------AI AI--------------------------------------------------------------------------     Third-party Imports --------------------------------------------------------------------------AI AI--------------------------------------------------------------------------     App Imports --------------------------------------------------------------------------AI AI--------------------------------------------------------------------------     Python Imports --------------------------------------------------------------------------AI AI-------------------------------------------------------------------     Database Access methods below -------------------------------------------------------------------AI AI-------------------------------------------------------------------     1. Select the Room     2. Select the user who sent the message     3. Select the message to be saved     4. Save message     5. Set room update time to message date_modified -------------------------------------------------------------------AI AI-------------------------------------------------------------------         WebSocket methods below     -------------------------------------------------------------------AI # Cache room usernames to send alerts # Check if the user connecting to the room's websocket belongs in the room # Clean code off message if message contains code # try: #     # room = await self.get_room(room_id) #     room_group_name = 'chat_%s' % room_id # except Exception as ex: #     raise ex #     await self.disconnect(500) AI-------------------------------------------------------------------         WebSocket methods below     -------------------------------------------------------------------AI # Check if the data has been sent to this consumer by the currently # logged in user