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

add userChats query

Browse Source
This commit is contained in:
knst-kotov 2022-06-11 17:35:10 +03:00
parent 0cef013137
commit 956dc3915c
2 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
inbox_resolvers/inbox.py
View File

@ -102,6 +102,19 @@ async def load_messages(chatId, size, page):
messages = [json.loads(msg) for msg in messages] messages = [json.loads(msg) for msg in messages]
return messages return messages
@query.field("userChats")
@login_required
async def user_chats(_, info):
user = info.context["request"].user
chats = await redis.execute("GET", f"chats_by_user/{user.slug}")
if not chats:
chats = list()
else:
chats = list(json.loads(chats))
return {"chats" : chats}
@query.field("enterChat") @query.field("enterChat")
@login_required @login_required
async def enter_chat(_, info, chatId, size): async def enter_chat(_, info, chatId, size):

7
inbox_schema.graphql
View File

@ -34,6 +34,11 @@ type EnterChatResult {
error: String error: String
} }
type UserChatsResult {
error: String
chats: [String]
}
################################### Mutation ################################### Mutation
type Mutation { type Mutation {
@ -49,7 +54,7 @@ type Mutation {
################################### Query ################################### Query
type Query { type Query {
# messages userChats: UserChatsResult!
enterChat(chatId: String!, size: Int = 50): EnterChatResult! enterChat(chatId: String!, size: Int = 50): EnterChatResult!
getMessages(chatId: String!, size: Int!, page: Int!): [Message]! getMessages(chatId: String!, size: Int!, page: Int!): [Message]!
} }