cloudreve/pkg/webdav/file.go

// Copyright 2014 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package webdav

import (
	"context"
	"net/http"
	"path"
	"path/filepath"
	"strconv"
	"time"

	model "github.com/cloudreve/Cloudreve/v3/models"
	"github.com/cloudreve/Cloudreve/v3/pkg/filesystem"
	"github.com/cloudreve/Cloudreve/v3/pkg/filesystem/fsctx"
)

// slashClean is equivalent to but slightly more efficient than
// path.Clean("/" + name).
func slashClean(name string) string {
	if name == "" || name[0] != '/' {
		name = "/" + name
	}
	return path.Clean(name)
}

// 更新Copy或Move后的修改时间
func updateCopyMoveModtime(req *http.Request, fs *filesystem.FileSystem, dst string) error {
	var modtime time.Time
	if timeVal := req.Header.Get("X-OC-Mtime"); timeVal != "" {
		timeUnix, err := strconv.ParseInt(timeVal, 10, 64)
		if err == nil {
			modtime = time.Unix(timeUnix, 0)
		}
	}

	if modtime.IsZero() {
		return nil
	}

	ok, fi := isPathExist(req.Context(), fs, dst)
	if !ok {
		return nil
	}

	if fi.IsDir() {
		return model.DB.Model(fi.(*model.Folder)).UpdateColumn("updated_at", modtime).Error
	}
	return model.DB.Model(fi.(*model.File)).UpdateColumn("updated_at", modtime).Error
}

// moveFiles moves files and/or directories from src to dst.
//
// See section 9.9.4 for when various HTTP status codes apply.
func moveFiles(ctx context.Context, fs *filesystem.FileSystem, src FileInfo, dst string, overwrite bool) (status int, err error) {

	var (
		fileIDs   []uint
		folderIDs []uint
	)
	if src.IsDir() {
		folderIDs = []uint{src.(*model.Folder).ID}
	} else {
		fileIDs = []uint{src.(*model.File).ID}
	}

	if overwrite {
		if err := _checkOverwriteFile(ctx, fs, src, dst); err != nil {
			return http.StatusInternalServerError, err
		}
	}

	// 判断是否需要移动
	if src.GetPosition() != path.Dir(dst) {
		err = fs.Move(
			context.WithValue(ctx, fsctx.WebdavDstName, path.Base(dst)),
			folderIDs,
			fileIDs,
			src.GetPosition(),
			path.Dir(dst),
		)
	} else if src.GetName() != path.Base(dst) {
		// 判断是否需要重命名
		err = fs.Rename(
			ctx,
			folderIDs,
			fileIDs,
			path.Base(dst),
		)
	}

	if err != nil {
		return http.StatusInternalServerError, err
	}
	return http.StatusNoContent, nil
}

// copyFiles copies files and/or directories from src to dst.
//
// See section 9.8.5 for when various HTTP status codes apply.
func copyFiles(ctx context.Context, fs *filesystem.FileSystem, src FileInfo, dst string, overwrite bool, depth int, recursion int) (status int, err error) {
	if recursion == 1000 {
		return http.StatusInternalServerError, errRecursionTooDeep
	}
	recursion++

	var (
		fileIDs   []uint
		folderIDs []uint
	)

	if overwrite {
		if err := _checkOverwriteFile(ctx, fs, src, dst); err != nil {
			return http.StatusInternalServerError, err
		}
	}

	if src.IsDir() {
		folderIDs = []uint{src.(*model.Folder).ID}
	} else {
		fileIDs = []uint{src.(*model.File).ID}
	}

	err = fs.Copy(
		context.WithValue(ctx, fsctx.WebdavDstName, path.Base(dst)),
		folderIDs,
		fileIDs,
		src.GetPosition(),
		path.Dir(dst),
	)
	if err != nil {
		return http.StatusInternalServerError, err
	}

	return http.StatusNoContent, nil
}

// 判断目标 文件/夹 是否已经存在，存在则先删除目标文件/夹
func _checkOverwriteFile(ctx context.Context, fs *filesystem.FileSystem, src FileInfo, dst string) error {
	if src.IsDir() {
		ok, folder := fs.IsPathExist(dst)
		if ok {
			return fs.Delete(ctx, []uint{folder.ID}, []uint{}, false, false)
		}
	} else {
		ok, file := fs.IsFileExist(dst)
		if ok {
			return fs.Delete(ctx, []uint{}, []uint{file.ID}, false, false)
		}
	}
	return nil
}

// walkFS traverses filesystem fs starting at name up to depth levels.
//
// Allowed values for depth are 0, 1 or infiniteDepth. For each visited node,
// walkFS calls walkFn. If a visited file system node is a directory and
// walkFn returns filepath.SkipDir, walkFS will skip traversal of this node.
func walkFS(
	ctx context.Context,
	fs *filesystem.FileSystem,
	depth int,
	name string,
	info FileInfo,
	walkFn func(reqPath string, info FileInfo, err error) error) error {
	// This implementation is based on Walk's code in the standard path/filepath package.
	err := walkFn(name, info, nil)
	if err != nil {
		if info.IsDir() && err == filepath.SkipDir {
			return nil
		}
		return err
	}
	if !info.IsDir() || depth == 0 {
		return nil
	}
	if depth == 1 {
		depth = 0
	}

	dirs, _ := info.(*model.Folder).GetChildFolder()
	files, _ := info.(*model.Folder).GetChildFiles()

	for _, fileInfo := range files {
		filename := path.Join(name, fileInfo.Name)
		err = walkFS(ctx, fs, depth, filename, &fileInfo, walkFn)
		if err != nil {
			if !fileInfo.IsDir() || err != filepath.SkipDir {
				return err
			}
		}
	}

	for _, fileInfo := range dirs {
		filename := path.Join(name, fileInfo.Name)
		err = walkFS(ctx, fs, depth, filename, &fileInfo, walkFn)
		if err != nil {
			if !fileInfo.IsDir() || err != filepath.SkipDir {
				return err
			}
		}
	}
	return nil
}