diff options
| author | Chris Lu <chris.lu@gmail.com> | 2014-07-20 23:12:49 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2014-07-20 23:12:49 -0700 |
| commit | 77fd5ecd982ddb32affd6911b4808e4bf5d28dc8 (patch) | |
| tree | 4f621ef75363f0f4703016baeb83a50aa0f8437b /go/filer/filer_embedded.go | |
| parent | 8e7f08d04daa6c80a1790e8d86bad149e9fb14b6 (diff) | |
| download | seaweedfs-77fd5ecd982ddb32affd6911b4808e4bf5d28dc8.tar.xz seaweedfs-77fd5ecd982ddb32affd6911b4808e4bf5d28dc8.zip | |
Add /admin/mv to move a file or a folder
Diffstat (limited to 'go/filer/filer_embedded.go')
| -rw-r--r-- | go/filer/filer_embedded.go | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/go/filer/filer_embedded.go b/go/filer/filer_embedded.go index 2a13805e9..a3b64d37b 100644 --- a/go/filer/filer_embedded.go +++ b/go/filer/filer_embedded.go @@ -47,6 +47,9 @@ func (filer *FilerEmbedded) FindFile(filePath string) (fid string, err error) { } return filer.files.FindFile(dirId, file) } +func (filer *FilerEmbedded) FindDirectory(dirPath string) (dirId DirectoryId, err error) { + return filer.directories.FindDirectory(dirPath) +} func (filer *FilerEmbedded) ListDirectories(dirPath string) (dirs []DirectoryEntry, err error) { return filer.directories.ListDirectories(dirPath) } @@ -98,6 +101,7 @@ func (filer *FilerEmbedded) DeleteDirectory(dirPath string, recursive bool) (err } } + func (filer *FilerEmbedded) DeleteFile(filePath string) (fid string, err error) { dir, file := filepath.Split(filePath) dirId, e := filer.directories.FindDirectory(dir) @@ -106,3 +110,32 @@ func (filer *FilerEmbedded) DeleteFile(filePath string) (fid string, err error) } return filer.files.DeleteFile(dirId, file) } + +/* +Move a folder or a file, with 4 Use cases: +mv fromDir toNewDir +mv fromDir toOldDir +mv fromFile toDir +mv fromFile toFile +*/ +func (filer *FilerEmbedded) Move(fromPath string, toPath string) error { + if _, dir_err := filer.FindDirectory(fromPath); dir_err == nil { + if _, err := filer.FindDirectory(toPath); err == nil { + // move folder under an existing folder + return filer.directories.MoveUnderDirectory(fromPath, toPath, "") + } else { + // move folder to a new folder + return filer.directories.MoveUnderDirectory(fromPath, filepath.Dir(toPath), filepath.Base(toPath)) + } + } + if fid, file_err := filer.DeleteFile(fromPath); file_err == nil { + if _, err := filer.FindDirectory(toPath); err == nil { + // move file under an existing folder + return filer.CreateFile(filepath.Join(toPath, filepath.Base(fromPath)), fid) + } else { + // move to a folder with new name + return filer.CreateFile(toPath, fid) + } + } + return fmt.Errorf("File %s is not found!", fromPath) +} |
