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

fix-add-index

Browse Source
This commit is contained in:
tonyrewin 2022-11-11 10:58:50 +03:00
parent 1f84ae58c2
commit e3da509f1e
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
resolvers/inbox.py
View File

@ -33,6 +33,7 @@ async def get_total_unread_counter(user_slug: str):
async def add_user_to_chat(user_slug: str, chat_id: str, chat=None): async def add_user_to_chat(user_slug: str, chat_id: str, chat=None):
for member in chat["users"]: for member in chat["users"]:
chats_ids = await redis.execute("GET", f"chats_by_user/{member}") chats_ids = await redis.execute("GET", f"chats_by_user/{member}")
chats_ids = list(json.loads(chats_ids))
if chat_id not in chats_ids: if chat_id not in chats_ids:
chats_ids.append(chat_id) chats_ids.append(chat_id)
await redis.execute("SET", f"chats_by_user/{member}", json.dumps(chats_ids)) await redis.execute("SET", f"chats_by_user/{member}", json.dumps(chats_ids))
@ -53,7 +54,7 @@ async def enter_chat(_, info, chat_id: str):
"error": "chat not exist" "error": "chat not exist"
} }
else: else:
chat = json.loads(chat) chat = dict(json.loads(chat))
if user.slug not in chat["users"]: if user.slug not in chat["users"]:
chat["users"].append(user.slug) chat["users"].append(user.slug)
await add_user_to_chat(user.slug, chat_id, chat) await add_user_to_chat(user.slug, chat_id, chat)
@ -70,7 +71,7 @@ async def invite_to_chat(_, info, invited: str, chat_id: str):
user = info.context["request"].user user = info.context["request"].user
chat = await redis.execute("GET", f"chats/{chat_id}") chat = await redis.execute("GET", f"chats/{chat_id}")
if chat: if chat:
chat = json.loads(chat) chat = dict(json.loads(chat))
if user.slug in chat['admins']: if user.slug in chat['admins']:
chat["users"].append(invited) chat["users"].append(invited)
await add_user_to_chat(user.slug, chat_id, chat) await add_user_to_chat(user.slug, chat_id, chat)
@ -88,7 +89,7 @@ async def update_chat(_, info, chat_new: dict):
chat_id = chat_new["id"] chat_id = chat_new["id"]
chat = await redis.execute("GET", f"chats/{chat_id}") chat = await redis.execute("GET", f"chats/{chat_id}")
if chat: if chat:
chat = json.loads(chat) chat = dict(json.loads(chat))
if user.slug in chat["admins"]: if user.slug in chat["admins"]:
chat.update({ chat.update({
"title": chat_new.get("title", chat["title"]), "title": chat_new.get("title", chat["title"]),