@@ -10,11 +10,11 @@ import (
10
10
"gopkg.in/oauth2.v3/models"
11
11
)
12
12
13
- // DefaultIncrKey store incr id
13
+ // DefaultIncrKey TokenStore incr id
14
14
const DefaultIncrKey = "oauth2_incr"
15
15
16
- // NewStore Create a token store instance based on redis
17
- func NewStore (cfg * Config ) (store oauth2.TokenStore , err error ) {
16
+ // NewTokenStore Create a token TokenStore instance based on redis
17
+ func NewTokenStore (cfg * Config ) (ts oauth2.TokenStore , err error ) {
18
18
opt := & redis.Options {
19
19
Network : cfg .Network ,
20
20
Addr : cfg .Addr ,
@@ -32,21 +32,21 @@ func NewStore(cfg *Config) (store oauth2.TokenStore, err error) {
32
32
err = verr
33
33
return
34
34
}
35
- store = & Store {cli : cli }
35
+ ts = & TokenStore {cli : cli }
36
36
return
37
37
}
38
38
39
- // Store Redis Store
40
- type Store struct {
39
+ // TokenStore Redis Token Store
40
+ type TokenStore struct {
41
41
cli * redis.Client
42
42
}
43
43
44
- func (rs * Store ) getBasicID (id int64 , info oauth2.TokenInfo ) string {
44
+ func (rs * TokenStore ) getBasicID (id int64 , info oauth2.TokenInfo ) string {
45
45
return "oauth2_" + info .GetClientID () + "_" + strconv .FormatInt (id , 10 )
46
46
}
47
47
48
- // Create Create and store the new token information
49
- func (rs * Store ) Create (info oauth2.TokenInfo ) (err error ) {
48
+ // Create Create and TokenStore the new token information
49
+ func (rs * TokenStore ) Create (info oauth2.TokenInfo ) (err error ) {
50
50
jv , err := json .Marshal (info )
51
51
if err != nil {
52
52
return
@@ -85,7 +85,7 @@ func (rs *Store) Create(info oauth2.TokenInfo) (err error) {
85
85
}
86
86
87
87
// remove
88
- func (rs * Store ) remove (key string ) (err error ) {
88
+ func (rs * TokenStore ) remove (key string ) (err error ) {
89
89
_ , verr := rs .cli .Del (key ).Result ()
90
90
if verr != redis .Nil {
91
91
err = verr
@@ -94,19 +94,19 @@ func (rs *Store) remove(key string) (err error) {
94
94
}
95
95
96
96
// RemoveByAccess Use the access token to delete the token information(Along with the refresh token)
97
- func (rs * Store ) RemoveByAccess (access string ) (err error ) {
97
+ func (rs * TokenStore ) RemoveByAccess (access string ) (err error ) {
98
98
err = rs .remove (access )
99
99
return
100
100
}
101
101
102
102
// RemoveByRefresh Use the refresh token to delete the token information
103
- func (rs * Store ) RemoveByRefresh (refresh string ) (err error ) {
103
+ func (rs * TokenStore ) RemoveByRefresh (refresh string ) (err error ) {
104
104
err = rs .remove (refresh )
105
105
return
106
106
}
107
107
108
108
// get
109
- func (rs * Store ) get (token string ) (ti oauth2.TokenInfo , err error ) {
109
+ func (rs * TokenStore ) get (token string ) (ti oauth2.TokenInfo , err error ) {
110
110
tv , verr := rs .cli .Get (token ).Result ()
111
111
if verr != nil {
112
112
if verr == redis .Nil {
@@ -137,13 +137,13 @@ func (rs *Store) get(token string) (ti oauth2.TokenInfo, err error) {
137
137
}
138
138
139
139
// GetByAccess Use the access token for token information data
140
- func (rs * Store ) GetByAccess (access string ) (ti oauth2.TokenInfo , err error ) {
140
+ func (rs * TokenStore ) GetByAccess (access string ) (ti oauth2.TokenInfo , err error ) {
141
141
ti , err = rs .get (access )
142
142
return
143
143
}
144
144
145
145
// GetByRefresh Use the refresh token for token information data
146
- func (rs * Store ) GetByRefresh (refresh string ) (ti oauth2.TokenInfo , err error ) {
146
+ func (rs * TokenStore ) GetByRefresh (refresh string ) (ti oauth2.TokenInfo , err error ) {
147
147
ti , err = rs .get (refresh )
148
148
return
149
149
}
0 commit comments