-
Notifications
You must be signed in to change notification settings - Fork 20
/
remove_contact_groups.go
83 lines (71 loc) · 2.54 KB
/
remove_contact_groups.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 actions
import (
"github.com/nyaruka/goflow/assets"
"github.com/nyaruka/goflow/flows"
"github.com/nyaruka/goflow/flows/events"
"github.com/nyaruka/goflow/flows/modifiers"
"github.com/pkg/errors"
)
func init() {
registerType(TypeRemoveContactGroups, func() flows.Action { return &RemoveContactGroupsAction{} })
}
// TypeRemoveContactGroups is the type for the remove from groups action
const TypeRemoveContactGroups string = "remove_contact_groups"
// RemoveContactGroupsAction can be used to remove a contact from one or more groups. A [event:contact_groups_changed] event will be created
// for the groups which the contact is removed from. Groups can either be explicitly provided or `all_groups` can be set to true to remove
// the contact from all non-query based groups.
//
// {
// "uuid": "8eebd020-1af5-431c-b943-aa670fc74da9",
// "type": "remove_contact_groups",
// "groups": [{
// "uuid": "b7cf0d83-f1c9-411c-96fd-c511a4cfa86d",
// "name": "Registered Users"
// }]
// }
//
// @action remove_contact_groups
type RemoveContactGroupsAction struct {
baseAction
universalAction
Groups []*assets.GroupReference `json:"groups,omitempty" validate:"dive"`
AllGroups bool `json:"all_groups,omitempty"`
}
// NewRemoveContactGroups creates a new remove from groups action
func NewRemoveContactGroups(uuid flows.ActionUUID, groups []*assets.GroupReference, allGroups bool) *RemoveContactGroupsAction {
return &RemoveContactGroupsAction{
baseAction: newBaseAction(TypeRemoveContactGroups, uuid),
Groups: groups,
AllGroups: allGroups,
}
}
// Validate validates our action is valid
func (a *RemoveContactGroupsAction) Validate() error {
if a.AllGroups && len(a.Groups) > 0 {
return errors.Errorf("can't specify specific groups when all_groups=true")
}
return nil
}
// Execute runs the action
func (a *RemoveContactGroupsAction) Execute(run flows.FlowRun, step flows.Step, logModifier flows.ModifierCallback, logEvent flows.EventCallback) error {
contact := run.Contact()
if contact == nil {
logEvent(events.NewErrorf("can't execute action in session without a contact"))
return nil
}
var groups []*flows.Group
var err error
if a.AllGroups {
for _, group := range run.Session().Assets().Groups().All() {
if !group.UsesQuery() {
groups = append(groups, group)
}
}
} else {
if groups, err = resolveGroups(run, a.Groups, logEvent); err != nil {
return err
}
}
a.applyModifier(run, modifiers.NewGroups(groups, modifiers.GroupsRemove), logModifier, logEvent)
return nil
}