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

fieldname-fix
All checks were successful
deploy / deploy (push) Successful in 1m15s
Details

Browse Source
This commit is contained in:
Untone 2023-11-16 18:16:51 +03:00
parent c22b560bcf
commit 33b1323630
2 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
inbox.graphql
View File

@ -39,13 +39,13 @@ type ChatResult {
type Mutation {
# inbox
createChat(title: String, members: [Int]!): ChatResult!
updateChat(chat: ChatInput!): ChatResult!
deleteChat(chatId: String!): ChatResult!
updateChat(chat_id: ChatInput!): ChatResult!
deleteChat(chat_id: String!): ChatResult!
createMessage(chat: String!, body: String!, replyTo: Int): ChatResult!
updateMessage(chatId: String!, id: Int!, body: String!): ChatResult!
deleteMessage(chatId: String!, id: Int!): ChatResult!
markAsRead(chatId: String!, ids: [Int]!): ChatResult!
createMessage(chat_id: String!, body: String!, reply_to: Int): ChatResult!
updateMessage(chat_id: String!, message_id: Int!, body: String!): ChatResult!
deleteMessage(chat_id: String!, message_id: Int!): ChatResult!
markAsRead(chat_id: String!, message_id: Int!): ChatResult!
}
@ -74,7 +74,7 @@ type Message {
body: String!
created_at: Int!
id: Int!
replyTo: Int
reply_to: Int
updated_at: Int
seen: Boolean
}

10
resolvers/messages.py
View File

@ -1,6 +1,5 @@
import json
from datetime import datetime, timezone
from typing import List
from services.auth import login_required
from services.presence import notify_message
@ -11,12 +10,12 @@ from validators.chat import Message
@mutation.field("createMessage")
@login_required
async def create_message(_, info, chat: str, body: str, reply_to=None):
async def create_message(_, info, chat_id: str, body: str, reply_to=None):
"""Создание сообщения с телом :body для чата :chat_id с возможным ответом на :reply_to"""
author_id = info.context["author_id"]
# Получение данных чата из Redis
chat_data = await redis.execute("GET", f"chats/{chat}")
chat_data = await redis.execute("GET", f"chats/{chat_id}")
print(f"[resolvers.messages] debug chat data: {chat_data}")
# Если данных чата нет, возвращаем ошибку
@ -139,7 +138,7 @@ async def delete_message(_, info, chat_id: str, message_id: int):
@mutation.field("markAsRead")
@login_required
async def mark_as_read(_, info, chat_id: str, messages: List[int]):
async def mark_as_read(_, info, chat_id: str, message_id: int):
author_id = info.context["author_id"]
chat_str = await redis.execute("GET", f"chats/{chat_id}")
@ -151,8 +150,7 @@ async def mark_as_read(_, info, chat_id: str, messages: List[int]):
if author_id not in members:
return {"error": "access denied"}
for message_id in messages:
await redis.execute("LREM", f"chats/{chat_id}/unread/{author_id}", 0, str(message_id))
await redis.execute("LREM", f"chats/{chat_id}/unread/{author_id}", 0, str(message_id))
message_data = await redis.execute("GET", f"chats/{chat_id}/messages/{str(message_id)}")
if not message_data: