summaryrefslogtreecommitdiffstats
path: root/bridge
diff options
context:
space:
mode:
authorWim <wim@42.be>2016-11-04 00:05:15 +0100
committerWim <wim@42.be>2016-11-04 23:03:31 +0100
commitc3a8b7a997f5baf2579c58fdadead7e428ef0061 (patch)
tree242462cd21509b550051c7f69952e79d8a0ce5a2 /bridge
parent95fac548bbedb541b1b6d383b2053e7a06a7d8d2 (diff)
downloadmatterbridge-msglm-c3a8b7a997f5baf2579c58fdadead7e428ef0061.tar.gz
matterbridge-msglm-c3a8b7a997f5baf2579c58fdadead7e428ef0061.tar.bz2
matterbridge-msglm-c3a8b7a997f5baf2579c58fdadead7e428ef0061.zip
Refactor modifyMessage
Diffstat (limited to 'bridge')
-rw-r--r--bridge/discord/discord.go4
-rw-r--r--bridge/gitter/gitter.go4
-rw-r--r--bridge/slack/slack.go13
-rw-r--r--bridge/xmpp/xmpp.go4
4 files changed, 16 insertions, 9 deletions
diff --git a/bridge/discord/discord.go b/bridge/discord/discord.go
index f1331dd4..446977ad 100644
--- a/bridge/discord/discord.go
+++ b/bridge/discord/discord.go
@@ -25,9 +25,9 @@ func init() {
flog = log.WithFields(log.Fields{"module": protocol})
}
-func New(config config.Protocol, origin string, c chan config.Message) *bdiscord {
+func New(cfg config.Protocol, origin string, c chan config.Message) *bdiscord {
b := &bdiscord{}
- b.Config = &config
+ b.Config = &cfg
b.Remote = c
b.protocol = protocol
b.origin = origin
diff --git a/bridge/gitter/gitter.go b/bridge/gitter/gitter.go
index 8d3a0459..95c41af4 100644
--- a/bridge/gitter/gitter.go
+++ b/bridge/gitter/gitter.go
@@ -23,9 +23,9 @@ func init() {
flog = log.WithFields(log.Fields{"module": protocol})
}
-func New(config config.Protocol, origin string, c chan config.Message) *Bgitter {
+func New(cfg config.Protocol, origin string, c chan config.Message) *Bgitter {
b := &Bgitter{}
- b.Config = &config
+ b.Config = &cfg
b.Remote = c
b.protocol = protocol
b.origin = origin
diff --git a/bridge/slack/slack.go b/bridge/slack/slack.go
index f9432863..3b0a6c85 100644
--- a/bridge/slack/slack.go
+++ b/bridge/slack/slack.go
@@ -14,6 +14,7 @@ type MMMessage struct {
Text string
Channel string
Username string
+ Raw *slack.MessageEvent
}
type Bslack struct {
@@ -25,6 +26,7 @@ type Bslack struct {
Remote chan config.Message
protocol string
origin string
+ si *slack.Info
channels []slack.Channel
}
@@ -35,13 +37,12 @@ func init() {
flog = log.WithFields(log.Fields{"module": protocol})
}
-func New(config config.Protocol, origin string, c chan config.Message) *Bslack {
+func New(cfg config.Protocol, origin string, c chan config.Message) *Bslack {
b := &Bslack{}
- b.Config = &config
+ b.Config = &cfg
b.Remote = c
b.protocol = protocol
b.origin = origin
- b.Config.UseAPI = config.UseAPI
return b
}
@@ -148,6 +149,10 @@ func (b *Bslack) handleSlack() {
time.Sleep(time.Second)
flog.Debug("Start listening for Slack messages")
for message := range mchan {
+ // do not send messages from ourself
+ if message.Username == b.si.User.Name {
+ continue
+ }
texts := strings.Split(message.Text, "\n")
for _, text := range texts {
flog.Debugf("Sending message from %s on %s to gateway", message.Username, b.FullOrigin())
@@ -177,6 +182,7 @@ func (b *Bslack) handleSlackClient(mchan chan *MMMessage) {
m.Username = user.Name
m.Channel = channel.Name
m.Text = ev.Text
+ m.Raw = ev
mchan <- m
}
count++
@@ -184,6 +190,7 @@ func (b *Bslack) handleSlackClient(mchan chan *MMMessage) {
flog.Debugf("%#v", ev.Error())
case *slack.ConnectedEvent:
b.channels = ev.Info.Channels
+ b.si = ev.Info
case *slack.InvalidAuthEvent:
flog.Fatalf("Invalid Token %#v", ev)
default:
diff --git a/bridge/xmpp/xmpp.go b/bridge/xmpp/xmpp.go
index a7c326be..164284e5 100644
--- a/bridge/xmpp/xmpp.go
+++ b/bridge/xmpp/xmpp.go
@@ -25,10 +25,10 @@ func init() {
flog = log.WithFields(log.Fields{"module": protocol})
}
-func New(config config.Protocol, origin string, c chan config.Message) *Bxmpp {
+func New(cfg config.Protocol, origin string, c chan config.Message) *Bxmpp {
b := &Bxmpp{}
b.xmppMap = make(map[string]string)
- b.Config = &config
+ b.Config = &cfg
b.protocol = protocol
b.origin = origin
b.Remote = c