forked from blind-oracle/go-radius
-
Notifications
You must be signed in to change notification settings - Fork 0
/
dictionary.go
146 lines (132 loc) · 3.43 KB
/
dictionary.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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
package radius
import (
"errors"
"sync"
)
var builtinOnce sync.Once
// Builtin is the built-in dictionary. It is initially loaded with the
// attributes defined in RFC 2865 and RFC 2866.
var Builtin *Dictionary
func initDictionary() {
Builtin = &Dictionary{}
}
type dictEntry struct {
Type byte
Name string
Codec AttributeCodec
}
// Dictionary stores mappings between attribute names and types and
// AttributeCodecs.
type Dictionary struct {
mu sync.RWMutex
attributesByType [256]*dictEntry
attributesByName map[string]*dictEntry
}
// Register registers the AttributeCodec for the given attribute name and type.
func (d *Dictionary) Register(name string, t byte, codec AttributeCodec) error {
d.mu.Lock()
if d.attributesByType[t] != nil {
d.mu.Unlock()
return errors.New("radius: attribute already registered")
}
entry := &dictEntry{
Type: t,
Name: name,
Codec: codec,
}
d.attributesByType[t] = entry
if d.attributesByName == nil {
d.attributesByName = make(map[string]*dictEntry)
}
d.attributesByName[name] = entry
d.mu.Unlock()
return nil
}
// MustRegister is a helper for Register that panics if it returns an error.
func (d *Dictionary) MustRegister(name string, t byte, codec AttributeCodec) {
if err := d.Register(name, t, codec); err != nil {
panic(err)
}
}
func (d *Dictionary) get(name string) (t byte, codec AttributeCodec, ok bool) {
d.mu.RLock()
entry := d.attributesByName[name]
d.mu.RUnlock()
if entry == nil {
return
}
t = entry.Type
codec = entry.Codec
ok = true
return
}
// Attr returns a new *Attribute whose type is registered under the given
// name.
//
// If name is not registered, nil and an error is returned.
//
// If the attribute's codec implements AttributeTransformer, the value is
// first transformed before being stored in *Attribute. If the transform
// function returns an error, nil and the error is returned.
func (d *Dictionary) Attr(name string, value interface{}) (*Attribute, error) {
t, codec, ok := d.get(name)
if !ok {
return nil, errors.New("radius: attribute name not registered")
}
if transformer, ok := codec.(AttributeTransformer); ok {
transformed, err := transformer.Transform(value)
if err != nil {
return nil, err
}
value = transformed
}
return &Attribute{
Type: t,
Value: value,
}, nil
}
// MustAttr is a helper for Attr that panics if Attr were to return an error.
func (d *Dictionary) MustAttr(name string, value interface{}) *Attribute {
attr, err := d.Attr(name, value)
if err != nil {
panic(err)
}
return attr
}
// Name returns the registered name for the given attribute type. ok is false
// if the given type is not registered.
func (d *Dictionary) Name(t byte) (name string, ok bool) {
d.mu.RLock()
entry := d.attributesByType[t]
d.mu.RUnlock()
if entry == nil {
return
}
name = entry.Name
ok = true
return
}
// Type returns the registered type for the given attribute name. ok is false
// if the given name is not registered.
func (d *Dictionary) Type(name string) (t byte, ok bool) {
d.mu.RLock()
entry := d.attributesByName[name]
d.mu.RUnlock()
if entry == nil {
return
}
t = entry.Type
ok = true
return
}
// Codec returns the AttributeCodec for the given registered type. nil is
// returned if the given type is not registered.
func (d *Dictionary) Codec(t byte) AttributeCodec {
d.mu.RLock()
entry := d.attributesByType[t]
d.mu.RUnlock()
if entry == nil {
return AttributeUnknown
}
return entry.Codec
}