Implement notifying operation change

See also: #17
snu-quiqcl · Nov 22, 2024 · f08565b · f08565b
1 parent fd60f8f
commit f08565b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/wlm_server/operation/consumers.py b/wlm_server/operation/consumers.py
@@ -1,3 +1,5 @@
+import json
+
 from channels.generic.websocket import AsyncWebsocketConsumer
 
 class OperationConsumer(AsyncWebsocketConsumer):
@@ -17,3 +19,7 @@ async def connect(self):
 
     async def disconnect(self, code):
         await self.channel_layer.group_discard(self.group_name, self.channel_name)
+
+    async def notify(self, event: dict[str, str]):
+        message = event['message']
+        await self.send(text_data=message)