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

chore: if file exist and size = 0, delete it while upload

Browse Source
This commit is contained in:
Noah Hsu 2022-07-30 20:04:21 +08:00
parent 8c27ca3e8b
commit 33b7d75d8a
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
internal/operations/fs.go
View File

@ -2,20 +2,20 @@ package operations
import ( import (
"context" "context"
"github.com/alist-org/alist/v3/internal/conf"
"github.com/alist-org/alist/v3/internal/errs"
log "github.com/sirupsen/logrus"
"os" "os"
stdpath "path" stdpath "path"
"strings" "strings"
"time" "time"
"github.com/Xhofe/go-cache" "github.com/Xhofe/go-cache"
"github.com/alist-org/alist/v3/internal/conf"
"github.com/alist-org/alist/v3/internal/driver" "github.com/alist-org/alist/v3/internal/driver"
"github.com/alist-org/alist/v3/internal/errs"
"github.com/alist-org/alist/v3/internal/model" "github.com/alist-org/alist/v3/internal/model"
"github.com/alist-org/alist/v3/pkg/singleflight" "github.com/alist-org/alist/v3/pkg/singleflight"
"github.com/alist-org/alist/v3/pkg/utils" "github.com/alist-org/alist/v3/pkg/utils"
"github.com/pkg/errors" "github.com/pkg/errors"
log "github.com/sirupsen/logrus"
) )
// In order to facilitate adding some other things before and after file operations // In order to facilitate adding some other things before and after file operations
@ -236,7 +236,19 @@ func Put(ctx context.Context, storage driver.Driver, dstDirPath string, file mod
log.Errorf("failed to close file streamer, %v", err) log.Errorf("failed to close file streamer, %v", err)
} }
}() }()
err := MakeDir(ctx, storage, dstDirPath) // if file exist and size = 0, delete it
dstPath := stdpath.Join(dstDirPath, file.GetName())
fi, err := Get(ctx, storage, dstPath)
if err == nil {
if fi.GetSize() == 0 {
err = Remove(ctx, storage, dstPath)
if err != nil {
return errors.WithMessagef(err, "failed remove file that exist and have size 0")
}
}
}
err = MakeDir(ctx, storage, dstDirPath)
if err != nil { if err != nil {
return errors.WithMessagef(err, "failed to make dir [%s]", dstDirPath) return errors.WithMessagef(err, "failed to make dir [%s]", dstDirPath)
} }