github
/
alist
mirror of https://github.com/Xhofe/alist
1
0
Fork 0
Code Issues Releases Wiki Activity

🎇 webdav update delete cache

pull/548/head
微凉 2021-12-16 22:02:45 +08:00
parent d49f92b542
commit 1c65588b4a
1 changed files with 21 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
drivers/ftp/driver.go
View File

@ -202,7 +202,11 @@ func (driver FTP) MakeDir(path string, account *model.Account) error {
return err
}
defer func() { _ = conn.Quit() }()
return conn.MakeDir(realPath)
err = conn.MakeDir(realPath)
if err == nil {
_ = base.DeleteCache(utils.Dir(path), account)
}
return err
}
func (driver FTP) Move(src string, dst string, account *model.Account) error {
@ -216,7 +220,12 @@ func (driver FTP) Move(src string, dst string, account *model.Account) error {
return err
}
defer func() { _ = conn.Quit() }()
return conn.Rename(realSrc, realDst)
err = conn.Rename(realSrc, realDst)
if err != nil {
_ = base.DeleteCache(utils.Dir(src), account)
_ = base.DeleteCache(utils.Dir(dst), account)
}
return err
}
func (driver FTP) Copy(src string, dst string, account *model.Account) error {
@ -231,7 +240,11 @@ func (driver FTP) Delete(path string, account *model.Account) error {
return err
}
defer func() { _ = conn.Quit() }()
return conn.Delete(realPath)
err = conn.Delete(realPath)
if err == nil {
_ = base.DeleteCache(utils.Dir(path), account)
}
return err
}
func (driver FTP) Upload(file *model.FileStream, account *model.Account) error {
@ -241,7 +254,11 @@ func (driver FTP) Upload(file *model.FileStream, account *model.Account) error {
return err
}
defer func() { _ = conn.Quit() }()
return conn.Stor(realPath, file)
err = conn.Stor(realPath, file)
if err == nil {
_ = base.DeleteCache(utils.Dir(file.ParentPath), account)
}
return err
}
var _ base.Driver = (*FTP)(nil)