discours.io/inbox
5
0
Fork 0
Code Pull Requests Actions Wiki Activity

decode-fix

Browse Source
This commit is contained in:
Untone 2023-10-13 16:41:52 +03:00
parent ac80b45b51
commit 1c46fc1d48
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
resolvers/load.py
View File

@ -20,7 +20,7 @@ async def load_messages(chat_id: str, limit: int = 5, offset: int = 0, ids=None)
mids = await redis.lrange( mids = await redis.lrange(
f"chats/{chat_id}/message_ids", offset, offset + limit f"chats/{chat_id}/message_ids", offset, offset + limit
) )
mids = [mid.decode("utf-8") for mid in mids] mids = [mid for mid in mids]
message_ids += mids message_ids += mids
if message_ids: if message_ids:
message_keys = [f"chats/{chat_id}/messages/{mid}" for mid in message_ids] message_keys = [f"chats/{chat_id}/messages/{mid}" for mid in message_ids]
@ -80,7 +80,7 @@ async def load_messages_by(_, info, by, limit: int = 10, offset: int = 0):
"""load :limit messages of :chat_id with :offset""" """load :limit messages of :chat_id with :offset"""
author_id = info.context["author_id"] author_id = info.context["author_id"]
user_chats = await redis.execute("SMEMBERS", "chats_by_author/" + str(author_id)) user_chats = await redis.execute("SMEMBERS", "chats_by_author/" + str(author_id))
user_chats = [c.decode("utf-8") for c in user_chats] user_chats = [c for c in user_chats]
if user_chats: if user_chats:
messages = [] messages = []
by_chat = by.get("chat") by_chat = by.get("chat")