Update.
This commit is contained in:
parent
7914511de5
commit
7f47a21d40
@ -33,6 +33,8 @@ class NotificationService(BaseService):
|
|||||||
channel_message = await self.services.channel_message.get(
|
channel_message = await self.services.channel_message.get(
|
||||||
uid=channel_message_uid
|
uid=channel_message_uid
|
||||||
)
|
)
|
||||||
|
if not channel_message["is_final"]:
|
||||||
|
return
|
||||||
user = await self.services.user.get(uid=channel_message["user_uid"])
|
user = await self.services.user.get(uid=channel_message["user_uid"])
|
||||||
self.app.db.begin()
|
self.app.db.begin()
|
||||||
async for channel_member in self.services.channel_member.find(
|
async for channel_member in self.services.channel_member.find(
|
||||||
|
Loading…
Reference in New Issue
Block a user