diff options
Diffstat (limited to 'store/sql_channel_store.go')
-rw-r--r-- | store/sql_channel_store.go | 52 |
1 files changed, 0 insertions, 52 deletions
diff --git a/store/sql_channel_store.go b/store/sql_channel_store.go index 309337e50..30f2cf7db 100644 --- a/store/sql_channel_store.go +++ b/store/sql_channel_store.go @@ -1257,58 +1257,6 @@ func (s SqlChannelStore) PermanentDeleteMembersByUser(userId string) StoreChanne return storeChannel } -func (s SqlChannelStore) SetLastViewedAt(channelId string, userId string, newLastViewedAt int64) StoreChannel { - storeChannel := make(StoreChannel, 1) - - go func() { - result := StoreResult{} - - var query string - - if utils.Cfg.SqlSettings.DriverName == model.DATABASE_DRIVER_POSTGRES { - query = `UPDATE - ChannelMembers - SET - MentionCount = 0, - MsgCount = Channels.TotalMsgCount - (SELECT COUNT(*) - FROM Posts - WHERE ChannelId = :ChannelId - AND CreateAt > :NewLastViewedAt), - LastViewedAt = :NewLastViewedAt - FROM - Channels - WHERE - Channels.Id = ChannelMembers.ChannelId - AND UserId = :UserId - AND ChannelId = :ChannelId` - } else if utils.Cfg.SqlSettings.DriverName == model.DATABASE_DRIVER_MYSQL { - query = `UPDATE - ChannelMembers, Channels - SET - ChannelMembers.MentionCount = 0, - ChannelMembers.MsgCount = Channels.TotalMsgCount - (SELECT COUNT(*) - FROM Posts - WHERE ChannelId = :ChannelId - AND CreateAt > :NewLastViewedAt), - ChannelMembers.LastViewedAt = :NewLastViewedAt - WHERE - Channels.Id = ChannelMembers.ChannelId - AND UserId = :UserId - AND ChannelId = :ChannelId` - } - - _, err := s.GetMaster().Exec(query, map[string]interface{}{"ChannelId": channelId, "UserId": userId, "NewLastViewedAt": newLastViewedAt}) - if err != nil { - result.Err = model.NewLocAppError("SqlChannelStore.SetLastViewedAt", "store.sql_channel.set_last_viewed_at.app_error", nil, "channel_id="+channelId+", user_id="+userId+", "+err.Error()) - } - - storeChannel <- result - close(storeChannel) - }() - - return storeChannel -} - func (s SqlChannelStore) UpdateLastViewedAt(channelIds []string, userId string) StoreChannel { storeChannel := make(StoreChannel, 1) |