status-im
/
matterbridge
mirror of https://github.com/status-im/matterbridge.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Add support for mattermost matterbridge plugin

This commit is contained in:
Wim 2018-11-11 21:56:12 +01:00
parent 2f042ad915
commit 730ccdd456
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gateway/gateway.go
View File

@ -321,6 +321,12 @@ func (gw *Gateway) handleMessage(msg config.Message, dest *bridge.Bridge) []*BrM
msg.ParentID = canonicalParentMsgID msg.ParentID = canonicalParentMsgID
} }
// if we are using mattermost plugin account, send messages to MattermostPlugin channel
// that can be picked up by the mattermost matterbridge plugin
if dest.Account == "mattermost.plugin" {
gw.Router.MattermostPlugin <- msg
}
mID, err := dest.Send(msg) mID, err := dest.Send(msg)
if err != nil { if err != nil {
flog.Error(err) flog.Error(err)

7
gateway/router.go
View File

@ -11,13 +11,14 @@ import (
) )
type Router struct { type Router struct {
Gateways map[string]*Gateway Gateways map[string]*Gateway
Message chan config.Message Message chan config.Message
MattermostPlugin chan config.Message
*config.Config *config.Config
} }
func NewRouter(cfg *config.Config) (*Router, error) { func NewRouter(cfg *config.Config) (*Router, error) {
r := &Router{Message: make(chan config.Message), Gateways: make(map[string]*Gateway), Config: cfg} r := &Router{Message: make(chan config.Message), MattermostPlugin: make(chan config.Message), Gateways: make(map[string]*Gateway), Config: cfg}
sgw := samechannelgateway.New(cfg) sgw := samechannelgateway.New(cfg)
gwconfigs := sgw.GetConfig() gwconfigs := sgw.GetConfig()