diff --git a/services/presence.py b/services/presence.py index c5c7d97..d4e068a 100644 --- a/services/presence.py +++ b/services/presence.py @@ -6,7 +6,7 @@ from validators.chat import Message async def notify_message(message: Message, chat_id: str): channel_name = f"chat:{chat_id}" - data = {**message, "kind": "new_message"} + data = {"payload": message, "kind": "new_message"} try: await redis.publish(channel_name, json.dumps(data)) except Exception as e: