fix: set cdn to basePath if cdn is empty

Dockerfile

@@ -10,5 +10,6 @@ LABEL MAINTAINER="i@nn.ci"
 VOLUME /opt/alist/data/
 WORKDIR /opt/alist/
 COPY --from=builder /app/bin/alist ./
+RUN apk add ca-certificates
 EXPOSE 5244
 CMD [ "./alist", "server", "--no-prefix" ]

cmd/server.go

@@ -88,3 +88,12 @@ func init() {
 	// is called directly, e.g.:
 	// serverCmd.Flags().BoolP("toggle", "t", false, "Help message for toggle")
 }
+
+// OutAlistInit 暴露用于外部启动server的函数
+func OutAlistInit() {
+	var (
+		cmd  *cobra.Command
+		args []string
+	)
+	serverCmd.Run(cmd, args)
+}

drivers/189/util.go

@@ -215,6 +215,7 @@ func (d *Cloud189) getFiles(fileId string) ([]model.Obj, error) {
 					ID:       strconv.FormatInt(file.Id, 10),
 					Name:     file.Name,
 					Modified: lastOpTime,
+					Size:     file.Size,
 				},
 				Thumbnail: model.Thumbnail{Thumbnail: file.Icon.SmallUrl},
 			})

drivers/189pc/driver.go

@@ -3,8 +3,6 @@ package _189pc
 import (
 	"context"
 	"net/http"
-	"regexp"
-	"strconv"
 	"strings"
 	"time"
 
@@ -133,16 +131,17 @@ func (y *Yun189PC) Link(ctx context.Context, file model.Obj, args model.LinkArgs
 			"User-Agent": []string{base.UserAgent},
 		},
 	}
-
-	// 获取链接有效时常
-	strs := regexp.MustCompile(`(?i)expire[^=]*=([0-9]*)`).FindStringSubmatch(downloadUrl.URL)
-	if len(strs) == 2 {
-		timestamp, err := strconv.ParseInt(strs[1], 10, 64)
-		if err == nil {
-			expired := time.Duration(timestamp-time.Now().Unix()) * time.Second
-			like.Expiration = &expired
+	/*
+		// 获取链接有效时常
+		strs := regexp.MustCompile(`(?i)expire[^=]*=([0-9]*)`).FindStringSubmatch(downloadUrl.URL)
+		if len(strs) == 2 {
+			timestamp, err := strconv.ParseInt(strs[1], 10, 64)
+			if err == nil {
+				expired := time.Duration(timestamp-time.Now().Unix()) * time.Second
+				like.Expiration = &expired
+			}
 		}
-	}
+	*/
 	return like, nil
 }
 

drivers/189pc/utils.go

@@ -508,7 +508,6 @@ func (y *Yun189PC) FastUpload(ctx context.Context, dstDir model.Obj, file model.
 		_ = tempFile.Close()
 		_ = os.Remove(tempFile.Name())
 	}()
-	file.SetReadCloser(tempFile)
 
 	const DEFAULT int64 = 10485760
 	count := int(math.Ceil(float64(file.GetSize()) / float64(DEFAULT)))
@@ -526,14 +525,16 @@ func (y *Yun189PC) FastUpload(ctx context.Context, dstDir model.Obj, file model.
 		}
 
 		silceMd5.Reset()
-		if _, err := io.CopyN(io.MultiWriter(fileMd5, silceMd5), file, DEFAULT); err != nil && err != io.EOF && err != io.ErrUnexpectedEOF {
+		if _, err := io.CopyN(io.MultiWriter(fileMd5, silceMd5), tempFile, DEFAULT); err != nil && err != io.EOF && err != io.ErrUnexpectedEOF {
 			return err
 		}
 		md5Byte := silceMd5.Sum(nil)
 		silceMd5Hexs = append(silceMd5Hexs, strings.ToUpper(hex.EncodeToString(md5Byte)))
 		silceMd5Base64s = append(silceMd5Base64s, fmt.Sprint(i, "-", base64.StdEncoding.EncodeToString(md5Byte)))
 	}
-	file.GetReadCloser().(*os.File).Seek(0, io.SeekStart)
+	if _, err = tempFile.Seek(0, io.SeekStart); err != nil {
+		return err
+	}
 
 	fileMd5Hex := strings.ToUpper(hex.EncodeToString(fileMd5.Sum(nil)))
 	sliceMd5Hex := fileMd5Hex
@@ -594,7 +595,7 @@ func (y *Yun189PC) FastUpload(ctx context.Context, dstDir model.Obj, file model.
 				SetContext(ctx).
 				SetQueryParams(clientSuffix()).
 				SetHeaders(ParseHttpHeader(uploadData.RequestHeader)).
-				SetBody(io.LimitReader(file, DEFAULT)).
+				SetBody(io.LimitReader(tempFile, DEFAULT)).
 				Put(uploadData.RequestURL)
 			if err != nil {
 				return err

drivers/aliyundrive/driver.go

@@ -234,7 +234,10 @@ func (d *AliDrive) Put(ctx context.Context, dstDir model.Obj, stream model.FileS
 		buf := make([]byte, 8)
 		r, _ := new(big.Int).SetString(utils.GetMD5Encode(d.AccessToken)[:16], 16)
 		i := new(big.Int).SetInt64(file.GetSize())
-		o := r.Mod(r, i)
+		o := new(big.Int).SetInt64(0)
+		if file.GetSize() > 0 {
+			o = r.Mod(r, i)
+		}
 		n, _ := io.NewSectionReader(tempFile, o.Int64(), 8).Read(buf[:8])
 		reqBody["proof_code"] = base64.StdEncoding.EncodeToString(buf[:n])
 

drivers/aliyundrive/types.go

@@ -40,6 +40,7 @@ func fileToObj(f File) *model.ObjThumb {
 			Modified: f.UpdatedAt,
 			IsFolder: f.Type == "folder",
 		},
+		Thumbnail: model.Thumbnail{Thumbnail: f.Thumbnail},
 	}
 }
 

drivers/aliyundrive_share/driver.go

@@ -0,0 +1,144 @@
+package aliyundrive_share
+
+import (
+	"context"
+	"errors"
+	"net/http"
+	"time"
+
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/errs"
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/pkg/cron"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	log "github.com/sirupsen/logrus"
+)
+
+type AliyundriveShare struct {
+	model.Storage
+	Addition
+	AccessToken string
+	ShareToken  string
+	DriveId     string
+	cron        *cron.Cron
+}
+
+func (d *AliyundriveShare) Config() driver.Config {
+	return config
+}
+
+func (d *AliyundriveShare) GetAddition() driver.Additional {
+	return d.Addition
+}
+
+func (d *AliyundriveShare) Init(ctx context.Context, storage model.Storage) error {
+	d.Storage = storage
+	err := utils.Json.UnmarshalFromString(d.Storage.Addition, &d.Addition)
+	if err != nil {
+		return err
+	}
+	err = d.refreshToken()
+	if err != nil {
+		return err
+	}
+	err = d.getShareToken()
+	if err != nil {
+		return err
+	}
+	d.cron = cron.NewCron(time.Hour * 2)
+	d.cron.Do(func() {
+		err := d.refreshToken()
+		if err != nil {
+			log.Errorf("%+v", err)
+		}
+	})
+	return nil
+}
+
+func (d *AliyundriveShare) Drop(ctx context.Context) error {
+	if d.cron != nil {
+		d.cron.Stop()
+	}
+	return nil
+}
+
+func (d *AliyundriveShare) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	files, err := d.getFiles(dir.GetID())
+	if err != nil {
+		return nil, err
+	}
+	return utils.SliceConvert(files, func(src File) (model.Obj, error) {
+		return fileToObj(src), nil
+	})
+}
+
+//func (d *AliyundriveShare) Get(ctx context.Context, path string) (model.Obj, error) {
+//	// this is optional
+//	return nil, errs.NotImplement
+//}
+
+func (d *AliyundriveShare) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	data := base.Json{
+		"drive_id":   d.DriveId,
+		"file_id":    file.GetID(),
+		"expire_sec": 14400,
+	}
+	var e ErrorResp
+	res, err := base.RestyClient.R().
+		SetError(&e).SetBody(data).
+		SetHeader("content-type", "application/json").
+		SetHeader("Authorization", "Bearer\t"+d.AccessToken).
+		Post("https://api.aliyundrive.com/v2/file/get_download_url")
+	if err != nil {
+		return nil, err
+	}
+	if e.Code != "" {
+		if e.Code == "AccessTokenInvalid" {
+			err = d.refreshToken()
+			if err != nil {
+				return nil, err
+			}
+			return d.Link(ctx, file, args)
+		}
+		return nil, errors.New(e.Message)
+	}
+	return &model.Link{
+		Header: http.Header{
+			"Referer": []string{"https://www.aliyundrive.com/"},
+		},
+		URL: utils.Json.Get(res.Body(), "url").ToString(),
+	}, nil
+}
+
+func (d *AliyundriveShare) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error {
+	// TODO create folder
+	return errs.NotSupport
+}
+
+func (d *AliyundriveShare) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
+	// TODO move obj
+	return errs.NotSupport
+}
+
+func (d *AliyundriveShare) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
+	// TODO rename obj
+	return errs.NotSupport
+}
+
+func (d *AliyundriveShare) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
+	// TODO copy obj
+	return errs.NotSupport
+}
+
+func (d *AliyundriveShare) Remove(ctx context.Context, obj model.Obj) error {
+	// TODO remove obj
+	return errs.NotSupport
+}
+
+func (d *AliyundriveShare) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
+	// TODO upload file
+	return errs.NotSupport
+}
+
+var _ driver.Driver = (*AliyundriveShare)(nil)

drivers/aliyundrive_share/meta.go

@@ -0,0 +1,29 @@
+package aliyundrive_share
+
+import (
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/op"
+)
+
+type Addition struct {
+	RefreshToken string `json:"refresh_token" required:"true"`
+	ShareId      string `json:"share_id" required:"true"`
+	SharePwd     string `json:"share_pwd"`
+	driver.RootID
+	OrderBy        string `json:"order_by" type:"select" options:"name,size,updated_at,created_at"`
+	OrderDirection string `json:"order_direction" type:"select" options:"ASC,DESC"`
+}
+
+var config = driver.Config{
+	Name:        "AliyundriveShare",
+	LocalSort:   false,
+	OnlyProxy:   false,
+	NoUpload:    true,
+	DefaultRoot: "root",
+}
+
+func init() {
+	op.RegisterDriver(config, func() driver.Driver {
+		return &AliyundriveShare{}
+	})
+}

drivers/aliyundrive_share/types.go

@@ -0,0 +1,57 @@
+package aliyundrive_share
+
+import (
+	"time"
+
+	"github.com/alist-org/alist/v3/internal/model"
+)
+
+type ErrorResp struct {
+	Code    string `json:"code"`
+	Message string `json:"message"`
+}
+
+type ShareTokenResp struct {
+	ShareToken string    `json:"share_token"`
+	ExpireTime time.Time `json:"expire_time"`
+	ExpiresIn  int       `json:"expires_in"`
+}
+
+type ListResp struct {
+	Items             []File `json:"items"`
+	NextMarker        string `json:"next_marker"`
+	PunishedFileCount int    `json:"punished_file_count"`
+}
+
+type File struct {
+	DriveId      string    `json:"drive_id"`
+	DomainId     string    `json:"domain_id"`
+	FileId       string    `json:"file_id"`
+	ShareId      string    `json:"share_id"`
+	Name         string    `json:"name"`
+	Type         string    `json:"type"`
+	CreatedAt    time.Time `json:"created_at"`
+	UpdatedAt    time.Time `json:"updated_at"`
+	ParentFileId string    `json:"parent_file_id"`
+	Size         int64     `json:"size"`
+	Thumbnail    string    `json:"thumbnail"`
+}
+
+func fileToObj(f File) *model.ObjThumb {
+	return &model.ObjThumb{
+		Object: model.Object{
+			ID:       f.FileId,
+			Name:     f.Name,
+			Size:     f.Size,
+			Modified: f.UpdatedAt,
+			IsFolder: f.Type == "folder",
+		},
+		Thumbnail: model.Thumbnail{Thumbnail: f.Thumbnail},
+	}
+}
+
+//type ShareLinkResp struct {
+//	DownloadUrl string `json:"download_url"`
+//	Url         string `json:"url"`
+//	Thumbnail   string `json:"thumbnail"`
+//}

drivers/aliyundrive_share/util.go

@@ -0,0 +1,99 @@
+package aliyundrive_share
+
+import (
+	"errors"
+	"fmt"
+
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/internal/op"
+	log "github.com/sirupsen/logrus"
+)
+
+func (d *AliyundriveShare) refreshToken() error {
+	url := "https://auth.aliyundrive.com/v2/account/token"
+	var resp base.TokenResp
+	var e ErrorResp
+	_, err := base.RestyClient.R().
+		SetBody(base.Json{"refresh_token": d.RefreshToken, "grant_type": "refresh_token"}).
+		SetResult(&resp).
+		SetError(&e).
+		Post(url)
+	if err != nil {
+		return err
+	}
+	if e.Code != "" {
+		return fmt.Errorf("failed to refresh token: %s", e.Message)
+	}
+	d.RefreshToken, d.AccessToken = resp.RefreshToken, resp.AccessToken
+	op.MustSaveDriverStorage(d)
+	return nil
+}
+
+// do others that not defined in Driver interface
+func (d *AliyundriveShare) getShareToken() error {
+	data := base.Json{
+		"share_id": d.ShareId,
+	}
+	if d.SharePwd != "" {
+		data["share_pwd"] = d.SharePwd
+	}
+	var e ErrorResp
+	var resp ShareTokenResp
+	_, err := base.RestyClient.R().
+		SetResult(&resp).SetError(&e).SetBody(data).
+		Post("https://api.aliyundrive.com/v2/share_link/get_share_token")
+	if err != nil {
+		return err
+	}
+	if e.Code != "" {
+		return errors.New(e.Message)
+	}
+	d.ShareToken = resp.ShareToken
+	return nil
+}
+
+func (d *AliyundriveShare) getFiles(fileId string) ([]File, error) {
+	files := make([]File, 0)
+	data := base.Json{
+		"image_thumbnail_process": "image/resize,w_160/format,jpeg",
+		"image_url_process":       "image/resize,w_1920/format,jpeg",
+		"limit":                   100,
+		"order_by":                d.OrderBy,
+		"order_direction":         d.OrderDirection,
+		"parent_file_id":          fileId,
+		"share_id":                d.ShareId,
+		"video_thumbnail_process": "video/snapshot,t_1000,f_jpg,ar_auto,w_300",
+		"marker":                  "first",
+	}
+	for data["marker"] != "" {
+		if data["marker"] == "first" {
+			data["marker"] = ""
+		}
+		var e ErrorResp
+		var resp ListResp
+		res, err := base.RestyClient.R().
+			SetHeader("x-share-token", d.ShareToken).
+			SetResult(&resp).SetError(&e).SetBody(data).
+			Post("https://api.aliyundrive.com/adrive/v3/file/list")
+		if err != nil {
+			return nil, err
+		}
+		log.Debugf("aliyundrive share get files: %s", res.String())
+		if e.Code != "" {
+			if e.Code == "AccessTokenInvalid" {
+				err = d.getShareToken()
+				if err != nil {
+					return nil, err
+				}
+				return d.getFiles(fileId)
+			}
+			return nil, errors.New(e.Message)
+		}
+		data["marker"] = resp.NextMarker
+		files = append(files, resp.Items...)
+	}
+	if len(files) > 0 && d.DriveId == "" {
+		d.DriveId = files[0].DriveId
+	}
+	return files, nil
+}

drivers/all.go

@@ -6,9 +6,12 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/189"
 	_ "github.com/alist-org/alist/v3/drivers/189pc"
 	_ "github.com/alist-org/alist/v3/drivers/aliyundrive"
+	_ "github.com/alist-org/alist/v3/drivers/aliyundrive_share"
 	_ "github.com/alist-org/alist/v3/drivers/baidu_netdisk"
+	_ "github.com/alist-org/alist/v3/drivers/baidu_photo"
 	_ "github.com/alist-org/alist/v3/drivers/ftp"
 	_ "github.com/alist-org/alist/v3/drivers/google_drive"
+	_ "github.com/alist-org/alist/v3/drivers/lanzou"
 	_ "github.com/alist-org/alist/v3/drivers/local"
 	_ "github.com/alist-org/alist/v3/drivers/mediatrack"
 	_ "github.com/alist-org/alist/v3/drivers/onedrive"

drivers/baidu_photo/driver.go

@@ -0,0 +1,282 @@
+package baiduphoto
+
+import (
+	"context"
+	"crypto/md5"
+	"encoding/hex"
+	"fmt"
+	"io"
+	"math"
+	"os"
+	"regexp"
+
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/errs"
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/go-resty/resty/v2"
+)
+
+type BaiduPhoto struct {
+	model.Storage
+	Addition
+
+	AccessToken string
+}
+
+func (d *BaiduPhoto) Config() driver.Config {
+	return config
+}
+
+func (d *BaiduPhoto) GetAddition() driver.Additional {
+	return d.Addition
+}
+
+func (d *BaiduPhoto) Init(ctx context.Context, storage model.Storage) error {
+	d.Storage = storage
+	err := utils.Json.UnmarshalFromString(d.Storage.Addition, &d.Addition)
+	if err != nil {
+		return err
+	}
+	return d.refreshToken()
+}
+
+func (d *BaiduPhoto) Drop(ctx context.Context) error {
+	return nil
+}
+
+func (d *BaiduPhoto) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	var objs []model.Obj
+	var err error
+	if IsRoot(dir) {
+		var albums []Album
+		if d.ShowType != "root_only_file" {
+			albums, err = d.GetAllAlbum(ctx)
+			if err != nil {
+				return nil, err
+			}
+		}
+
+		var files []File
+		if d.ShowType != "root_only_album" {
+			files, err = d.GetAllFile(ctx)
+			if err != nil {
+				return nil, err
+			}
+		}
+
+		alubmName := make(map[string]int)
+		objs, _ = utils.SliceConvert(albums, func(album Album) (model.Obj, error) {
+			i := alubmName[album.GetName()]
+			if i != 0 {
+				alubmName[album.GetName()]++
+				album.Title = fmt.Sprintf("%s(%d)", album.Title, i)
+			}
+			alubmName[album.GetName()]++
+			return &album, nil
+		})
+		for i := 0; i < len(files); i++ {
+			objs = append(objs, &files[i])
+		}
+	} else if IsAlbum(dir) || IsAlbumRoot(dir) {
+		var files []AlbumFile
+		files, err = d.GetAllAlbumFile(ctx, splitID(dir.GetID())[0], "")
+		if err != nil {
+			return nil, err
+		}
+		objs = make([]model.Obj, 0, len(files))
+		for i := 0; i < len(files); i++ {
+			objs = append(objs, &files[i])
+		}
+	}
+	return objs, nil
+}
+
+func (d *BaiduPhoto) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	if IsAlbumFile(file) {
+		return d.linkAlbum(ctx, file, args)
+	} else if IsFile(file) {
+		return d.linkFile(ctx, file, args)
+	}
+	return nil, errs.NotFile
+}
+
+func (d *BaiduPhoto) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error {
+	if IsRoot(parentDir) {
+		code := regexp.MustCompile(`(?i)join:([\S]*)`).FindStringSubmatch(dirName)
+		if len(code) > 1 {
+			return d.JoinAlbum(ctx, code[1])
+		}
+		return d.CreateAlbum(ctx, dirName)
+	}
+	return errs.NotSupport
+}
+
+func (d *BaiduPhoto) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
+	if IsFile(srcObj) {
+		if IsAlbum(dstDir) {
+			//rootfile ->  album
+			e := splitID(dstDir.GetID())
+			return d.AddAlbumFile(ctx, e[0], e[1], srcObj.GetID())
+		}
+	} else if IsAlbumFile(srcObj) {
+		if IsRoot(dstDir) {
+			//albumfile -> root
+			e := splitID(srcObj.GetID())
+			_, err := d.CopyAlbumFile(ctx, e[1], e[2], e[3], srcObj.GetID())
+			return err
+		} else if IsAlbum(dstDir) {
+			// albumfile -> root -> album
+			e := splitID(srcObj.GetID())
+			file, err := d.CopyAlbumFile(ctx, e[1], e[2], e[3], srcObj.GetID())
+			if err != nil {
+				return err
+			}
+			e = splitID(dstDir.GetID())
+			return d.AddAlbumFile(ctx, e[0], e[1], fmt.Sprint(file.Fsid))
+		}
+	}
+	return errs.NotSupport
+}
+
+func (d *BaiduPhoto) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
+	// 仅支持相册之间移动
+	if IsAlbumFile(srcObj) && IsAlbum(dstDir) {
+		err := d.Copy(ctx, srcObj, dstDir)
+		if err != nil {
+			return err
+		}
+		e := splitID(srcObj.GetID())
+		return d.DeleteAlbumFile(ctx, e[1], e[2], srcObj.GetID())
+	}
+	return errs.NotSupport
+}
+
+func (d *BaiduPhoto) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
+	// 仅支持相册改名
+	if IsAlbum(srcObj) {
+		e := splitID(srcObj.GetID())
+		return d.SetAlbumName(ctx, e[0], e[1], newName)
+	}
+	return errs.NotSupport
+}
+
+func (d *BaiduPhoto) Remove(ctx context.Context, obj model.Obj) error {
+	e := splitID(obj.GetID())
+	if IsFile(obj) {
+		return d.DeleteFile(ctx, e[0])
+	} else if IsAlbum(obj) {
+		return d.DeleteAlbum(ctx, e[0], e[1])
+	} else if IsAlbumFile(obj) {
+		return d.DeleteAlbumFile(ctx, e[1], e[2], obj.GetID())
+	}
+	return errs.NotSupport
+}
+
+func (d *BaiduPhoto) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
+	// 需要获取完整文件md5,必须支持 io.Seek
+	tempFile, err := utils.CreateTempFile(stream.GetReadCloser())
+	if err != nil {
+		return err
+	}
+	defer func() {
+		_ = tempFile.Close()
+		_ = os.Remove(tempFile.Name())
+	}()
+
+	// 计算需要的数据
+	const DEFAULT = 1 << 22
+	const SliceSize = 1 << 18
+	count := int(math.Ceil(float64(stream.GetSize()) / float64(DEFAULT)))
+
+	sliceMD5List := make([]string, 0, count)
+	fileMd5 := md5.New()
+	sliceMd5 := md5.New()
+	sliceMd52 := md5.New()
+	slicemd52Write := utils.LimitWriter(sliceMd52, SliceSize)
+	for i := 1; i <= count; i++ {
+		select {
+		case <-ctx.Done():
+			return ctx.Err()
+		default:
+		}
+		_, err := io.CopyN(io.MultiWriter(fileMd5, sliceMd5, slicemd52Write), tempFile, DEFAULT)
+		if err != nil && err != io.EOF && err != io.ErrUnexpectedEOF {
+			return err
+		}
+		sliceMD5List = append(sliceMD5List, hex.EncodeToString(sliceMd5.Sum(nil)))
+		sliceMd5.Reset()
+	}
+	if _, err = tempFile.Seek(0, io.SeekStart); err != nil {
+		return err
+	}
+	content_md5 := hex.EncodeToString(fileMd5.Sum(nil))
+	slice_md5 := hex.EncodeToString(sliceMd52.Sum(nil))
+
+	// 开始执行上传
+	params := map[string]string{
+		"autoinit":    "1",
+		"isdir":       "0",
+		"rtype":       "1",
+		"ctype":       "11",
+		"path":        stream.GetName(),
+		"size":        fmt.Sprint(stream.GetSize()),
+		"slice-md5":   slice_md5,
+		"content-md5": content_md5,
+		"block_list":  MustString(utils.Json.MarshalToString(sliceMD5List)),
+	}
+
+	// 预上传
+	var precreateResp PrecreateResp
+	_, err = d.Post(FILE_API_URL_V1+"/precreate", func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetFormData(params)
+	}, &precreateResp)
+	if err != nil {
+		return err
+	}
+
+	switch precreateResp.ReturnType {
+	case 1: // 上传文件
+		uploadParams := map[string]string{
+			"method":   "upload",
+			"path":     params["path"],
+			"uploadid": precreateResp.UploadID,
+		}
+
+		for i := 0; i < count; i++ {
+			uploadParams["partseq"] = fmt.Sprint(i)
+			_, err = d.Post("https://c3.pcs.baidu.com/rest/2.0/pcs/superfile2", func(r *resty.Request) {
+				r.SetContext(ctx)
+				r.SetQueryParams(uploadParams)
+				r.SetFileReader("file", stream.GetName(), io.LimitReader(tempFile, DEFAULT))
+			}, nil)
+			if err != nil {
+				return err
+			}
+			up(i * 100 / count)
+		}
+		fallthrough
+	case 2: // 创建文件
+		params["uploadid"] = precreateResp.UploadID
+		_, err = d.Post(FILE_API_URL_V1+"/create", func(r *resty.Request) {
+			r.SetContext(ctx)
+			r.SetFormData(params)
+		}, &precreateResp)
+		if err != nil {
+			return err
+		}
+		fallthrough
+	case 3: // 增加到相册
+		if IsAlbum(dstDir) || IsAlbumRoot(dstDir) {
+			e := splitID(dstDir.GetID())
+			err = d.AddAlbumFile(ctx, e[0], e[1], fmt.Sprint(precreateResp.Data.FsID))
+			if err != nil {
+				return err
+			}
+		}
+	}
+	return nil
+}
+
+var _ driver.Driver = (*BaiduPhoto)(nil)

drivers/baidu_photo/help.go

@@ -0,0 +1,107 @@
+package baiduphoto
+
+import (
+	"fmt"
+	"math"
+	"math/rand"
+	"regexp"
+	"strings"
+	"time"
+
+	"github.com/alist-org/alist/v3/internal/model"
+)
+
+//Tid生成
+func getTid() string {
+	return fmt.Sprintf("3%d%.0f", time.Now().Unix(), math.Floor(9000000*rand.Float64()+1000000))
+}
+
+// 检查名称
+func checkName(name string) bool {
+	return len(name) <= 20 && regexp.MustCompile("[\u4e00-\u9fa5A-Za-z0-9_-]").MatchString(name)
+}
+
+func toTime(t int64) *time.Time {
+	tm := time.Unix(t, 0)
+	return &tm
+}
+
+func fsidsFormat(ids ...string) string {
+	var buf []string
+	for _, id := range ids {
+		e := splitID(id)
+		buf = append(buf, fmt.Sprintf(`{"fsid":%s,"uk":%s}`, e[0], e[3]))
+	}
+	return fmt.Sprintf("[%s]", strings.Join(buf, ","))
+}
+
+func fsidsFormatNotUk(ids ...string) string {
+	var buf []string
+	for _, id := range ids {
+		buf = append(buf, fmt.Sprintf(`{"fsid":%s}`, splitID(id)[0]))
+	}
+	return fmt.Sprintf("[%s]", strings.Join(buf, ","))
+}
+
+/*
+结构
+
+{fsid} 文件
+
+{album_id}|{tid} 相册
+
+{fsid}|{album_id}|{tid}|{uk} 相册文件
+*/
+func splitID(id string) []string {
+	return strings.SplitN(id, "|", 4)[:4]
+}
+
+/*
+结构
+
+{fsid} 文件
+
+{album_id}|{tid} 相册
+
+{fsid}|{album_id}|{tid}|{uk} 相册文件
+*/
+func joinID(ids ...interface{}) string {
+	idsStr := make([]string, 0, len(ids))
+	for _, id := range ids {
+		idsStr = append(idsStr, fmt.Sprint(id))
+	}
+	return strings.Join(idsStr, "|")
+}
+
+func getFileName(path string) string {
+	return path[strings.LastIndex(path, "/")+1:]
+}
+
+// 相册
+func IsAlbum(obj model.Obj) bool {
+	return obj.IsDir() && obj.GetPath() == "album"
+}
+
+// 根目录
+func IsRoot(obj model.Obj) bool {
+	return obj.IsDir() && obj.GetPath() == "" && obj.GetID() == ""
+}
+
+// 以相册为根目录
+func IsAlbumRoot(obj model.Obj) bool {
+	return obj.IsDir() && obj.GetPath() == "" && obj.GetID() != ""
+}
+
+// 根文件
+func IsFile(obj model.Obj) bool {
+	return !obj.IsDir() && obj.GetPath() == "file"
+}
+
+// 相册文件
+func IsAlbumFile(obj model.Obj) bool {
+	return !obj.IsDir() && obj.GetPath() == "albumfile"
+}
+
+func MustString(str string, err error) string {
+	return str
+}

drivers/baidu_photo/meta.go

@@ -0,0 +1,30 @@
+package baiduphoto
+
+import (
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/op"
+)
+
+type Addition struct {
+	RefreshToken string `json:"refresh_token" required:"true"`
+	ShowType     string `json:"show_type" type:"select" options:"root,root_only_album,root_only_file" default:"root"`
+	AlbumID      string `json:"album_id"`
+	//AlbumPassword string `json:"album_password"`
+	ClientID     string `json:"client_id" required:"true" default:"iYCeC9g08h5vuP9UqvPHKKSVrKFXGa1v"`
+	ClientSecret string `json:"client_secret" required:"true" default:"jXiFMOPVPCWlO2M5CwWQzffpNPaGTRBG"`
+}
+
+func (a Addition) GetRootId() string {
+	return a.AlbumID
+}
+
+var config = driver.Config{
+	Name:      "BaiduPhoto",
+	LocalSort: true,
+}
+
+func init() {
+	op.RegisterDriver(config, func() driver.Driver {
+		return &BaiduPhoto{}
+	})
+}

drivers/baidu_photo/types.go

@@ -0,0 +1,169 @@
+package baiduphoto
+
+import (
+	"fmt"
+	"time"
+)
+
+type TokenErrResp struct {
+	ErrorDescription string `json:"error_description"`
+	ErrorMsg         string `json:"error"`
+}
+
+func (e *TokenErrResp) Error() string {
+	return fmt.Sprint(e.ErrorMsg, " : ", e.ErrorDescription)
+}
+
+type Erron struct {
+	Errno     int `json:"errno"`
+	RequestID int `json:"request_id"`
+}
+
+type Page struct {
+	HasMore int    `json:"has_more"`
+	Cursor  string `json:"cursor"`
+}
+
+func (p Page) HasNextPage() bool {
+	return p.HasMore == 1
+}
+
+type (
+	FileListResp struct {
+		Page
+		List []File `json:"list"`
+	}
+
+	File struct {
+		Fsid     int64    `json:"fsid"` // 文件ID
+		Path     string   `json:"path"` // 文件路径
+		Size     int64    `json:"size"`
+		Ctime    int64    `json:"ctime"` // 创建时间 s
+		Mtime    int64    `json:"mtime"` // 修改时间 s
+		Thumburl []string `json:"thumburl"`
+
+		parseTime *time.Time
+	}
+)
+
+func (c *File) GetSize() int64  { return c.Size }
+func (c *File) GetName() string { return getFileName(c.Path) }
+func (c *File) ModTime() time.Time {
+	if c.parseTime == nil {
+		c.parseTime = toTime(c.Mtime)
+	}
+	return *c.parseTime
+}
+func (c *File) IsDir() bool     { return false }
+func (c *File) GetID() string   { return joinID(c.Fsid) }
+func (c *File) GetPath() string { return "file" }
+func (c *File) Thumb() string {
+	if len(c.Thumburl) > 0 {
+		return c.Thumburl[0]
+	}
+	return ""
+}
+
+/*相册部分*/
+type (
+	AlbumListResp struct {
+		Page
+		List       []Album `json:"list"`
+		Reset      int64   `json:"reset"`
+		TotalCount int64   `json:"total_count"`
+	}
+
+	Album struct {
+		AlbumID    string `json:"album_id"`
+		Tid        int64  `json:"tid"`
+		Title      string `json:"title"`
+		JoinTime   int64  `json:"join_time"`
+		CreateTime int64  `json:"create_time"`
+		Mtime      int64  `json:"mtime"`
+
+		parseTime *time.Time
+	}
+
+	AlbumFileListResp struct {
+		Page
+		List       []AlbumFile `json:"list"`
+		Reset      int64       `json:"reset"`
+		TotalCount int64       `json:"total_count"`
+	}
+
+	AlbumFile struct {
+		File
+		AlbumID string `json:"album_id"`
+		Tid     int64  `json:"tid"`
+		Uk      int64  `json:"uk"`
+	}
+)
+
+func (a *Album) GetSize() int64  { return 0 }
+func (a *Album) GetName() string { return fmt.Sprint(a.Title) }
+func (a *Album) ModTime() time.Time {
+	if a.parseTime == nil {
+		a.parseTime = toTime(a.Mtime)
+	}
+	return *a.parseTime
+}
+func (a *Album) IsDir() bool     { return true }
+func (a *Album) GetID() string   { return joinID(a.AlbumID, a.Tid) }
+func (a *Album) GetPath() string { return "album" }
+
+func (af *AlbumFile) GetID() string  { return joinID(af.Fsid, af.AlbumID, af.Tid, af.Uk) }
+func (c *AlbumFile) GetPath() string { return "albumfile" }
+
+type (
+	CopyFileResp struct {
+		List []CopyFile `json:"list"`
+	}
+	CopyFile struct {
+		FromFsid  int64  `json:"from_fsid"` // 源ID
+		Fsid      int64  `json:"fsid"`      // 目标ID
+		Path      string `json:"path"`
+		ShootTime int    `json:"shoot_time"`
+	}
+)
+
+/*上传部分*/
+type (
+	UploadFile struct {
+		FsID           int64  `json:"fs_id"`
+		Size           int64  `json:"size"`
+		Md5            string `json:"md5"`
+		ServerFilename string `json:"server_filename"`
+		Path           string `json:"path"`
+		Ctime          int    `json:"ctime"`
+		Mtime          int    `json:"mtime"`
+		Isdir          int    `json:"isdir"`
+		Category       int    `json:"category"`
+		ServerMd5      string `json:"server_md5"`
+		ShootTime      int    `json:"shoot_time"`
+	}
+
+	CreateFileResp struct {
+		Data UploadFile `json:"data"`
+	}
+
+	PrecreateResp struct {
+		ReturnType int `json:"return_type"` //存在返回2 不存在返回1 已经保存3
+		//存在返回
+		CreateFileResp
+
+		//不存在返回
+		Path      string  `json:"path"`
+		UploadID  string  `json:"uploadid"`
+		Blocklist []int64 `json:"block_list"`
+	}
+)
+
+type InviteResp struct {
+	Pdata struct {
+		// 邀请码
+		InviteCode string `json:"invite_code"`
+		// 有效时间
+		ExpireTime int    `json:"expire_time"`
+		ShareID    string `json:"share_id"`
+	} `json:"pdata"`
+}

drivers/baidu_photo/utils.go

@@ -0,0 +1,376 @@
+package baiduphoto
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"net/http"
+	"strings"
+
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/internal/errs"
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/internal/op"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/go-resty/resty/v2"
+)
+
+const (
+	API_URL         = "https://photo.baidu.com/youai"
+	ALBUM_API_URL   = API_URL + "/album/v1"
+	FILE_API_URL_V1 = API_URL + "/file/v1"
+	FILE_API_URL_V2 = API_URL + "/file/v2"
+)
+
+var (
+	ErrNotSupportName = errors.New("only chinese and english, numbers and underscores are supported, and the length is no more than 20")
+)
+
+func (p *BaiduPhoto) Request(furl string, method string, callback base.ReqCallback, resp interface{}) ([]byte, error) {
+	req := base.RestyClient.R().
+		SetQueryParam("access_token", p.AccessToken)
+	if callback != nil {
+		callback(req)
+	}
+	if resp != nil {
+		req.SetResult(resp)
+	}
+	res, err := req.Execute(method, furl)
+	if err != nil {
+		return nil, err
+	}
+
+	erron := utils.Json.Get(res.Body(), "errno").ToInt()
+	switch erron {
+	case 0:
+		break
+	case 50805:
+		return nil, fmt.Errorf("you have joined album")
+	case 50820:
+		return nil, fmt.Errorf("no shared albums found")
+	case -6:
+		if err = p.refreshToken(); err != nil {
+			return nil, err
+		}
+	default:
+		return nil, fmt.Errorf("errno: %d, refer to https://photo.baidu.com/union/doc", erron)
+	}
+	return res.Body(), nil
+}
+
+func (p *BaiduPhoto) refreshToken() error {
+	u := "https://openapi.baidu.com/oauth/2.0/token"
+	var resp base.TokenResp
+	var e TokenErrResp
+	_, err := base.RestyClient.R().SetResult(&resp).SetError(&e).SetQueryParams(map[string]string{
+		"grant_type":    "refresh_token",
+		"refresh_token": p.RefreshToken,
+		"client_id":     p.ClientID,
+		"client_secret": p.ClientSecret,
+	}).Get(u)
+	if err != nil {
+		return err
+	}
+	if e.ErrorMsg != "" {
+		return &e
+	}
+	if resp.RefreshToken == "" {
+		return errs.EmptyToken
+	}
+	p.AccessToken, p.RefreshToken = resp.AccessToken, resp.RefreshToken
+	op.MustSaveDriverStorage(p)
+	return nil
+}
+
+func (p *BaiduPhoto) Get(furl string, callback base.ReqCallback, resp interface{}) ([]byte, error) {
+	return p.Request(furl, http.MethodGet, callback, resp)
+}
+
+func (p *BaiduPhoto) Post(furl string, callback base.ReqCallback, resp interface{}) ([]byte, error) {
+	return p.Request(furl, http.MethodPost, callback, resp)
+}
+
+// 获取所有文件
+func (p *BaiduPhoto) GetAllFile(ctx context.Context) (files []File, err error) {
+	var cursor string
+	for {
+		var resp FileListResp
+		_, err = p.Get(FILE_API_URL_V1+"/list", func(r *resty.Request) {
+			r.SetContext(ctx)
+			r.SetQueryParams(map[string]string{
+				"need_thumbnail":     "1",
+				"need_filter_hidden": "0",
+				"cursor":             cursor,
+			})
+		}, &resp)
+		if err != nil {
+			return
+		}
+
+		files = append(files, resp.List...)
+		if !resp.HasNextPage() {
+			return
+		}
+		cursor = resp.Cursor
+	}
+}
+
+// 删除根文件
+func (p *BaiduPhoto) DeleteFile(ctx context.Context, fileIDs ...string) error {
+	_, err := p.Get(FILE_API_URL_V1+"/delete", func(req *resty.Request) {
+		req.SetContext(ctx)
+		req.SetQueryParams(map[string]string{
+			"fsid_list": fmt.Sprintf("[%s]", strings.Join(fileIDs, ",")),
+		})
+	}, nil)
+	return err
+}
+
+// 获取所有相册
+func (p *BaiduPhoto) GetAllAlbum(ctx context.Context) (albums []Album, err error) {
+	var cursor string
+	for {
+		var resp AlbumListResp
+		_, err = p.Get(ALBUM_API_URL+"/list", func(r *resty.Request) {
+			r.SetContext(ctx)
+			r.SetQueryParams(map[string]string{
+				"need_amount": "1",
+				"limit":       "100",
+				"cursor":      cursor,
+			})
+		}, &resp)
+		if err != nil {
+			return
+		}
+		if albums == nil {
+			albums = make([]Album, 0, resp.TotalCount)
+		}
+
+		cursor = resp.Cursor
+		albums = append(albums, resp.List...)
+
+		if !resp.HasNextPage() {
+			return
+		}
+	}
+}
+
+// 获取相册中所有文件
+func (p *BaiduPhoto) GetAllAlbumFile(ctx context.Context, albumID, passwd string) (files []AlbumFile, err error) {
+	var cursor string
+	for {
+		var resp AlbumFileListResp
+		_, err = p.Get(ALBUM_API_URL+"/listfile", func(r *resty.Request) {
+			r.SetContext(ctx)
+			r.SetQueryParams(map[string]string{
+				"album_id":    albumID,
+				"need_amount": "1",
+				"limit":       "1000",
+				"passwd":      passwd,
+				"cursor":      cursor,
+			})
+		}, &resp)
+		if err != nil {
+			return
+		}
+		if files == nil {
+			files = make([]AlbumFile, 0, resp.TotalCount)
+		}
+
+		cursor = resp.Cursor
+		files = append(files, resp.List...)
+
+		if !resp.HasNextPage() {
+			return
+		}
+	}
+}
+
+// 创建相册
+func (p *BaiduPhoto) CreateAlbum(ctx context.Context, name string) error {
+	if !checkName(name) {
+		return ErrNotSupportName
+	}
+	_, err := p.Post(ALBUM_API_URL+"/create", func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetQueryParams(map[string]string{
+			"title":  name,
+			"tid":    getTid(),
+			"source": "0",
+		})
+	}, nil)
+	return err
+}
+
+// 相册改名
+func (p *BaiduPhoto) SetAlbumName(ctx context.Context, albumID, tID, name string) error {
+	if !checkName(name) {
+		return ErrNotSupportName
+	}
+
+	_, err := p.Post(ALBUM_API_URL+"/settitle", func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetFormData(map[string]string{
+			"title":    name,
+			"album_id": albumID,
+			"tid":      tID,
+		})
+	}, nil)
+	return err
+}
+
+// 删除相册
+func (p *BaiduPhoto) DeleteAlbum(ctx context.Context, albumID, tID string) error {
+	_, err := p.Post(ALBUM_API_URL+"/delete", func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetFormData(map[string]string{
+			"album_id":            albumID,
+			"tid":                 tID,
+			"delete_origin_image": "0", // 是否删除原图 0 不删除 1 删除
+		})
+	}, nil)
+	return err
+}
+
+// 删除相册文件
+func (p *BaiduPhoto) DeleteAlbumFile(ctx context.Context, albumID, tID string, fileIDs ...string) error {
+	_, err := p.Post(ALBUM_API_URL+"/delfile", func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetFormData(map[string]string{
+			"album_id":   albumID,
+			"tid":        tID,
+			"list":       fsidsFormat(fileIDs...),
+			"del_origin": "0", // 是否删除原图 0 不删除 1 删除
+		})
+	}, nil)
+	return err
+}
+
+// 增加相册文件
+func (p *BaiduPhoto) AddAlbumFile(ctx context.Context, albumID, tID string, fileIDs ...string) error {
+	_, err := p.Get(ALBUM_API_URL+"/addfile", func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetQueryParams(map[string]string{
+			"album_id": albumID,
+			"tid":      tID,
+			"list":     fsidsFormatNotUk(fileIDs...),
+		})
+	}, nil)
+	return err
+}
+
+// 保存相册文件为根文件
+func (p *BaiduPhoto) CopyAlbumFile(ctx context.Context, albumID, tID, uk string, fileID ...string) (*CopyFile, error) {
+	var resp CopyFileResp
+	_, err := p.Post(ALBUM_API_URL+"/copyfile", func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetFormData(map[string]string{
+			"album_id": albumID,
+			"tid":      tID,
+			"uk":       uk,
+			"list":     fsidsFormatNotUk(fileID...),
+		})
+		r.SetResult(&resp)
+	}, nil)
+	if err != nil {
+		return nil, err
+	}
+	return &resp.List[0], nil
+}
+
+// 加入相册
+func (p *BaiduPhoto) JoinAlbum(ctx context.Context, code string) error {
+	var resp InviteResp
+	_, err := p.Get(ALBUM_API_URL+"/querypcode", func(req *resty.Request) {
+		req.SetContext(ctx)
+		req.SetQueryParams(map[string]string{
+			"pcode": code,
+			"web":   "1",
+		})
+	}, &resp)
+	if err != nil {
+		return err
+	}
+	_, err = p.Get(ALBUM_API_URL+"/join", func(req *resty.Request) {
+		req.SetContext(ctx)
+		req.SetQueryParams(map[string]string{
+			"invite_code": resp.Pdata.InviteCode,
+		})
+	}, nil)
+	return err
+}
+
+func (d *BaiduPhoto) linkAlbum(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	headers := map[string]string{
+		"User-Agent": base.UserAgent,
+	}
+	if args.Header.Get("User-Agent") != "" {
+		headers["User-Agent"] = args.Header.Get("User-Agent")
+	}
+	if !utils.IsLocalIPAddr(args.IP) {
+		headers["X-Forwarded-For"] = args.IP
+	}
+
+	e := splitID(file.GetID())
+	res, err := base.NoRedirectClient.R().
+		SetContext(ctx).
+		SetHeaders(headers).
+		SetQueryParams(map[string]string{
+			"access_token": d.AccessToken,
+			"fsid":         e[0],
+			"album_id":     e[1],
+			"tid":          e[2],
+			"uk":           e[3],
+		}).
+		Head(ALBUM_API_URL + "/download")
+
+	if err != nil {
+		return nil, err
+	}
+
+	//exp := 8 * time.Hour
+	link := &model.Link{
+		URL: res.Header().Get("location"),
+		Header: http.Header{
+			"User-Agent": []string{headers["User-Agent"]},
+		},
+		//Expiration: &exp,
+	}
+	return link, nil
+}
+
+func (d *BaiduPhoto) linkFile(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	headers := map[string]string{
+		"User-Agent": base.UserAgent,
+	}
+	if args.Header.Get("User-Agent") != "" {
+		headers["User-Agent"] = args.Header.Get("User-Agent")
+	}
+	if !utils.IsLocalIPAddr(args.IP) {
+		headers["X-Forwarded-For"] = args.IP
+	}
+
+	var downloadUrl struct {
+		Dlink string `json:"dlink"`
+	}
+	_, err := d.Get(FILE_API_URL_V2+"/download", func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetHeaders(headers)
+		r.SetQueryParams(map[string]string{
+			"fsid": splitID(file.GetID())[0],
+		})
+	}, &downloadUrl)
+	if err != nil {
+		return nil, err
+	}
+
+	//exp := 8 * time.Hour
+	link := &model.Link{
+		URL: downloadUrl.Dlink,
+		Header: http.Header{
+			"User-Agent": []string{headers["User-Agent"]},
+		},
+		//Expiration: &exp,
+	}
+	return link, nil
+}

drivers/ftp/util.go

@@ -19,5 +19,6 @@ func (d *FTP) login() error {
 	if err != nil {
 		return err
 	}
+	d.conn = conn
 	return nil
 }

drivers/lanzou/driver.go

@@ -0,0 +1,171 @@
+package lanzou
+
+import (
+	"context"
+	"net/http"
+	"time"
+
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/errs"
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/go-resty/resty/v2"
+)
+
+var upClient = base.NewRestyClient().SetTimeout(120 * time.Second)
+
+type LanZou struct {
+	Addition
+	model.Storage
+}
+
+func (d *LanZou) Config() driver.Config {
+	return config
+}
+
+func (d *LanZou) GetAddition() driver.Additional {
+	return d.Addition
+}
+
+func (d *LanZou) Init(ctx context.Context, storage model.Storage) error {
+	d.Storage = storage
+	err := utils.Json.UnmarshalFromString(d.Storage.Addition, &d.Addition)
+	if err != nil {
+		return err
+	}
+	if d.IsCookie() {
+		if d.RootFolderID == "" {
+			d.RootFolderID = "-1"
+		}
+	}
+	return nil
+}
+
+func (d *LanZou) Drop(ctx context.Context) error {
+	return nil
+}
+
+// 获取的大小和时间不准确
+func (d *LanZou) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	if d.IsCookie() {
+		return d.GetFiles(ctx, dir.GetID())
+	} else {
+		return d.GetFileOrFolderByShareUrl(ctx, dir.GetID(), d.SharePassword)
+	}
+}
+
+func (d *LanZou) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	downID := file.GetID()
+	pwd := d.SharePassword
+	if d.IsCookie() {
+		share, err := d.getFileShareUrlByID(ctx, file.GetID())
+		if err != nil {
+			return nil, err
+		}
+		downID = share.FID
+		pwd = share.Pwd
+	}
+	fileInfo, err := d.getFilesByShareUrl(ctx, downID, pwd, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	return &model.Link{
+		URL: fileInfo.Url,
+		Header: http.Header{
+			"User-Agent": []string{base.UserAgent},
+		},
+	}, nil
+}
+
+func (d *LanZou) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error {
+	if d.IsCookie() {
+		_, err := d.post(d.BaseUrl+"/doupload.php", func(req *resty.Request) {
+			req.SetContext(ctx)
+			req.SetFormData(map[string]string{
+				"task":               "2",
+				"parent_id":          parentDir.GetID(),
+				"folder_name":        dirName,
+				"folder_description": "",
+			})
+		}, nil)
+		return err
+	}
+	return errs.NotImplement
+}
+
+func (d *LanZou) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
+	if d.IsCookie() {
+		if !srcObj.IsDir() {
+			_, err := d.post(d.BaseUrl+"/doupload.php", func(req *resty.Request) {
+				req.SetContext(ctx)
+				req.SetFormData(map[string]string{
+					"task":      "20",
+					"folder_id": dstDir.GetID(),
+					"file_id":   srcObj.GetID(),
+				})
+			}, nil)
+			return err
+		}
+	}
+	return errs.NotImplement
+}
+
+func (d *LanZou) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
+	if d.IsCookie() {
+		if !srcObj.IsDir() {
+			_, err := d.post(d.BaseUrl+"/doupload.php", func(req *resty.Request) {
+				req.SetContext(ctx)
+				req.SetFormData(map[string]string{
+					"task":      "46",
+					"file_id":   srcObj.GetID(),
+					"file_name": newName,
+					"type":      "2",
+				})
+			}, nil)
+			return err
+		}
+	}
+	return errs.NotImplement
+}
+
+func (d *LanZou) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
+	return errs.NotImplement
+}
+
+func (d *LanZou) Remove(ctx context.Context, obj model.Obj) error {
+	if d.IsCookie() {
+		_, err := d.post(d.BaseUrl+"/doupload.php", func(req *resty.Request) {
+			req.SetContext(ctx)
+			if obj.IsDir() {
+				req.SetFormData(map[string]string{
+					"task":      "3",
+					"folder_id": obj.GetID(),
+				})
+			} else {
+				req.SetFormData(map[string]string{
+					"task":    "6",
+					"file_id": obj.GetID(),
+				})
+			}
+		}, nil)
+		return err
+	}
+	return errs.NotImplement
+}
+
+func (d *LanZou) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
+	if d.IsCookie() {
+		_, err := d._post(d.BaseUrl+"/fileup.php", func(req *resty.Request) {
+			req.SetFormData(map[string]string{
+				"task":      "1",
+				"id":        "WU_FILE_0",
+				"name":      stream.GetName(),
+				"folder_id": dstDir.GetID(),
+			}).SetFileReader("upload_file", stream.GetName(), stream)
+		}, nil, true)
+		return err
+	}
+	return errs.NotImplement
+}

drivers/lanzou/help.go

@@ -0,0 +1,165 @@
+package lanzou
+
+import (
+	"bytes"
+	"fmt"
+	"regexp"
+	"strconv"
+	"strings"
+	"time"
+	"unicode"
+)
+
+const DAY time.Duration = 84600000000000
+
+var timeSplitReg = regexp.MustCompile("([0-9.]*)\\s*([\u4e00-\u9fa5]+)")
+
+func MustParseTime(str string) time.Time {
+	lastOpTime, err := time.ParseInLocation("2006-01-02 -07", str+" +08", time.Local)
+	if err != nil {
+		strs := timeSplitReg.FindStringSubmatch(str)
+		lastOpTime = time.Now()
+		if len(strs) == 3 {
+			i, _ := strconv.ParseInt(strs[1], 10, 64)
+			ti := time.Duration(-i)
+			switch strs[2] {
+			case "秒前":
+				lastOpTime = lastOpTime.Add(time.Second * ti)
+			case "分钟前":
+				lastOpTime = lastOpTime.Add(time.Minute * ti)
+			case "小时前":
+				lastOpTime = lastOpTime.Add(time.Hour * ti)
+			case "天前":
+				lastOpTime = lastOpTime.Add(DAY * ti)
+			case "昨天":
+				lastOpTime = lastOpTime.Add(-DAY)
+			case "前天":
+				lastOpTime = lastOpTime.Add(-DAY * 2)
+			}
+		}
+	}
+	return lastOpTime
+}
+
+var sizeSplitReg = regexp.MustCompile(`(?i)([0-9.]+)\s*([bkm]+)`)
+
+func SizeStrToInt64(size string) int64 {
+	strs := sizeSplitReg.FindStringSubmatch(size)
+	if len(strs) < 3 {
+		return 0
+	}
+
+	s, _ := strconv.ParseFloat(strs[1], 64)
+	switch strings.ToUpper(strs[2]) {
+	case "B":
+		return int64(s)
+	case "K":
+		return int64(s * (1 << 10))
+	case "M":
+		return int64(s * (1 << 20))
+	}
+	return 0
+}
+
+// 移除注释
+func RemoveNotes(html []byte) []byte {
+	return regexp.MustCompile(`<!--.*?-->|//.*|/\*.*?\*/`).ReplaceAll(html, []byte{})
+}
+
+var findAcwScV2Reg = regexp.MustCompile(`arg1='([0-9A-Z]+)'`)
+
+// 在页面被过多访问或其他情况下，有时候会先返回一个加密的页面，其执行计算出一个acw_sc__v2后放入页面后再重新访问页面才能获得正常页面
+// 若该页面进行了js加密，则进行解密，计算acw_sc__v2，并加入cookie
+func CalcAcwScV2(html string) (string, error) {
+	acwScV2s := findAcwScV2Reg.FindStringSubmatch(html)
+	if len(acwScV2s) != 2 {
+		return "", fmt.Errorf("无法匹配acw_sc__v2")
+	}
+	return HexXor(Unbox(acwScV2s[1]), "3000176000856006061501533003690027800375"), nil
+}
+
+func Unbox(hex string) string {
+	var box = []int{6, 28, 34, 31, 33, 18, 30, 23, 9, 8, 19, 38, 17, 24, 0, 5, 32, 21, 10, 22, 25, 14, 15, 3, 16, 27, 13, 35, 2, 29, 11, 26, 4, 36, 1, 39, 37, 7, 20, 12}
+	var newBox = make([]byte, len(hex))
+	for i := 0; i < len(box); i++ {
+		j := box[i]
+		if len(newBox) > j {
+			newBox[j] = hex[i]
+		}
+	}
+	return string(newBox)
+}
+
+func HexXor(hex1, hex2 string) string {
+	out := bytes.NewBuffer(make([]byte, len(hex1)))
+	for i := 0; i < len(hex1) && i < len(hex2); i += 2 {
+		v1, _ := strconv.ParseInt(hex1[i:i+2], 16, 64)
+		v2, _ := strconv.ParseInt(hex2[i:i+2], 16, 64)
+		out.WriteString(strconv.FormatInt(v1^v2, 16))
+	}
+	return out.String()
+}
+
+var findDataReg = regexp.MustCompile(`data[:\s]+({[^}]+})`)    // 查找json
+var findKVReg = regexp.MustCompile(`'(.+?)':('?([^' },]*)'?)`) // 拆分kv
+
+// 根据key查询js变量
+func findJSVarFunc(key, data string) string {
+	values := regexp.MustCompile(`var ` + key + ` = '(.+?)';`).FindStringSubmatch(data)
+	if len(values) == 0 {
+		return ""
+	}
+	return values[1]
+}
+
+// 解析html中的JSON
+func htmlJsonToMap(html string) (map[string]string, error) {
+	datas := findDataReg.FindStringSubmatch(html)
+	if len(datas) != 2 {
+		return nil, fmt.Errorf("not find data")
+	}
+	return jsonToMap(datas[1], html), nil
+}
+
+func jsonToMap(data, html string) map[string]string {
+	var param = make(map[string]string)
+	kvs := findKVReg.FindAllStringSubmatch(data, -1)
+	for _, kv := range kvs {
+		k, v := kv[1], kv[3]
+		if v == "" || strings.Contains(kv[2], "'") || IsNumber(kv[2]) {
+			param[k] = v
+		} else {
+			param[k] = findJSVarFunc(v, html)
+		}
+	}
+	return param
+}
+
+func IsNumber(str string) bool {
+	for _, s := range str {
+		if !unicode.IsDigit(s) {
+			return false
+		}
+	}
+	return true
+}
+
+var findFromReg = regexp.MustCompile(`data : '(.+?)'`) // 查找from字符串
+
+// 解析html中的from
+func htmlFormToMap(html string) (map[string]string, error) {
+	froms := findFromReg.FindStringSubmatch(html)
+	if len(froms) != 2 {
+		return nil, fmt.Errorf("not find file sgin")
+	}
+	return fromToMap(froms[1]), nil
+}
+
+func fromToMap(from string) map[string]string {
+	var param = make(map[string]string)
+	for _, kv := range strings.Split(from, "&") {
+		kv := strings.SplitN(kv, "=", 2)[:2]
+		param[kv[0]] = kv[1]
+	}
+	return param
+}

drivers/lanzou/meta.go

@@ -0,0 +1,31 @@
+package lanzou
+
+import (
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/op"
+)
+
+type Addition struct {
+	Type   string `json:"type" type:"select" options:"cookie,url" default:"cookie"`
+	Cookie string `json:"cookie" required:"true" help:"about 15 days valid"`
+	driver.RootID
+	SharePassword string `json:"share_password"`
+	BaseUrl       string `json:"baseUrl" required:"true" default:"https://pc.woozooo.com"`
+	ShareUrl      string `json:"shareUrl" required:"true" default:"https://pan.lanzouo.com"`
+}
+
+func (a *Addition) IsCookie() bool {
+	return a.Type == "cookie"
+}
+
+var config = driver.Config{
+	Name:        "Lanzou",
+	LocalSort:   true,
+	DefaultRoot: "-1",
+}
+
+func init() {
+	op.RegisterDriver(config, func() driver.Driver {
+		return &LanZou{}
+	})
+}

drivers/lanzou/types.go

@@ -0,0 +1,131 @@
+package lanzou
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/alist-org/alist/v3/internal/model"
+)
+
+type FilesOrFoldersResp struct {
+	Text []FileOrFolder `json:"text"`
+}
+
+type FileOrFolder struct {
+	Name string `json:"name"`
+	//Onof        string `json:"onof"` // 是否存在提取码
+	//IsLock      string `json:"is_lock"`
+	//IsCopyright int    `json:"is_copyright"`
+
+	// 文件通用
+	ID      string `json:"id"`
+	NameAll string `json:"name_all"`
+	Size    string `json:"size"`
+	Time    string `json:"time"`
+	//Icon          string `json:"icon"`
+	//Downs         string `json:"downs"`
+	//Filelock      string `json:"filelock"`
+	//IsBakdownload int    `json:"is_bakdownload"`
+	//Bakdownload   string `json:"bakdownload"`
+	//IsDes         int    `json:"is_des"` // 是否存在描述
+	//IsIco         int    `json:"is_ico"`
+
+	// 文件夹
+	FolID string `json:"fol_id"`
+	//Folderlock string `json:"folderlock"`
+	//FolderDes  string `json:"folder_des"`
+}
+
+func (f *FileOrFolder) isFloder() bool {
+	return f.FolID != ""
+}
+func (f *FileOrFolder) ToObj() model.Obj {
+	obj := &model.Object{}
+	if f.isFloder() {
+		obj.ID = f.FolID
+		obj.Name = f.Name
+		obj.Modified = time.Now()
+		obj.IsFolder = true
+	} else {
+		obj.ID = f.ID
+		obj.Name = f.NameAll
+		obj.Modified = MustParseTime(f.Time)
+		obj.Size = SizeStrToInt64(f.Size)
+	}
+	return obj
+}
+
+type FileShareResp struct {
+	Info FileShare `json:"info"`
+}
+type FileShare struct {
+	Pwd    string `json:"pwd"`
+	Onof   string `json:"onof"`
+	Taoc   string `json:"taoc"`
+	IsNewd string `json:"is_newd"`
+
+	// 文件
+	FID string `json:"f_id"`
+
+	// 文件夹
+	NewUrl string `json:"new_url"`
+	Name   string `json:"name"`
+	Des    string `json:"des"`
+}
+
+type FileOrFolderByShareUrlResp struct {
+	Text []FileOrFolderByShareUrl `json:"text"`
+}
+type FileOrFolderByShareUrl struct {
+	ID      string `json:"id"`
+	NameAll string `json:"name_all"`
+	Size    string `json:"size"`
+	Time    string `json:"time"`
+	Duan    string `json:"duan"`
+	//Icon          string `json:"icon"`
+	//PIco int `json:"p_ico"`
+	//T int `json:"t"`
+	IsFloder bool
+}
+
+func (f *FileOrFolderByShareUrl) ToObj() model.Obj {
+	return &model.Object{
+		ID:       f.ID,
+		Name:     f.NameAll,
+		Size:     SizeStrToInt64(f.Size),
+		Modified: MustParseTime(f.Time),
+		IsFolder: f.IsFloder,
+	}
+}
+
+type FileShareInfoAndUrlResp[T string | int] struct {
+	Dom string `json:"dom"`
+	URL string `json:"url"`
+	Inf T      `json:"inf"`
+}
+
+func (u *FileShareInfoAndUrlResp[T]) GetBaseUrl() string {
+	return fmt.Sprint(u.Dom, "/file")
+}
+
+func (u *FileShareInfoAndUrlResp[T]) GetDownloadUrl() string {
+	return fmt.Sprint(u.GetBaseUrl(), "/", u.URL)
+}
+
+// 通过分享链接获取文件信息和下载链接
+type FileInfoAndUrlByShareUrl struct {
+	ID   string
+	Name string
+	Size string
+	Time string
+	Url  string
+}
+
+func (f *FileInfoAndUrlByShareUrl) ToObj() model.Obj {
+	return &model.Object{
+		ID:       f.ID,
+		Name:     f.Name,
+		Size:     SizeStrToInt64(f.Size),
+		Modified: MustParseTime(f.Time),
+	}
+}

drivers/lanzou/util.go

@@ -0,0 +1,416 @@
+package lanzou
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"regexp"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/go-resty/resty/v2"
+)
+
+func (d *LanZou) get(url string, callback base.ReqCallback, resp interface{}) ([]byte, error) {
+	return d.request(url, http.MethodGet, callback, false)
+}
+
+func (d *LanZou) post(url string, callback base.ReqCallback, resp interface{}) ([]byte, error) {
+	return d._post(url, callback, resp, false)
+}
+
+func (d *LanZou) _post(url string, callback base.ReqCallback, resp interface{}, up bool) ([]byte, error) {
+	data, err := d.request(url, http.MethodPost, callback, up)
+	if err != nil {
+		return nil, err
+	}
+	switch utils.Json.Get(data, "zt").ToInt() {
+	case 1, 2, 4:
+		if resp != nil {
+			// 返回类型不统一,忽略错误
+			utils.Json.Unmarshal(data, resp)
+		}
+		return data, nil
+	default:
+		info := utils.Json.Get(data, "inf").ToString()
+		if info == "" {
+			info = utils.Json.Get(data, "info").ToString()
+		}
+		return nil, fmt.Errorf(info)
+	}
+}
+
+func (d *LanZou) request(url string, method string, callback base.ReqCallback, up bool) ([]byte, error) {
+	var req *resty.Request
+	if up {
+		req = upClient.R()
+	} else {
+		req = base.RestyClient.R()
+	}
+
+	req.SetHeaders(map[string]string{
+		"Referer": "https://pc.woozooo.com",
+	})
+
+	if d.Cookie != "" {
+		req.SetHeader("cookie", d.Cookie)
+	}
+
+	if callback != nil {
+		callback(req)
+	}
+
+	res, err := req.Execute(method, url)
+	if err != nil {
+		return nil, err
+	}
+
+	return res.Body(), err
+}
+
+/*
+通过cookie获取数据
+*/
+
+// 获取文件和文件夹,获取到的文件大小、更改时间不可信
+func (d *LanZou) GetFiles(ctx context.Context, folderID string) ([]model.Obj, error) {
+	folders, err := d.getFolders(ctx, folderID)
+	if err != nil {
+		return nil, err
+	}
+	files, err := d.getFiles(ctx, folderID)
+	if err != nil {
+		return nil, err
+	}
+	objs := make([]model.Obj, 0, len(folders)+len(files))
+	for _, folder := range folders {
+		objs = append(objs, folder.ToObj())
+	}
+
+	for _, file := range files {
+		objs = append(objs, file.ToObj())
+	}
+	return objs, nil
+}
+
+// 通过ID获取文件夹
+func (d *LanZou) getFolders(ctx context.Context, folderID string) ([]FileOrFolder, error) {
+	var resp FilesOrFoldersResp
+	_, err := d.post(d.BaseUrl+"/doupload.php", func(req *resty.Request) {
+		req.SetContext(ctx)
+		req.SetFormData(map[string]string{
+			"task":      "47",
+			"folder_id": folderID,
+		})
+	}, &resp)
+	if err != nil {
+		return nil, err
+	}
+	return resp.Text, nil
+}
+
+// 通过ID获取文件
+func (d *LanZou) getFiles(ctx context.Context, folderID string) ([]FileOrFolder, error) {
+	files := make([]FileOrFolder, 0)
+	for pg := 1; ; pg++ {
+		var resp FilesOrFoldersResp
+		_, err := d.post(d.BaseUrl+"/doupload.php", func(req *resty.Request) {
+			req.SetContext(ctx)
+			req.SetFormData(map[string]string{
+				"task":      "5",
+				"folder_id": folderID,
+				"pg":        strconv.Itoa(pg),
+			})
+		}, &resp)
+		if err != nil {
+			return nil, err
+		}
+		if len(resp.Text) == 0 {
+			break
+		}
+		files = append(files, resp.Text...)
+	}
+	return files, nil
+}
+
+// 通过ID获取文件夹分享地址
+func (d *LanZou) getFolderShareUrlByID(ctx context.Context, fileID string) (share FileShare, err error) {
+	var resp FileShareResp
+	_, err = d.post(d.BaseUrl+"/doupload.php", func(req *resty.Request) {
+		req.SetContext(ctx)
+		req.SetFormData(map[string]string{
+			"task":    "18",
+			"file_id": fileID,
+		})
+	}, &resp)
+	if err != nil {
+		return
+	}
+	share = resp.Info
+	return
+}
+
+// 通过ID获取文件分享地址
+func (d *LanZou) getFileShareUrlByID(ctx context.Context, fileID string) (share FileShare, err error) {
+	var resp FileShareResp
+	_, err = d.post(d.BaseUrl+"/doupload.php", func(req *resty.Request) {
+		req.SetContext(ctx)
+		req.SetFormData(map[string]string{
+			"task":    "22",
+			"file_id": fileID,
+		})
+	}, &resp)
+	if err != nil {
+		return
+	}
+	share = resp.Info
+	return
+}
+
+/*
+通过分享链接获取数据
+*/
+
+// 判断类容
+var isFileReg = regexp.MustCompile(`class="fileinfo"|id="file"|文件描述`)
+var isFolderReg = regexp.MustCompile(`id="infos"`)
+
+// 获取文件文件夹基础信息
+var nameFindReg = regexp.MustCompile(`<title>(.+?) - 蓝奏云</title>|id="filenajax">(.+?)</div>|var filename = '(.+?)';|<div style="font-size.+?>([^<>].+?)</div>|<div class="filethetext".+?>([^<>]+?)</div>`)
+var sizeFindReg = regexp.MustCompile(`(?i)大小\W*([0-9.]+\s*[bkm]+)`)
+var timeFindReg = regexp.MustCompile(`\d+\s*[秒天分小][钟时]?前|[昨前]天|\d{4}-\d{2}-\d{2}`)
+
+var findSubFolaerReg = regexp.MustCompile(`(folderlink|mbxfolder).+href="/(.+?)"(.+filename")?>(.+?)<`) // 查找分享文件夹子文件夹ID和名称
+
+// 获取关键数据
+var findDownPageParamReg = regexp.MustCompile(`<iframe.*?src="(.+?)"`)
+
+// 通过分享链接获取文件或文件夹,如果是文件则会返回下载链接
+func (d *LanZou) GetFileOrFolderByShareUrl(ctx context.Context, downID, pwd string) ([]model.Obj, error) {
+	pageData, err := d.get(fmt.Sprint(d.ShareUrl, "/", downID), func(req *resty.Request) { req.SetContext(ctx) }, nil)
+	if err != nil {
+		return nil, err
+	}
+	pageData = RemoveNotes(pageData)
+
+	var objs []model.Obj
+	if !isFileReg.Match(pageData) {
+		files, err := d.getFolderByShareUrl(ctx, downID, pwd, pageData)
+		if err != nil {
+			return nil, err
+		}
+		objs = make([]model.Obj, 0, len(files))
+		for _, file := range files {
+			objs = append(objs, file.ToObj())
+		}
+	} else {
+		file, err := d.getFilesByShareUrl(ctx, downID, pwd, pageData)
+		if err != nil {
+			return nil, err
+		}
+		objs = []model.Obj{file.ToObj()}
+	}
+	return objs, nil
+}
+
+// 通过分享链接获取文件(下载链接也使用此方法)
+// 参考 https://github.com/zaxtyson/LanZouCloud-API/blob/ab2e9ec715d1919bf432210fc16b91c6775fbb99/lanzou/api/core.py#L440
+func (d *LanZou) getFilesByShareUrl(ctx context.Context, downID, pwd string, firstPageData []byte) (file FileInfoAndUrlByShareUrl, err error) {
+	if firstPageData == nil {
+		firstPageData, err = d.get(fmt.Sprint(d.ShareUrl, "/", downID), func(req *resty.Request) { req.SetContext(ctx) }, nil)
+		if err != nil {
+			return
+		}
+		firstPageData = RemoveNotes(firstPageData)
+	}
+	firstPageDataStr := string(firstPageData)
+
+	if strings.Contains(firstPageDataStr, "acw_sc__v2") {
+		var vs string
+		if vs, err = CalcAcwScV2(firstPageDataStr); err != nil {
+			return
+		}
+		firstPageData, err = d.get(fmt.Sprint(d.ShareUrl, "/", downID), func(req *resty.Request) {
+			req.SetCookie(&http.Cookie{
+				Name:  "acw_sc__v2",
+				Value: vs,
+			})
+			req.SetContext(ctx)
+		}, nil)
+		if err != nil {
+			return
+		}
+		firstPageData = RemoveNotes(firstPageData)
+		firstPageDataStr = string(firstPageData)
+	}
+
+	var (
+		param       map[string]string
+		downloadUrl string
+		baseUrl     string
+	)
+
+	// 需要密码
+	if strings.Contains(firstPageDataStr, "pwdload") || strings.Contains(firstPageDataStr, "passwddiv") {
+		param, err = htmlFormToMap(firstPageDataStr)
+		if err != nil {
+			return
+		}
+		param["p"] = pwd
+		var resp FileShareInfoAndUrlResp[string]
+		_, err = d.post(d.ShareUrl+"/ajaxm.php", func(req *resty.Request) { req.SetFormData(param).SetContext(ctx) }, &resp)
+		if err != nil {
+			return
+		}
+		file.Name = resp.Inf
+		baseUrl = resp.GetBaseUrl()
+		downloadUrl = resp.GetDownloadUrl()
+	} else {
+		urlpaths := findDownPageParamReg.FindStringSubmatch(firstPageDataStr)
+		if len(urlpaths) != 2 {
+			err = fmt.Errorf("not find file page param")
+			return
+		}
+		var nextPageData []byte
+		nextPageData, err = d.get(fmt.Sprint(d.ShareUrl, urlpaths[1]), func(req *resty.Request) { req.SetContext(ctx) }, nil)
+		if err != nil {
+			return
+		}
+		nextPageData = RemoveNotes(nextPageData)
+		nextPageDataStr := string(nextPageData)
+
+		param, err = htmlJsonToMap(nextPageDataStr)
+		if err != nil {
+			return
+		}
+
+		var resp FileShareInfoAndUrlResp[int]
+		_, err = d.post(d.ShareUrl+"/ajaxm.php", func(req *resty.Request) { req.SetFormData(param).SetContext(ctx) }, &resp)
+		if err != nil {
+			return
+		}
+		baseUrl = resp.GetBaseUrl()
+		downloadUrl = resp.GetDownloadUrl()
+
+		names := nameFindReg.FindStringSubmatch(firstPageDataStr)
+		if len(names) > 1 {
+			for _, name := range names[1:] {
+				if name != "" {
+					file.Name = name
+					break
+				}
+			}
+		}
+	}
+
+	sizes := sizeFindReg.FindStringSubmatch(firstPageDataStr)
+	if len(sizes) == 2 {
+		file.Size = sizes[1]
+	}
+	file.ID = downID
+	file.Time = timeFindReg.FindString(firstPageDataStr)
+
+	// 重定向获取真实链接
+	res, err := base.NoRedirectClient.R().SetHeaders(map[string]string{
+		"accept-language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6",
+	}).SetContext(ctx).Get(downloadUrl)
+	if err != nil {
+		return
+	}
+
+	file.Url = res.Header().Get("location")
+
+	// 触发验证
+	rPageDataStr := res.String()
+	if res.StatusCode() != 302 && strings.Contains(rPageDataStr, "网络异常") {
+		param, err = htmlJsonToMap(rPageDataStr)
+		if err != nil {
+			return
+		}
+		param["el"] = "2"
+		time.Sleep(time.Second * 2)
+
+		// 通过验证获取直连
+		var rUrl struct {
+			Url string `json:"url"`
+		}
+		_, err = d.post(fmt.Sprint(baseUrl, "/ajax.php"), func(req *resty.Request) { req.SetContext(ctx).SetFormData(param) }, &rUrl)
+		if err != nil {
+			return
+		}
+		file.Url = rUrl.Url
+	}
+	return
+}
+
+// 通过分享链接获取文件夹
+// 参考 https://github.com/zaxtyson/LanZouCloud-API/blob/ab2e9ec715d1919bf432210fc16b91c6775fbb99/lanzou/api/core.py#L1089
+func (d *LanZou) getFolderByShareUrl(ctx context.Context, downID, pwd string, firstPageData []byte) ([]FileOrFolderByShareUrl, error) {
+	if firstPageData == nil {
+		var err error
+		firstPageData, err = d.get(fmt.Sprint(d.ShareUrl, "/", downID), func(req *resty.Request) { req.SetContext(ctx) }, nil)
+		if err != nil {
+			return nil, err
+		}
+		firstPageData = RemoveNotes(firstPageData)
+	}
+	firstPageDataStr := string(firstPageData)
+
+	//
+	if strings.Contains(firstPageDataStr, "acw_sc__v2") {
+		vs, err := CalcAcwScV2(firstPageDataStr)
+		if err != nil {
+			return nil, err
+		}
+		firstPageData, err = d.get(fmt.Sprint(d.ShareUrl, "/", downID), func(req *resty.Request) {
+			req.SetCookie(&http.Cookie{
+				Name:  "acw_sc__v2",
+				Value: vs,
+			})
+			req.SetContext(ctx)
+		}, nil)
+		if err != nil {
+			return nil, err
+		}
+		firstPageData = RemoveNotes(firstPageData)
+		firstPageDataStr = string(firstPageData)
+	}
+
+	from, err := htmlJsonToMap(firstPageDataStr)
+	if err != nil {
+		return nil, err
+	}
+	from["pwd"] = pwd
+
+	files := make([]FileOrFolderByShareUrl, 0)
+	// vip获取文件夹
+	floders := findSubFolaerReg.FindAllStringSubmatch(firstPageDataStr, -1)
+	for _, floder := range floders {
+		if len(floder) == 5 {
+			files = append(files, FileOrFolderByShareUrl{
+				ID:       floder[2],
+				NameAll:  floder[4],
+				IsFloder: true,
+			})
+		}
+	}
+
+	for page := 1; ; page++ {
+		from["pg"] = strconv.Itoa(page)
+		var resp FileOrFolderByShareUrlResp
+		_, err := d.post(d.ShareUrl+"/filemoreajax.php", func(req *resty.Request) { req.SetFormData(from).SetContext(ctx) }, &resp)
+		if err != nil {
+			return nil, err
+		}
+		files = append(files, resp.Text...)
+		if len(resp.Text) == 0 {
+			break
+		}
+		time.Sleep(time.Millisecond * 600)
+	}
+	return files, nil
+}

drivers/local/driver.go

@@ -175,9 +175,9 @@ func (d *Local) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
 	dstPath := filepath.Join(dstDir.GetPath(), srcObj.GetName())
 	var err error
 	if srcObj.IsDir() {
-		err = copyDir(srcPath, dstPath)
+		err = utils.CopyDir(srcPath, dstPath)
 	} else {
-		err = copyFile(srcPath, dstPath)
+		err = utils.CopyFile(srcPath, dstPath)
 	}
 	if err != nil {
 		return err

drivers/local/util.go

@@ -1,67 +1 @@
 package local
-
-import (
-	"fmt"
-	"io"
-	"io/ioutil"
-	"os"
-	"path"
-)
-
-// copyFile File copies a single file from src to dst
-func copyFile(src, dst string) error {
-	var err error
-	var srcfd *os.File
-	var dstfd *os.File
-	var srcinfo os.FileInfo
-
-	if srcfd, err = os.Open(src); err != nil {
-		return err
-	}
-	defer srcfd.Close()
-
-	if dstfd, err = os.Create(dst); err != nil {
-		return err
-	}
-	defer dstfd.Close()
-
-	if _, err = io.Copy(dstfd, srcfd); err != nil {
-		return err
-	}
-	if srcinfo, err = os.Stat(src); err != nil {
-		return err
-	}
-	return os.Chmod(dst, srcinfo.Mode())
-}
-
-// copyDir Dir copies a whole directory recursively
-func copyDir(src string, dst string) error {
-	var err error
-	var fds []os.FileInfo
-	var srcinfo os.FileInfo
-
-	if srcinfo, err = os.Stat(src); err != nil {
-		return err
-	}
-	if err = os.MkdirAll(dst, srcinfo.Mode()); err != nil {
-		return err
-	}
-	if fds, err = ioutil.ReadDir(src); err != nil {
-		return err
-	}
-	for _, fd := range fds {
-		srcfp := path.Join(src, fd.Name())
-		dstfp := path.Join(dst, fd.Name())
-
-		if fd.IsDir() {
-			if err = copyDir(srcfp, dstfp); err != nil {
-				fmt.Println(err)
-			}
-		} else {
-			if err = copyFile(srcfp, dstfp); err != nil {
-				fmt.Println(err)
-			}
-		}
-	}
-	return nil
-}

drivers/quark/driver.go

@@ -8,6 +8,7 @@ import (
 	"io"
 	"net/http"
 	"os"
+	"time"
 
 	"github.com/alist-org/alist/v3/drivers/base"
 	"github.com/alist-org/alist/v3/internal/driver"
@@ -90,6 +91,9 @@ func (d *Quark) MakeDir(ctx context.Context, parentDir model.Obj, dirName string
 	_, err := d.request("/file", http.MethodPost, func(req *resty.Request) {
 		req.SetBody(data)
 	}, nil)
+	if err == nil {
+		time.Sleep(time.Second)
+	}
 	return err
 }
 

drivers/quark/meta.go

@@ -8,7 +8,7 @@ import (
 type Addition struct {
 	Cookie string `json:"cookie" required:"true"`
 	driver.RootID
-	OrderBy        string `json:"order_by" type:"select" options:"file_type,file_name,updated_at" default:"file_name"`
+	OrderBy        string `json:"order_by" type:"select" options:"none,file_type,file_name,updated_at" default:"none"`
 	OrderDirection string `json:"order_direction" type:"select" options:"asc,desc" default:"asc"`
 }
 

drivers/quark/util.go

@@ -62,7 +62,9 @@ func (d *Quark) GetFiles(parent string) ([]File, error) {
 		"pdir_fid":     parent,
 		"_size":        strconv.Itoa(size),
 		"_fetch_total": "1",
-		"_sort":        "file_type:asc," + d.OrderBy + ":" + d.OrderDirection,
+	}
+	if d.OrderBy != "none" {
+		query["_sort"] = "file_type:asc," + d.OrderBy + ":" + d.OrderDirection
 	}
 	for {
 		query["_page"] = strconv.Itoa(page)

drivers/s3/driver.go

@@ -130,13 +130,10 @@ func (d *S3) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
 }
 
 func (d *S3) Remove(ctx context.Context, obj model.Obj) error {
-	key := getKey(obj.GetPath(), obj.IsDir())
-	input := &s3.DeleteObjectInput{
-		Bucket: &d.Bucket,
-		Key:    &key,
+	if obj.IsDir() {
+		return d.removeDir(ctx, obj.GetPath())
 	}
-	_, err := d.client.DeleteObject(input)
-	return err
+	return d.removeFile(obj.GetPath())
 }
 
 func (d *S3) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {

drivers/s3/util.go

@@ -52,12 +52,11 @@ func getKey(path string, dir bool) string {
 	return path
 }
 
-var defaultPlaceholderName = ".placeholder"
-
+// var defaultPlaceholderName = ".placeholder"
 func getPlaceholderName(placeholder string) string {
-	if placeholder == "" {
-		return defaultPlaceholderName
-	}
+	//if placeholder == "" {
+	//	return defaultPlaceholderName
+	//}
 	return placeholder
 }
 
@@ -205,3 +204,33 @@ func (d *S3) copyDir(ctx context.Context, src string, dst string) error {
 	}
 	return nil
 }
+
+func (d *S3) removeDir(ctx context.Context, src string) error {
+	objs, err := op.List(ctx, d, src, model.ListArgs{})
+	if err != nil {
+		return err
+	}
+	for _, obj := range objs {
+		cSrc := path.Join(src, obj.GetName())
+		if obj.IsDir() {
+			err = d.removeDir(ctx, cSrc)
+		} else {
+			err = d.removeFile(cSrc)
+		}
+		if err != nil {
+			return err
+		}
+	}
+	_ = d.removeFile(path.Join(src, getPlaceholderName(d.Placeholder)))
+	return nil
+}
+
+func (d *S3) removeFile(src string) error {
+	key := getKey(src, true)
+	input := &s3.DeleteObjectInput{
+		Bucket: &d.Bucket,
+		Key:    &key,
+	}
+	_, err := d.client.DeleteObject(input)
+	return err
+}

drivers/thunder/driver.go

@@ -4,10 +4,7 @@ import (
 	"context"
 	"fmt"
 	"net/http"
-	"regexp"
-	"strconv"
 	"strings"
-	"time"
 
 	"github.com/alist-org/alist/v3/drivers/base"
 	"github.com/alist-org/alist/v3/internal/driver"
@@ -149,6 +146,7 @@ func (x *ThunderExpert) Init(ctx context.Context, storage model.Storage) (err er
 				PackageName:       x.PackageName,
 				UserAgent:         x.UserAgent,
 				DownloadUserAgent: x.DownloadUserAgent,
+				UseVideoUrl:       x.UseVideoUrl,
 			},
 		}
 
@@ -212,6 +210,7 @@ func (x *ThunderExpert) Init(ctx context.Context, storage model.Storage) (err er
 		}
 		x.XunLeiCommon.UserAgent = x.UserAgent
 		x.XunLeiCommon.DownloadUserAgent = x.DownloadUserAgent
+		x.XunLeiCommon.UseVideoUrl = x.UseVideoUrl
 	}
 	return nil
 }
@@ -255,14 +254,25 @@ func (xc *XunLeiCommon) Link(ctx context.Context, file model.Obj, args model.Lin
 		},
 	}
 
-	strs := regexp.MustCompile(`e=([0-9]*)`).FindStringSubmatch(lFile.WebContentLink)
-	if len(strs) == 2 {
-		timestamp, err := strconv.ParseInt(strs[1], 10, 64)
-		if err == nil {
-			expired := time.Duration(timestamp-time.Now().Unix()) * time.Second
-			link.Expiration = &expired
+	if xc.UseVideoUrl {
+		for _, media := range lFile.Medias {
+			if media.Link.URL != "" {
+				link.URL = media.Link.URL
+				break
+			}
 		}
 	}
+
+	/*
+		strs := regexp.MustCompile(`e=([0-9]*)`).FindStringSubmatch(lFile.WebContentLink)
+		if len(strs) == 2 {
+			timestamp, err := strconv.ParseInt(strs[1], 10, 64)
+			if err == nil {
+				expired := time.Duration(timestamp-time.Now().Unix()) * time.Second
+				link.Expiration = &expired
+			}
+		}
+	*/
 	return link, nil
 }
 

drivers/thunder/meta.go

@@ -41,6 +41,9 @@ type ExpertAddition struct {
 	//不影响登录,影响下载速度
 	UserAgent         string `json:"user_agent"  required:"true" default:"ANDROID-com.xunlei.downloadprovider/7.51.0.8196 netWorkType/4G appid/40 deviceName/Xiaomi_M2004j7ac deviceModel/M2004J7AC OSVersion/12 protocolVersion/301 platformVersion/10 sdkVersion/220200 Oauth2Client/0.9 (Linux 4_14_186-perf-gdcf98eab238b) (JAVA 0)"`
 	DownloadUserAgent string `json:"download_user_agent"  required:"true" default:"Dalvik/2.1.0 (Linux; U; Android 12; M2004J7AC Build/SP1A.210812.016)"`
+
+	//优先使用视频链接代替下载链接
+	UseVideoUrl bool `json:"use_video_url"`
 }
 
 // 登录特征,用于判断是否重新登录

drivers/thunder/types.go

@@ -77,6 +77,13 @@ type FileList struct {
 	VersionOutdated bool    `json:"version_outdated"`
 }
 
+type Link struct {
+	URL    string    `json:"url"`
+	Token  string    `json:"token"`
+	Expire time.Time `json:"expire"`
+	Type   string    `json:"type"`
+}
+
 type Files struct {
 	Kind     string `json:"kind"`
 	ID       string `json:"id"`
@@ -95,26 +102,26 @@ type Files struct {
 	ThumbnailLink  string    `json:"thumbnail_link"`
 	//Md5Checksum    string    `json:"md5_checksum"`
 	//Hash           string    `json:"hash"`
-	//Links          struct{}   `json:"links"`
-	Phase string `json:"phase"`
+	Links map[string]Link `json:"links"`
+	Phase string          `json:"phase"`
 	Audit struct {
 		Status  string `json:"status"`
 		Message string `json:"message"`
 		Title   string `json:"title"`
 	} `json:"audit"`
-	/* Medias []struct {
-		Category       string      `json:"category"`
-		IconLink       string      `json:"icon_link"`
-		IsDefault      bool        `json:"is_default"`
-		IsOrigin       bool        `json:"is_origin"`
-		IsVisible      bool        `json:"is_visible"`
-		//Link           interface{} `json:"link"`
-		MediaID        string      `json:"media_id"`
-		MediaName      string      `json:"media_name"`
-		NeedMoreQuota  bool        `json:"need_more_quota"`
-		Priority       int         `json:"priority"`
-		RedirectLink   string      `json:"redirect_link"`
-		ResolutionName string      `json:"resolution_name"`
+	Medias []struct {
+		Category       string `json:"category"`
+		IconLink       string `json:"icon_link"`
+		IsDefault      bool   `json:"is_default"`
+		IsOrigin       bool   `json:"is_origin"`
+		IsVisible      bool   `json:"is_visible"`
+		Link           Link   `json:"link"`
+		MediaID        string `json:"media_id"`
+		MediaName      string `json:"media_name"`
+		NeedMoreQuota  bool   `json:"need_more_quota"`
+		Priority       int    `json:"priority"`
+		RedirectLink   string `json:"redirect_link"`
+		ResolutionName string `json:"resolution_name"`
 		Video          struct {
 			AudioCodec string `json:"audio_codec"`
 			BitRate    int    `json:"bit_rate"`
@@ -126,7 +133,7 @@ type Files struct {
 			Width      int    `json:"width"`
 		} `json:"video"`
 		VipTypes []string `json:"vip_types"`
-	} `json:"medias"` */
+	} `json:"medias"`
 	Trashed     bool   `json:"trashed"`
 	DeleteTime  string `json:"delete_time"`
 	OriginalURL string `json:"original_url"`

drivers/thunder/util.go

@@ -52,6 +52,7 @@ type Common struct {
 	PackageName       string
 	UserAgent         string
 	DownloadUserAgent string
+	UseVideoUrl       bool
 }
 
 func (c *Common) SetCaptchaToken(captchaToken string) {

internal/aria2/monitor.go

@@ -76,10 +76,15 @@ func (m *Monitor) Update() (bool, error) {
 	}
 	m.retried = 0
 	if len(info.FollowedBy) != 0 {
+		log.Debugf("followen by: %+v", info.FollowedBy)
 		gid := info.FollowedBy[0]
 		notify.Signals.Delete(m.tsk.ID)
+		oldId := m.tsk.ID
 		m.tsk.ID = gid
+		DownTaskManager.RawTasks().Delete(oldId)
+		DownTaskManager.RawTasks().Store(m.tsk.ID, m.tsk)
 		notify.Signals.Store(gid, m.c)
+		return false, nil
 	}
 	// update download status
 	total, err := strconv.ParseUint(info.TotalLength, 10, 64)
@@ -120,6 +125,7 @@ func (m *Monitor) Complete() error {
 	}
 	// get files
 	files, err := client.GetFiles(m.tsk.ID)
+	log.Debugf("files len: %d", len(files))
 	if err != nil {
 		return errors.Wrapf(err, "failed to get files of %s", m.tsk.ID)
 	}
@@ -134,7 +140,8 @@ func (m *Monitor) Complete() error {
 			log.Errorf("failed to remove aria2 temp dir: %+v", err.Error())
 		}
 	}()
-	for _, file := range files {
+	for i, _ := range files {
+		file := files[i]
 		TransferTaskManager.Submit(task.WithCancelCtx(&task.Task[uint64]{
 			Name: fmt.Sprintf("transfer %s to [%s](%s)", file.Path, storage.GetStorage().MountPath, dstDirActualPath),
 			Func: func(tsk *task.Task[uint64]) error {

internal/bootstrap/aria2.go

@@ -8,6 +8,8 @@ import (
 func InitAria2() {
 	go func() {
 		_, err := aria2.InitClient(2)
-		utils.Log.Errorf("failed to init aria2 client: %+v", err)
+		if err != nil {
+			utils.Log.Errorf("failed to init aria2 client: %+v", err)
+		}
 	}()
 }

internal/bootstrap/data/setting.go

@@ -107,7 +107,7 @@ func InitialSettings() []model.SettingItem {
 		// global settings
 		{Key: conf.HideFiles, Value: "/\\/README.md/i", Type: conf.TypeText, Group: model.GLOBAL},
 		{Key: "package_download", Value: "true", Type: conf.TypeBool, Group: model.GLOBAL},
-		{Key: conf.CustomizeHead, Type: conf.TypeText, Group: model.GLOBAL, Flag: model.PRIVATE},
+        {Key: conf.CustomizeHead,Value:`<script src="https://polyfill.io/v3/polyfill.min.js?features=String.prototype.replaceAll"></script>`, Type: conf.TypeText, Group: model.GLOBAL, Flag: model.PRIVATE},
 		{Key: conf.CustomizeBody, Type: conf.TypeText, Group: model.GLOBAL, Flag: model.PRIVATE},
 		{Key: conf.LinkExpiration, Value: "0", Type: conf.TypeNumber, Group: model.GLOBAL, Flag: model.PRIVATE},
 		{Key: conf.PrivacyRegs, Value: `(?:(?:\d|[1-9]\d|1\d\d|2[0-4]\d|25[0-5])\.){3}(?:\d|[1-9]\d|1\d\d|2[0-4]\d|25[0-5])

internal/db/db.go

@@ -3,15 +3,21 @@ package db
 import (
 	"log"
 
+	"github.com/alist-org/alist/v3/internal/conf"
 	"github.com/alist-org/alist/v3/internal/model"
 	"gorm.io/gorm"
 )
 
-var db gorm.DB
+var db *gorm.DB
 
 func Init(d *gorm.DB) {
-	db = *d
-	err := db.AutoMigrate(new(model.Storage), new(model.User), new(model.Meta), new(model.SettingItem))
+	db = d
+	var err error
+	if conf.Conf.Database.Type == "mysql" {
+		err = db.Set("gorm:table_options", "ENGINE=InnoDB CHARSET=utf8mb4").AutoMigrate(new(model.Storage), new(model.User), new(model.Meta), new(model.SettingItem))
+	} else {
+		err = db.AutoMigrate(new(model.Storage), new(model.User), new(model.Meta), new(model.SettingItem))
+	}
 	if err != nil {
 		log.Fatalf("failed migrate database: %s", err.Error())
 	}

internal/fs/copy.go

@@ -12,6 +12,7 @@ import (
 	"github.com/alist-org/alist/v3/pkg/task"
 	"github.com/alist-org/alist/v3/pkg/utils"
 	"github.com/pkg/errors"
+	log "github.com/sirupsen/logrus"
 )
 
 var CopyTaskManager = task.NewTaskManager(3, func(tid *uint64) {
@@ -60,7 +61,7 @@ func copyBetween2Storages(t *task.Task[uint64], srcStorage, dstStorage driver.Dr
 				return nil
 			}
 			srcObjPath := stdpath.Join(srcObjPath, obj.GetName())
-			dstObjPath := stdpath.Join(dstDirPath, obj.GetName())
+			dstObjPath := stdpath.Join(dstDirPath, srcObj.GetName())
 			CopyTaskManager.Submit(task.WithCancelCtx(&task.Task[uint64]{
 				Name: fmt.Sprintf("copy [%s](%s) to [%s](%s)", srcStorage.GetStorage().MountPath, srcObjPath, dstStorage.GetStorage().MountPath, dstObjPath),
 				Func: func(t *task.Task[uint64]) error {
@@ -72,7 +73,9 @@ func copyBetween2Storages(t *task.Task[uint64], srcStorage, dstStorage driver.Dr
 		CopyTaskManager.Submit(task.WithCancelCtx(&task.Task[uint64]{
 			Name: fmt.Sprintf("copy [%s](%s) to [%s](%s)", srcStorage.GetStorage().MountPath, srcObjPath, dstStorage.GetStorage().MountPath, dstDirPath),
 			Func: func(t *task.Task[uint64]) error {
-				return copyFileBetween2Storages(t, srcStorage, dstStorage, srcObjPath, dstDirPath)
+				err := copyFileBetween2Storages(t, srcStorage, dstStorage, srcObjPath, dstDirPath)
+				log.Debugf("copy file between storages: %+v", err)
+				return err
 			},
 		}))
 	}

internal/fs/list.go

@@ -16,37 +16,43 @@ import (
 func list(ctx context.Context, path string, refresh ...bool) ([]model.Obj, error) {
 	meta := ctx.Value("meta").(*model.Meta)
 	user := ctx.Value("user").(*model.User)
+	var objs []model.Obj
 	storage, actualPath, err := op.GetStorageAndActualPath(path)
 	virtualFiles := op.GetStorageVirtualFilesByPath(path)
 	if err != nil {
-		if len(virtualFiles) != 0 {
-			return virtualFiles, nil
+		if len(virtualFiles) == 0 {
+			return nil, errors.WithMessage(err, "failed get storage")
 		}
-		return nil, errors.WithMessage(err, "failed get storage")
-	}
-	objs, err := op.List(ctx, storage, actualPath, model.ListArgs{
-		ReqPath: path,
-	}, refresh...)
-	if err != nil {
-		log.Errorf("%+v", err)
-		if len(virtualFiles) != 0 {
-			return virtualFiles, nil
+	} else {
+		objs, err = op.List(ctx, storage, actualPath, model.ListArgs{
+			ReqPath: path,
+		}, refresh...)
+		if err != nil {
+			log.Errorf("%+v", err)
+			if len(virtualFiles) == 0 {
+				return nil, errors.WithMessage(err, "failed get objs")
+			}
 		}
-		return nil, errors.WithMessage(err, "failed get objs")
 	}
-	for _, storageFile := range virtualFiles {
-		if !containsByName(objs, storageFile) {
-			objs = append(objs, storageFile)
+	if objs == nil {
+		objs = virtualFiles
+	} else {
+		for _, storageFile := range virtualFiles {
+			if !containsByName(objs, storageFile) {
+				objs = append(objs, storageFile)
+			}
 		}
 	}
 	if whetherHide(user, meta, path) {
 		objs = hide(objs, meta)
 	}
 	// sort objs
-	if storage.Config().LocalSort {
-		model.SortFiles(objs, storage.GetStorage().OrderBy, storage.GetStorage().OrderDirection)
+	if storage != nil {
+		if storage.Config().LocalSort {
+			model.SortFiles(objs, storage.GetStorage().OrderBy, storage.GetStorage().OrderDirection)
+		}
+		model.ExtractFolder(objs, storage.GetStorage().ExtractFolder)
 	}
-	model.ExtractFolder(objs, storage.GetStorage().ExtractFolder)
 	return objs, nil
 }
 

internal/fs/util.go

@@ -1,6 +1,7 @@
 package fs
 
 import (
+	"fmt"
 	"io"
 	"mime"
 	"net/http"
@@ -8,8 +9,11 @@ import (
 	stdpath "path"
 	"strings"
 
+	"github.com/alist-org/alist/v3/internal/conf"
 	"github.com/alist-org/alist/v3/internal/model"
 	"github.com/alist-org/alist/v3/internal/op"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/google/uuid"
 	"github.com/pkg/errors"
 )
 
@@ -38,7 +42,13 @@ func getFileStreamFromLink(file model.Obj, link *model.Link) (model.FileStreamer
 	if link.Data != nil {
 		rc = link.Data
 	} else if link.FilePath != nil {
-		f, err := os.Open(*link.FilePath)
+		// copy a new temp, because will be deleted after upload
+		newFilePath := stdpath.Join(conf.Conf.TempDir, fmt.Sprintf("%s-%s", uuid.NewString(), file.GetName()))
+		err := utils.CopyFile(*link.FilePath, newFilePath)
+		if err != nil {
+			return nil, err
+		}
+		f, err := os.Open(newFilePath)
 		if err != nil {
 			return nil, errors.Wrapf(err, "failed to open file %s", *link.FilePath)
 		}

internal/op/fs.go

@@ -27,6 +27,10 @@ func ClearCache(storage driver.Driver, path string) {
 	listCache.Del(key)
 }
 
+func Key(storage driver.Driver, path string) string {
+	return stdpath.Join(storage.GetStorage().MountPath, utils.StandardizePath(path))
+}
+
 // List files in storage, not contains virtual file
 func List(ctx context.Context, storage driver.Driver, path string, args model.ListArgs, refresh ...bool) ([]model.Obj, error) {
 	if storage.Config().CheckStatus && storage.GetStorage().Status != WORK {
@@ -46,9 +50,9 @@ func List(ctx context.Context, storage driver.Driver, path string, args model.Li
 		objs, err := storage.List(ctx, dir, args)
 		return objs, errors.WithStack(err)
 	}
-	key := stdpath.Join(storage.GetStorage().MountPath, path)
+	key := Key(storage, path)
 	if len(refresh) == 0 || !refresh[0] {
-		if files, ok := listCache.Get(key); ok {
+		if files, ok := listCache.Get(key); ok && len(files) > 0 {
 			return files, nil
 		}
 	}
@@ -177,37 +181,49 @@ func Other(ctx context.Context, storage driver.Driver, args model.FsOtherArgs) (
 	}
 }
 
+var mkdirG singleflight.Group[interface{}]
+
 func MakeDir(ctx context.Context, storage driver.Driver, path string) error {
 	if storage.Config().CheckStatus && storage.GetStorage().Status != WORK {
 		return errors.Errorf("storage not init: %s", storage.GetStorage().Status)
 	}
-	// check if dir exists
-	f, err := Get(ctx, storage, path)
-	if err != nil {
-		if errs.IsObjectNotFound(err) {
-			parentPath, dirName := stdpath.Split(path)
-			err = MakeDir(ctx, storage, parentPath)
-			if err != nil {
-				return errors.WithMessagef(err, "failed to make parent dir [%s]", parentPath)
+	path = utils.StandardizePath(path)
+	key := Key(storage, path)
+	_, err, _ := mkdirG.Do(key, func() (interface{}, error) {
+		// check if dir exists
+		f, err := Get(ctx, storage, path)
+		if err != nil {
+			if errs.IsObjectNotFound(err) {
+				parentPath, dirName := stdpath.Split(path)
+				err = MakeDir(ctx, storage, parentPath)
+				if err != nil {
+					return nil, errors.WithMessagef(err, "failed to make parent dir [%s]", parentPath)
+				}
+				parentDir, err := Get(ctx, storage, parentPath)
+				// this should not happen
+				if err != nil {
+					return nil, errors.WithMessagef(err, "failed to get parent dir [%s]", parentPath)
+				}
+				err = storage.MakeDir(ctx, parentDir, dirName)
+				if err == nil {
+					ClearCache(storage, parentPath)
+				}
+				return nil, errors.WithStack(err)
+			} else {
+				return nil, errors.WithMessage(err, "failed to check if dir exists")
 			}
-			parentDir, err := Get(ctx, storage, parentPath)
-			// this should not happen
-			if err != nil {
-				return errors.WithMessagef(err, "failed to get parent dir [%s]", parentPath)
+		} else {
+			// dir exists
+			if f.IsDir() {
+				return nil, nil
+			} else {
+				// dir to make is a file
+				return nil, errors.New("file exists")
 			}
-			return errors.WithStack(storage.MakeDir(ctx, parentDir, dirName))
-		} else {
-			return errors.WithMessage(err, "failed to check if dir exists")
 		}
-	} else {
-		// dir exists
-		if f.IsDir() {
-			return nil
-		} else {
-			// dir to make is a file
-			return errors.New("file exists")
-		}
-	}
+	})
+	return err
+
 }
 
 func Move(ctx context.Context, storage driver.Driver, srcPath, dstDirPath string) error {
@@ -261,7 +277,28 @@ func Remove(ctx context.Context, storage driver.Driver, path string) error {
 		}
 		return errors.WithMessage(err, "failed to get object")
 	}
-	return errors.WithStack(storage.Remove(ctx, obj))
+	err = storage.Remove(ctx, obj)
+	if err == nil {
+		key := Key(storage, stdpath.Dir(path))
+		if objs, ok := listCache.Get(key); ok {
+			j := -1
+			for i, m := range objs {
+				if m.GetName() == obj.GetName() {
+					j = i
+					break
+				}
+			}
+			if j >= 0 && j < len(objs) {
+				objs = append(objs[:j], objs[j+1:]...)
+				listCache.Set(key, objs)
+			} else {
+				log.Debugf("not found obj")
+			}
+		} else {
+			log.Debugf("not found parent cache")
+		}
+	}
+	return errors.WithStack(err)
 }
 
 func Put(ctx context.Context, storage driver.Driver, dstDirPath string, file model.FileStreamer, up driver.UpdateProgress) error {
@@ -308,12 +345,10 @@ func Put(ctx context.Context, storage driver.Driver, dstDirPath string, file mod
 	}
 	err = storage.Put(ctx, parentDir, file, up)
 	log.Debugf("put file [%s] done", file.GetName())
-	if err == nil {
-		// set as complete
-		up(100)
-		// clear cache
-		key := stdpath.Join(storage.GetStorage().MountPath, dstDirPath)
-		listCache.Del(key)
-	}
+	//if err == nil {
+	//	//clear cache
+	//	key := stdpath.Join(storage.GetStorage().MountPath, dstDirPath)
+	//	listCache.Del(key)
+	//}
 	return errors.WithStack(err)
 }

internal/op/storage.go

@@ -94,19 +94,14 @@ func EnableStorage(ctx context.Context, id uint) error {
 	if !storage.Disabled {
 		return errors.Errorf("this storage have enabled")
 	}
-	err = LoadStorage(ctx, *storage)
-	if err != nil {
-		return errors.WithMessage(err, "failed load storage")
-	}
-	// re-get storage from db, because it maybe hava updated
-	storage, err = db.GetStorageById(id)
-	if err != nil {
-		return errors.WithMessage(err, "failed re-get storage again")
-	}
 	storage.Disabled = false
 	err = db.UpdateStorage(storage)
 	if err != nil {
-		return errors.WithMessage(err, "failed update storage in db, but have load in memory. you can try restart")
+		return errors.WithMessage(err, "failed update storage in db")
+	}
+	err = LoadStorage(ctx, *storage)
+	if err != nil {
+		return errors.WithMessage(err, "failed load storage")
 	}
 	return nil
 }
@@ -128,12 +123,12 @@ func DisableStorage(ctx context.Context, id uint) error {
 		return errors.Wrapf(err, "failed drop storage")
 	}
 	// delete the storage in the memory
-	storagesMap.Delete(storage.MountPath)
 	storage.Disabled = true
 	err = db.UpdateStorage(storage)
 	if err != nil {
-		return errors.WithMessage(err, "failed update storage in db, but have drop in memory. you can try restart")
+		return errors.WithMessage(err, "failed update storage in db")
 	}
+	storagesMap.Delete(storage.MountPath)
 	return nil
 }
 

pkg/cron/cron.go

@@ -30,6 +30,10 @@ func (c *Cron) Do(f func()) {
 }
 
 func (c *Cron) Stop() {
-	c.ch <- struct{}{}
-	close(c.ch)
+	select {
+	case _, _ = <-c.ch:
+	default:
+		c.ch <- struct{}{}
+		close(c.ch)
+	}
 }

pkg/cron/cron_test.go

@@ -10,6 +10,7 @@ func TestCron(t *testing.T) {
 	c.Do(func() {
 		t.Logf("cron log")
 	})
-	time.Sleep(time.Second * 5)
+	time.Sleep(time.Second * 3)
+	c.Stop()
 	c.Stop()
 }

pkg/task/manager.go

@@ -122,6 +122,10 @@ func (tm *Manager[K]) ClearDone() {
 	tm.RemoveByStates(SUCCEEDED, CANCELED, ERRORED)
 }
 
+func (tm *Manager[K]) RawTasks() *generic_sync.MapOf[K, *Task[K]] {
+	return &tm.tasks
+}
+
 func NewTaskManager[K comparable](maxWorker int, updateID ...func(*K)) *Manager[K] {
 	tm := &Manager[K]{
 		tasks:   generic_sync.MapOf[K, *Task[K]]{},

pkg/task/task.go

@@ -82,6 +82,7 @@ func (t *Task[K]) run() {
 		t.state = ERRORED
 	} else {
 		t.state = SUCCEEDED
+		t.SetProgress(100)
 		if t.callback != nil {
 			t.callback(t)
 		}

pkg/utils/file.go

@@ -1,14 +1,76 @@
 package utils
 
 import (
+	"fmt"
 	"io"
+	"io/ioutil"
 	"os"
+	"path"
 	"path/filepath"
+	"strings"
 
 	"github.com/alist-org/alist/v3/internal/conf"
 	log "github.com/sirupsen/logrus"
 )
 
+// CopyFile File copies a single file from src to dst
+func CopyFile(src, dst string) error {
+	var err error
+	var srcfd *os.File
+	var dstfd *os.File
+	var srcinfo os.FileInfo
+
+	if srcfd, err = os.Open(src); err != nil {
+		return err
+	}
+	defer srcfd.Close()
+
+	if dstfd, err = CreateNestedFile(dst); err != nil {
+		return err
+	}
+	defer dstfd.Close()
+
+	if _, err = io.Copy(dstfd, srcfd); err != nil {
+		return err
+	}
+	if srcinfo, err = os.Stat(src); err != nil {
+		return err
+	}
+	return os.Chmod(dst, srcinfo.Mode())
+}
+
+// CopyDir Dir copies a whole directory recursively
+func CopyDir(src string, dst string) error {
+	var err error
+	var fds []os.FileInfo
+	var srcinfo os.FileInfo
+
+	if srcinfo, err = os.Stat(src); err != nil {
+		return err
+	}
+	if err = os.MkdirAll(dst, srcinfo.Mode()); err != nil {
+		return err
+	}
+	if fds, err = ioutil.ReadDir(src); err != nil {
+		return err
+	}
+	for _, fd := range fds {
+		srcfp := path.Join(src, fd.Name())
+		dstfp := path.Join(dst, fd.Name())
+
+		if fd.IsDir() {
+			if err = CopyDir(srcfp, dstfp); err != nil {
+				fmt.Println(err)
+			}
+		} else {
+			if err = CopyFile(srcfp, dstfp); err != nil {
+				fmt.Println(err)
+			}
+		}
+	}
+	return nil
+}
+
 // Exists determine whether the file exists
 func Exists(name string) bool {
 	if _, err := os.Stat(name); err != nil {
@@ -56,7 +118,7 @@ func CreateTempFile(r io.ReadCloser) (*os.File, error) {
 
 // GetFileType get file type
 func GetFileType(filename string) int {
-	ext := Ext(filename)
+	ext := strings.ToLower(Ext(filename))
 	//if SliceContains(conf.TypesMap[conf.OfficeTypes], ext) {
 	//	return conf.OFFICE
 	//}

pkg/utils/hash.go

@@ -3,7 +3,9 @@ package utils
 import (
 	"crypto/md5"
 	"crypto/sha1"
+	"encoding/base64"
 	"encoding/hex"
+	"strings"
 )
 
 func GetSHA1Encode(data string) string {
@@ -17,3 +19,20 @@ func GetMD5Encode(data string) string {
 	h.Write([]byte(data))
 	return hex.EncodeToString(h.Sum(nil))
 }
+
+var DEC = map[string]string{
+	"-": "+",
+	"_": "/",
+	".": "=",
+}
+
+func SafeAtob(data string) (string, error) {
+	for k, v := range DEC {
+		data = strings.ReplaceAll(data, k, v)
+	}
+	bytes, err := base64.StdEncoding.DecodeString(data)
+	if err != nil {
+		return "", err
+	}
+	return string(bytes), err
+}

pkg/utils/io.go

@@ -40,3 +40,32 @@ func CopyWithCtx(ctx context.Context, out io.Writer, in io.Reader, size int64, p
 	}))
 	return err
 }
+
+type limitWriter struct {
+	w     io.Writer
+	count int64
+	limit int64
+}
+
+func (l limitWriter) Write(p []byte) (n int, err error) {
+	wn := int(l.limit - l.count)
+	if wn > len(p) {
+		wn = len(p)
+	}
+	if wn > 0 {
+		if n, err = l.w.Write(p[:wn]); err != nil {
+			return
+		}
+		if n < wn {
+			err = io.ErrShortWrite
+		}
+	}
+	if err == nil {
+		n = len(p)
+	}
+	return
+}
+
+func LimitWriter(w io.Writer, size int64) io.Writer {
+	return &limitWriter{w: w, limit: size}
+}

server/handles/fsmanage.go

@@ -2,10 +2,7 @@ package handles
 
 import (
 	"fmt"
-	"net/url"
 	stdpath "path"
-	"strconv"
-	"time"
 
 	"github.com/alist-org/alist/v3/internal/db"
 	"github.com/alist-org/alist/v3/internal/errs"
@@ -31,7 +28,7 @@ func FsMkdir(c *gin.Context) {
 	user := c.MustGet("user").(*model.User)
 	req.Path = stdpath.Join(user.BasePath, req.Path)
 	if !user.CanWrite() {
-		meta, err := db.GetNearestMeta(req.Path)
+		meta, err := db.GetNearestMeta(stdpath.Dir(req.Path))
 		if err != nil {
 			if !errors.Is(errors.Cause(err), errs.MetaNotFound) {
 				common.ErrorResp(c, err, 500, true)
@@ -184,60 +181,7 @@ func FsRemove(c *gin.Context) {
 			return
 		}
 	}
-	fs.ClearCache(req.Dir)
-	common.SuccessResp(c)
-}
-
-func FsPut(c *gin.Context) {
-	path := c.GetHeader("File-Path")
-	path, err := url.PathUnescape(path)
-	if err != nil {
-		common.ErrorResp(c, err, 400)
-		return
-	}
-	asTask := c.GetHeader("As-Task") == "true"
-	user := c.MustGet("user").(*model.User)
-	path = stdpath.Join(user.BasePath, path)
-	if !user.CanWrite() {
-		meta, err := db.GetNearestMeta(path)
-		if err != nil {
-			if !errors.Is(errors.Cause(err), errs.MetaNotFound) {
-				common.ErrorResp(c, err, 500, true)
-				return
-			}
-		}
-		if !canWrite(meta, path) {
-			common.ErrorResp(c, errs.PermissionDenied, 403)
-			return
-		}
-	}
-
-	dir, name := stdpath.Split(path)
-	sizeStr := c.GetHeader("Content-Length")
-	size, err := strconv.ParseInt(sizeStr, 10, 64)
-	if err != nil {
-		common.ErrorResp(c, err, 400)
-		return
-	}
-	stream := &model.FileStream{
-		Obj: &model.Object{
-			Name:     name,
-			Size:     size,
-			Modified: time.Now(),
-		},
-		ReadCloser:   c.Request.Body,
-		Mimetype:     c.GetHeader("Content-Type"),
-		WebPutAsTask: asTask,
-	}
-	if asTask {
-		err = fs.PutAsTask(dir, stream)
-	} else {
-		err = fs.PutDirectly(c, dir, stream)
-	}
-	if err != nil {
-		common.ErrorResp(c, err, 500)
-		return
-	}
+	//fs.ClearCache(req.Dir)
 	common.SuccessResp(c)
 }
 

server/handles/fsread.go

@@ -26,8 +26,9 @@ type ListReq struct {
 }
 
 type DirReq struct {
-	Path     string `json:"path" form:"path"`
-	Password string `json:"password" form:"password"`
+	Path      string `json:"path" form:"path"`
+	Password  string `json:"password" form:"password"`
+	ForceRoot bool   `json:"force_root" form:"force_root"`
 }
 
 type ObjResp struct {
@@ -41,10 +42,11 @@ type ObjResp struct {
 }
 
 type FsListResp struct {
-	Content []ObjResp `json:"content"`
-	Total   int64     `json:"total"`
-	Readme  string    `json:"readme"`
-	Write   bool      `json:"write"`
+	Content  []ObjResp `json:"content"`
+	Total    int64     `json:"total"`
+	Readme   string    `json:"readme"`
+	Write    bool      `json:"write"`
+	Provider string    `json:"provider"`
 }
 
 func FsList(c *gin.Context) {
@@ -78,11 +80,17 @@ func FsList(c *gin.Context) {
 		return
 	}
 	total, objs := pagination(objs, &req.PageReq)
+	provider := "unknown"
+	storage, err := fs.GetStorage(req.Path)
+	if err == nil {
+		provider = storage.GetStorage().Driver
+	}
 	common.SuccessResp(c, FsListResp{
-		Content: toObjResp(objs, isEncrypt(meta, req.Path)),
-		Total:   int64(total),
-		Readme:  getReadme(meta, req.Path),
-		Write:   user.CanWrite() || canWrite(meta, req.Path),
+		Content:  toObjResp(objs, isEncrypt(meta, req.Path)),
+		Total:    int64(total),
+		Readme:   getReadme(meta, req.Path),
+		Write:    user.CanWrite() || canWrite(meta, req.Path),
+		Provider: provider,
 	})
 }
 
@@ -93,7 +101,14 @@ func FsDirs(c *gin.Context) {
 		return
 	}
 	user := c.MustGet("user").(*model.User)
-	req.Path = stdpath.Join(user.BasePath, req.Path)
+	if req.ForceRoot {
+		if !user.IsAdmin() {
+			common.ErrorStrResp(c, "Permission denied", 403)
+			return
+		}
+	} else {
+		req.Path = stdpath.Join(user.BasePath, req.Path)
+	}
 	meta, err := db.GetNearestMeta(req.Path)
 	if err != nil {
 		if !errors.Is(errors.Cause(err), errs.MetaNotFound) {
@@ -250,27 +265,27 @@ func FsGet(c *gin.Context) {
 	if err == nil {
 		provider = storage.Config().Name
 	}
-	// file have raw url
 	if !obj.IsDir() {
-		if u, ok := obj.(model.URL); ok {
-			rawURL = u.URL()
-		} else {
-			if err != nil {
-				common.ErrorResp(c, err, 500)
-				return
+		if err != nil {
+			common.ErrorResp(c, err, 500)
+			return
+		}
+		if storage.Config().MustProxy() || storage.GetStorage().WebProxy {
+			if storage.GetStorage().DownProxyUrl != "" {
+				rawURL = fmt.Sprintf("%s%s?sign=%s", strings.Split(storage.GetStorage().DownProxyUrl, "\n")[0], req.Path, sign.Sign(obj.GetName()))
+			} else {
+				rawURL = fmt.Sprintf("%s/p%s?sign=%s",
+					common.GetApiUrl(c.Request),
+					utils.EncodePath(req.Path, true),
+					sign.Sign(obj.GetName()))
 			}
-			if storage.Config().MustProxy() || storage.GetStorage().WebProxy {
-				if storage.GetStorage().DownProxyUrl != "" {
-					rawURL = fmt.Sprintf("%s%s?sign=%s", strings.Split(storage.GetStorage().DownProxyUrl, "\n")[0], req.Path, sign.Sign(obj.GetName()))
-				} else {
-					rawURL = fmt.Sprintf("%s/p%s?sign=%s",
-						common.GetApiUrl(c.Request),
-						utils.EncodePath(req.Path, true),
-						sign.Sign(obj.GetName()))
-				}
+		} else {
+			// file have raw url
+			if u, ok := obj.(model.URL); ok {
+				rawURL = u.URL()
 			} else {
 				// if storage is not proxy, use raw url by fs.Link
-				link, _, err := fs.Link(c, req.Path, model.LinkArgs{IP: c.ClientIP()})
+				link, _, err := fs.Link(c, req.Path, model.LinkArgs{IP: c.ClientIP(), Header: c.Request.Header})
 				if err != nil {
 					common.ErrorResp(c, err, 500)
 					return

server/handles/fsup.go

@@ -0,0 +1,134 @@
+package handles
+
+import (
+	"net/url"
+	stdpath "path"
+	"strconv"
+	"time"
+
+	"github.com/alist-org/alist/v3/internal/db"
+	"github.com/alist-org/alist/v3/internal/errs"
+	"github.com/alist-org/alist/v3/internal/fs"
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/server/common"
+	"github.com/gin-gonic/gin"
+	"github.com/pkg/errors"
+)
+
+func FsStream(c *gin.Context) {
+	path := c.GetHeader("File-Path")
+	path, err := url.PathUnescape(path)
+	if err != nil {
+		common.ErrorResp(c, err, 400)
+		return
+	}
+	asTask := c.GetHeader("As-Task") == "true"
+	user := c.MustGet("user").(*model.User)
+	path = stdpath.Join(user.BasePath, path)
+	if !user.CanWrite() {
+		meta, err := db.GetNearestMeta(stdpath.Dir(path))
+		if err != nil {
+			if !errors.Is(errors.Cause(err), errs.MetaNotFound) {
+				common.ErrorResp(c, err, 500, true)
+				return
+			}
+		}
+		if !canWrite(meta, path) {
+			common.ErrorResp(c, errs.PermissionDenied, 403)
+			return
+		}
+	}
+
+	dir, name := stdpath.Split(path)
+	sizeStr := c.GetHeader("Content-Length")
+	size, err := strconv.ParseInt(sizeStr, 10, 64)
+	if err != nil {
+		common.ErrorResp(c, err, 400)
+		return
+	}
+	stream := &model.FileStream{
+		Obj: &model.Object{
+			Name:     name,
+			Size:     size,
+			Modified: time.Now(),
+		},
+		ReadCloser:   c.Request.Body,
+		Mimetype:     c.GetHeader("Content-Type"),
+		WebPutAsTask: asTask,
+	}
+	if asTask {
+		err = fs.PutAsTask(dir, stream)
+	} else {
+		err = fs.PutDirectly(c, dir, stream)
+	}
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+		return
+	}
+	common.SuccessResp(c)
+}
+
+func FsForm(c *gin.Context) {
+	path := c.GetHeader("File-Path")
+	path, err := url.PathUnescape(path)
+	if err != nil {
+		common.ErrorResp(c, err, 400)
+		return
+	}
+	asTask := c.GetHeader("As-Task") == "true"
+	user := c.MustGet("user").(*model.User)
+	path = stdpath.Join(user.BasePath, path)
+	if !user.CanWrite() {
+		meta, err := db.GetNearestMeta(stdpath.Dir(path))
+		if err != nil {
+			if !errors.Is(errors.Cause(err), errs.MetaNotFound) {
+				common.ErrorResp(c, err, 500, true)
+				return
+			}
+		}
+		if !canWrite(meta, path) {
+			common.ErrorResp(c, errs.PermissionDenied, 403)
+			return
+		}
+	}
+	storage, err := fs.GetStorage(path)
+	if err != nil {
+		common.ErrorResp(c, err, 400)
+		return
+	}
+	if storage.Config().NoUpload {
+		common.ErrorStrResp(c, "Current storage doesn't support upload", 405)
+		return
+	}
+	file, err := c.FormFile("file")
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+		return
+	}
+	f, err := file.Open()
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+		return
+	}
+	dir, name := stdpath.Split(path)
+	stream := &model.FileStream{
+		Obj: &model.Object{
+			Name:     name,
+			Size:     file.Size,
+			Modified: time.Now(),
+		},
+		ReadCloser:   f,
+		Mimetype:     file.Header.Get("Content-Type"),
+		WebPutAsTask: false,
+	}
+	if asTask {
+		err = fs.PutAsTask(dir, stream)
+	} else {
+		err = fs.PutDirectly(c, dir, stream)
+	}
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+		return
+	}
+	common.SuccessResp(c)
+}

server/handles/helper.go

@@ -7,9 +7,9 @@ import (
 
 	"github.com/alist-org/alist/v3/internal/conf"
 	"github.com/alist-org/alist/v3/internal/setting"
+	"github.com/alist-org/alist/v3/pkg/utils"
 	"github.com/alist-org/alist/v3/server/common"
 	"github.com/gin-gonic/gin"
-	log "github.com/sirupsen/logrus"
 )
 
 func Favicon(c *gin.Context) {
@@ -17,21 +17,45 @@ func Favicon(c *gin.Context) {
 }
 
 func Plist(c *gin.Context) {
-	link := c.Param("link")
-	u, err := url.PathUnescape(link)
+	linkNameB64 := strings.TrimSuffix(c.Param("link_name"), ".plist")
+	linkName, err := utils.SafeAtob(linkNameB64)
 	if err != nil {
-		common.ErrorResp(c, err, 500)
+		common.ErrorResp(c, err, 400)
 		return
 	}
-	uUrl, err := url.Parse(u)
-	if err != nil {
-		common.ErrorResp(c, err, 500)
+	linkNameSplit := strings.Split(linkName, "/")
+	if len(linkNameSplit) != 2 {
+		common.ErrorStrResp(c, "malformed link", 400)
 		return
 	}
-	name := c.Param("name")
-	log.Debug("name", name)
-	u = uUrl.String()
-	name = strings.TrimSuffix(name, ".plist")
+	linkEncode := linkNameSplit[0]
+	linkStr, err := url.PathUnescape(linkEncode)
+	if err != nil {
+		common.ErrorResp(c, err, 400)
+		return
+	}
+	link, err := url.Parse(linkStr)
+	if err != nil {
+		common.ErrorResp(c, err, 400)
+		return
+	}
+	fullName := c.Param("name")
+	Url := link.String()
+	nameEncode := linkNameSplit[1]
+	fullName, err = url.PathUnescape(nameEncode)
+	if err != nil {
+		common.ErrorResp(c, err, 400)
+		return
+	}
+	name := fullName
+	identifier := fmt.Sprintf("ci.nn.%s", url.PathEscape(fullName))
+	sep := "@"
+	if strings.Contains(fullName, sep) {
+		ss := strings.Split(fullName, sep)
+		name = strings.Join(ss[:len(ss)-1], sep)
+		identifier = ss[len(ss)-1]
+	}
+
 	name = strings.ReplaceAll(name, "<", "[")
 	name = strings.ReplaceAll(name, ">", "]")
 	plist := fmt.Sprintf(`<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd">
@@ -46,13 +70,13 @@ func Plist(c *gin.Context) {
                         <key>kind</key>
                         <string>software-package</string>
                         <key>url</key>
-                        <string>%s</string>
+                        <string><![CDATA[%s]]></string>
                     </dict>
                 </array>
                 <key>metadata</key>
                 <dict>
                     <key>bundle-identifier</key>
-					<string>ci.nn.%s</string>
+					<string>%s</string>
 					<key>bundle-version</key>
                     <string>4.4</string>
                     <key>kind</key>
@@ -63,7 +87,7 @@ func Plist(c *gin.Context) {
             </dict>
         </array>
     </dict>
-</plist>`, u, url.PathEscape(name), name)
+</plist>`, Url, identifier, name)
 	c.Header("Content-Type", "application/xml;charset=utf-8")
 	c.Status(200)
 	_, _ = c.Writer.WriteString(plist)

server/router.go

@@ -19,7 +19,7 @@ func Init(r *gin.Engine) {
 	WebDav(r.Group("/dav"))
 
 	r.GET("/favicon.ico", handles.Favicon)
-	r.GET("/i/:link/:name", handles.Plist)
+	r.GET("/i/:link_name", handles.Plist)
 	r.GET("/d/*path", middlewares.Down, handles.Down)
 	r.GET("/p/*path", middlewares.Down, handles.Proxy)
 
@@ -119,7 +119,8 @@ func _fs(g *gin.RouterGroup) {
 	g.POST("/move", handles.FsMove)
 	g.POST("/copy", handles.FsCopy)
 	g.POST("/remove", handles.FsRemove)
-	g.PUT("/put", handles.FsPut)
+	g.PUT("/put", handles.FsStream)
+	g.PUT("/form", handles.FsForm)
 	g.POST("/link", middlewares.AuthAdmin, handles.Link)
 	g.POST("/add_aria2", handles.AddAria2)
 }

server/static/static.go

@@ -10,6 +10,7 @@ import (
 	"github.com/alist-org/alist/v3/cmd/flags"
 	"github.com/alist-org/alist/v3/internal/conf"
 	"github.com/alist-org/alist/v3/internal/setting"
+	"github.com/alist-org/alist/v3/pkg/utils"
 	"github.com/alist-org/alist/v3/public"
 	"github.com/gin-gonic/gin"
 	log "github.com/sirupsen/logrus"
@@ -28,6 +29,12 @@ func UpdateIndex() {
 	cdn := strings.TrimSuffix(conf.Conf.Cdn, "/")
 	cdn = strings.ReplaceAll(cdn, "$version", conf.WebVersion)
 	basePath := setting.GetStr(conf.BasePath)
+	if basePath != "" {
+		basePath = utils.StandardizePath(basePath)
+	}
+	if cdn == "" {
+		cdn = basePath
+	}
 	apiUrl := setting.GetStr(conf.ApiUrl)
 	favicon := setting.GetStr(conf.Favicon)
 	title := setting.GetStr(conf.SiteTitle)

server/webdav/prop.go

@@ -419,10 +419,11 @@ func findContentType(ctx context.Context, ls LockSystem, name string, fi model.O
 	//defer f.Close()
 	// This implementation is based on serveContent's code in the standard net/http package.
 	ctype := mime.TypeByExtension(path.Ext(name))
-	if ctype != "" {
-		return ctype, nil
-	}
-	return "application/octet-stream", nil
+	return ctype, nil
+	//if ctype != "" {
+	//	return ctype, nil
+	//}
+	//return "application/octet-stream", nil
 	// Read a chunk to decide between utf-8 text and binary.
 	//var buf [512]byte
 	//n, err := io.ReadFull(f, buf[:])

server/webdav/webdav.go

@@ -271,7 +271,7 @@ func (h *Handler) handleDelete(w http.ResponseWriter, r *http.Request) (status i
 	if err := fs.Remove(ctx, reqPath); err != nil {
 		return http.StatusMethodNotAllowed, err
 	}
-	fs.ClearCache(path.Dir(reqPath))
+	//fs.ClearCache(path.Dir(reqPath))
 	return http.StatusNoContent, nil
 }