from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer


@classmethod
def notify_ws_clients(self, message):
        """
        Inform client there is a new message.
        """

        notification = {
            "type": "recieve_group_message",
            "message": "{}".format(message),
        }

        channel_layer = get_channel_layer()
        print("user.id {}".format(self.user.id))
        print("user.id {}".format(self.recipient.id))

        async_to_sync(channel_layer.group_send)("{}".format(self.user.id), notification)
        async_to_sync(channel_layer.group_send)(
            "{}".format(self.recipient.id), notification
        )