From 95cefd56434ac3afb9966d608e3c37a06446262b Mon Sep 17 00:00:00 2001 From: tonyrewin Date: Mon, 12 Dec 2022 10:35:12 +0300 Subject: [PATCH] fix decode id --- resolvers/inbox/load.py | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/resolvers/inbox/load.py b/resolvers/inbox/load.py index 00a50736..fd746df9 100644 --- a/resolvers/inbox/load.py +++ b/resolvers/inbox/load.py @@ -19,16 +19,16 @@ async def load_messages(chat_id: str, limit: int = 5, offset: int = 0, ids=[]): message_ids += ids try: if limit: - message_ids = await redis.lrange(f"chats/{chat_id}/message_ids", - offset, - offset + limit - ) + mids = await redis.lrange(f"chats/{chat_id}/message_ids", + offset, + offset + limit + ) + mids = [mid.decode("utf-8") for mid in mids] + message_ids += mids except Exception as e: print(e) if message_ids: - message_keys = [ - f"chats/{chat_id}/messages/{mid.decode('utf-8')}" for mid in message_ids - ] + message_keys = [f"chats/{chat_id}/messages/{mid}" for mid in message_ids] messages = await redis.mget(*message_keys) messages = [json.loads(msg.decode('utf-8')) for msg in messages] replies = []