lug/matterbridge
10
0
Fork 2
Code Issues 5 Pull Requests Actions Packages Projects Releases Wiki Activity

Moved channel topic/purpose update into new function.

Browse Source
This commit is contained in:
Patrick Connolly 2018-11-13 18:21:37 +08:00
parent 6d0dcdb718
commit 95cf8c11d5
1 changed files with 39 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
bridge/slack/slack.go
View File

@ -280,25 +280,15 @@ func (b *Bslack) sendRTM(msg config.Message) (string, error) {
} }
return "", nil return "", nil
} }
if (msg.Event == config.EVENT_TOPIC_CHANGE) && b.GetBool("SyncTopicChange") {
incomingChangeType, text := b.extractTopicOrPurpose(msg.Text) var handled bool
switch incomingChangeType {
case "topic": // Handle topic/purpose updates.
if strings.HasSuffix(channelInfo.Topic.Value, "[nosync]") { if handled, err = b.updateTopicOrPurpose(&msg, channelInfo); handled {
break return "", err
}
b.rtm.SetTopicOfConversation(channelInfo.ID, text)
case "purpose":
if strings.HasSuffix(channelInfo.Purpose.Value, "[nosync]") {
break
}
b.rtm.SetPurposeOfConversation(channelInfo.ID, text)
}
return "", nil
} }
// Handle message deletions. // Handle message deletions.
var handled bool
if handled, err = b.deleteMessage(&msg, channelInfo); handled { if handled, err = b.deleteMessage(&msg, channelInfo); handled {
return msg.ID, err return msg.ID, err
} }
@ -331,6 +321,39 @@ func (b *Bslack) sendRTM(msg config.Message) (string, error) {
return b.postMessage(&msg, messageParameters, channelInfo) return b.postMessage(&msg, messageParameters, channelInfo)
} }
func (b *Bslack) updateTopicOrPurpose(msg *config.Message, channelInfo *slack.Channel) (handled bool, err error) {
if msg.Event != config.EVENT_TOPIC_CHANGE {
return false, nil
}
if !b.GetBool("SyncTopicChange") {
return false, nil
}
incomingChangeType, text := b.extractTopicOrPurpose(msg.Text)
switch incomingChangeType {
case "topic":
if strings.HasSuffix(channelInfo.Topic.Value, "[nosync]") {
break
}
_, err = b.rtm.SetTopicOfConversation(channelInfo.ID, text)
case "purpose":
if strings.HasSuffix(channelInfo.Purpose.Value, "[nosync]") {
break
}
_, err = b.rtm.SetPurposeOfConversation(channelInfo.ID, text)
}
if err != nil {
if err = b.handleRateLimit(err); err != nil {
b.Log.Errorf("Failed to update channel topic/purpose on Slack: %#v", err)
return true, err
}
}
return true, nil
}
func (b *Bslack) deleteMessage(msg *config.Message, channelInfo *slack.Channel) (bool, error) { func (b *Bslack) deleteMessage(msg *config.Message, channelInfo *slack.Channel) (bool, error) {
if msg.Event != config.EventMsgDelete { if msg.Event != config.EventMsgDelete {
return false, nil return false, nil