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

stabfix
All checks were successful
Deploy on push / deploy (push) Successful in 1m10s
Details

Browse Source
This commit is contained in:
Untone 2024-06-09 15:49:37 +03:00
parent 51f56c0f1f
commit 8708efece2
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
services/triggers.py
View File

@ -31,10 +31,12 @@ async def handle_author_follower_change(author_id: int, follower_id: int, is_ins
async def handle_topic_follower_change(topic_id: int, follower_id: int, is_insert: bool): async def handle_topic_follower_change(topic_id: int, follower_id: int, is_insert: bool):
logger.info(topic_id) logger.info(topic_id)
topic_query = select(Topic).filter(Topic.id == topic_id) topic_query = select(Topic).filter(Topic.id == topic_id)
[topic] = get_with_stat(topic_query) topic = get_with_stat(topic_query)
follower_query = select(Author).filter(Author.id == follower_id) follower_query = select(Author).filter(Author.id == follower_id)
[follower] = get_with_stat(follower_query) follower = get_with_stat(follower_query)
if follower and topic: if isinstance(follower[0],Author) and isinstance(topic[0], Topic):
topic = topic[0]
follower = follower[0]
await cache_topic(topic.dict()) await cache_topic(topic.dict())
await cache_author(follower.dict()) await cache_author(follower.dict())
await cache_follows(follower.id, "topic", topic.id, is_insert) await cache_follows(follower.id, "topic", topic.id, is_insert)