From 81700598ece28850edfb3e8cc57b3d2724bbbe8d Mon Sep 17 00:00:00 2001 From: Ibrahim Serdar Acikgoz Date: Tue, 10 May 2022 17:25:57 +0300 Subject: [PATCH] app/cluster.go: add PublishWebSocketEvent method (#20171) --- app/cluster.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/app/cluster.go b/app/cluster.go index 4d0850f980..07dd032471 100644 --- a/app/cluster.go +++ b/app/cluster.go @@ -43,6 +43,12 @@ func (s *clusterWrapper) PublishPluginClusterEvent(productID string, ev model.Pl return nil } +func (s *clusterWrapper) PublishWebSocketEvent(productID string, event string, payload map[string]interface{}, broadcast *model.WebsocketBroadcast) { + ev := model.NewWebSocketEvent(fmt.Sprintf("custom_%v_%v", productID, event), "", "", "", nil) + ev = ev.SetBroadcast(broadcast).SetData(payload) + s.srv.Publish(ev) +} + func (s *clusterWrapper) SetPluginKeyWithOptions(productID string, key string, value []byte, options model.PluginKVSetOptions) (bool, *model.AppError) { return s.srv.setPluginKeyWithOptions(productID, key, value, options) }