diff --git a/src/snek/service/chat.py b/src/snek/service/chat.py
index 54e60dc..17c677b 100644
--- a/src/snek/service/chat.py
+++ b/src/snek/service/chat.py
@@ -17,10 +17,8 @@ class ChatService(BaseService):
             message
         )
         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)
         await self.services.notification.create_channel_message(channel_message_uid)
         sent_to_count = await self.services.socket.broadcast(channel_uid, dict(
diff --git a/src/snek/service/notification.py b/src/snek/service/notification.py
index 6db762c..a703f23 100644
--- a/src/snek/service/notification.py
+++ b/src/snek/service/notification.py
@@ -36,6 +36,11 @@ class NotificationService(BaseService):
             is_muted=False,
             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["object_uid"] = channel_message_uid
             model["object_type"] = "channel_message"