🔧 refactor(redis): replace direct constant usage with RedisKeyCacheSeconds function for cache duration
This commit is contained in:
@@ -2,12 +2,10 @@ package constant
|
|||||||
|
|
||||||
import "one-api/common"
|
import "one-api/common"
|
||||||
|
|
||||||
var (
|
// 使用函数来避免初始化顺序带来的赋值问题
|
||||||
TokenCacheSeconds = common.SyncFrequency
|
func RedisKeyCacheSeconds() int {
|
||||||
UserId2GroupCacheSeconds = common.SyncFrequency
|
return common.SyncFrequency
|
||||||
UserId2QuotaCacheSeconds = common.SyncFrequency
|
}
|
||||||
UserId2StatusCacheSeconds = common.SyncFrequency
|
|
||||||
)
|
|
||||||
|
|
||||||
// Cache keys
|
// Cache keys
|
||||||
const (
|
const (
|
||||||
|
|||||||
@@ -10,7 +10,7 @@ import (
|
|||||||
func cacheSetToken(token Token) error {
|
func cacheSetToken(token Token) error {
|
||||||
key := common.GenerateHMAC(token.Key)
|
key := common.GenerateHMAC(token.Key)
|
||||||
token.Clean()
|
token.Clean()
|
||||||
err := common.RedisHSetObj(fmt.Sprintf("token:%s", key), &token, time.Duration(constant.TokenCacheSeconds)*time.Second)
|
err := common.RedisHSetObj(fmt.Sprintf("token:%s", key), &token, time.Duration(constant.RedisKeyCacheSeconds())*time.Second)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -70,7 +70,7 @@ func updateUserCache(user User) error {
|
|||||||
return common.RedisHSetObj(
|
return common.RedisHSetObj(
|
||||||
getUserCacheKey(user.Id),
|
getUserCacheKey(user.Id),
|
||||||
user.ToBaseUser(),
|
user.ToBaseUser(),
|
||||||
time.Duration(constant.UserId2QuotaCacheSeconds)*time.Second,
|
time.Duration(constant.RedisKeyCacheSeconds())*time.Second,
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user