create-msg-fix
This commit is contained in:
parent
1591b9548f
commit
f59b8474e4
|
@ -38,7 +38,6 @@ async def create_message(_, info, chat: str, body: str, replyTo=None):
|
||||||
await redis.execute("LPUSH", f"chats/{chat['id']}/message_ids", str(message_id))
|
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))
|
await redis.execute("SET", f"chats/{chat['id']}/next_message_id", str(message_id + 1))
|
||||||
|
|
||||||
chat = json.loads(chat)
|
|
||||||
users = chat["users"]
|
users = chat["users"]
|
||||||
for user_slug in users:
|
for user_slug in users:
|
||||||
await redis.execute(
|
await redis.execute(
|
||||||
|
|
Loading…
Reference in New Issue
Block a user