Skip to content

Commit

Permalink
Add channel to group when connecting
Browse files Browse the repository at this point in the history
See also: #17
  • Loading branch information
BECATRUE committed Nov 28, 2024
1 parent d628f27 commit 63c834b
Showing 1 changed file with 16 additions and 0 deletions.
16 changes: 16 additions & 0 deletions wlm_server/operation/consumers.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
from channels.generic.websocket import AsyncWebsocketConsumer

class OperationConsumer(AsyncWebsocketConsumer):
"""Consumer for notifying the operation change of a specific channel.
Attributes:
ch: Target WLM channel.
group_name: Name of group it belongs to in the channel layer.
"""

# pylint: disable=attribute-defined-outside-init
async def connect(self):
self.ch = self.scope['url_route']['kwargs']['ch']
self.group_name = f'channel_{self.ch}'
await self.channel_layer.group_add(self.group_name, self.channel_name)
await self.accept()

0 comments on commit 63c834b

Please sign in to comment.