ProjectHentai/alist
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: cache nil value for meta

Browse Source
This commit is contained in:
Noah Hsu 2022-12-28 17:44:34 +08:00
parent ed6c8194a7
commit e89489453d
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/op/meta.go
View File

@ -27,7 +27,7 @@ func getNearestMeta(path string) (*model.Meta, error) {
if err == nil { if err == nil {
return meta, nil return meta, nil
} }
if errors.Cause(err) != gorm.ErrRecordNotFound { if errors.Cause(err) != errs.MetaNotFound {
return nil, err return nil, err
} }
if path == "/" { if path == "/" {
@ -42,11 +42,18 @@ func GetMetaByPath(path string) (*model.Meta, error) {
func getMetaByPath(path string) (*model.Meta, error) { func getMetaByPath(path string) (*model.Meta, error) {
meta, ok := metaCache.Get(path) meta, ok := metaCache.Get(path)
if ok { if ok {
if meta == nil {
return meta, errs.MetaNotFound
}
return meta, nil return meta, nil
} }
meta, err, _ := metaG.Do(path, func() (*model.Meta, error) { meta, err, _ := metaG.Do(path, func() (*model.Meta, error) {
_meta, err := db.GetMetaByPath(path) _meta, err := db.GetMetaByPath(path)
if err != nil { if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
metaCache.Set(path, nil)
return nil, errs.MetaNotFound
}
return nil, err return nil, err
} }
metaCache.Set(path, _meta, cache.WithEx[*model.Meta](time.Hour)) metaCache.Set(path, _meta, cache.WithEx[*model.Meta](time.Hour))
@ -76,6 +83,7 @@ func UpdateMeta(u *model.Meta) error {
func CreateMeta(u *model.Meta) error { func CreateMeta(u *model.Meta) error {
u.Path = utils.FixAndCleanPath(u.Path) u.Path = utils.FixAndCleanPath(u.Path)
metaCache.Del(u.Path)
return db.CreateMeta(u) return db.CreateMeta(u)
} }