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

followers-cache-fix

Browse Source
This commit is contained in:
Untone 2024-05-06 10:29:50 +03:00
parent a5d99fa517
commit 52f5a4e813
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
services/cache.py
View File

@ -106,19 +106,19 @@ async def cache_follower(follower: dict, author: dict, is_insert=True):
if author_id and follower_id: if author_id and follower_id:
redis_key = f"author:{author_id}:followers" redis_key = f"author:{author_id}:followers"
followers_str = await redis.execute("GET", redis_key) followers_str = await redis.execute("GET", redis_key)
followers = [] followers = json.loads(followers_str) if isinstance(followers_str, str) else []
if isinstance(followers_str, str):
followers = json.loads(followers_str)
if is_insert and not any([int(f["id"]) == author_id for f in followers]): if is_insert and not any([int(f["id"]) == author_id for f in followers]):
followers.append(follower) followers.append(follower)
author_str = await redis.execute("GET", f"author:{follower_id}")
if isinstance(author_str, str):
author = json.loads(author_str)
author["stat"]["followers"] = len(followers)
await cache_author(author)
else: else:
followers = list(set([e for e in followers if int(e["id"]) != author_id])) followers = [e for e in followers if int(e["id"]) != author_id]
followers = list(set(followers))
author_str = await redis.execute("GET", f"author:{follower_id}")
if isinstance(author_str, str):
author = json.loads(author_str)
author["stat"]["followers"] = len(followers)
await cache_author(author)
payload = json.dumps(followers, cls=CustomJSONEncoder) payload = json.dumps(followers, cls=CustomJSONEncoder)
await redis.execute("SET", redis_key, payload) await redis.execute("SET", redis_key, payload)
return followers return followers