discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

events-fix
All checks were successful
Deploy on push / deploy (push) Successful in 23s
Details

Browse Source
This commit is contained in:
Untone 2024-02-26 04:46:23 +03:00
parent eab1700b0d
commit f40eff2822
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
services/event_listeners.py
View File

@ -9,6 +9,7 @@ from orm.shout import ShoutAuthor, Shout
from orm.topic import Topic, TopicFollower from orm.topic import Topic, TopicFollower
from resolvers.stat import get_with_stat from resolvers.stat import get_with_stat
from services.rediscache import redis from services.rediscache import redis
from services.logger import root_logger as logger
DEFAULT_FOLLOWS = { DEFAULT_FOLLOWS = {
@ -28,7 +29,8 @@ async def update_follows_topics_cache(follows, author_id: int, ttl=25 * 60 * 60)
try: try:
payload = json.dumps(follows) payload = json.dumps(follows)
await redis.execute('SETEX', f'author:{author_id}:follows-topics', ttl, payload) await redis.execute('SETEX', f'author:{author_id}:follows-topics', ttl, payload)
except Exception: except Exception as exc:
logger.error(exc)
import traceback import traceback
traceback.print_exc() traceback.print_exc()
@ -38,7 +40,8 @@ async def update_follows_authors_cache(follows, author_id: int, ttl=25 * 60 * 60
try: try:
payload = json.dumps(follows) payload = json.dumps(follows)
await redis.execute('SETEX', f'author:{author_id}:follows-authors', ttl, payload) await redis.execute('SETEX', f'author:{author_id}:follows-authors', ttl, payload)
except Exception: except Exception as exc:
logger.error(exc)
import traceback import traceback
traceback.print_exc() traceback.print_exc()
@ -88,7 +91,7 @@ def after_reaction_insert(mapper, connection, reaction: Reaction):
for author in authors: for author in authors:
asyncio.create_task(update_author_cache(author.author())) asyncio.create_task(update_author_cache(author.author()))
shout = connection.execute(select(Shout).where(Shout.id == reaction.shout)).first() shout = connection.execute(select(Shout).select_from(Shout).where(Shout.id == reaction.shout)).first()
if shout: if shout:
after_shouts_update(mapper, connection, shout) after_shouts_update(mapper, connection, shout)