This commit is contained in:
parent
3f83d252fa
commit
37b3391660
|
@ -6,7 +6,7 @@ from validators.chat import Message
|
||||||
|
|
||||||
async def notify_message(message: Message, chat_id: str):
|
async def notify_message(message: Message, chat_id: str):
|
||||||
channel_name = f"chat:{chat_id}"
|
channel_name = f"chat:{chat_id}"
|
||||||
data = {**message, "kind": "new_message"}
|
data = {"payload": message, "kind": "new_message"}
|
||||||
try:
|
try:
|
||||||
await redis.publish(channel_name, json.dumps(data))
|
await redis.publish(channel_name, json.dumps(data))
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
|
|
Loading…
Reference in New Issue
Block a user