discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

step-by-step-create-message-debug

Browse Source
This commit is contained in:
tonyrewin 2022-11-16 20:13:12 +03:00
parent 5704b08d12
commit 4278be2a0b
1 changed files with 28 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
resolvers/inbox/messages.py
View File

@ -18,36 +18,38 @@ async def create_message(_, info, chat: str, body: str, replyTo=None):
return { return {
"error": "chat not exist" "error": "chat not exist"
} }
message_id = await redis.execute("GET", f"chats/{chat.id}/next_message_id") else:
message_id = int(message_id) chat = json.loads(chat)
new_message = { message_id = await redis.execute("GET", f"chats/{chat.id}/next_message_id")
"chatId": chat.id, message_id = int(message_id)
"id": message_id, new_message = {
"author": user.slug, "chatId": chat.id,
"body": body, "id": message_id,
"replyTo": replyTo, "author": user.slug,
"createdAt": int(datetime.now().timestamp()), "body": body,
} "replyTo": replyTo,
await redis.execute( "createdAt": int(datetime.now().timestamp()),
"SET", f"chats/{chat.id}/messages/{message_id}", json.dumps(new_message) }
)
await redis.execute("LPUSH", f"chats/{chat.id}/message_ids", str(message_id))
await redis.execute("SET", f"chats/{chat.id}/next_message_id", str(message_id + 1))
chat = json.loads(chat)
users = chat["users"]
for user_slug in users:
await redis.execute( await redis.execute(
"LPUSH", f"chats/{chat.id}/unread/{user_slug}", str(message_id) "SET", f"chats/{chat.id}/messages/{message_id}", json.dumps(new_message)
) )
await redis.execute("LPUSH", f"chats/{chat.id}/message_ids", str(message_id))
await redis.execute("SET", f"chats/{chat.id}/next_message_id", str(message_id + 1))
result = MessageResult("NEW", new_message) chat = json.loads(chat)
await MessagesStorage.put(result) users = chat["users"]
for user_slug in users:
await redis.execute(
"LPUSH", f"chats/{chat.id}/unread/{user_slug}", str(message_id)
)
return { result = MessageResult("NEW", new_message)
"message": new_message, await MessagesStorage.put(result)
"error": None
} return {
"message": new_message,
"error": None
}
@mutation.field("updateMessage") @mutation.field("updateMessage")