25f59b2918
billy defines a common file system interface that is used in multiple go packages. vfs.Handle implements billy.File mostly, only two methods needed to be added to make it compliant. An interface check is added as well. This is a preliminary work for adding serve nfs command.
135 lines
2.8 KiB
Go
135 lines
2.8 KiB
Go
package vfstest
|
|
|
|
import (
|
|
"os"
|
|
"time"
|
|
|
|
"github.com/rclone/rclone/lib/file"
|
|
"github.com/rclone/rclone/vfs"
|
|
)
|
|
|
|
// Oser defines the things that the "os" package can do
|
|
//
|
|
// This covers what the VFS can do also
|
|
type Oser interface {
|
|
Chtimes(name string, atime time.Time, mtime time.Time) error
|
|
Create(name string) (vfs.Handle, error)
|
|
Mkdir(name string, perm os.FileMode) error
|
|
Open(name string) (vfs.Handle, error)
|
|
OpenFile(name string, flags int, perm os.FileMode) (fd vfs.Handle, err error)
|
|
ReadDir(dirname string) ([]os.FileInfo, error)
|
|
ReadFile(filename string) (b []byte, err error)
|
|
Remove(name string) error
|
|
Rename(oldName, newName string) error
|
|
Stat(path string) (os.FileInfo, error)
|
|
}
|
|
|
|
// realOs is an implementation of Oser backed by the "os" package
|
|
type realOs struct {
|
|
}
|
|
|
|
// realOsFile is an implementation of vfs.Handle
|
|
type realOsFile struct {
|
|
*os.File
|
|
}
|
|
|
|
// Flush
|
|
func (f realOsFile) Flush() error {
|
|
return nil
|
|
}
|
|
|
|
// Release
|
|
func (f realOsFile) Release() error {
|
|
return f.File.Close()
|
|
}
|
|
|
|
// Node
|
|
func (f realOsFile) Node() vfs.Node {
|
|
return nil
|
|
}
|
|
|
|
func (f realOsFile) Lock() error {
|
|
return os.ErrInvalid
|
|
}
|
|
|
|
func (f realOsFile) Unlock() error {
|
|
return os.ErrInvalid
|
|
}
|
|
|
|
// Chtimes
|
|
func (r realOs) Chtimes(name string, atime time.Time, mtime time.Time) error {
|
|
return os.Chtimes(name, atime, mtime)
|
|
}
|
|
|
|
// Create
|
|
func (r realOs) Create(name string) (vfs.Handle, error) {
|
|
fd, err := file.OpenFile(name, os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0666)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return realOsFile{File: fd}, err
|
|
}
|
|
|
|
// Mkdir
|
|
func (r realOs) Mkdir(name string, perm os.FileMode) error {
|
|
return os.Mkdir(name, perm)
|
|
}
|
|
|
|
// Open
|
|
func (r realOs) Open(name string) (vfs.Handle, error) {
|
|
fd, err := os.Open(name)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return realOsFile{File: fd}, err
|
|
}
|
|
|
|
// OpenFile
|
|
func (r realOs) OpenFile(name string, flags int, perm os.FileMode) (vfs.Handle, error) {
|
|
fd, err := file.OpenFile(name, flags, perm)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return realOsFile{File: fd}, err
|
|
}
|
|
|
|
// ReadDir
|
|
func (r realOs) ReadDir(dirname string) ([]os.FileInfo, error) {
|
|
entries, err := os.ReadDir(dirname)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
infos := make([]os.FileInfo, 0, len(entries))
|
|
for _, entry := range entries {
|
|
info, err := entry.Info()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
infos = append(infos, info)
|
|
}
|
|
return infos, nil
|
|
}
|
|
|
|
// ReadFile
|
|
func (r realOs) ReadFile(filename string) (b []byte, err error) {
|
|
return os.ReadFile(filename)
|
|
}
|
|
|
|
// Remove
|
|
func (r realOs) Remove(name string) error {
|
|
return os.Remove(name)
|
|
}
|
|
|
|
// Rename
|
|
func (r realOs) Rename(oldName, newName string) error {
|
|
return os.Rename(oldName, newName)
|
|
}
|
|
|
|
// Stat
|
|
func (r realOs) Stat(path string) (os.FileInfo, error) {
|
|
return os.Stat(path)
|
|
}
|
|
|
|
// Check interfaces
|
|
var _ Oser = &realOs{}
|
|
var _ vfs.Handle = &realOsFile{}
|