/
mod_slack.go
85 lines (74 loc) · 2.5 KB
/
mod_slack.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
// mod_slack.go - Slack sink code
// Copyright 2024 F5 Inc.
// Licensed under the BSD 3-clause license; see LICENSE.md for more information.
package main
import (
"fmt"
"log"
"reflect"
"regexp"
"strings"
"github.com/slack-go/slack"
)
func updateSlack(cfg deputizeSlackConfig, pdOnCallEmails []string, slackAuthToken string) error {
log.Printf("Beginning Slack Update.\n")
slackAPI := slack.New(slackAuthToken)
var oncallUsers []*slack.User
for _, email := range pdOnCallEmails {
user, err := slackAPI.GetUserByEmail(email)
if err != nil {
return fmt.Errorf("unable to getUserByEmail: %s", err)
}
oncallUsers = append(oncallUsers, user)
}
var slackUIDs []string
for _, user := range oncallUsers {
slackUIDs = append(slackUIDs, user.ID)
}
log.Printf("Current Oncall UIDs: %+v\n", slackUIDs)
for _, channel := range cfg.Channels {
c, err := slackAPI.GetConversationInfo(&slack.GetConversationInfoInput{ChannelID: channel})
if err != nil {
log.Printf("Warning: Got %s back from Slack API\n", err)
}
// Does the channel topic have a | in it? that's our delimiter, attempt to split.
channelTopic := strings.Split(c.Topic.Value, "|")
// Pull out current On Call folks
r, _ := regexp.Compile("U[A-Z0-9]+")
topicUIDs := r.FindAllString(channelTopic[0], -1)
log.Printf("Oncall UIDs from channel %s: %+v\n", channel, topicUIDs)
// See if they match w/ current on call, if not then update topic
if !reflect.DeepEqual(slackUIDs, topicUIDs) {
log.Printf("Difference between Current and Topic UIDs, updating topic.\n")
topic := "On-Call: "
// slackify the UIDs
for i, uid := range slackUIDs {
topic = topic + "<@" + uid + ">"
if i+1 < len(slackUIDs) {
topic = topic + ", "
}
}
if len(channelTopic) > 1 {
_, err := slackAPI.SetTopicOfConversation(channel, fmt.Sprintf("%s |%s", topic, channelTopic[1]))
if err != nil {
log.Printf("Warning: Got %s back from Slack API\n", err)
}
} else {
_, err := slackAPI.SetTopicOfConversation(channel, fmt.Sprintf("%s |", topic))
if err != nil {
log.Printf("Warning: Got %s back from Slack API\n", err)
}
}
if cfg.PostMessage {
slackParams := slack.PostMessageParameters{}
slackParams.AsUser = true
_, _, err := slackAPI.PostMessage(channel, slack.MsgOptionPostMessageParameters(slackParams), slack.MsgOptionText(topic, false))
if err != nil {
log.Printf("Warning: Got %s back from Slack API\n", err)
}
}
}
}
log.Printf("Slack update complete.\n")
return nil
}