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

redis-hset-fix
All checks were successful
Deploy to core / deploy (push) Successful in 1m25s
Details

Browse Source
This commit is contained in:
Untone 2024-02-21 13:51:07 +03:00
parent 2cfcab744e
commit 3b867ded20
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
orm/author.py
View File

@ -48,7 +48,7 @@ class Author(Base):
@event.listens_for(Author, "after_update") @event.listens_for(Author, "after_update")
async def after_author_update(mapper, connection, target): async def after_author_update(mapper, connection, target):
redis_key = f"user:{target.user}:author" redis_key = f"user:{target.user}:author"
await redis.execute("HSET", redis_key, vars(target)) await redis.execute("HSET", redis_key, **vars(target))
async def update_follows_for_user(connection, user_id, entity_type, entity, is_insert): async def update_follows_for_user(connection, user_id, entity_type, entity, is_insert):
@ -70,7 +70,7 @@ async def update_follows_for_user(connection, user_id, entity_type, entity, is_i
e for e in follows[f"{entity_type}s"] if e["id"] != entity.id e for e in follows[f"{entity_type}s"] if e["id"] != entity.id
] ]
await redis.execute("HSET", redis_key, vars(follows)) await redis.execute("HSET", redis_key, **vars(follows))
async def handle_author_follower_change(connection, author_id, follower_id, is_insert): async def handle_author_follower_change(connection, author_id, follower_id, is_insert):

2
resolvers/author.py
View File

@ -200,7 +200,7 @@ async def get_author_by_user_id(user_id: str):
logger.info(f"getting author id for {user_id}") logger.info(f"getting author id for {user_id}")
q = select(Author).filter(Author.user == user_id) q = select(Author).filter(Author.user == user_id)
author = await load_author_with_stats(q) author = await load_author_with_stats(q)
await redis.execute("HSET", redis_key, author.dict()) await redis.execute("HSET", redis_key, **author.dict())
return author return author

2
resolvers/follower.py
View File

@ -137,7 +137,7 @@ async def get_follows_by_user_id(user_id: str):
logger.debug(f"getting follows for {user_id}") logger.debug(f"getting follows for {user_id}")
follows = query_follows(user_id) follows = query_follows(user_id)
await redis.execute("HSET", redis_key, follows) await redis.execute("HSET", redis_key, **follows)
return follows return follows