diff --git a/app/notification.go b/app/notification.go index 3e488d7c23..449e49ab4d 100644 --- a/app/notification.go +++ b/app/notification.go @@ -191,10 +191,6 @@ func (a *App) SendNotifications(post *model.Post, team *model.Team, channel *mod mac := make(chan *model.AppError, 1) go func(userID string) { defer close(mac) - isRootMention := false - if rootMentions != nil { - _, isRootMention = rootMentions.Mentions[userID] - } _, incrementMentions := mentions.Mentions[userID] // if the user was not explicitly mentioned, check if they explicitly unfollowed the thread if !incrementMentions { @@ -210,7 +206,8 @@ func (a *App) SendNotifications(post *model.Post, team *model.Team, channel *mod return } } - _, err := a.Srv().Store.Thread().MaintainMembership(userID, post.RootId, true, !isRootMention && incrementMentions, *a.Config().ServiceSettings.ThreadAutoFollow, userID == post.UserId, userID == post.UserId) + _, err := a.Srv().Store.Thread().MaintainMembership(userID, post.RootId, true, incrementMentions, *a.Config().ServiceSettings.ThreadAutoFollow, userID == post.UserId, userID == post.UserId) + if err != nil { mac <- model.NewAppError("SendNotifications", "app.channel.autofollow.app_error", nil, err.Error(), http.StatusInternalServerError) return