diff --git a/resolvers/load.py b/resolvers/load.py index f880e83..000460e 100644 --- a/resolvers/load.py +++ b/resolvers/load.py @@ -34,11 +34,11 @@ async def load_messages(chat_id: str, limit: int = 5, offset: int = 0, ids: Opti replies = [] for m in messages: if m: - rt = json.loads(m).get("replyTo") - if rt: - rt = int(rt) - if rt not in message_ids: - replies.append(rt) + reply_to = json.loads(m).get("replyTo") + if reply_to: + reply_to = int(reply_to) + if reply_to not in message_ids: + replies.append(reply_to) if replies: messages += await load_messages(chat_id, offset, limit, replies) except Exception as e: