kfet/utils.py

@@ -1,6 +1,7 @@
 import json
 import math
 
+from asgiref.sync import sync_to_async
 from channels.generic.websocket import AsyncJsonWebsocketConsumer
 from django.core.cache import cache
 from django.core.serializers.json import DjangoJSONEncoder
@@ -95,7 +96,7 @@ class PermConsumerMixin:
         """Check permissions on connection."""
         self.user = self.scope["user"]
 
-        if self.user.has_perms(self.perms_connect):
+        if await sync_to_async(self.user.has_perms)(self.perms_connect):
             await super().connect()
         else:
             await self.close()