-
Notifications
You must be signed in to change notification settings - Fork 20
/
base.go
82 lines (65 loc) · 2.5 KB
/
base.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
package modifiers
import (
"encoding/json"
"github.com/nyaruka/goflow/assets"
"github.com/nyaruka/goflow/envs"
"github.com/nyaruka/goflow/flows"
"github.com/nyaruka/goflow/flows/events"
"github.com/nyaruka/goflow/utils"
"github.com/pkg/errors"
)
// ErrNoModifier is the error instance returned when a modifier is read but due to missing assets can't be returned
var ErrNoModifier = errors.New("no modifier to return because of missing assets")
type readFunc func(flows.SessionAssets, json.RawMessage, assets.MissingCallback) (flows.Modifier, error)
// RegisteredTypes is the registered modifier types
var RegisteredTypes = map[string]readFunc{}
// egisters a new type of modifier
func registerType(name string, f readFunc) {
RegisteredTypes[name] = f
}
// base of all modifier types
type baseModifier struct {
Type_ string `json:"type" validate:"required"`
}
// creates new base modifier
func newBaseModifier(typeName string) baseModifier {
return baseModifier{Type_: typeName}
}
// Type returns the type of this modifier
func (m *baseModifier) Type() string { return m.Type_ }
// helper to re-evaluate groups and log any changes to membership
func (m *baseModifier) reevaluateGroups(env envs.Environment, assets flows.SessionAssets, contact *flows.Contact, log flows.EventCallback) {
added, removed, errors := contact.ReevaluateQueryBasedGroups(env)
// add error event for each group we couldn't re-evaluate
for _, err := range errors {
log(events.NewError(err))
}
// make sure from all static groups are removed for non-active contacts
if contact.Status() != flows.ContactStatusActive {
for _, g := range contact.Groups().All() {
if !g.UsesQuery() {
contact.Groups().Remove(g)
removed = append(removed, g)
}
}
}
// add groups changed event for the groups we were added/removed to/from
if len(added) > 0 || len(removed) > 0 {
log(events.NewContactGroupsChanged(added, removed))
}
}
//------------------------------------------------------------------------------------------
// JSON Encoding / Decoding
//------------------------------------------------------------------------------------------
// ReadModifier reads a modifier from the given JSON
func ReadModifier(assets flows.SessionAssets, data json.RawMessage, missing assets.MissingCallback) (flows.Modifier, error) {
typeName, err := utils.ReadTypeFromJSON(data)
if err != nil {
return nil, err
}
f := RegisteredTypes[typeName]
if f == nil {
return nil, errors.Errorf("unknown type: '%s'", typeName)
}
return f(assets, data, missing)
}