Notifications accept.

Browse Source
This commit is contained in:
retoor 2025-03-05 18:09:54 +01:00
parent e1324e99bf
commit afbf53938b
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -17,10 +17,8 @@ class ChatService(BaseService):
message message
) )
channel_message_uid = channel_message["uid"] channel_message_uid = channel_message["uid"]
if not channel_message['new_count']:
channel_message['new_count'] = 0
channel_message['new_count'] += 1
await self.services.channel_message.save(channel_message)
user = await self.services.user.get(uid=user_uid) user = await self.services.user.get(uid=user_uid)
await self.services.notification.create_channel_message(channel_message_uid) await self.services.notification.create_channel_message(channel_message_uid)
sent_to_count = await self.services.socket.broadcast(channel_uid, dict( sent_to_count = await self.services.socket.broadcast(channel_uid, dict(

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

@ -36,6 +36,11 @@ class NotificationService(BaseService):
is_muted=False, is_muted=False,
deleted_at=None, deleted_at=None,
): ):
if not channel_member['new_count']:
channel_member['new_count'] = 0
channel_member['new_count'] += 1
await self.services.channel_member.save(channel_member)
model = await self.new() model = await self.new()
model["object_uid"] = channel_message_uid model["object_uid"] = channel_message_uid
model["object_type"] = "channel_message" model["object_type"] = "channel_message"