mirror of
https://github.com/rclone/rclone.git
synced 2024-11-23 04:00:17 +08:00
d0888edc0a
Fix spelling of: above, already, anonymous, associated, authentication, bandwidth, because, between, blocks, calculate, candidates, cautious, changelog, cleaner, clipboard, command, completely, concurrently, considered, constructs, corrupt, current, daemon, dependencies, deprecated, directory, dispatcher, download, eligible, ellipsis, encrypter, endpoint, entrieslist, essentially, existing writers, existing, expires, filesystem, flushing, frequently, hierarchy, however, implementation, implements, inaccurate, individually, insensitive, longer, maximum, metadata, modified, multipart, namedirfirst, nextcloud, obscured, opened, optional, owncloud, pacific, passphrase, password, permanently, persimmon, positive, potato, protocol, quota, receiving, recommends, referring, requires, revisited, satisfied, satisfies, satisfy, semver, serialized, session, storage, strategies, stringlist, successful, supported, surprise, temporarily, temporary, transactions, unneeded, update, uploads, wrapped Signed-off-by: Josh Soref <jsoref@users.noreply.github.com>
229 lines
5.7 KiB
Go
229 lines
5.7 KiB
Go
package vfstest
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/rclone/rclone/fs"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
// TestDirLs checks out listing
|
|
func TestDirLs(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
run.checkDir(t, "")
|
|
|
|
run.mkdir(t, "a directory")
|
|
run.createFile(t, "a file", "hello")
|
|
|
|
run.checkDir(t, "a directory/|a file 5")
|
|
|
|
run.rmdir(t, "a directory")
|
|
run.rm(t, "a file")
|
|
|
|
run.checkDir(t, "")
|
|
}
|
|
|
|
// TestDirCreateAndRemoveDir tests creating and removing a directory
|
|
func TestDirCreateAndRemoveDir(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
run.mkdir(t, "dir")
|
|
run.mkdir(t, "dir/subdir")
|
|
run.checkDir(t, "dir/|dir/subdir/")
|
|
|
|
// Check we can't delete a directory with stuff in
|
|
err := run.os.Remove(run.path("dir"))
|
|
assert.Error(t, err, "file exists")
|
|
|
|
// Now delete subdir then dir - should produce no errors
|
|
run.rmdir(t, "dir/subdir")
|
|
run.checkDir(t, "dir/")
|
|
run.rmdir(t, "dir")
|
|
run.checkDir(t, "")
|
|
}
|
|
|
|
// TestDirCreateAndRemoveFile tests creating and removing a file
|
|
func TestDirCreateAndRemoveFile(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
run.mkdir(t, "dir")
|
|
run.createFile(t, "dir/file", "potato")
|
|
run.checkDir(t, "dir/|dir/file 6")
|
|
|
|
// Check we can't delete a directory with stuff in
|
|
err := run.os.Remove(run.path("dir"))
|
|
assert.Error(t, err, "file exists")
|
|
|
|
// Now delete file
|
|
run.rm(t, "dir/file")
|
|
|
|
run.checkDir(t, "dir/")
|
|
run.rmdir(t, "dir")
|
|
run.checkDir(t, "")
|
|
}
|
|
|
|
// TestDirRenameFile tests renaming a file
|
|
func TestDirRenameFile(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
run.mkdir(t, "dir")
|
|
run.createFile(t, "file", "potato")
|
|
run.checkDir(t, "dir/|file 6")
|
|
|
|
err := run.os.Rename(run.path("file"), run.path("file2"))
|
|
require.NoError(t, err)
|
|
run.checkDir(t, "dir/|file2 6")
|
|
|
|
data := run.readFile(t, "file2")
|
|
assert.Equal(t, "potato", data)
|
|
|
|
err = run.os.Rename(run.path("file2"), run.path("dir/file3"))
|
|
require.NoError(t, err)
|
|
run.checkDir(t, "dir/|dir/file3 6")
|
|
|
|
data = run.readFile(t, "dir/file3")
|
|
require.NoError(t, err)
|
|
assert.Equal(t, "potato", data)
|
|
|
|
run.rm(t, "dir/file3")
|
|
run.rmdir(t, "dir")
|
|
run.checkDir(t, "")
|
|
}
|
|
|
|
// TestDirRenameEmptyDir tests renaming and empty directory
|
|
func TestDirRenameEmptyDir(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
run.mkdir(t, "dir")
|
|
run.mkdir(t, "dir1")
|
|
run.checkDir(t, "dir/|dir1/")
|
|
|
|
err := run.os.Rename(run.path("dir1"), run.path("dir/dir2"))
|
|
require.NoError(t, err)
|
|
run.checkDir(t, "dir/|dir/dir2/")
|
|
|
|
err = run.os.Rename(run.path("dir/dir2"), run.path("dir/dir3"))
|
|
require.NoError(t, err)
|
|
run.checkDir(t, "dir/|dir/dir3/")
|
|
|
|
run.rmdir(t, "dir/dir3")
|
|
run.rmdir(t, "dir")
|
|
run.checkDir(t, "")
|
|
}
|
|
|
|
// TestDirRenameFullDir tests renaming a full directory
|
|
func TestDirRenameFullDir(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
run.mkdir(t, "dir")
|
|
run.mkdir(t, "dir1")
|
|
run.createFile(t, "dir1/potato.txt", "maris piper")
|
|
run.checkDir(t, "dir/|dir1/|dir1/potato.txt 11")
|
|
|
|
err := run.os.Rename(run.path("dir1"), run.path("dir/dir2"))
|
|
require.NoError(t, err)
|
|
run.checkDir(t, "dir/|dir/dir2/|dir/dir2/potato.txt 11")
|
|
|
|
err = run.os.Rename(run.path("dir/dir2"), run.path("dir/dir3"))
|
|
require.NoError(t, err)
|
|
run.checkDir(t, "dir/|dir/dir3/|dir/dir3/potato.txt 11")
|
|
|
|
run.rm(t, "dir/dir3/potato.txt")
|
|
run.rmdir(t, "dir/dir3")
|
|
run.rmdir(t, "dir")
|
|
run.checkDir(t, "")
|
|
}
|
|
|
|
// TestDirModTime tests mod times
|
|
func TestDirModTime(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
run.mkdir(t, "dir")
|
|
mtime := time.Date(2012, time.November, 18, 17, 32, 31, 0, time.UTC)
|
|
err := run.os.Chtimes(run.path("dir"), mtime, mtime)
|
|
require.NoError(t, err)
|
|
|
|
info, err := run.os.Stat(run.path("dir"))
|
|
require.NoError(t, err)
|
|
|
|
// avoid errors because of timezone differences
|
|
assert.Equal(t, info.ModTime().Unix(), mtime.Unix())
|
|
|
|
run.rmdir(t, "dir")
|
|
}
|
|
|
|
// TestDirCacheFlush tests flushing the dir cache
|
|
func TestDirCacheFlush(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
|
|
run.checkDir(t, "")
|
|
|
|
run.mkdir(t, "dir")
|
|
run.mkdir(t, "otherdir")
|
|
run.createFile(t, "dir/file", "1")
|
|
run.createFile(t, "otherdir/file", "1")
|
|
|
|
dm := newDirMap("otherdir/|otherdir/file 1|dir/|dir/file 1")
|
|
localDm := make(dirMap)
|
|
run.readLocal(t, localDm, "")
|
|
assert.Equal(t, dm, localDm, "expected vs fuse mount")
|
|
|
|
err := run.fremote.Mkdir(context.Background(), "dir/subdir")
|
|
require.NoError(t, err)
|
|
|
|
root, err := run.vfs.Root()
|
|
require.NoError(t, err)
|
|
|
|
// expect newly created "subdir" on remote to not show up
|
|
root.ForgetPath("otherdir", fs.EntryDirectory)
|
|
run.readLocal(t, localDm, "")
|
|
assert.Equal(t, dm, localDm, "expected vs fuse mount")
|
|
|
|
root.ForgetPath("dir", fs.EntryDirectory)
|
|
dm = newDirMap("otherdir/|otherdir/file 1|dir/|dir/file 1|dir/subdir/")
|
|
run.readLocal(t, localDm, "")
|
|
assert.Equal(t, dm, localDm, "expected vs fuse mount")
|
|
|
|
run.rm(t, "otherdir/file")
|
|
run.rmdir(t, "otherdir")
|
|
run.rm(t, "dir/file")
|
|
run.rmdir(t, "dir/subdir")
|
|
run.rmdir(t, "dir")
|
|
run.checkDir(t, "")
|
|
}
|
|
|
|
// TestDirCacheFlushOnDirRename tests flushing the dir cache on rename
|
|
func TestDirCacheFlushOnDirRename(t *testing.T) {
|
|
run.skipIfNoFUSE(t)
|
|
run.mkdir(t, "dir")
|
|
run.createFile(t, "dir/file", "1")
|
|
|
|
dm := newDirMap("dir/|dir/file 1")
|
|
localDm := make(dirMap)
|
|
run.readLocal(t, localDm, "")
|
|
assert.Equal(t, dm, localDm, "expected vs fuse mount")
|
|
|
|
// expect remotely created directory to not show up
|
|
err := run.fremote.Mkdir(context.Background(), "dir/subdir")
|
|
require.NoError(t, err)
|
|
run.readLocal(t, localDm, "")
|
|
assert.Equal(t, dm, localDm, "expected vs fuse mount")
|
|
|
|
err = run.os.Rename(run.path("dir"), run.path("rid"))
|
|
require.NoError(t, err)
|
|
|
|
dm = newDirMap("rid/|rid/subdir/|rid/file 1")
|
|
localDm = make(dirMap)
|
|
run.readLocal(t, localDm, "")
|
|
assert.Equal(t, dm, localDm, "expected vs fuse mount")
|
|
|
|
run.rm(t, "rid/file")
|
|
run.rmdir(t, "rid/subdir")
|
|
run.rmdir(t, "rid")
|
|
run.checkDir(t, "")
|
|
}
|