bcdfad3c83
This changes log statements from log to fs package, which is required for --use-json-log to properly make log output in JSON format. The recently added custom linting rule, handled by ruleguard via gocritic via golangci-lint, warns about these and suggests the alternative. Fixing was therefore basically running "golangci-lint run --fix", although some manual fixup of mainly imports are necessary following that.
85 lines
2.1 KiB
Go
85 lines
2.1 KiB
Go
// Clean the left over test files
|
|
|
|
package main
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"regexp"
|
|
|
|
"github.com/rclone/rclone/fs"
|
|
"github.com/rclone/rclone/fs/fspath"
|
|
"github.com/rclone/rclone/fs/list"
|
|
"github.com/rclone/rclone/fs/operations"
|
|
)
|
|
|
|
// MatchTestRemote matches the remote names used for testing (copied
|
|
// from fstest/fstest.go so we don't have to import that and get all
|
|
// its flags)
|
|
var MatchTestRemote = regexp.MustCompile(`^rclone-test-[abcdefghijklmnopqrstuvwxyz0123456789]{12,24}(_segments)?$`)
|
|
|
|
// cleanFs runs a single clean fs for left over directories
|
|
func cleanFs(ctx context.Context, remote string, cleanup bool) error {
|
|
f, err := fs.NewFs(context.Background(), remote)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
var lastErr error
|
|
if cleanup {
|
|
fs.Logf(nil, "%q - running cleanup", remote)
|
|
err = operations.CleanUp(ctx, f)
|
|
if err != nil {
|
|
lastErr = err
|
|
fs.Errorf(f, "Cleanup failed: %v", err)
|
|
}
|
|
}
|
|
entries, err := list.DirSorted(ctx, f, true, "")
|
|
if err != nil {
|
|
return err
|
|
}
|
|
err = entries.ForDirError(func(dir fs.Directory) error {
|
|
dirPath := dir.Remote()
|
|
fullPath := fspath.JoinRootPath(remote, dirPath)
|
|
if MatchTestRemote.MatchString(dirPath) {
|
|
if *dryRun {
|
|
fs.Logf(nil, "Not Purging %s - -dry-run", fullPath)
|
|
return nil
|
|
}
|
|
fs.Logf(nil, "Purging %s", fullPath)
|
|
dir, err := fs.NewFs(context.Background(), fullPath)
|
|
if err != nil {
|
|
err = fmt.Errorf("NewFs failed: %w", err)
|
|
lastErr = err
|
|
fs.Errorf(fullPath, "%v", err)
|
|
return nil
|
|
}
|
|
err = operations.Purge(ctx, dir, "")
|
|
if err != nil {
|
|
err = fmt.Errorf("purge failed: %w", err)
|
|
lastErr = err
|
|
fs.Errorf(dir, "%v", err)
|
|
return nil
|
|
}
|
|
}
|
|
return nil
|
|
})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return lastErr
|
|
}
|
|
|
|
// cleanRemotes cleans the list of remotes passed in
|
|
func cleanRemotes(conf *Config) error {
|
|
var lastError error
|
|
for _, backend := range conf.Backends {
|
|
remote := backend.Remote
|
|
fs.Logf(nil, "%q - Cleaning", remote)
|
|
err := cleanFs(context.Background(), remote, backend.CleanUp)
|
|
if err != nil {
|
|
lastError = err
|
|
fs.Logf(nil, "Failed to purge %q: %v", remote, err)
|
|
}
|
|
}
|
|
return lastError
|
|
}
|