mirror of
https://github.com/spbleadersofdigtal/backend.git
synced 2025-10-30 23:27:31 +03:00
25 lines
722 B
Python
25 lines
722 B
Python
import functools
|
|
|
|
from channels.generic.websocket import AsyncJsonWebsocketConsumer, JsonWebsocketConsumer
|
|
|
|
|
|
def login_required(func):
|
|
@functools.wraps(func)
|
|
def wrapper(self, *args, **kwargs):
|
|
if not self.scope.get("user", False) or not self.scope["user"].is_authenticated:
|
|
self.send_error("Login is required")
|
|
else:
|
|
return func(self, *args, **kwargs)
|
|
|
|
return wrapper
|
|
|
|
|
|
class BaseConsumer(AsyncJsonWebsocketConsumer):
|
|
async def send_error(self, msg):
|
|
await self.send_json({"type": "error", "data": {"msg": msg}})
|
|
|
|
|
|
class SyncBaseConsumer(JsonWebsocketConsumer):
|
|
def send_error(self, msg):
|
|
self.send_json({"type": "error", "data": {"msg": msg}})
|