From d7976549a0b45a42c04ac043a15677b7ca1228e9 Mon Sep 17 00:00:00 2001
From: Joram Wilander <jwawilander@gmail.com>
Date: Wed, 27 Jun 2018 08:46:38 -0400
Subject: MM-9674 Add plugin API for publishing custom WebSocket events (#8999)

* Add plugin API for publishing custom WebSocket events

* Add clearer payload comment

* Update comment
---
 plugin/client_rpc_generated.go | 27 +++++++++++++++++++++++++++
 1 file changed, 27 insertions(+)

(limited to 'plugin/client_rpc_generated.go')

diff --git a/plugin/client_rpc_generated.go b/plugin/client_rpc_generated.go
index b32a3e36e..9880814b2 100644
--- a/plugin/client_rpc_generated.go
+++ b/plugin/client_rpc_generated.go
@@ -1101,3 +1101,30 @@ func (s *APIRPCServer) KVDelete(args *KVDeleteArgs, returns *KVDeleteReturns) er
 	}
 	return nil
 }
+
+type PublishWebSocketEventArgs struct {
+	A string
+	B map[string]interface{}
+	C *model.WebsocketBroadcast
+}
+
+type PublishWebSocketEventReturns struct {
+}
+
+func (g *APIRPCClient) PublishWebSocketEvent(event string, payload map[string]interface{}, broadcast *model.WebsocketBroadcast) {
+	_args := &PublishWebSocketEventArgs{event, payload, broadcast}
+	_returns := &PublishWebSocketEventReturns{}
+	if err := g.client.Call("Plugin.PublishWebSocketEvent", _args, _returns); err != nil {
+		g.log.Error("RPC call to PublishWebSocketEvent API failed.", mlog.Err(err))
+	}
+	return
+}
+
+func (s *APIRPCServer) PublishWebSocketEvent(args *PublishWebSocketEventArgs, returns *PublishWebSocketEventReturns) error {
+	if hook, ok := s.impl.(interface {
+		PublishWebSocketEvent(event string, payload map[string]interface{}, broadcast *model.WebsocketBroadcast)
+	}); ok {
+		hook.PublishWebSocketEvent(args.A, args.B, args.C)
+	}
+	return nil
+}
-- 
cgit v1.2.3-1-g7c22