mirror of https://github.com/Xhofe/alist
fix(fs): remove old target object from cache before updating (#8352)
parent
d0ee90cd11
commit
c8470b9a2a
|
@ -3,6 +3,7 @@ package op
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
stdpath "path"
|
stdpath "path"
|
||||||
|
"slices"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/Xhofe/go-cache"
|
"github.com/Xhofe/go-cache"
|
||||||
|
@ -25,6 +26,12 @@ func updateCacheObj(storage driver.Driver, path string, oldObj model.Obj, newObj
|
||||||
key := Key(storage, path)
|
key := Key(storage, path)
|
||||||
objs, ok := listCache.Get(key)
|
objs, ok := listCache.Get(key)
|
||||||
if ok {
|
if ok {
|
||||||
|
for i, obj := range objs {
|
||||||
|
if obj.GetName() == newObj.GetName() {
|
||||||
|
objs = slices.Delete(objs, i, i+1)
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
for i, obj := range objs {
|
for i, obj := range objs {
|
||||||
if obj.GetName() == oldObj.GetName() {
|
if obj.GetName() == oldObj.GetName() {
|
||||||
objs[i] = newObj
|
objs[i] = newObj
|
||||||
|
|
Loading…
Reference in New Issue