diff --git a/resolvers/messages.py b/resolvers/messages.py index 1196ce7..1e52c30 100644 --- a/resolvers/messages.py +++ b/resolvers/messages.py @@ -54,9 +54,6 @@ async def create_message(_, info, chat: str, body: str, reply_to=None): for member_id in members: await redis.execute("LPUSH", f"chats/{chat_dict['id']}/unread/{member_id}", str(message_id)) - # result = FollowingResult("NEW", "chat", new_message) - # await FollowingManager.push("chat", result) - # subscribe on updates await notify_message(new_message, chat_dict["id"]) diff --git a/validators/chat.py b/validators/chat.py index 5383968..af8a0d6 100644 --- a/validators/chat.py +++ b/validators/chat.py @@ -25,7 +25,7 @@ class ChatPayload(TypedDict): createdBy: int description: Optional[str] messages: Optional[List[Message]] - unread: Optional[int] + unread: Optional[List[int]] class ChatUpdate(TypedDict):