summaryrefslogtreecommitdiffstats
path: root/api/web_hub.go
diff options
context:
space:
mode:
authorJoramWilander <jwawilander@gmail.com>2015-10-07 11:39:45 -0400
committerJoramWilander <jwawilander@gmail.com>2015-10-07 11:39:45 -0400
commit1421e1ec4aa09c0e7094643d342d095cdd91d506 (patch)
tree80eac658b063f64c019dd71eaa6ac4bbb062d91e /api/web_hub.go
parentdfaef4bd7227391e21890c720f9668acb3a64c28 (diff)
downloadchat-1421e1ec4aa09c0e7094643d342d095cdd91d506.tar.gz
chat-1421e1ec4aa09c0e7094643d342d095cdd91d506.tar.bz2
chat-1421e1ec4aa09c0e7094643d342d095cdd91d506.zip
Fix user_added websocket event and update websocket channel access cache on add/remove member.
Diffstat (limited to 'api/web_hub.go')
-rw-r--r--api/web_hub.go10
1 files changed, 7 insertions, 3 deletions
diff --git a/api/web_hub.go b/api/web_hub.go
index 44d405283..15528c612 100644
--- a/api/web_hub.go
+++ b/api/web_hub.go
@@ -30,11 +30,15 @@ func PublishAndForget(message *model.Message) {
}()
}
+func UpdateChannelAccessCache(teamId, userId, channelId string) {
+ if nh, ok := hub.teamHubs[teamId]; ok {
+ nh.UpdateChannelAccessCache(userId, channelId)
+ }
+}
+
func UpdateChannelAccessCacheAndForget(teamId, userId, channelId string) {
go func() {
- if nh, ok := hub.teamHubs[teamId]; ok {
- nh.UpdateChannelAccessCache(userId, channelId)
- }
+ UpdateChannelAccessCache(teamId, userId, channelId)
}()
}