fix(kfet/utils): Add sync_to_async

This commit is contained in:
Tom Hubrecht 2025-01-23 22:52:22 +01:00
parent ee61ed97d2
commit 4f8813bc81
Signed by: thubrecht
SSH key fingerprint: SHA256:r+nK/SIcWlJ0zFZJGHtlAoRwq1Rm+WcKAm5ADYMoQPc

View file

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