diff --git a/kfet/utils.py b/kfet/utils.py index 540f260c..e7ec91c2 100644 --- a/kfet/utils.py +++ b/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()