25 lines
713 B
Python
25 lines
713 B
Python
import json
|
|
import asyncio
|
|
|
|
from orm.notification import Notification
|
|
from services.db import local_session
|
|
from services.rediscache import redis
|
|
|
|
|
|
async def handle_reaction(notification: dict[str, str | int]):
|
|
"""создаеёт новое хранимое уведомление"""
|
|
with local_session() as session:
|
|
try:
|
|
n = Notification(**notification)
|
|
session.add(n)
|
|
session.commit()
|
|
except Exception as e:
|
|
session.rollback()
|
|
print(f"[listener.handle_reaction] error: {str(e)}")
|
|
|
|
|
|
async def reactions_worker():
|
|
async for message in redis.listen("reaction"):
|
|
if message:
|
|
await handle_reaction(message)
|