package bmattermost import ( "errors" "fmt" "strings" "sync" "github.com/42wim/matterbridge/bridge" "github.com/42wim/matterbridge/bridge/config" "github.com/42wim/matterbridge/bridge/helper" "github.com/42wim/matterbridge/matterhook" "github.com/matterbridge/matterclient" "github.com/rs/xid" ) type Bmattermost struct { mh *matterhook.Client mc *matterclient.Client v6 bool uuid string TeamID string *bridge.Config avatarMap map[string]string channelsMutex sync.RWMutex channelInfoMap map[string]*config.ChannelInfo } const mattermostPlugin = "mattermost.plugin" func New(cfg *bridge.Config) bridge.Bridger { b := &Bmattermost{ Config: cfg, avatarMap: make(map[string]string), channelInfoMap: make(map[string]*config.ChannelInfo), } b.v6 = b.GetBool("v6") b.uuid = xid.New().String() return b } func (b *Bmattermost) Command(cmd string) string { return "" } func (b *Bmattermost) Connect() error { if b.Account == mattermostPlugin { return nil } if strings.HasPrefix(b.getVersion(), "6.") || strings.HasPrefix(b.getVersion(), "7.") { if !b.v6 { b.v6 = true } } if b.GetString("WebhookBindAddress") != "" { if err := b.doConnectWebhookBind(); err != nil { return err } go b.handleMatter() return nil } switch { case b.GetString("WebhookURL") != "": if err := b.doConnectWebhookURL(); err != nil { return err } go b.handleMatter() return nil case b.GetString("Token") != "": b.Log.Info("Connecting using token (sending and receiving)") err := b.apiLogin() if err != nil { return err } go b.handleMatter() case b.GetString("Login") != "": b.Log.Info("Connecting using login/password (sending and receiving)") b.Log.Infof("Using mattermost v6 methods: %t", b.v6) err := b.apiLogin() if err != nil { return err } go b.handleMatter() } if b.GetString("WebhookBindAddress") == "" && b.GetString("WebhookURL") == "" && b.GetString("Login") == "" && b.GetString("Token") == "" { return errors.New("no connection method found. See that you have WebhookBindAddress, WebhookURL or Token/Login/Password/Server/Team configured") } return nil } func (b *Bmattermost) Disconnect() error { return nil } func (b *Bmattermost) JoinChannel(channel config.ChannelInfo) error { if b.Account == mattermostPlugin { return nil } b.channelsMutex.Lock() b.channelInfoMap[channel.ID] = &channel b.channelsMutex.Unlock() // we can only join channels using the API if b.GetString("WebhookURL") == "" && b.GetString("WebhookBindAddress") == "" { id := b.getChannelID(channel.Name) if id == "" { return fmt.Errorf("Could not find channel ID for channel %s", channel.Name) } return b.mc.JoinChannel(id) } return nil } func (b *Bmattermost) Send(msg config.Message) (string, error) { if b.Account == mattermostPlugin { return "", nil } b.Log.Debugf("=> Receiving %#v", msg) // Make a action /me of the message if msg.Event == config.EventUserAction { msg.Text = "*" + msg.Text + "*" } // map the file SHA to our user (caches the avatar) if msg.Event == config.EventAvatarDownload { return b.cacheAvatar(&msg) } // Use webhook to send the message if b.GetString("WebhookURL") != "" { return b.sendWebhook(msg) } // Delete message if msg.Event == config.EventMsgDelete { if msg.ID == "" { return "", nil } return msg.ID, b.mc.DeleteMessage(msg.ID) } // Handle prefix hint for unthreaded messages. if msg.ParentNotFound() { msg.ParentID = "" msg.Text = fmt.Sprintf("[thread]: %s", msg.Text) } // we only can reply to the root of the thread, not to a specific ID (like discord for example does) if msg.ParentID != "" { post, _, err := b.mc.Client.GetPost(msg.ParentID, "") if err != nil { b.Log.Errorf("getting post %s failed: %s", msg.ParentID, err) } if post.RootId != "" { msg.ParentID = post.RootId } } // Upload a file if it exists if msg.Extra != nil { for _, rmsg := range helper.HandleExtra(&msg, b.General) { if _, err := b.mc.PostMessage(b.getChannelID(rmsg.Channel), rmsg.Username+rmsg.Text, msg.ParentID); err != nil { b.Log.Errorf("PostMessage failed: %s", err) } } if len(msg.Extra["file"]) > 0 { return b.handleUploadFile(&msg) } } // Prepend nick if configured if b.GetBool("PrefixMessagesWithNick") { msg.Text = msg.Username + msg.Text } // Edit message if we have an ID if msg.ID != "" { return b.mc.EditMessage(msg.ID, msg.Text) } // Post normal message return b.mc.PostMessage(b.getChannelID(msg.Channel), msg.Text, msg.ParentID) }