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

redis-set-result-fix-2

Browse Source
This commit is contained in:
Untone 2023-10-13 12:50:00 +03:00
parent 723a0a2818
commit e75b37e177
2 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
resolvers/chats.py
View File

@ -52,8 +52,6 @@ async def create_chat(_, info, title="", members=None):
if author_id not in members: if author_id not in members:
members.append(int(author_id)) members.append(int(author_id))
await redis.execute('MULTI')
# NOTE: private chats has no title # NOTE: private chats has no title
# reuse private chat created before if exists # reuse private chat created before if exists
if len(members) == 2 and title == "": if len(members) == 2 and title == "":
@ -90,9 +88,6 @@ async def create_chat(_, info, title="", members=None):
await redis.execute("SET", f"chats/{chat_id}", json.dumps(chat)) await redis.execute("SET", f"chats/{chat_id}", json.dumps(chat))
await redis.execute("SET", f"chats/{chat_id}/next_message_id", str(0)) await redis.execute("SET", f"chats/{chat_id}/next_message_id", str(0))
response = await redis.execute('EXEC')
print(f"EXEC response: {response}")
return {"error": None, "chat": chat} return {"error": None, "chat": chat}

3
resolvers/load.py
View File

@ -45,16 +45,15 @@ async def load_chats(_, info, limit: int = 50, offset: int = 0):
"""load :limit chats of current user with :offset""" """load :limit chats of current user with :offset"""
author_id = info.context["author_id"] author_id = info.context["author_id"]
print(f"Loading chats for user with id={author_id}") print(f"Loading chats for user with id={author_id}")
await redis.execute('MULTI')
cids = (await redis.execute("SMEMBERS", f"chats_by_author/{author_id}")) or [] cids = (await redis.execute("SMEMBERS", f"chats_by_author/{author_id}")) or []
members_online = (await redis.execute("SMEMBERS", "authors-online")) or [] members_online = (await redis.execute("SMEMBERS", "authors-online")) or []
await redis.execute('EXEC')
cids = list(cids)[offset:(offset + limit)] cids = list(cids)[offset:(offset + limit)]
chats = [] chats = []
lock = asyncio.Lock() lock = asyncio.Lock()
if len(cids) == 0: if len(cids) == 0:
print(f"[resolvers.load] no chats for user with id={author_id}, create one with Discours (id=2)") print(f"[resolvers.load] no chats for user with id={author_id}, create one with Discours (id=2)")
r = await create_chat(None, info, members=[2]) # member with id = 2 is discours r = await create_chat(None, info, members=[2]) # member with id = 2 is discours
print(f"{r}")
cids.append(r["chat"]["id"]) cids.append(r["chat"]["id"])
for cid in cids: for cid in cids:
print(f"Processing chat ID: {cid}") print(f"Processing chat ID: {cid}")