Система уведомлений с websocket

class Notification(models.Model):
    recipient = models.ForeignKey(User, on_delete=models.CASCADE)
    message = models.CharField(max_length=255)
    created_at = models.DateTimeField(auto_now_add=True)
 
    def __str__(self):
        return f"{self.recipient}: {self.message}"

class NotificationConsumer(AsyncConsumer):
    async def websocket_connect(self, event):
        await self.send({
            "type": "websocket.accept"
        })
        user = self.scope["user"]
        if user.is_authenticated:
            notifications = await self.get_notifications(user)
            await self.send_notifications(notifications)
 
    async def websocket_receive(self, event):
        pass
 
    async def websocket_disconnect(self, event):
        pass
 
    @database_sync_to_async
    def get_notifications(self, user):
        return list(Notification.objects.filter(recipient=user).order_by("-created_at"))
 
    async def send_notifications(self, notifications):
        for notification in notifications:
            await self.send({
                "type": "websocket.send",
                "text": json.dumps({
                    "id": notification.id,
                    "message": notification.message,
                    "created_at": str(notification.created_at)
                })
            })