36 lines
1.0 KiB
Python
36 lines
1.0 KiB
Python
|
import json
|
||
|
|
from orm.reaction import Reaction
|
||
|
|
from orm.shout import Shout
|
||
|
|
from services.redis import redis
|
||
|
|
|
||
|
|
|
||
|
|
async def notify_reaction(reaction: Reaction):
|
||
|
|
channel_name = f"new_reaction"
|
||
|
|
data = {**reaction, "kind": f"new_reaction{reaction.kind}"}
|
||
|
|
try:
|
||
|
|
await redis.publish(channel_name, json.dumps(data))
|
||
|
|
except Exception as e:
|
||
|
|
print(f"Failed to publish to channel {channel_name}: {e}")
|
||
|
|
|
||
|
|
|
||
|
|
async def notify_shout(shout: Shout):
|
||
|
|
channel_name = f"new_shout"
|
||
|
|
data = {**shout, "kind": "new_shout"}
|
||
|
|
try:
|
||
|
|
await redis.publish(channel_name, json.dumps(data))
|
||
|
|
except Exception as e:
|
||
|
|
print(f"Failed to publish to channel {channel_name}: {e}")
|
||
|
|
|
||
|
|
|
||
|
|
async def notify_follower(follower_id: int, author_id: int):
|
||
|
|
channel_name = f"new_follower"
|
||
|
|
data = {
|
||
|
|
"follower_id": follower_id,
|
||
|
|
"author_id": author_id,
|
||
|
|
"kind": "new_follower",
|
||
|
|
}
|
||
|
|
try:
|
||
|
|
await redis.publish(channel_name, json.dumps(data))
|
||
|
|
except Exception as e:
|
||
|
|
print(f"Failed to publish to channel {channel_name}: {e}")
|