webdav: removed unnecessary error checks

This commit is contained in:
Alex Duchesne 2024-04-07 17:32:30 -04:00
parent 0cb3ef1d92
commit 166e94d82e
1 changed files with 11 additions and 18 deletions

View File

@ -16,6 +16,7 @@ import (
"golang.org/x/net/webdav" "golang.org/x/net/webdav"
"github.com/restic/restic/internal/bloblru" "github.com/restic/restic/internal/bloblru"
"github.com/restic/restic/internal/debug"
"github.com/restic/restic/internal/errors" "github.com/restic/restic/internal/errors"
"github.com/restic/restic/internal/restic" "github.com/restic/restic/internal/restic"
"github.com/restic/restic/internal/walker" "github.com/restic/restic/internal/walker"
@ -88,11 +89,6 @@ func init() {
} }
func runWebServer(ctx context.Context, opts WebdavOptions, gopts GlobalOptions, args []string) error { func runWebServer(ctx context.Context, opts WebdavOptions, gopts GlobalOptions, args []string) error {
// PathTemplates and TimeTemplate are ignored for now because `fuse.snapshots_dir(struct)`
// is not accessible when building on Windows and it would be ridiculous to duplicate the
// code. It should be shared, somehow.
if len(args) > 1 { if len(args) > 1 {
return errors.Fatal("wrong number of parameters") return errors.Fatal("wrong number of parameters")
} }
@ -148,6 +144,8 @@ func runWebServer(ctx context.Context, opts WebdavOptions, gopts GlobalOptions,
children: nil, children: nil,
snapshot: sn, snapshot: sn,
} }
// Ignore PathTemplates for now because `fuse.snapshots_dir(struct)` is not accessible when building
// on Windows and it would be ridiculous to duplicate the code. It should be shared, somehow!
davFS.addNode("/ids/"+node.name, node) davFS.addNode("/ids/"+node.name, node)
davFS.addNode("/hosts/"+sn.Hostname+"/"+node.name, node) davFS.addNode("/hosts/"+sn.Hostname+"/"+node.name, node)
davFS.addNode("/snapshots/"+sn.Time.Format(opts.TimeTemplate)+"/"+node.name, node) davFS.addNode("/snapshots/"+sn.Time.Format(opts.TimeTemplate)+"/"+node.name, node)
@ -169,6 +167,7 @@ func runWebServer(ctx context.Context, opts WebdavOptions, gopts GlobalOptions,
return http.ListenAndServe(bindAddress, wd) return http.ListenAndServe(bindAddress, wd)
} }
// Implements webdav.FileSystem
type webdavFS struct { type webdavFS struct {
repo restic.Repository repo restic.Repository
root webdavFSNode root webdavFSNode
@ -277,7 +276,7 @@ func (fs *webdavFS) findNode(fullname string) (*webdavFSNode, error) {
} }
func (fs *webdavFS) OpenFile(ctx context.Context, name string, flag int, perm os.FileMode) (webdav.File, error) { func (fs *webdavFS) OpenFile(ctx context.Context, name string, flag int, perm os.FileMode) (webdav.File, error) {
Printf("OpenFile %s\n", name) debug.Log("OpenFile %s", name)
// Client can only read // Client can only read
if flag&(os.O_WRONLY|os.O_RDWR) != 0 { if flag&(os.O_WRONLY|os.O_RDWR) != 0 {
@ -291,9 +290,6 @@ func (fs *webdavFS) OpenFile(ctx context.Context, name string, flag int, perm os
if err != nil { if err != nil {
return nil, err return nil, err
} }
if node == nil {
return nil, os.ErrNotExist
}
return &openFile{fullpath: path.Clean("/" + name), node: node, fs: fs}, nil return &openFile{fullpath: path.Clean("/" + name), node: node, fs: fs}, nil
} }
@ -302,9 +298,6 @@ func (fs *webdavFS) Stat(ctx context.Context, name string) (os.FileInfo, error)
if err != nil { if err != nil {
return nil, err return nil, err
} }
if node == nil {
return nil, os.ErrNotExist
}
return node, nil return node, nil
} }
@ -325,11 +318,11 @@ type openFile struct {
node *webdavFSNode node *webdavFSNode
fs *webdavFS fs *webdavFS
cursor int64 cursor int64
children []os.FileInfo
// cumsize[i] holds the cumulative size of blobs[:i].
cumsize []uint64
initialized bool initialized bool
// cumsize[i] holds the cumulative size of blobs[:i].
children []os.FileInfo
cumsize []uint64
} }
func (f *openFile) getBlobAt(ctx context.Context, i int) (blob []byte, err error) { func (f *openFile) getBlobAt(ctx context.Context, i int) (blob []byte, err error) {
@ -349,7 +342,7 @@ func (f *openFile) getBlobAt(ctx context.Context, i int) (blob []byte, err error
} }
func (f *openFile) Read(p []byte) (int, error) { func (f *openFile) Read(p []byte) (int, error) {
Printf("Read %s %d %d\n", f.fullpath, f.cursor, len(p)) debug.Log("Read %s %d %d", f.fullpath, f.cursor, len(p))
if f.node.IsDir() || f.cursor < 0 { if f.node.IsDir() || f.cursor < 0 {
return 0, os.ErrInvalid return 0, os.ErrInvalid
} }
@ -414,7 +407,7 @@ func (f *openFile) Read(p []byte) (int, error) {
} }
func (f *openFile) Readdir(count int) ([]os.FileInfo, error) { func (f *openFile) Readdir(count int) ([]os.FileInfo, error) {
Printf("Readdir %s %d %d\n", f.fullpath, f.cursor, count) debug.Log("Readdir %s %d %d", f.fullpath, f.cursor, count)
if !f.node.IsDir() || f.cursor < 0 { if !f.node.IsDir() || f.cursor < 0 {
return nil, os.ErrInvalid return nil, os.ErrInvalid
} }
@ -449,7 +442,7 @@ func (f *openFile) Readdir(count int) ([]os.FileInfo, error) {
} }
func (f *openFile) Seek(offset int64, whence int) (int64, error) { func (f *openFile) Seek(offset int64, whence int) (int64, error) {
Printf("Seek %s %d %d\n", f.fullpath, offset, whence) debug.Log("Seek %s %d %d", f.fullpath, offset, whence)
switch whence { switch whence {
case io.SeekStart: case io.SeekStart:
f.cursor = offset f.cursor = offset