diff --git a/src/snek/service/chat.py b/src/snek/service/chat.py index a008c70..aef0cdd 100644 --- a/src/snek/service/chat.py +++ b/src/snek/service/chat.py @@ -20,11 +20,10 @@ class ChatService(BaseService): 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() 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"], html=channel_message["html"], user_uid=user_uid, @@ -36,4 +35,6 @@ class ChatService(BaseService): uid=channel_message['uid'], user_nick=user['nick'] )) + async self.app.create_task(self.services.notification.create_channel_message(channel_message_uid)) + return True