Transactions.

Browse Source
This commit is contained in:
retoor 2025-03-27 21:12:19 +01:00
parent 73e8779bdc
commit 6f043d2139
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/snek/service/chat.py
View File

@ -20,11 +20,10 @@ class ChatService(BaseService):
user = await self.services.user.get(uid=user_uid) user = await self.services.user.get(uid=user_uid)
async self.app.create_task(self.services.notification.create_channel_message(channel_message_uid))
channel['last_message_on'] = now() channel['last_message_on'] = now()
await self.services.channel.save(channel) await self.services.channel.save(channel)
self.services.socket.broadcast(channel_uid, dict( await self.services.socket.broadcast(channel_uid, dict(
message=channel_message["message"], message=channel_message["message"],
html=channel_message["html"], html=channel_message["html"],
user_uid=user_uid, user_uid=user_uid,
@ -36,4 +35,6 @@ class ChatService(BaseService):
uid=channel_message['uid'], uid=channel_message['uid'],
user_nick=user['nick'] user_nick=user['nick']
)) ))
async self.app.create_task(self.services.notification.create_channel_message(channel_message_uid))
return True return True