Rename group name for notifying operation change

See also: #17
snu-quiqcl · Dec 3, 2024 · 5e87785 · 5e87785
1 parent 6e93902
commit 5e87785
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/wlm_server/operation/consumers.py b/wlm_server/operation/consumers.py
@@ -11,7 +11,7 @@ class OperationConsumer(AsyncWebsocketConsumer):
     # 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}'
+        self.group_name = f'channel_{self.ch}_operation'
         await self.channel_layer.group_add(self.group_name, self.channel_name)
         await self.accept()
 

diff --git a/wlm_server/operation/views.py b/wlm_server/operation/views.py
@@ -37,7 +37,7 @@ def handle_info(request, ch: int):
             notif = {'on': True}
             channel_layer = get_channel_layer()
             async_to_sync(channel_layer.group_send)(
-                f'channel_{ch}', {'type': 'notify', 'message': json.dumps(notif)}
+                f'channel_{ch}_operation', {'type': 'notify', 'message': json.dumps(notif)}
             )
         operation.save()
     else:
@@ -48,7 +48,7 @@ def handle_info(request, ch: int):
             notif = {'on': False}
             channel_layer = get_channel_layer()
             async_to_sync(channel_layer.group_send)(
-                f'channel_{ch}', {'type': 'notify', 'message': json.dumps(notif)}
+                f'channel_{ch}_operation', {'type': 'notify', 'message': json.dumps(notif)}
             )
         if not util.is_wlm_running():
             message = MessageInfo(ActionType.CLOSE, None, None)