Adding caching to get channel member (#5518)

1 files changed, 12 insertions, 0 deletions

diff --git a/app/web_hub.go b/app/web_hub.go
index a214ffb5e..13852e8eb 100644
--- a/app/web_hub.go
+++ b/app/web_hub.go
@@ -170,6 +170,18 @@ func InvalidateCacheForUser(userId string) {
 	}
 }
 
+func InvalidateCacheForChannelMember(channelId string, userId string) {
+	InvalidateCacheForChannelMemberSkipClusterSend(channelId, userId)
+
+	if einterfaces.GetClusterInterface() != nil {
+		einterfaces.GetClusterInterface().InvalidateCacheForChannelMember(channelId, userId)
+	}
+}
+
+func InvalidateCacheForChannelMemberSkipClusterSend(channelId string, userId string) {
+	Srv.Store.Channel().InvalidateMember(channelId, userId)
+}
+
 func InvalidateCacheForUserSkipClusterSend(userId string) {
 	Srv.Store.Channel().InvalidateAllChannelMembersForUser(userId)
 	Srv.Store.User().InvalidateProfilesInChannelCacheByUser(userId)