diff options
Diffstat (limited to 'api/web_hub.go')
| -rw-r--r-- | api/web_hub.go | 23 |
1 files changed, 6 insertions, 17 deletions
diff --git a/api/web_hub.go b/api/web_hub.go index 5f480880e..23c01eb1b 100644 --- a/api/web_hub.go +++ b/api/web_hub.go @@ -101,30 +101,19 @@ func PublishSkipClusterSend(message *model.WebSocketEvent) { } func InvalidateCacheForUser(userId string) { - - Srv.Store.Channel().InvalidateAllChannelMembersForUser(userId) - - for _, hub := range hubs { - hub.InvalidateUser(userId) - } + InvalidateCacheForUserSkipClusterSend(userId) if einterfaces.GetClusterInterface() != nil { einterfaces.GetClusterInterface().InvalidateCacheForUser(userId) } } -func InvalidateCacheForChannel(channelId string) { - - // XXX TODO FIX ME - // This can be removed, but the performance branch - // needs to be merged into master so it can be removed - // from the enterprise repo as well. - - // hub.invalidateChannel <- channelId +func InvalidateCacheForUserSkipClusterSend(userId string) { + Srv.Store.Channel().InvalidateAllChannelMembersForUser(userId) - // if einterfaces.GetClusterInterface() != nil { - // einterfaces.GetClusterInterface().InvalidateCacheForChannel(channelId) - // } + for _, hub := range hubs { + hub.InvalidateUser(userId) + } } func (h *Hub) Register(webConn *WebConn) { |