diff --git a/resolvers/messages.py b/resolvers/messages.py index 533abbf..e5d9872 100644 --- a/resolvers/messages.py +++ b/resolvers/messages.py @@ -21,7 +21,7 @@ async def create_message(_, info, chat: str, body: str, reply_to=None): if not chat: return {"error": "chat is not exist"} else: - chat = dict(json.loads(chat)) + chat = vars(json.loads(chat)) message_id = await redis.execute("GET", f"chats/{chat['id']}/next_message_id") message_id = int(message_id) new_message = { diff --git a/resolvers/unread.py b/resolvers/unread.py index c1872a9..a81733b 100644 --- a/resolvers/unread.py +++ b/resolvers/unread.py @@ -7,7 +7,7 @@ from services.auth import login_required async def get_unread_counter(chat_id: str, author_id: int): try: unread = await redis.execute( - "LLEN", f"chats/{chat_id.decode('utf-8')}/unread/{author_id}" + "LLEN", f"chats/{chat_id}/unread/{author_id}" ) if unread: return unread