/
usergroup.go
83 lines (70 loc) · 1.61 KB
/
usergroup.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
package slack
import (
"context"
"fmt"
"github.com/slack-go/slack"
"github.com/target/goalert/permission"
"github.com/target/goalert/validation"
)
type UserGroup struct {
ID string
TeamID string
Name string
Handle string
}
// User will lookup a single Slack user group.
func (s *ChannelSender) UserGroup(ctx context.Context, id string) (*UserGroup, error) {
err := permission.LimitCheckAny(ctx, permission.User, permission.System)
if err != nil {
return nil, err
}
ug, ok := s.ugInfoCache.Get(id)
if ok {
return &ug, nil
}
groups, err := s.ListUserGroups(ctx)
if err != nil {
return nil, err
}
for _, g := range groups {
if g.ID == id {
s.ugInfoCache.Add(id, g)
return &g, nil
}
}
return nil, validation.NewGenericError("invalid user group id")
}
// ListUserGroups will return a list of all Slack user groups.
func (s *ChannelSender) ListUserGroups(ctx context.Context) ([]UserGroup, error) {
err := permission.LimitCheckAny(ctx, permission.User, permission.System)
if err != nil {
return nil, err
}
id, err := s.TeamID(ctx)
if err != nil {
return nil, err
}
groups, ok := s.ugCache.Get(id)
if !ok {
err = s.withClient(ctx, func(c *slack.Client) error {
groups, err = c.GetUserGroupsContext(ctx)
return err
})
if err != nil {
return nil, fmt.Errorf("get user groups: %w", err)
}
s.ugCache.Add(id, groups)
}
res := make([]UserGroup, 0, len(groups))
for _, g := range groups {
grp := UserGroup{
ID: g.ID,
Name: g.Name,
Handle: "@" + g.Handle,
TeamID: g.TeamID,
}
res = append(res, grp)
s.ugInfoCache.Add(g.ID, grp)
}
return res, nil
}