From de64f9166b79589a7aff5936b4fac8d34de0f219 Mon Sep 17 00:00:00 2001 From: Interitio Date: Tue, 28 Jul 2026 09:14:27 +0300 Subject: [PATCH] fix: Channel sample payload format --- plugin/channel.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/plugin/channel.py b/plugin/channel.py index e08460c..b6f4b2d 100644 --- a/plugin/channel.py +++ b/plugin/channel.py @@ -107,14 +107,16 @@ class CampaignChannel(Channel): reward_progress=random.randint(0, 105), reward_cap=150, ) - await self.send_event(payload, websocket=websocket) + await self.send_campaign_update(1, payload, websocket=websocket) async def del_connection(self, websocket): for wss in self.communities.values(): wss.discard(websocket) await super().del_connection(websocket) - async def send_campaign_update(self, communityid: int, payload, websocket=None): + async def send_campaign_update( + self, communityid: int, payload: CampaignPayload, websocket=None + ): for ws in (websocket,) if websocket else self.communities[communityid]: await self.send_event( { @@ -125,7 +127,9 @@ class CampaignChannel(Channel): websocket=ws, ) - async def send_campaign_ended(self, communityid: int, payload, websocket=None): + async def send_campaign_ended( + self, communityid: int, payload: CampaignPayload, websocket=None + ): for ws in (websocket,) if websocket else self.communities[communityid]: await self.send_event( {