From f08565be08e50d968d5154a8daf7446423d2e737 Mon Sep 17 00:00:00 2001 From: Jaehun You Date: Thu, 21 Nov 2024 16:04:58 +0900 Subject: [PATCH] Implement notifying operation change See also: #17 --- wlm_server/operation/consumers.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/wlm_server/operation/consumers.py b/wlm_server/operation/consumers.py index dcbe96d..89dbbb9 100644 --- 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)