Dismiss activity center notifications of community on leave or Mark read

protocol/activity_center_persistence.go

@@ -401,6 +401,30 @@ func (db sqlitePersistence) DismissActivityCenterNotifications(ids []types.HexBy
 
 }
 
+func (db sqlitePersistence) DismissAllActivityCenterNotificationsFromCommunity(communityID string) error {
+
+	chatIDs, err := db.AllChatIDsByCommunity(communityID)
+	if err != nil {
+		return err
+	}
+
+	chatIDsCount := len(chatIDs)
+	if chatIDsCount == 0 {
+		return nil
+	}
+
+	chatIDsArgs := make([]interface{}, 0, chatIDsCount)
+	for _, chatID := range chatIDs {
+		chatIDsArgs = append(chatIDsArgs, chatID)
+	}
+
+	inVector := strings.Repeat("?, ", chatIDsCount-1) + "?"
+	query := "UPDATE activity_center_notifications SET read = 1, dismissed = 1 WHERE chat_id IN (" + inVector + ")" // nolint: gosec
+	_, err = db.db.Exec(query, chatIDsArgs...)
+	return err
+
+}
+
 func (db sqlitePersistence) AcceptAllActivityCenterNotifications() ([]*ActivityCenterNotification, error) {
 	var tx *sql.Tx
 	var err error

protocol/messenger.go

@@ -4080,6 +4080,11 @@ func (m *Messenger) MarkAllRead(chatID string) error {
 }
 
 func (m *Messenger) MarkAllReadInCommunity(communityID string) ([]string, error) {
+	err := m.persistence.DismissAllActivityCenterNotificationsFromCommunity(communityID)
+	if err != nil {
+		return nil, err
+	}
+
 	chatIDs, err := m.persistence.AllChatIDsByCommunity(communityID)
 	if err != nil {
 		return nil, err

protocol/messenger_communities.go

@@ -468,6 +468,11 @@ func (m *Messenger) DeclineRequestToJoinCommunity(request *requests.DeclineReque
 }
 
 func (m *Messenger) LeaveCommunity(communityID types.HexBytes) (*MessengerResponse, error) {
+	err := m.persistence.DismissAllActivityCenterNotificationsFromCommunity(communityID.String())
+	if err != nil {
+		return nil, err
+	}
+
 	mr, err := m.leaveCommunity(communityID)
 	if err != nil {
 		return nil, err