2023-10-04 20:14:06 +03:00
|
|
|
import json
|
2023-10-05 00:28:06 +03:00
|
|
|
from services.redis import redis
|
2023-10-04 20:14:06 +03:00
|
|
|
|
|
|
|
|
|
|
|
|
|
async def notify_message(message, chat_id: str):
|
|
|
|
|
channel_name = f"chat:{chat_id}"
|
|
|
|
|
data = {**message, "kind": "new_message"}
|
|
|
|
|
try:
|
2023-10-05 00:20:43 +03:00
|
|
|
await redis.publish(channel_name, json.dumps(data))
|
2023-10-04 20:14:06 +03:00
|
|
|
except Exception as e:
|
|
|
|
|
print(f"Failed to publish to channel {channel_name}: {e}")
|
