summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorWim <wim@42.be>2017-02-24 17:58:51 +0100
committerWim <wim@42.be>2017-02-24 17:58:51 +0100
commit84c0b745af8349f6dff185c21751f51b1f7d3101 (patch)
tree46f10ed34cccccf96ab28db6446b4ecb3f2fac04
parent8b286fb009c26325268d4b838b3b83413af83f11 (diff)
downloadmatterbridge-msglm-84c0b745af8349f6dff185c21751f51b1f7d3101.tar.gz
matterbridge-msglm-84c0b745af8349f6dff185c21751f51b1f7d3101.tar.bz2
matterbridge-msglm-84c0b745af8349f6dff185c21751f51b1f7d3101.zip
Use roomalias instead of internal ID (matrix)
-rw-r--r--bridge/matrix/matrix.go39
-rw-r--r--matterbridge.toml.sample2
2 files changed, 33 insertions, 8 deletions
diff --git a/bridge/matrix/matrix.go b/bridge/matrix/matrix.go
index 222a8fd0..add7e408 100644
--- a/bridge/matrix/matrix.go
+++ b/bridge/matrix/matrix.go
@@ -4,6 +4,7 @@ import (
"github.com/42wim/matterbridge/bridge/config"
log "github.com/Sirupsen/logrus"
matrix "github.com/matrix-org/gomatrix"
+ "sync"
)
type Bmatrix struct {
@@ -12,6 +13,8 @@ type Bmatrix struct {
Remote chan config.Message
Account string
UserID string
+ RoomMap map[string]string
+ sync.RWMutex
}
var flog *log.Entry
@@ -23,6 +26,7 @@ func init() {
func New(cfg config.Protocol, account string, c chan config.Message) *Bmatrix {
b := &Bmatrix{}
+ b.RoomMap = make(map[string]string)
b.Config = &cfg
b.Account = account
b.Remote = c
@@ -58,26 +62,47 @@ func (b *Bmatrix) Disconnect() error {
}
func (b *Bmatrix) JoinChannel(channel string) error {
- _, err := b.mc.JoinRoom(channel, "", nil)
+ resp, err := b.mc.JoinRoom(channel, "", nil)
+ if err != nil {
+ return err
+ }
+ b.Lock()
+ b.RoomMap[resp.RoomID] = channel
+ b.Unlock()
return err
}
func (b *Bmatrix) Send(msg config.Message) error {
flog.Debugf("Receiving %#v", msg)
- b.mc.SendText(msg.Channel, msg.Username+msg.Text)
+ channel := b.getRoomID(msg.Channel)
+ flog.Debugf("Sending to channel %s", channel)
+ b.mc.SendText(channel, msg.Username+msg.Text)
return nil
}
+func (b *Bmatrix) getRoomID(channel string) string {
+ b.RLock()
+ defer b.RUnlock()
+ for ID, name := range b.RoomMap {
+ if name == channel {
+ return ID
+ }
+ }
+ return ""
+}
func (b *Bmatrix) handlematrix() error {
- warning := "Not relaying this message, please setup a dedicated bot user"
syncer := b.mc.Syncer.(*matrix.DefaultSyncer)
syncer.OnEventType("m.room.message", func(ev *matrix.Event) {
if ev.Content["msgtype"].(string) == "m.text" && ev.Sender != b.UserID {
+ b.RLock()
+ channel, ok := b.RoomMap[ev.RoomID]
+ b.RUnlock()
+ if !ok {
+ flog.Debugf("Unknown room %s", ev.RoomID)
+ return
+ }
flog.Debugf("Sending message from %s on %s to gateway", ev.Sender, b.Account)
- b.Remote <- config.Message{Username: ev.Sender, Text: ev.Content["body"].(string), Channel: ev.RoomID, Account: b.Account}
- }
- if ev.Sender == b.UserID && ev.Content["body"].(string) != warning {
- b.mc.SendText(ev.RoomID, warning)
+ b.Remote <- config.Message{Username: ev.Sender, Text: ev.Content["body"].(string), Channel: channel, Account: b.Account}
}
flog.Debugf("Received: %#v", ev)
})
diff --git a/matterbridge.toml.sample b/matterbridge.toml.sample
index f0901ce9..0f6e9936 100644
--- a/matterbridge.toml.sample
+++ b/matterbridge.toml.sample
@@ -608,7 +608,7 @@ enable=true
# see (https://www.linkedin.com/pulse/telegram-bots-beginners-marco-frau)
#hipchat - id_channel (see https://www.hipchat.com/account/xmpp for the correct channel)
#rocketchat - #channel (# is required)
- #matrix - room internal ID (looks like !QJFqjsGJwmQzbuBfff:matrix.org)
+ #matrix - #channel:server (eg #yourchannel:matrix.org)
#REQUIRED
channel="#testing"