discours.io/inbox
5
0
Fork 0
Code Pull Requests Actions Wiki Activity

fix-validator
All checks were successful
deploy / deploy (push) Successful in 1m10s
Details

Browse Source
This commit is contained in:
Untone 2023-10-16 20:44:51 +03:00
parent e58b5eb0a1
commit 22a9b44612
2 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
resolvers/messages.py
View File

@ -54,9 +54,6 @@ async def create_message(_, info, chat: str, body: str, reply_to=None):
for member_id in members: for member_id in members:
await redis.execute("LPUSH", f"chats/{chat_dict['id']}/unread/{member_id}", str(message_id)) 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 # subscribe on updates
await notify_message(new_message, chat_dict["id"]) await notify_message(new_message, chat_dict["id"])

2
validators/chat.py
View File

@ -25,7 +25,7 @@ class ChatPayload(TypedDict):
createdBy: int createdBy: int
description: Optional[str] description: Optional[str]
messages: Optional[List[Message]] messages: Optional[List[Message]]
unread: Optional[int] unread: Optional[List[int]]
class ChatUpdate(TypedDict): class ChatUpdate(TypedDict):