package brocketchat import ( "github.com/42wim/matterbridge/bridge/config" "github.com/42wim/matterbridge/hook/rockethook" "github.com/42wim/matterbridge/matterhook" log "github.com/Sirupsen/logrus" ) type MMhook struct { mh *matterhook.Client rh *rockethook.Client } type Brocketchat struct { MMhook Config *config.Protocol Remote chan config.Message Account string } var flog *log.Entry var protocol = "rocketchat" func init() { flog = log.WithFields(log.Fields{"module": protocol}) } func New(cfg config.Protocol, account string, c chan config.Message) *Brocketchat { b := &Brocketchat{} b.Config = &cfg b.Remote = c b.Account = account return b } func (b *Brocketchat) Command(cmd string) string { return "" } func (b *Brocketchat) Connect() error { flog.Info("Connecting webhooks") b.mh = matterhook.New(b.Config.WebhookURL, matterhook.Config{InsecureSkipVerify: b.Config.SkipTLSVerify, DisableServer: true}) b.rh = rockethook.New(b.Config.WebhookURL, rockethook.Config{BindAddress: b.Config.WebhookBindAddress}) go b.handleRocketHook() return nil } func (b *Brocketchat) Disconnect() error { return nil } func (b *Brocketchat) JoinChannel(channel config.ChannelInfo) error { return nil } func (b *Brocketchat) Send(msg config.Message) (string, error) { flog.Debugf("Receiving %#v", msg) matterMessage := matterhook.OMessage{IconURL: b.Config.IconURL} matterMessage.Channel = msg.Channel matterMessage.UserName = msg.Username matterMessage.Type = "" matterMessage.Text = msg.Text err := b.mh.Send(matterMessage) if err != nil { flog.Info(err) return "", err } return "", nil } func (b *Brocketchat) handleRocketHook() { for { message := b.rh.Receive() flog.Debugf("Receiving from rockethook %#v", message) // do not loop if message.UserName == b.Config.Nick { continue } flog.Debugf("Sending message from %s on %s to gateway", message.UserName, b.Account) b.Remote <- config.Message{Text: message.Text, Username: message.UserName, Channel: message.ChannelName, Account: b.Account, UserID: message.UserID} } }