blob: 77d6ea69ac32ed736ecbbc74f63b091d99b99b15 (
plain)
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
|
package attributes
import (
"context"
"errors"
"net/http"
)
type attrKey int
const contextKey attrKey = iota
type attrs map[string]interface{}
func (v attrs) get(key string) interface{} {
if v == nil {
return ""
}
return v[key]
}
func (v attrs) set(key string, value interface{}) {
v[key] = value
}
func (v attrs) del(key string) {
delete(v, key)
}
// Init returns request with new context and attribute bag.
func Init(r *http.Request) *http.Request {
return r.WithContext(context.WithValue(r.Context(), contextKey, attrs{}))
}
// All returns all context attributes.
func All(r *http.Request) map[string]interface{} {
v := r.Context().Value(contextKey)
if v == nil {
return attrs{}
}
return v.(attrs)
}
// Get gets the value from request context. It replaces any existing
// values.
func Get(r *http.Request, key string) interface{} {
v := r.Context().Value(contextKey)
if v == nil {
return nil
}
return v.(attrs).get(key)
}
// Set sets the key to value. It replaces any existing
// values. Context specific.
func Set(r *http.Request, key string, value interface{}) error {
v := r.Context().Value(contextKey)
if v == nil {
return errors.New("unable to find `psr:attributes` context key")
}
v.(attrs).set(key, value)
return nil
}
// Delete deletes values associated with attribute key.
func (v attrs) Delete(key string) {
if v == nil {
return
}
v.del(key)
}
|
