From 4149e82455d2645d7bc5c910f72c7e311d2a5920 Mon Sep 17 00:00:00 2001 From: Joram Wilander Date: Tue, 14 Feb 2017 10:27:34 -0500 Subject: Fix here notifications (#5377) --- app/notification.go | 24 ++++++++++-------------- 1 file changed, 10 insertions(+), 14 deletions(-) (limited to 'app/notification.go') diff --git a/app/notification.go b/app/notification.go index fdff13c4f..e707b3d22 100644 --- a/app/notification.go +++ b/app/notification.go @@ -196,22 +196,18 @@ func SendNotifications(post *model.Post, team *model.Team, channel *model.Channe } if hereNotification { - if result := <-Srv.Store.Status().GetOnline(); result.Err != nil { - return nil, result.Err - } else { - statuses := result.Data.([]*model.Status) - for _, status := range statuses { - if status.UserId == post.UserId { - continue - } + statuses := GetAllStatuses() + for _, status := range statuses { + if status.UserId == post.UserId { + continue + } - _, profileFound := profileMap[status.UserId] - _, alreadyMentioned := mentionedUserIds[status.UserId] + _, profileFound := profileMap[status.UserId] + _, alreadyMentioned := mentionedUserIds[status.UserId] - if status.Status == model.STATUS_ONLINE && profileFound && !alreadyMentioned { - mentionedUsersList = append(mentionedUsersList, status.UserId) - updateMentionChans = append(updateMentionChans, Srv.Store.Channel().IncrementMentionCount(post.ChannelId, status.UserId)) - } + if status.Status == model.STATUS_ONLINE && profileFound && !alreadyMentioned { + mentionedUsersList = append(mentionedUsersList, status.UserId) + updateMentionChans = append(updateMentionChans, Srv.Store.Channel().IncrementMentionCount(post.ChannelId, status.UserId)) } } } -- cgit v1.2.3-1-g7c22