diff --git a/app/cluster_handlers.go b/app/cluster_handlers.go index 32a1d0b56e..9485529e4f 100644 --- a/app/cluster_handlers.go +++ b/app/cluster_handlers.go @@ -14,67 +14,67 @@ import ( // The cluster event handlers are spread across this function and // NewLocalCacheLayer. Be careful to not have duplicated handlers here and // there. -func (a *App) RegisterAllClusterMessageHandlers() { - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_PUBLISH, a.ClusterPublishHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_UPDATE_STATUS, a.ClusterUpdateStatusHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_ALL_CACHES, a.ClusterInvalidateAllCachesHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_MEMBERS_NOTIFY_PROPS, a.ClusterInvalidateCacheForChannelMembersNotifyPropHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_BY_NAME, a.ClusterInvalidateCacheForChannelByNameHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_USER, a.ClusterInvalidateCacheForUserHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_USER_TEAMS, a.ClusterInvalidateCacheForUserTeamsHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_CLEAR_SESSION_CACHE_FOR_USER, a.ClusterClearSessionCacheForUserHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_CLEAR_SESSION_CACHE_FOR_ALL_USERS, a.ClusterClearSessionCacheForAllUsersHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INSTALL_PLUGIN, a.ClusterInstallPluginHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_REMOVE_PLUGIN, a.ClusterRemovePluginHandler) - a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_BUSY_STATE_CHANGED, a.ClusterBusyStateChgHandler) +func (a *App) registerAllClusterMessageHandlers() { + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_PUBLISH, a.clusterPublishHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_UPDATE_STATUS, a.clusterUpdateStatusHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_ALL_CACHES, a.clusterInvalidateAllCachesHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_MEMBERS_NOTIFY_PROPS, a.clusterInvalidateCacheForChannelMembersNotifyPropHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_CHANNEL_BY_NAME, a.clusterInvalidateCacheForChannelByNameHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_USER, a.clusterInvalidateCacheForUserHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_USER_TEAMS, a.clusterInvalidateCacheForUserTeamsHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_CLEAR_SESSION_CACHE_FOR_USER, a.clusterClearSessionCacheForUserHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_CLEAR_SESSION_CACHE_FOR_ALL_USERS, a.clusterClearSessionCacheForAllUsersHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INSTALL_PLUGIN, a.clusterInstallPluginHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_REMOVE_PLUGIN, a.clusterRemovePluginHandler) + a.Cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_BUSY_STATE_CHANGED, a.clusterBusyStateChgHandler) } -func (a *App) ClusterPublishHandler(msg *model.ClusterMessage) { +func (a *App) clusterPublishHandler(msg *model.ClusterMessage) { event := model.WebSocketEventFromJson(strings.NewReader(msg.Data)) a.PublishSkipClusterSend(event) } -func (a *App) ClusterUpdateStatusHandler(msg *model.ClusterMessage) { +func (a *App) clusterUpdateStatusHandler(msg *model.ClusterMessage) { status := model.StatusFromJson(strings.NewReader(msg.Data)) a.AddStatusCacheSkipClusterSend(status) } -func (a *App) ClusterInvalidateAllCachesHandler(msg *model.ClusterMessage) { +func (a *App) clusterInvalidateAllCachesHandler(msg *model.ClusterMessage) { a.InvalidateAllCachesSkipSend() } -func (a *App) ClusterInvalidateCacheForChannelMembersNotifyPropHandler(msg *model.ClusterMessage) { +func (a *App) clusterInvalidateCacheForChannelMembersNotifyPropHandler(msg *model.ClusterMessage) { a.InvalidateCacheForChannelMembersNotifyPropsSkipClusterSend(msg.Data) } -func (a *App) ClusterInvalidateCacheForChannelByNameHandler(msg *model.ClusterMessage) { +func (a *App) clusterInvalidateCacheForChannelByNameHandler(msg *model.ClusterMessage) { a.InvalidateCacheForChannelByNameSkipClusterSend(msg.Props["id"], msg.Props["name"]) } -func (a *App) ClusterInvalidateCacheForUserHandler(msg *model.ClusterMessage) { +func (a *App) clusterInvalidateCacheForUserHandler(msg *model.ClusterMessage) { a.InvalidateCacheForUserSkipClusterSend(msg.Data) } -func (a *App) ClusterInvalidateCacheForUserTeamsHandler(msg *model.ClusterMessage) { +func (a *App) clusterInvalidateCacheForUserTeamsHandler(msg *model.ClusterMessage) { a.InvalidateCacheForUserTeamsSkipClusterSend(msg.Data) } -func (a *App) ClusterClearSessionCacheForUserHandler(msg *model.ClusterMessage) { +func (a *App) clusterClearSessionCacheForUserHandler(msg *model.ClusterMessage) { a.ClearSessionCacheForUserSkipClusterSend(msg.Data) } -func (a *App) ClusterClearSessionCacheForAllUsersHandler(msg *model.ClusterMessage) { +func (a *App) clusterClearSessionCacheForAllUsersHandler(msg *model.ClusterMessage) { a.ClearSessionCacheForAllUsersSkipClusterSend() } -func (a *App) ClusterInstallPluginHandler(msg *model.ClusterMessage) { +func (a *App) clusterInstallPluginHandler(msg *model.ClusterMessage) { a.InstallPluginFromData(model.PluginEventDataFromJson(strings.NewReader(msg.Data))) } -func (a *App) ClusterRemovePluginHandler(msg *model.ClusterMessage) { +func (a *App) clusterRemovePluginHandler(msg *model.ClusterMessage) { a.RemovePluginFromData(model.PluginEventDataFromJson(strings.NewReader(msg.Data))) } -func (a *App) ClusterBusyStateChgHandler(msg *model.ClusterMessage) { +func (a *App) clusterBusyStateChgHandler(msg *model.ClusterMessage) { a.ServerBusyStateChanged(model.ServerBusyStateFromJson(strings.NewReader(msg.Data))) } diff --git a/app/server.go b/app/server.go index d1698f5d5d..bb1759bf44 100644 --- a/app/server.go +++ b/app/server.go @@ -276,7 +276,7 @@ func NewServer(options ...Option) (*Server, error) { } if s.joinCluster && s.Cluster != nil { - s.FakeApp().RegisterAllClusterMessageHandlers() + s.FakeApp().registerAllClusterMessageHandlers() s.Cluster.StartInterNodeCommunication() }