This commit is contained in:
parent
e0d2ae37eb
commit
c06dc5ebe7
|
@ -30,7 +30,7 @@ async def load_messages(chat_id: str, limit: int = 5, offset: int = 0, ids: Opti
|
||||||
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]
|
||||||
messages = (await redis.mget(*message_keys)) or []
|
messages = (await redis.mget(*message_keys)) or []
|
||||||
messages = [json.loads(m) if m else None for m in messages]
|
messages = [json.loads(m) if isinstance(m, str) else m for m in messages]
|
||||||
replies = []
|
replies = []
|
||||||
for m in messages:
|
for m in messages:
|
||||||
if m:
|
if m:
|
||||||
|
|
Loading…
Reference in New Issue
Block a user