kpsul/kfet/consumers.py

from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer

from .utils import DjangoJsonWebsocketConsumer, PermConsumerMixin


class KPsul(PermConsumerMixin, DjangoJsonWebsocketConsumer):
    groups = ["kfet.kpsul"]
    perms_connect = ["kfet.is_team"]

    async def kpsul(self, event):
        await self.send_json(event)

    @classmethod
    @async_to_sync
    async def group_send(cls, group, data):
        channel_layer = get_channel_layer()
        await channel_layer.group_send(group, data)
Simplify group_send for kpsul 2022-06-29 11:10:37 +02:00			`from asgiref.sync import async_to_sync`
			`from channels.layers import get_channel_layer`

kfet.open kfet.open app - Base data (raw_open, last_update...) is stored and shared through cache system. - 2 websockets groups: one for team users, one for other users. - UI is initialized and kept up-to-date with WS. - raw_open and force_close can be updated with standard HTTP requests. At this time, there isn't any restriction on raw_open view. Common sense tell us to change this behavior. Misc - Clean channels routing. - 'PermConsumerMixin': user who sent the message is available as argument in connection_groups method, which returns groups to which the user should be appended on websocket connection (and discarded on disconnection). - New kfet.utils module: should be used for mixins, whatever is useful and not concerns the kfet app. - Clean JS dependencies. 2017-06-21 07:08:28 +02:00			`from .utils import DjangoJsonWebsocketConsumer, PermConsumerMixin`
Merge branch 'master' into aureplop/kfet_open 2017-06-12 15:18:42 +02:00

Enable authentication on KPsul websocket. - PermConsumerMixin allows checking permissions on connection to a consumer. - KPsul consumer uses this mixin to check if connecting user has the permission `kfet.is_team`. Fixes #67. 2017-04-09 16:10:27 +02:00			`class KPsul(PermConsumerMixin, DjangoJsonWebsocketConsumer):`
core -- Apply black + isort to all files 2018-10-06 12:35:49 +02:00			`groups = ["kfet.kpsul"]`
			`perms_connect = ["kfet.is_team"]`
Update to django channels 2 2022-06-27 15:34:24 +02:00
			`async def kpsul(self, event):`
			`await self.send_json(event)`
Simplify group_send for kpsul 2022-06-29 11:10:37 +02:00
			`@classmethod`
			`@async_to_sync`
			`async def group_send(cls, group, data):`
			`channel_layer = get_channel_layer()`
			`await channel_layer.group_send(group, data)`