feat: add ca-certificates for docker (fix: #1679)

.github/ISSUE_TEMPLATE/bug_report.yml

@@ -12,9 +12,10 @@ body:
       label: Please make sure of the following things
       description: You may select more than one, even select all.
       options:
-        - label: I have read the [documentation](https://alist-doc.nn.ci).
+        - label: I have read the [documentation](https://alist.nn.ci).
         - label: I'm sure there are no duplicate issues or discussions.
         - label: I'm sure it's due to `alist` and not something else(such as `Dependencies` or `Operational`).
+        - label: I'm sure I'm using the latest version
   - type: input
     id: version
     attributes:

.github/ISSUE_TEMPLATE/feature_request.yml

@@ -7,7 +7,7 @@ body:
       label: Please make sure of the following things
       description: You may select more than one, even select all.
       options:
-        - label: I have read the [documentation](https://alist-doc.nn.ci).
+        - label: I have read the [documentation](https://alist.nn.ci).
         - label: I'm sure there are no duplicate issues or discussions.
         - label: I'm sure this feature is not implemented.
         - label: I'm sure it's a reasonable and popular requirement.

.github/workflows/issue_check_inactive.yml

@@ -14,3 +14,4 @@ jobs:
           actions: 'check-inactive'
           token: ${{ secrets.GITHUB_TOKEN }}
           inactive-day: 30
+          body: Hello, this issue has been inactive for more than 30 days and will be closed if inactive for another 30 days.

.github/workflows/issue_close_inactive.yml

@@ -0,0 +1,20 @@
+name: Close inactive
+
+on:
+  schedule:
+    - cron: "0 0 */7 * *"
+
+jobs:
+  close-inactive:
+    runs-on: ubuntu-latest
+    steps:
+      - name: close-issues
+        uses: actions-cool/issues-helper@v3
+        with:
+          actions: 'close-issues'
+          token: ${{ secrets.GITHUB_TOKEN }}
+          labels: 'inactive'
+          inactive-day: 30
+          close-reason: 'not_planned'
+          body: |
+            Hello @${{ github.event.issue.user.login }}, this issue was closed due to inactive more than 60 days. You can reopen or recreate it if you think it should continue.

.github/workflows/issue_close_question.yml

@@ -1,11 +1,11 @@
-name: Check need info
+name: Close need info
 
 on:
   schedule:
     - cron: "0 0 */7 * *"
 
 jobs:
-  check-need-info:
+  close-need-info:
     runs-on: ubuntu-latest
     steps:
       - name: close-issues

.github/workflows/issue_similarity.yml

@@ -16,3 +16,4 @@ jobs:
           comment-body: '${index}. ${similarity} #${number}'
           show-footer: false
           show-mentioned: true
+          since-days: 730

CODE_OF_CONDUCT.md

@@ -0,0 +1,128 @@
+# Contributor Covenant Code of Conduct
+
+## Our Pledge
+
+We as members, contributors, and leaders pledge to make participation in our
+community a harassment-free experience for everyone, regardless of age, body
+size, visible or invisible disability, ethnicity, sex characteristics, gender
+identity and expression, level of experience, education, socio-economic status,
+nationality, personal appearance, race, religion, or sexual identity
+and orientation.
+
+We pledge to act and interact in ways that contribute to an open, welcoming,
+diverse, inclusive, and healthy community.
+
+## Our Standards
+
+Examples of behavior that contributes to a positive environment for our
+community include:
+
+* Demonstrating empathy and kindness toward other people
+* Being respectful of differing opinions, viewpoints, and experiences
+* Giving and gracefully accepting constructive feedback
+* Accepting responsibility and apologizing to those affected by our mistakes,
+  and learning from the experience
+* Focusing on what is best not just for us as individuals, but for the
+  overall community
+
+Examples of unacceptable behavior include:
+
+* The use of sexualized language or imagery, and sexual attention or
+  advances of any kind
+* Trolling, insulting or derogatory comments, and personal or political attacks
+* Public or private harassment
+* Publishing others' private information, such as a physical or email
+  address, without their explicit permission
+* Other conduct which could reasonably be considered inappropriate in a
+  professional setting
+
+## Enforcement Responsibilities
+
+Community leaders are responsible for clarifying and enforcing our standards of
+acceptable behavior and will take appropriate and fair corrective action in
+response to any behavior that they deem inappropriate, threatening, offensive,
+or harmful.
+
+Community leaders have the right and responsibility to remove, edit, or reject
+comments, commits, code, wiki edits, issues, and other contributions that are
+not aligned to this Code of Conduct, and will communicate reasons for moderation
+decisions when appropriate.
+
+## Scope
+
+This Code of Conduct applies within all community spaces, and also applies when
+an individual is officially representing the community in public spaces.
+Examples of representing our community include using an official e-mail address,
+posting via an official social media account, or acting as an appointed
+representative at an online or offline event.
+
+## Enforcement
+
+Instances of abusive, harassing, or otherwise unacceptable behavior may be
+reported to the community leaders responsible for enforcement at
+i@nn.ci.
+All complaints will be reviewed and investigated promptly and fairly.
+
+All community leaders are obligated to respect the privacy and security of the
+reporter of any incident.
+
+## Enforcement Guidelines
+
+Community leaders will follow these Community Impact Guidelines in determining
+the consequences for any action they deem in violation of this Code of Conduct:
+
+### 1. Correction
+
+**Community Impact**: Use of inappropriate language or other behavior deemed
+unprofessional or unwelcome in the community.
+
+**Consequence**: A private, written warning from community leaders, providing
+clarity around the nature of the violation and an explanation of why the
+behavior was inappropriate. A public apology may be requested.
+
+### 2. Warning
+
+**Community Impact**: A violation through a single incident or series
+of actions.
+
+**Consequence**: A warning with consequences for continued behavior. No
+interaction with the people involved, including unsolicited interaction with
+those enforcing the Code of Conduct, for a specified period of time. This
+includes avoiding interactions in community spaces as well as external channels
+like social media. Violating these terms may lead to a temporary or
+permanent ban.
+
+### 3. Temporary Ban
+
+**Community Impact**: A serious violation of community standards, including
+sustained inappropriate behavior.
+
+**Consequence**: A temporary ban from any sort of interaction or public
+communication with the community for a specified period of time. No public or
+private interaction with the people involved, including unsolicited interaction
+with those enforcing the Code of Conduct, is allowed during this period.
+Violating these terms may lead to a permanent ban.
+
+### 4. Permanent Ban
+
+**Community Impact**: Demonstrating a pattern of violation of community
+standards, including sustained inappropriate behavior,  harassment of an
+individual, or aggression toward or disparagement of classes of individuals.
+
+**Consequence**: A permanent ban from any sort of public interaction within
+the community.
+
+## Attribution
+
+This Code of Conduct is adapted from the [Contributor Covenant][homepage],
+version 2.0, available at
+https://www.contributor-covenant.org/version/2/0/code_of_conduct.html.
+
+Community Impact Guidelines were inspired by [Mozilla's code of conduct
+enforcement ladder](https://github.com/mozilla/diversity).
+
+[homepage]: https://www.contributor-covenant.org
+
+For answers to common questions about this code of conduct, see the FAQ at
+https://www.contributor-covenant.org/faq. Translations are available at
+https://www.contributor-covenant.org/translations.

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" ]

README.md

@@ -29,7 +29,7 @@
 
 ---
 
-English | [中文](./README_cn.md) | [Contributors](./CONTRIBUTORS.md) | [Contributing](./CONTRIBUTING.md)
+English | [中文](./README_cn.md) | [Contributors](./CONTRIBUTORS.md) | [Contributing](./CONTRIBUTING.md) | [CODE_OF_CONDUCT](./CODE_OF_CONDUCT.md)
 
 ## Features
 
@@ -51,6 +51,7 @@ English | [中文](./README_cn.md) | [Contributors](./CONTRIBUTORS.md) | [Contri
     - [x] [YandexDisk](https://disk.yandex.com/)
     - [x] [BaiduNetdisk](http://pan.baidu.com/)
     - [x] [Quark](https://pan.quark.cn)
+    - [x] [Thunder](https://pan.xunlei.com)
 - [x] Easy to deploy and out-of-the-box
 - [x] File preview (PDF, markdown, code, plain text, ...)
 - [x] Image preview in gallery mode

README_cn.md

@@ -29,7 +29,7 @@
 
 ---
 
-[English](./README.md) | 中文 | [Contributors](./CONTRIBUTORS.md) | [Contributing](./CONTRIBUTING.md)
+[English](./README.md) | 中文 | [Contributors](./CONTRIBUTORS.md) | [Contributing](./CONTRIBUTING.md) | [CODE_OF_CONDUCT](./CODE_OF_CONDUCT.md)
 
 ## Features
 
@@ -51,6 +51,7 @@
     - [x] [Yandex.Disk](https://disk.yandex.com/)
     - [x] [百度网盘](http://pan.baidu.com/)
     - [x] [夸克网盘](https://pan.quark.cn)
+    - [x] [迅雷网盘](https://pan.xunlei.com)
 - [x] 部署方便，开箱即用
 - [x] 文件预览（PDF、markdown、代码、纯文本……）
 - [x] 画廊模式下的图像预览

build.sh

@@ -25,11 +25,11 @@ ldflags="\
 "
 
 FetchWebDev() {
-  curl -L https://codeload.github.com/alist-org/web-dist/tar.gz/refs/heads/main -o web-dist-main.tar.gz
-  tar -zxvf web-dist-main.tar.gz
+  curl -L https://codeload.github.com/alist-org/web-dist/tar.gz/refs/heads/dev -o web-dist-dev.tar.gz
+  tar -zxvf web-dist-dev.tar.gz
   rm -rf public/dist
-  mv -f web-dist-main/dist public
-  rm -rf web-dist-main web-dist-main.tar.gz
+  mv -f web-dist-dev/dist public
+  rm -rf web-dist-dev web-dist-dev.tar.gz
 }
 
 FetchWebRelease() {

cmd/admin.go

@@ -11,15 +11,16 @@ import (
 
 // passwordCmd represents the password command
 var passwordCmd = &cobra.Command{
-	Use:   "password",
-	Short: "Show admin user's password",
+	Use:     "admin",
+	Aliases: []string{"password"},
+	Short:   "Show admin user's info",
 	Run: func(cmd *cobra.Command, args []string) {
 		Init()
 		admin, err := db.GetAdmin()
 		if err != nil {
 			utils.Log.Errorf("failed get admin user: %+v", err)
 		} else {
-			utils.Log.Infof("admin user's password is: %s", admin.Password)
+			utils.Log.Infof("admin user's info: \nusername: %s\npassword: %s", admin.Username, admin.Password)
 		}
 	},
 }

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/123/driver.go

@@ -9,10 +9,10 @@ import (
 	"fmt"
 	"io"
 	"net/http"
+	"net/url"
 	"os"
 
 	"github.com/alist-org/alist/v3/drivers/base"
-	"github.com/alist-org/alist/v3/internal/conf"
 	"github.com/alist-org/alist/v3/internal/driver"
 	"github.com/alist-org/alist/v3/internal/errs"
 	"github.com/alist-org/alist/v3/internal/model"
@@ -22,6 +22,7 @@ import (
 	"github.com/aws/aws-sdk-go/aws/session"
 	"github.com/aws/aws-sdk-go/service/s3/s3manager"
 	"github.com/go-resty/resty/v2"
+	log "github.com/sirupsen/logrus"
 )
 
 type Pan123 struct {
@@ -68,9 +69,47 @@ func (d *Pan123) List(ctx context.Context, dir model.Obj, args model.ListArgs) (
 
 func (d *Pan123) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
 	if f, ok := file.(File); ok {
-		return &model.Link{
-			URL: f.DownloadUrl,
-		}, nil
+		var resp DownResp
+		var headers map[string]string
+		if !utils.IsLocalIPAddr(args.IP) {
+			headers = map[string]string{
+				//"X-Real-IP":       "1.1.1.1",
+				"X-Forwarded-For": args.IP,
+			}
+		}
+		data := base.Json{
+			"driveId":   0,
+			"etag":      f.Etag,
+			"fileId":    f.FileId,
+			"fileName":  f.FileName,
+			"s3keyFlag": f.S3KeyFlag,
+			"size":      f.Size,
+			"type":      f.Type,
+		}
+		_, err := d.request("https://www.123pan.com/api/file/download_info", http.MethodPost, func(req *resty.Request) {
+			req.SetBody(data).SetHeaders(headers)
+		}, &resp)
+		if err != nil {
+			return nil, err
+		}
+		u, err := url.Parse(resp.Data.DownloadUrl)
+		if err != nil {
+			return nil, err
+		}
+		u_ := fmt.Sprintf("https://%s%s", u.Host, u.Path)
+		res, err := base.NoRedirectClient.R().SetQueryParamsFromValues(u.Query()).Head(u_)
+		if err != nil {
+			return nil, err
+		}
+		log.Debug(res.String())
+		link := model.Link{
+			URL: resp.Data.DownloadUrl,
+		}
+		log.Debugln("res code: ", res.StatusCode())
+		if res.StatusCode() == 302 {
+			link.URL = res.Header().Get("location")
+		}
+		return &link, nil
 	} else {
 		return nil, fmt.Errorf("can't convert obj")
 	}
@@ -153,7 +192,7 @@ func (d *Pan123) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 		uploadFile = io.MultiReader(buf, stream)
 	} else {
 		// 计算完整文件MD5
-		tempFile, err := os.CreateTemp(conf.Conf.TempDir, "file-*")
+		tempFile, err := utils.CreateTempFile(stream.GetReadCloser())
 		if err != nil {
 			return err
 		}
@@ -161,11 +200,9 @@ func (d *Pan123) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 			_ = tempFile.Close()
 			_ = os.Remove(tempFile.Name())
 		}()
-
-		if _, err = io.Copy(io.MultiWriter(tempFile, h), stream); err != nil {
+		if _, err = io.Copy(h, tempFile); err != nil {
 			return err
 		}
-
 		_, err = tempFile.Seek(0, io.SeekStart)
 		if err != nil {
 			return err
@@ -220,8 +257,4 @@ func (d *Pan123) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 	return err
 }
 
-func (d *Pan123) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*Pan123)(nil)

drivers/139/driver.go

@@ -319,8 +319,4 @@ func (d *Yun139) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 	return nil
 }
 
-func (d *Yun139) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*Yun139)(nil)

drivers/189/driver.go

@@ -7,7 +7,6 @@ import (
 
 	"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"
@@ -208,8 +207,4 @@ func (d *Cloud189) Put(ctx context.Context, dstDir model.Obj, stream model.FileS
 	return d.newUpload(dstDir, stream, up)
 }
 
-func (d *Cloud189) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*Cloud189)(nil)

drivers/189pc/driver.go

@@ -3,14 +3,11 @@ package _189pc
 import (
 	"context"
 	"net/http"
-	"regexp"
-	"strconv"
 	"strings"
 	"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"
@@ -134,7 +131,7 @@ 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 {
@@ -144,6 +141,7 @@ func (y *Yun189PC) Link(ctx context.Context, file model.Obj, args model.LinkArgs
 				like.Expiration = &expired
 			}
 		}
+	*/
 	return like, nil
 }
 
@@ -278,7 +276,3 @@ func (y *Yun189PC) Put(ctx context.Context, dstDir model.Obj, stream model.FileS
 	}
 	return y.CommonUpload(ctx, dstDir, stream, up)
 }
-
-func (y *Yun189PC) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}

drivers/189pc/help.go

@@ -78,8 +78,7 @@ func timestamp() int64 {
 }
 
 func MustParseTime(str string) *time.Time {
-	loc, _ := time.LoadLocation("Asia/Shanghai")
-	lastOpTime, _ := time.ParseInLocation("2006-01-02 15:04:05", str, loc)
+	lastOpTime, _ := time.ParseInLocation("2006-01-02 15:04:05 -07", str+" +08", time.Local)
 	return &lastOpTime
 }
 

drivers/189pc/meta.go

@@ -9,7 +9,7 @@ type Addition struct {
 	Username string `json:"username" required:"true"`
 	Password string `json:"password" required:"true"`
 	VCode    string `json:"validate_code"`
-	RootFolderID   string `json:"root_folder_id"`
+	driver.RootID
 	OrderBy        string `json:"order_by" type:"select" options:"filename,filesize,lastOpTime" default:"filename"`
 	OrderDirection string `json:"order_direction" type:"select" options:"asc,desc" default:"asc"`
 	Type           string `json:"type" type:"select" options:"personal,family" default:"personal"`
@@ -17,10 +17,6 @@ type Addition struct {
 	RapidUpload    bool   `json:"rapid_upload"`
 }
 
-func (a Addition) GetRootId() string {
-	return a.RootFolderID
-}
-
 var config = driver.Config{
 	Name:        "189CloudPC",
 	DefaultRoot: "-11",

drivers/189pc/utils.go

@@ -140,13 +140,7 @@ func (y *Yun189PC) getFiles(ctx context.Context, fileId string) ([]model.Obj, er
 	fullUrl += "/listFiles.action"
 
 	res := make([]model.Obj, 0, 130)
-	for pageNum := 1; pageNum < 100; pageNum++ {
-		select {
-		case <-ctx.Done():
-			return nil, ctx.Err()
-		default:
-		}
-
+	for pageNum := 1; ; pageNum++ {
 		var resp Cloud189FilesResp
 		_, err := y.get(fullUrl, func(r *resty.Request) {
 			r.SetContext(ctx)
@@ -506,14 +500,14 @@ func (y *Yun189PC) CommonUpload(ctx context.Context, dstDir model.Obj, file mode
 // 快传
 func (y *Yun189PC) FastUpload(ctx context.Context, dstDir model.Obj, file model.FileStreamer, up driver.UpdateProgress) (err error) {
 	// 需要获取完整文件md5,必须支持 io.Seek
-	if _, ok := file.GetReadCloser().(*os.File); !ok {
-		r, err := utils.CreateTempFile(file)
+	tempFile, err := utils.CreateTempFile(file.GetReadCloser())
 	if err != nil {
 		return err
 	}
-		file.Close()
-		file.SetReadCloser(r)
-	}
+	defer func() {
+		_ = tempFile.Close()
+		_ = os.Remove(tempFile.Name())
+	}()
 
 	const DEFAULT int64 = 10485760
 	count := int(math.Ceil(float64(file.GetSize()) / float64(DEFAULT)))
@@ -531,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
@@ -599,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

@@ -264,8 +264,10 @@ func (d *AliDrive) Put(ctx context.Context, dstDir model.Obj, stream model.FileS
 			return err
 		}
 		res.Body.Close()
+		if count > 0 {
 			up(i * 100 / count)
 		}
+	}
 	var resp2 base.Json
 	_, err, e = d.request("https://api.aliyundrive.com/v2/file/complete", http.MethodPost, func(req *resty.Request) {
 		req.SetBody(base.Json{
@@ -284,7 +286,29 @@ func (d *AliDrive) Put(ctx context.Context, dstDir model.Obj, stream model.FileS
 }
 
 func (d *AliDrive) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
+	var resp base.Json
+	var url string
+	data := base.Json{
+		"drive_id": d.DriveId,
+		"file_id":  args.Obj.GetID(),
+	}
+	switch args.Method {
+	case "doc_preview":
+		url = "https://api.aliyundrive.com/v2/file/get_office_preview_url"
+		data["access_token"] = d.AccessToken
+	case "video_preview":
+		url = "https://api.aliyundrive.com/v2/file/get_video_preview_play_info"
+		data["category"] = "live_transcoding"
+	default:
 		return nil, errs.NotSupport
+	}
+	_, err, _ := d.request(url, http.MethodPost, func(req *resty.Request) {
+		req.SetBody(data)
+	}, &resp)
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
 }
 
 var _ driver.Driver = (*AliDrive)(nil)

drivers/all.go

@@ -7,6 +7,7 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/189pc"
 	_ "github.com/alist-org/alist/v3/drivers/aliyundrive"
 	_ "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/local"
@@ -17,6 +18,7 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/s3"
 	_ "github.com/alist-org/alist/v3/drivers/sftp"
 	_ "github.com/alist-org/alist/v3/drivers/teambition"
+	_ "github.com/alist-org/alist/v3/drivers/thunder"
 	_ "github.com/alist-org/alist/v3/drivers/uss"
 	_ "github.com/alist-org/alist/v3/drivers/virtual"
 	_ "github.com/alist-org/alist/v3/drivers/webdav"

drivers/baidu_netdisk/driver.go

@@ -14,9 +14,7 @@ import (
 	"strings"
 
 	"github.com/alist-org/alist/v3/drivers/base"
-	"github.com/alist-org/alist/v3/internal/conf"
 	"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"
 	log "github.com/sirupsen/logrus"
@@ -119,12 +117,7 @@ func (d *BaiduNetdisk) Remove(ctx context.Context, obj model.Obj) error {
 }
 
 func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
-	var tempFile *os.File
-	var err error
-	if f, ok := stream.GetReadCloser().(*os.File); ok {
-		tempFile = f
-	} else {
-		tempFile, err = os.CreateTemp(conf.Conf.TempDir, "file-*")
+	tempFile, err := utils.CreateTempFile(stream.GetReadCloser())
 	if err != nil {
 		return err
 	}
@@ -132,15 +125,6 @@ func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.F
 		_ = tempFile.Close()
 		_ = os.Remove(tempFile.Name())
 	}()
-		_, err = io.Copy(tempFile, stream)
-		if err != nil {
-			return err
-		}
-		_, err = tempFile.Seek(0, io.SeekStart)
-		if err != nil {
-			return err
-		}
-	}
 	var Default int64 = 4 * 1024 * 1024
 	defaultByteData := make([]byte, Default)
 	count := int(math.Ceil(float64(stream.GetSize()) / float64(Default)))
@@ -217,7 +201,7 @@ func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.F
 		"uploadid":     precreateResp.Uploadid,
 	}
 	left = stream.GetSize()
-	for _, partseq := range precreateResp.BlockList {
+	for i, partseq := range precreateResp.BlockList {
 		byteSize := Default
 		var byteData []byte
 		if left < Default {
@@ -238,13 +222,12 @@ func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.F
 			return err
 		}
 		log.Debugln(res.String())
+		if len(precreateResp.BlockList) > 0 {
+			up(i * 100 / len(precreateResp.BlockList))
+		}
 	}
 	_, err = d.create(path, stream.GetSize(), 0, precreateResp.Uploadid, block_list_str)
 	return err
 }
 
-func (d *BaiduNetdisk) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*BaiduNetdisk)(nil)

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/driver.go

@@ -127,8 +127,4 @@ func (d *FTP) Put(ctx context.Context, dstDir model.Obj, stream model.FileStream
 	return d.conn.Stor(stdpath.Join(dstDir.GetPath(), stream.GetName()), stream)
 }
 
-func (d *FTP) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*FTP)(nil)

drivers/google_drive/driver.go

@@ -141,8 +141,4 @@ func (d *GoogleDrive) Put(ctx context.Context, dstDir model.Obj, stream model.Fi
 	return err
 }
 
-func (d *GoogleDrive) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*GoogleDrive)(nil)

drivers/google_drive/types.go

@@ -34,7 +34,7 @@ func fileToObj(f File) *model.ObjThumb {
 			Name:     f.Name,
 			Size:     size,
 			Modified: time.Time{},
-			IsFolder: false,
+			IsFolder: f.MimeType == "application/vnd.google-apps.folder",
 		},
 		Thumbnail: model.Thumbnail{},
 	}

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
@@ -217,8 +217,4 @@ func (d *Local) Put(ctx context.Context, dstDir model.Obj, stream model.FileStre
 	return nil
 }
 
-func (d *Local) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*Local)(nil)

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/mediatrack/driver.go

@@ -12,9 +12,7 @@ import (
 	"strconv"
 
 	"github.com/alist-org/alist/v3/drivers/base"
-	"github.com/alist-org/alist/v3/internal/conf"
 	"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/internal/op"
 	"github.com/alist-org/alist/v3/pkg/utils"
@@ -177,7 +175,7 @@ func (d *MediaTrack) Put(ctx context.Context, dstDir model.Obj, stream model.Fil
 	if err != nil {
 		return err
 	}
-	tempFile, err := os.CreateTemp(conf.Conf.TempDir, "file-*")
+	tempFile, err := utils.CreateTempFile(stream.GetReadCloser())
 	if err != nil {
 		return err
 	}
@@ -185,14 +183,6 @@ func (d *MediaTrack) Put(ctx context.Context, dstDir model.Obj, stream model.Fil
 		_ = tempFile.Close()
 		_ = os.Remove(tempFile.Name())
 	}()
-	_, err = io.Copy(tempFile, stream)
-	if err != nil {
-		return err
-	}
-	_, err = tempFile.Seek(0, io.SeekStart)
-	if err != nil {
-		return err
-	}
 	uploader := s3manager.NewUploader(s)
 	input := &s3manager.UploadInput{
 		Bucket: &resp.Data.Bucket,
@@ -230,8 +220,4 @@ func (d *MediaTrack) Put(ctx context.Context, dstDir model.Obj, stream model.Fil
 	return err
 }
 
-func (d *MediaTrack) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*MediaTrack)(nil)

drivers/onedrive/driver.go

@@ -144,8 +144,4 @@ func (d *Onedrive) Put(ctx context.Context, dstDir model.Obj, stream model.FileS
 	return err
 }
 
-func (d *Onedrive) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*Onedrive)(nil)

drivers/pikpak/driver.go

@@ -11,9 +11,7 @@ import (
 	"strings"
 
 	"github.com/alist-org/alist/v3/drivers/base"
-	"github.com/alist-org/alist/v3/internal/conf"
 	"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/aws/aws-sdk-go/aws"
@@ -134,12 +132,7 @@ func (d *PikPak) Remove(ctx context.Context, obj model.Obj) error {
 }
 
 func (d *PikPak) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
-	var tempFile *os.File
-	var err error
-	if f, ok := stream.GetReadCloser().(*os.File); ok {
-		tempFile = f
-	} else {
-		tempFile, err = os.CreateTemp(conf.Conf.TempDir, "file-*")
+	tempFile, err := utils.CreateTempFile(stream.GetReadCloser())
 	if err != nil {
 		return err
 	}
@@ -147,15 +140,6 @@ func (d *PikPak) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 		_ = tempFile.Close()
 		_ = os.Remove(tempFile.Name())
 	}()
-		_, err = io.Copy(tempFile, stream)
-		if err != nil {
-			return err
-		}
-		_, err = tempFile.Seek(0, io.SeekStart)
-		if err != nil {
-			return err
-		}
-	}
 	// cal sha1
 	s := sha1.New()
 	_, err = io.Copy(s, tempFile)
@@ -182,6 +166,10 @@ func (d *PikPak) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 	if err != nil {
 		return err
 	}
+	if stream.GetSize() == 0 {
+		log.Debugln(string(res))
+		return nil
+	}
 	params := jsoniter.Get(res, "resumable").Get("params")
 	endpoint := params.Get("endpoint").ToString()
 	endpointS := strings.Split(endpoint, ".")
@@ -210,8 +198,4 @@ func (d *PikPak) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 	return err
 }
 
-func (d *PikPak) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*PikPak)(nil)

drivers/quark/driver.go

@@ -8,9 +8,9 @@ import (
 	"io"
 	"net/http"
 	"os"
+	"time"
 
 	"github.com/alist-org/alist/v3/drivers/base"
-	"github.com/alist-org/alist/v3/internal/conf"
 	"github.com/alist-org/alist/v3/internal/driver"
 	"github.com/alist-org/alist/v3/internal/errs"
 	"github.com/alist-org/alist/v3/internal/model"
@@ -91,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
 }
 
@@ -135,12 +138,7 @@ func (d *Quark) Remove(ctx context.Context, obj model.Obj) error {
 }
 
 func (d *Quark) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
-	var tempFile *os.File
-	var err error
-	if f, ok := stream.GetReadCloser().(*os.File); ok {
-		tempFile = f
-	} else {
-		tempFile, err = os.CreateTemp(conf.Conf.TempDir, "file-*")
+	tempFile, err := utils.CreateTempFile(stream.GetReadCloser())
 	if err != nil {
 		return err
 	}
@@ -148,15 +146,6 @@ func (d *Quark) Put(ctx context.Context, dstDir model.Obj, stream model.FileStre
 		_ = tempFile.Close()
 		_ = os.Remove(tempFile.Name())
 	}()
-		_, err = io.Copy(tempFile, stream)
-		if err != nil {
-			return err
-		}
-		_, err = tempFile.Seek(0, io.SeekStart)
-		if err != nil {
-			return err
-		}
-	}
 	m := md5.New()
 	_, err = io.Copy(m, tempFile)
 	if err != nil {
@@ -230,8 +219,4 @@ func (d *Quark) Put(ctx context.Context, dstDir model.Obj, stream model.FileStre
 	return d.upFinish(pre)
 }
 
-func (d *Quark) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*Quark)(nil)

drivers/quark/meta.go

@@ -15,6 +15,7 @@ type Addition struct {
 var config = driver.Config{
 	Name:        "Quark",
 	OnlyProxy:   true,
+	DefaultRoot: "0",
 }
 
 func New() driver.Driver {

drivers/s3/driver.go

@@ -10,7 +10,6 @@ import (
 	"time"
 
 	"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/aws/aws-sdk-go/aws/session"
@@ -119,7 +118,7 @@ func (d *S3) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
 }
 
 func (d *S3) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
-	err := d.copy(srcObj.GetPath(), stdpath.Join(stdpath.Dir(srcObj.GetPath()), newName), srcObj.IsDir())
+	err := d.copy(ctx, srcObj.GetPath(), stdpath.Join(stdpath.Dir(srcObj.GetPath()), newName), srcObj.IsDir())
 	if err != nil {
 		return err
 	}
@@ -127,7 +126,7 @@ func (d *S3) Rename(ctx context.Context, srcObj model.Obj, newName string) error
 }
 
 func (d *S3) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
-	return d.copy(srcObj.GetPath(), stdpath.Join(dstDir.GetPath(), srcObj.GetName()), srcObj.IsDir())
+	return d.copy(ctx, srcObj.GetPath(), stdpath.Join(dstDir.GetPath(), srcObj.GetName()), srcObj.IsDir())
 }
 
 func (d *S3) Remove(ctx context.Context, obj model.Obj) error {
@@ -153,8 +152,4 @@ func (d *S3) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreame
 	return err
 }
 
-func (d *S3) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*S3)(nil)

drivers/s3/util.go

@@ -1,12 +1,14 @@
 package s3
 
 import (
+	"context"
 	"errors"
 	"net/http"
 	"path"
 	"strings"
 
 	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/internal/op"
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/aws/credentials"
 	"github.com/aws/aws-sdk-go/aws/request"
@@ -165,14 +167,41 @@ func (d *S3) listV2(prefix string) ([]model.Obj, error) {
 	return files, nil
 }
 
-func (d *S3) copy(src string, dst string, isDir bool) error {
-	srcKey := getKey(src, isDir)
-	dstKey := getKey(dst, isDir)
+func (d *S3) copy(ctx context.Context, src string, dst string, isDir bool) error {
+	if isDir {
+		return d.copyDir(ctx, src, dst)
+	}
+	return d.copyFile(ctx, src, dst)
+}
+
+func (d *S3) copyFile(ctx context.Context, src string, dst string) error {
+	srcKey := getKey(src, false)
+	dstKey := getKey(dst, false)
 	input := &s3.CopyObjectInput{
 		Bucket:     &d.Bucket,
-		CopySource: &srcKey,
+		CopySource: aws.String("/" + d.Bucket + "/" + srcKey),
 		Key:        &dstKey,
 	}
 	_, err := d.client.CopyObject(input)
 	return err
 }
+
+func (d *S3) copyDir(ctx context.Context, src string, dst 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())
+		cDst := path.Join(dst, obj.GetName())
+		if obj.IsDir() {
+			err = d.copyDir(ctx, cSrc, cDst)
+		} else {
+			err = d.copyFile(ctx, cSrc, cDst)
+		}
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}

drivers/sftp/driver.go

@@ -99,8 +99,4 @@ func (d *SFTP) Put(ctx context.Context, dstDir model.Obj, stream model.FileStrea
 	return err
 }
 
-func (d *SFTP) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*SFTP)(nil)

drivers/teambition/driver.go

@@ -7,7 +7,6 @@ import (
 
 	"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"
@@ -156,8 +155,4 @@ func (d *Teambition) Put(ctx context.Context, dstDir model.Obj, stream model.Fil
 	return d.finishUpload(newFile, dstDir.GetID())
 }
 
-func (d *Teambition) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*Teambition)(nil)

drivers/template/driver.go

@@ -42,10 +42,10 @@ func (d *Template) List(ctx context.Context, dir model.Obj, args model.ListArgs)
 	return nil, errs.NotImplement
 }
 
-func (d *Template) Get(ctx context.Context, path string) (model.Obj, error) {
-	// this is optional
-	return nil, errs.NotImplement
-}
+//func (d *Template) Get(ctx context.Context, path string) (model.Obj, error) {
+//	// this is optional
+//	return nil, errs.NotImplement
+//}
 
 func (d *Template) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
 	// TODO return link of file
@@ -82,8 +82,8 @@ func (d *Template) Put(ctx context.Context, dstDir model.Obj, stream model.FileS
 	return errs.NotImplement
 }
 
-func (d *Template) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
+//func (d *Template) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
+//	return nil, errs.NotSupport
+//}
 
 var _ driver.Driver = (*Template)(nil)

drivers/thunder/driver.go

@@ -0,0 +1,492 @@
+package thunder
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"strings"
+
+	"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/internal/op"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/credentials"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/s3/s3manager"
+	"github.com/go-resty/resty/v2"
+)
+
+type Thunder struct {
+	*XunLeiCommon
+	model.Storage
+	Addition
+
+	identity string
+}
+
+func (x *Thunder) Config() driver.Config {
+	return config
+}
+
+func (x *Thunder) GetAddition() driver.Additional {
+	return x.Addition
+}
+
+func (x *Thunder) Init(ctx context.Context, storage model.Storage) (err error) {
+	x.Storage = storage
+	if err = utils.Json.UnmarshalFromString(x.Storage.Addition, &x.Addition); err != nil {
+		return err
+	}
+
+	// 初始化所需参数
+	if x.XunLeiCommon == nil {
+		x.XunLeiCommon = &XunLeiCommon{
+			Common: &Common{
+				client: base.NewRestyClient(),
+				Algorithms: []string{
+					"HPxr4BVygTQVtQkIMwQH33ywbgYG5l4JoR",
+					"GzhNkZ8pOBsCY+7",
+					"v+l0ImTpG7c7/",
+					"e5ztohgVXNP",
+					"t",
+					"EbXUWyVVqQbQX39Mbjn2geok3/0WEkAVxeqhtx857++kjJiRheP8l77gO",
+					"o7dvYgbRMOpHXxCs",
+					"6MW8TD8DphmakaxCqVrfv7NReRRN7ck3KLnXBculD58MvxjFRqT+",
+					"kmo0HxCKVfmxoZswLB4bVA/dwqbVAYghSb",
+					"j",
+					"4scKJNdd7F27Hv7tbt",
+				},
+				DeviceID:          "9aa5c268e7bcfc197a9ad88e2fb330e5",
+				ClientID:          "Xp6vsxz_7IYVw2BB",
+				ClientSecret:      "Xp6vsy4tN9toTVdMSpomVdXpRmES",
+				ClientVersion:     "7.51.0.8196",
+				PackageName:       "com.xunlei.downloadprovider",
+				UserAgent:         "ANDROID-com.xunlei.downloadprovider/7.51.0.8196 netWorkType/5G appid/40 deviceName/Xiaomi_M2004j7ac deviceModel/M2004J7AC OSVersion/12 protocolVersion/301 platformVersion/10 sdkVersion/220200 Oauth2Client/0.9 (Linux 4_14_186-perf-gddfs8vbb238b) (JAVA 0)",
+				DownloadUserAgent: "Dalvik/2.1.0 (Linux; U; Android 12; M2004J7AC Build/SP1A.210812.016)",
+			},
+			refreshTokenFunc: func() error {
+				// 通过RefreshToken刷新
+				token, err := x.RefreshToken(x.TokenResp.RefreshToken)
+				if err != nil {
+					// 重新登录
+					token, err = x.Login(x.Username, x.Password)
+					if err != nil {
+						x.GetStorage().SetStatus(fmt.Sprintf("%+v", err.Error()))
+						op.MustSaveDriverStorage(x)
+					}
+				}
+				x.SetTokenResp(token)
+				return err
+			},
+		}
+	}
+
+	// 自定义验证码token
+	ctoekn := strings.TrimSpace(x.CaptchaToken)
+	if ctoekn != "" {
+		x.SetCaptchaToken(ctoekn)
+		x.CaptchaToken = ""
+	}
+
+	// 防止重复登录
+	identity := x.GetIdentity()
+	if x.identity != identity || !x.IsLogin() {
+		x.identity = identity
+		// 登录
+		token, err := x.Login(x.Username, x.Password)
+		if err != nil {
+			return err
+		}
+		x.SetTokenResp(token)
+	}
+	return nil
+}
+
+func (x *Thunder) Drop(ctx context.Context) error {
+	return nil
+}
+
+type ThunderExpert struct {
+	*XunLeiCommon
+	model.Storage
+	ExpertAddition
+
+	identity string
+}
+
+func (x *ThunderExpert) Config() driver.Config {
+	return configExpert
+}
+
+func (x *ThunderExpert) GetAddition() driver.Additional {
+	return x.ExpertAddition
+}
+
+func (x *ThunderExpert) Init(ctx context.Context, storage model.Storage) (err error) {
+	x.Storage = storage
+	if err = utils.Json.UnmarshalFromString(x.Storage.Addition, &x.ExpertAddition); err != nil {
+		return err
+	}
+
+	// 防止重复登录
+	identity := x.GetIdentity()
+	if identity != x.identity || !x.IsLogin() {
+		x.identity = identity
+		x.XunLeiCommon = &XunLeiCommon{
+			Common: &Common{
+				client: base.NewRestyClient(),
+
+				DeviceID:          x.DeviceID,
+				ClientID:          x.ClientID,
+				ClientSecret:      x.ClientSecret,
+				ClientVersion:     x.ClientVersion,
+				PackageName:       x.PackageName,
+				UserAgent:         x.UserAgent,
+				DownloadUserAgent: x.DownloadUserAgent,
+			},
+		}
+
+		if x.CaptchaToken != "" {
+			x.SetCaptchaToken(x.CaptchaToken)
+			x.CaptchaToken = ""
+		}
+
+		// 签名方法
+		if x.SignType == "captcha_sign" {
+			x.Common.Timestamp = x.Timestamp
+			x.Common.CaptchaSign = x.CaptchaSign
+		} else {
+			x.Common.Algorithms = strings.Split(x.Algorithms, ",")
+		}
+
+		// 登录方式
+		if x.LoginType == "refresh_token" {
+			// 通过RefreshToken登录
+			token, err := x.XunLeiCommon.RefreshToken(x.ExpertAddition.RefreshToken)
+			if err != nil {
+				return err
+			}
+			x.SetTokenResp(token)
+
+			// 刷新token方法
+			x.SetRefreshTokenFunc(func() error {
+				token, err := x.XunLeiCommon.RefreshToken(x.TokenResp.RefreshToken)
+				if err != nil {
+					x.GetStorage().SetStatus(fmt.Sprintf("%+v", err.Error()))
+				}
+				x.SetTokenResp(token)
+				op.MustSaveDriverStorage(x)
+				return err
+			})
+		} else {
+			// 通过用户密码登录
+			token, err := x.Login(x.Username, x.Password)
+			if err != nil {
+				return err
+			}
+			x.SetTokenResp(token)
+			x.SetRefreshTokenFunc(func() error {
+				token, err := x.XunLeiCommon.RefreshToken(x.TokenResp.RefreshToken)
+				if err != nil {
+					token, err = x.Login(x.Username, x.Password)
+					if err != nil {
+						x.GetStorage().SetStatus(fmt.Sprintf("%+v", err.Error()))
+					}
+				}
+				x.SetTokenResp(token)
+				op.MustSaveDriverStorage(x)
+				return err
+			})
+		}
+	} else {
+		// 仅修改验证码token
+		if x.CaptchaToken != "" {
+			x.SetCaptchaToken(x.CaptchaToken)
+			x.CaptchaToken = ""
+		}
+		x.XunLeiCommon.UserAgent = x.UserAgent
+		x.XunLeiCommon.DownloadUserAgent = x.DownloadUserAgent
+	}
+	return nil
+}
+
+func (x *ThunderExpert) Drop(ctx context.Context) error {
+	return nil
+}
+
+func (x *ThunderExpert) SetTokenResp(token *TokenResp) {
+	x.XunLeiCommon.SetTokenResp(token)
+	if token != nil {
+		x.ExpertAddition.RefreshToken = token.RefreshToken
+	}
+}
+
+type XunLeiCommon struct {
+	*Common
+	*TokenResp // 登录信息
+
+	refreshTokenFunc func() error
+}
+
+func (xc *XunLeiCommon) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	return xc.getFiles(ctx, dir.GetID())
+}
+
+func (xc *XunLeiCommon) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	var lFile Files
+	_, err := xc.Request(FILE_API_URL+"/{fileID}", http.MethodGet, func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetPathParam("fileID", file.GetID())
+		//r.SetQueryParam("space", "")
+	}, &lFile)
+	if err != nil {
+		return nil, err
+	}
+	link := &model.Link{
+		URL: lFile.WebContentLink,
+		Header: http.Header{
+			"User-Agent": {xc.DownloadUserAgent},
+		},
+	}
+
+	/*
+		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
+}
+
+func (xc *XunLeiCommon) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error {
+	_, err := xc.Request(FILE_API_URL, http.MethodPost, func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetBody(&base.Json{
+			"kind":      FOLDER,
+			"name":      dirName,
+			"parent_id": parentDir.GetID(),
+		})
+	}, nil)
+	return err
+}
+
+func (xc *XunLeiCommon) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
+	_, err := xc.Request(FILE_API_URL+":batchMove", http.MethodPost, func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetBody(&base.Json{
+			"to":  base.Json{"parent_id": dstDir.GetID()},
+			"ids": []string{srcObj.GetID()},
+		})
+	}, nil)
+	return err
+}
+
+func (xc *XunLeiCommon) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
+	_, err := xc.Request(FILE_API_URL+"/{fileID}", http.MethodPatch, func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetPathParam("fileID", srcObj.GetID())
+		r.SetBody(&base.Json{"name": newName})
+	}, nil)
+	return err
+}
+
+func (xc *XunLeiCommon) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
+	_, err := xc.Request(FILE_API_URL+":batchCopy", http.MethodPost, func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetBody(&base.Json{
+			"to":  base.Json{"parent_id": dstDir.GetID()},
+			"ids": []string{srcObj.GetID()},
+		})
+	}, nil)
+	return err
+}
+
+func (xc *XunLeiCommon) Remove(ctx context.Context, obj model.Obj) error {
+	_, err := xc.Request(FILE_API_URL+"/{fileID}/trash", http.MethodPatch, func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetPathParam("fileID", obj.GetID())
+		r.SetBody("{}")
+	}, nil)
+	return err
+}
+
+func (xc *XunLeiCommon) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
+	var resp UploadTaskResponse
+	_, err := xc.Request(FILE_API_URL, http.MethodPost, func(r *resty.Request) {
+		r.SetContext(ctx)
+		r.SetBody(&base.Json{
+			"kind":        FILE,
+			"parent_id":   dstDir.GetID(),
+			"name":        stream.GetName(),
+			"size":        stream.GetSize(),
+			"hash":        "1CF254FBC456E1B012CD45C546636AA62CF8350E",
+			"upload_type": UPLOAD_TYPE_RESUMABLE,
+		})
+	}, &resp)
+	if err != nil {
+		return err
+	}
+
+	param := resp.Resumable.Params
+	if resp.UploadType == UPLOAD_TYPE_RESUMABLE {
+		param.Endpoint = strings.TrimLeft(param.Endpoint, param.Bucket+".")
+		s, err := session.NewSession(&aws.Config{
+			Credentials: credentials.NewStaticCredentials(param.AccessKeyID, param.AccessKeySecret, param.SecurityToken),
+			Region:      aws.String("xunlei"),
+			Endpoint:    aws.String(param.Endpoint),
+		})
+		if err != nil {
+			return err
+		}
+		_, err = s3manager.NewUploader(s).UploadWithContext(ctx, &s3manager.UploadInput{
+			Bucket:  aws.String(param.Bucket),
+			Key:     aws.String(param.Key),
+			Expires: aws.Time(param.Expiration),
+			Body:    stream,
+		})
+		return err
+	}
+	return nil
+}
+
+func (xc *XunLeiCommon) getFiles(ctx context.Context, folderId string) ([]model.Obj, error) {
+	files := make([]model.Obj, 0)
+	var pageToken string
+	for {
+		var fileList FileList
+		_, err := xc.Request(FILE_API_URL, http.MethodGet, func(r *resty.Request) {
+			r.SetContext(ctx)
+			r.SetQueryParams(map[string]string{
+				"space":      "",
+				"__type":     "drive",
+				"refresh":    "true",
+				"__sync":     "true",
+				"parent_id":  folderId,
+				"page_token": pageToken,
+				"with_audit": "true",
+				"limit":      "100",
+				"filters":    `{"phase":{"eq":"PHASE_TYPE_COMPLETE"},"trashed":{"eq":false}}`,
+			})
+		}, &fileList)
+		if err != nil {
+			return nil, err
+		}
+
+		for i := 0; i < len(fileList.Files); i++ {
+			files = append(files, &fileList.Files[i])
+		}
+
+		if fileList.NextPageToken == "" {
+			break
+		}
+		pageToken = fileList.NextPageToken
+	}
+	return files, nil
+}
+
+// 设置刷新Token的方法
+func (xc *XunLeiCommon) SetRefreshTokenFunc(fn func() error) {
+	xc.refreshTokenFunc = fn
+}
+
+// 设置Token
+func (xc *XunLeiCommon) SetTokenResp(tr *TokenResp) {
+	xc.TokenResp = tr
+}
+
+// 携带Authorization和CaptchaToken的请求
+func (xc *XunLeiCommon) Request(url string, method string, callback base.ReqCallback, resp interface{}) ([]byte, error) {
+	data, err := xc.Common.Request(url, method, func(req *resty.Request) {
+		req.SetHeaders(map[string]string{
+			"Authorization":   xc.Token(),
+			"X-Captcha-Token": xc.GetCaptchaToken(),
+		})
+		if callback != nil {
+			callback(req)
+		}
+	}, resp)
+
+	errResp, ok := err.(*ErrResp)
+	if !ok {
+		return nil, err
+	}
+
+	switch errResp.ErrorCode {
+	case 0:
+		return data, nil
+	case 4122, 4121, 10, 16:
+		if xc.refreshTokenFunc != nil {
+			if err = xc.refreshTokenFunc(); err == nil {
+				break
+			}
+		}
+		return nil, err
+	case 9: // 验证码token过期
+		if err = xc.RefreshCaptchaTokenAtLogin(GetAction(method, url), xc.UserID); err != nil {
+			return nil, err
+		}
+	default:
+		return nil, err
+	}
+	return xc.Request(url, method, callback, resp)
+}
+
+// 刷新Token
+func (xc *XunLeiCommon) RefreshToken(refreshToken string) (*TokenResp, error) {
+	var resp TokenResp
+	_, err := xc.Common.Request(XLUSER_API_URL+"/auth/token", http.MethodPost, func(req *resty.Request) {
+		req.SetBody(&base.Json{
+			"grant_type":    "refresh_token",
+			"refresh_token": refreshToken,
+			"client_id":     xc.ClientID,
+			"client_secret": xc.ClientSecret,
+		})
+	}, &resp)
+	if err != nil {
+		return nil, err
+	}
+
+	if resp.RefreshToken == "" {
+		return nil, errs.EmptyToken
+	}
+	return &resp, nil
+}
+
+// 登录
+func (xc *XunLeiCommon) Login(username, password string) (*TokenResp, error) {
+	url := XLUSER_API_URL + "/auth/signin"
+	err := xc.RefreshCaptchaTokenInLogin(GetAction(http.MethodPost, url), username)
+	if err != nil {
+		return nil, err
+	}
+
+	var resp TokenResp
+	_, err = xc.Common.Request(url, http.MethodPost, func(req *resty.Request) {
+		req.SetBody(&SignInRequest{
+			CaptchaToken: xc.GetCaptchaToken(),
+			ClientID:     xc.ClientID,
+			ClientSecret: xc.ClientSecret,
+			Username:     username,
+			Password:     password,
+		})
+	}, &resp)
+	if err != nil {
+		return nil, err
+	}
+	return &resp, nil
+}
+
+func (xc *XunLeiCommon) IsLogin() bool {
+	if xc.TokenResp == nil {
+		return false
+	}
+	_, err := xc.Request(XLUSER_API_URL+"/user/me", http.MethodGet, nil, nil)
+	return err == nil
+}

drivers/thunder/meta.go

@@ -0,0 +1,99 @@
+package thunder
+
+import (
+	"crypto/md5"
+	"encoding/hex"
+
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/op"
+	"github.com/alist-org/alist/v3/pkg/utils"
+)
+
+// 高级设置
+type ExpertAddition struct {
+	driver.RootID
+
+	LoginType string `json:"login_type" type:"select" options:"user,refresh_token" default:"user"`
+	SignType  string `json:"sign_type" type:"select" options:"algorithms,captcha_sign" default:"algorithms"`
+
+	// 登录方式1
+	Username string `json:"username" required:"true" help:"login type is user,this is required"`
+	Password string `json:"password" required:"true" help:"login type is user,this is required"`
+	// 登录方式2
+	RefreshToken string `json:"refresh_token" required:"true" help:"login type is refresh_token,this is required"`
+
+	// 签名方法1
+	Algorithms string `json:"algorithms" required:"true" help:"sign type is algorithms,this is required" default:"HPxr4BVygTQVtQkIMwQH33ywbgYG5l4JoR,GzhNkZ8pOBsCY+7,v+l0ImTpG7c7/,e5ztohgVXNP,t,EbXUWyVVqQbQX39Mbjn2geok3/0WEkAVxeqhtx857++kjJiRheP8l77gO,o7dvYgbRMOpHXxCs,6MW8TD8DphmakaxCqVrfv7NReRRN7ck3KLnXBculD58MvxjFRqT+,kmo0HxCKVfmxoZswLB4bVA/dwqbVAYghSb,j,4scKJNdd7F27Hv7tbt"`
+	// 签名方法2
+	CaptchaSign string `json:"captcha_sign" required:"true" help:"sign type is captcha_sign,this is required"`
+	Timestamp   string `json:"timestamp" required:"true" help:"sign type is captcha_sign,this is required"`
+
+	// 验证码
+	CaptchaToken string `json:"captcha_token"`
+
+	// 必要且影响登录,由签名决定
+	DeviceID      string `json:"device_id"  required:"true" default:"9aa5c268e7bcfc197a9ad88e2fb330e5"`
+	ClientID      string `json:"client_id"  required:"true" default:"Xp6vsxz_7IYVw2BB"`
+	ClientSecret  string `json:"client_secret"  required:"true" default:"Xp6vsy4tN9toTVdMSpomVdXpRmES"`
+	ClientVersion string `json:"client_version"  required:"true" default:"7.51.0.8196"`
+	PackageName   string `json:"package_name"  required:"true" default:"com.xunlei.downloadprovider"`
+
+	//不影响登录,影响下载速度
+	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)"`
+}
+
+// 登录特征,用于判断是否重新登录
+func (i *ExpertAddition) GetIdentity() string {
+	hash := md5.New()
+	if i.LoginType == "refresh_token" {
+		hash.Write([]byte(i.RefreshToken))
+	} else {
+		hash.Write([]byte(i.Username + i.Password))
+	}
+
+	if i.SignType == "captcha_sign" {
+		hash.Write([]byte(i.CaptchaSign + i.Timestamp))
+	} else {
+		hash.Write([]byte(i.Algorithms))
+	}
+
+	hash.Write([]byte(i.DeviceID))
+	hash.Write([]byte(i.ClientID))
+	hash.Write([]byte(i.ClientSecret))
+	hash.Write([]byte(i.ClientVersion))
+	hash.Write([]byte(i.PackageName))
+	return hex.EncodeToString(hash.Sum(nil))
+}
+
+type Addition struct {
+	driver.RootID
+	Username     string `json:"username" required:"true"`
+	Password     string `json:"password" required:"true"`
+	CaptchaToken string `json:"captcha_token"`
+}
+
+// 登录特征,用于判断是否重新登录
+func (i *Addition) GetIdentity() string {
+	return utils.GetMD5Encode(i.Username + i.Password)
+}
+
+var config = driver.Config{
+	Name:      "Thunder",
+	LocalSort: true,
+	OnlyProxy: true,
+}
+
+var configExpert = driver.Config{
+	Name:      "ThunderExpert",
+	LocalSort: true,
+}
+
+func init() {
+	op.RegisterDriver(config, func() driver.Driver {
+		return &Thunder{}
+	})
+	op.RegisterDriver(configExpert, func() driver.Driver {
+		return &ThunderExpert{}
+	})
+}

drivers/thunder/types.go

@@ -0,0 +1,188 @@
+package thunder
+
+import (
+	"fmt"
+	"strconv"
+	"time"
+)
+
+type ErrResp struct {
+	ErrorCode        int64  `json:"error_code"`
+	ErrorMsg         string `json:"error"`
+	ErrorDescription string `json:"error_description"`
+	//	ErrorDetails   interface{} `json:"error_details"`
+}
+
+func (e *ErrResp) IsError() bool {
+	return e.ErrorCode != 0 || e.ErrorMsg != "" || e.ErrorDescription != ""
+}
+
+func (e *ErrResp) Error() string {
+	return fmt.Sprintf("ErrorCode: %d ,Error: %s ,ErrorDescription: %s ", e.ErrorCode, e.ErrorMsg, e.ErrorDescription)
+}
+
+/*
+* 验证码Token
+**/
+type CaptchaTokenRequest struct {
+	Action       string            `json:"action"`
+	CaptchaToken string            `json:"captcha_token"`
+	ClientID     string            `json:"client_id"`
+	DeviceID     string            `json:"device_id"`
+	Meta         map[string]string `json:"meta"`
+	RedirectUri  string            `json:"redirect_uri"`
+}
+
+type CaptchaTokenResponse struct {
+	CaptchaToken string `json:"captcha_token"`
+	ExpiresIn    int64  `json:"expires_in"`
+	Url          string `json:"url"`
+}
+
+/*
+* 登录
+**/
+type TokenResp struct {
+	TokenType    string `json:"token_type"`
+	AccessToken  string `json:"access_token"`
+	RefreshToken string `json:"refresh_token"`
+	ExpiresIn    int64  `json:"expires_in"`
+
+	Sub    string `json:"sub"`
+	UserID string `json:"user_id"`
+}
+
+func (t *TokenResp) Token() string {
+	return fmt.Sprint(t.TokenType, " ", t.AccessToken)
+}
+
+type SignInRequest struct {
+	CaptchaToken string `json:"captcha_token"`
+
+	ClientID     string `json:"client_id"`
+	ClientSecret string `json:"client_secret"`
+
+	Username string `json:"username"`
+	Password string `json:"password"`
+}
+
+/*
+* 文件
+**/
+type FileList struct {
+	Kind            string  `json:"kind"`
+	NextPageToken   string  `json:"next_page_token"`
+	Files           []Files `json:"files"`
+	Version         string  `json:"version"`
+	VersionOutdated bool    `json:"version_outdated"`
+}
+
+type Files struct {
+	Kind     string `json:"kind"`
+	ID       string `json:"id"`
+	ParentID string `json:"parent_id"`
+	Name     string `json:"name"`
+	//UserID         string    `json:"user_id"`
+	Size string `json:"size"`
+	//Revision       string    `json:"revision"`
+	//FileExtension  string    `json:"file_extension"`
+	//MimeType       string    `json:"mime_type"`
+	//Starred        bool      `json:"starred"`
+	WebContentLink string    `json:"web_content_link"`
+	CreatedTime    time.Time `json:"created_time"`
+	ModifiedTime   time.Time `json:"modified_time"`
+	IconLink       string    `json:"icon_link"`
+	ThumbnailLink  string    `json:"thumbnail_link"`
+	//Md5Checksum    string    `json:"md5_checksum"`
+	//Hash           string    `json:"hash"`
+	//Links          struct{}   `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"`
+		Video          struct {
+			AudioCodec string `json:"audio_codec"`
+			BitRate    int    `json:"bit_rate"`
+			Duration   int    `json:"duration"`
+			FrameRate  int    `json:"frame_rate"`
+			Height     int    `json:"height"`
+			VideoCodec string `json:"video_codec"`
+			VideoType  string `json:"video_type"`
+			Width      int    `json:"width"`
+		} `json:"video"`
+		VipTypes []string `json:"vip_types"`
+	} `json:"medias"` */
+	Trashed     bool   `json:"trashed"`
+	DeleteTime  string `json:"delete_time"`
+	OriginalURL string `json:"original_url"`
+	//Params            struct{} `json:"params"`
+	//OriginalFileIndex int    `json:"original_file_index"`
+	//Space             string `json:"space"`
+	//Apps              []interface{} `json:"apps"`
+	//Writable   bool   `json:"writable"`
+	//FolderType string `json:"folder_type"`
+	//Collection interface{} `json:"collection"`
+}
+
+func (c *Files) GetSize() int64     { size, _ := strconv.ParseInt(c.Size, 10, 64); return size }
+func (c *Files) GetName() string    { return c.Name }
+func (c *Files) ModTime() time.Time { return c.ModifiedTime }
+func (c *Files) IsDir() bool        { return c.Kind == FOLDER }
+func (c *Files) GetID() string      { return c.ID }
+func (c *Files) GetPath() string    { return "" }
+func (c *Files) Thumb() string      { return c.ThumbnailLink }
+
+/*
+* 上传
+**/
+type UploadTaskResponse struct {
+	UploadType string `json:"upload_type"`
+
+	/*//UPLOAD_TYPE_FORM
+	Form struct {
+		//Headers struct{} `json:"headers"`
+		Kind       string `json:"kind"`
+		Method     string `json:"method"`
+		MultiParts struct {
+			OSSAccessKeyID string `json:"OSSAccessKeyId"`
+			Signature      string `json:"Signature"`
+			Callback       string `json:"callback"`
+			Key            string `json:"key"`
+			Policy         string `json:"policy"`
+			XUserData      string `json:"x:user_data"`
+		} `json:"multi_parts"`
+		URL string `json:"url"`
+	} `json:"form"`*/
+
+	//UPLOAD_TYPE_RESUMABLE
+	Resumable struct {
+		Kind   string `json:"kind"`
+		Params struct {
+			AccessKeyID     string    `json:"access_key_id"`
+			AccessKeySecret string    `json:"access_key_secret"`
+			Bucket          string    `json:"bucket"`
+			Endpoint        string    `json:"endpoint"`
+			Expiration      time.Time `json:"expiration"`
+			Key             string    `json:"key"`
+			SecurityToken   string    `json:"security_token"`
+		} `json:"params"`
+		Provider string `json:"provider"`
+	} `json:"resumable"`
+
+	File Files `json:"file"`
+}

drivers/thunder/util.go

@@ -0,0 +1,166 @@
+package thunder
+
+import (
+	"fmt"
+	"net/http"
+	"regexp"
+	"time"
+
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/go-resty/resty/v2"
+)
+
+const (
+	API_URL        = "https://api-pan.xunlei.com/drive/v1"
+	FILE_API_URL   = API_URL + "/files"
+	XLUSER_API_URL = "https://xluser-ssl.xunlei.com/v1"
+)
+
+const (
+	FOLDER    = "drive#folder"
+	FILE      = "drive#file"
+	RESUMABLE = "drive#resumable"
+)
+
+const (
+	UPLOAD_TYPE_UNKNOWN = "UPLOAD_TYPE_UNKNOWN"
+	//UPLOAD_TYPE_FORM      = "UPLOAD_TYPE_FORM"
+	UPLOAD_TYPE_RESUMABLE = "UPLOAD_TYPE_RESUMABLE"
+	UPLOAD_TYPE_URL       = "UPLOAD_TYPE_URL"
+)
+
+func GetAction(method string, url string) string {
+	urlpath := regexp.MustCompile(`://[^/]+((/[^/\s?#]+)*)`).FindStringSubmatch(url)[1]
+	return method + ":" + urlpath
+}
+
+type Common struct {
+	client *resty.Client
+
+	captchaToken string
+
+	// 签名相关,二选一
+	Algorithms             []string
+	Timestamp, CaptchaSign string
+
+	// 必要值,签名相关
+	DeviceID          string
+	ClientID          string
+	ClientSecret      string
+	ClientVersion     string
+	PackageName       string
+	UserAgent         string
+	DownloadUserAgent string
+}
+
+func (c *Common) SetCaptchaToken(captchaToken string) {
+	c.captchaToken = captchaToken
+}
+func (c *Common) GetCaptchaToken() string {
+	return c.captchaToken
+}
+
+// 刷新验证码token(登录后)
+func (c *Common) RefreshCaptchaTokenAtLogin(action, userID string) error {
+	metas := map[string]string{
+		"client_version": c.ClientVersion,
+		"package_name":   c.PackageName,
+		"user_id":        userID,
+	}
+	metas["timestamp"], metas["captcha_sign"] = c.GetCaptchaSign()
+	return c.refreshCaptchaToken(action, metas)
+}
+
+// 刷新验证码token(登录时)
+func (c *Common) RefreshCaptchaTokenInLogin(action, username string) error {
+	metas := make(map[string]string)
+	if ok, _ := regexp.MatchString(`\w+([-+.]\w+)*@\w+([-.]\w+)*\.\w+([-.]\w+)*`, username); ok {
+		metas["email"] = username
+	} else if len(username) >= 11 && len(username) <= 18 {
+		metas["phone_number"] = username
+	} else {
+		metas["username"] = username
+	}
+	return c.refreshCaptchaToken(action, metas)
+}
+
+// 获取验证码签名
+func (c *Common) GetCaptchaSign() (timestamp, sign string) {
+	if len(c.Algorithms) == 0 {
+		return c.Timestamp, c.CaptchaSign
+	}
+	timestamp = fmt.Sprint(time.Now().UnixMilli())
+	str := fmt.Sprint(c.ClientID, c.ClientVersion, c.PackageName, c.DeviceID, timestamp)
+	for _, algorithm := range c.Algorithms {
+		str = utils.GetMD5Encode(str + algorithm)
+	}
+	sign = "1." + str
+	return
+}
+
+// 刷新验证码token
+func (c *Common) refreshCaptchaToken(action string, metas map[string]string) error {
+	param := CaptchaTokenRequest{
+		Action:       action,
+		CaptchaToken: c.captchaToken,
+		ClientID:     c.ClientID,
+		DeviceID:     c.DeviceID,
+		Meta:         metas,
+		RedirectUri:  "xlaccsdk01://xunlei.com/callback?state=harbor",
+	}
+	var e ErrResp
+	var resp CaptchaTokenResponse
+	_, err := c.Request(XLUSER_API_URL+"/shield/captcha/init", http.MethodPost, func(req *resty.Request) {
+		req.SetError(&e).SetBody(param)
+	}, &resp)
+
+	if err != nil {
+		return err
+	}
+
+	if e.IsError() {
+		return &e
+	}
+
+	if resp.Url != "" {
+		return fmt.Errorf("need verify:%s", resp.Url)
+	}
+
+	if resp.CaptchaToken == "" {
+		return fmt.Errorf("empty captchaToken")
+	}
+
+	c.SetCaptchaToken(resp.CaptchaToken)
+	return nil
+}
+
+// 只有基础信息的请求
+func (c *Common) Request(url, method string, callback base.ReqCallback, resp interface{}) ([]byte, error) {
+	req := c.client.R().SetHeaders(map[string]string{
+		"user-agent":       c.UserAgent,
+		"accept":           "application/json;charset=UTF-8",
+		"x-device-id":      c.DeviceID,
+		"x-client-id":      c.ClientID,
+		"x-client-version": c.ClientVersion,
+	})
+
+	if callback != nil {
+		callback(req)
+	}
+	if resp != nil {
+		req.SetResult(resp)
+	}
+	res, err := req.Execute(method, url)
+	if err != nil {
+		return nil, err
+	}
+
+	var erron ErrResp
+	utils.Json.Unmarshal(res.Body(), &erron)
+	if erron.IsError() {
+		return nil, &erron
+	}
+
+	return res.Body(), nil
+}

drivers/uss/driver.go

@@ -9,7 +9,6 @@ import (
 	"time"
 
 	"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/upyun/go-sdk/v3/upyun"
@@ -140,8 +139,4 @@ func (d *USS) Put(ctx context.Context, dstDir model.Obj, stream model.FileStream
 	})
 }
 
-func (d *USS) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*USS)(nil)

drivers/virtual/driver.go

@@ -6,7 +6,6 @@ import (
 	"time"
 
 	"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/alist-org/alist/v3/pkg/utils/random"
@@ -89,8 +88,4 @@ func (d *Virtual) Put(ctx context.Context, dstDir model.Obj, stream model.FileSt
 	return nil
 }
 
-func (d *Virtual) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*Virtual)(nil)

drivers/webdav/driver.go

@@ -8,7 +8,6 @@ import (
 	"time"
 
 	"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/gowebdav"
@@ -123,8 +122,4 @@ func (d *WebDav) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 	return err
 }
 
-func (d *WebDav) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*WebDav)(nil)

drivers/yandex_disk/driver.go

@@ -8,7 +8,6 @@ import (
 
 	"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"
@@ -139,8 +138,4 @@ func (d *YandexDisk) Put(ctx context.Context, dstDir model.Obj, stream model.Fil
 	return err
 }
 
-func (d *YandexDisk) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
-	return nil, errs.NotSupport
-}
-
 var _ driver.Driver = (*YandexDisk)(nil)

internal/bootstrap/aria2.go

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

internal/bootstrap/config.go

@@ -48,16 +48,14 @@ func InitConfig() {
 		confFromEnv()
 	}
 	// convert abs path
-	var absPath string
-	var err error
 	if !filepath.IsAbs(conf.Conf.TempDir) {
-		absPath, err = filepath.Abs(conf.Conf.TempDir)
+		absPath, err := filepath.Abs(conf.Conf.TempDir)
 		if err != nil {
 			log.Fatalf("get abs path error: %+v", err)
 		}
-	}
 		conf.Conf.TempDir = absPath
-	err = os.RemoveAll(filepath.Join(conf.Conf.TempDir))
+	}
+	err := os.RemoveAll(filepath.Join(conf.Conf.TempDir))
 	if err != nil {
 		log.Errorln("failed delete temp file:", err)
 	}

internal/bootstrap/data/setting.go

@@ -35,15 +35,12 @@ func initSettings() {
 	for i := range initialSettingItems {
 		v := initialSettingItems[i]
 		_, err := db.GetSettingItemByKey(v.Key)
-		if err == nil {
-			continue
-		}
-		if errors.Is(err, gorm.ErrRecordNotFound) {
+		if errors.Is(err, gorm.ErrRecordNotFound) || v.Key == conf.VERSION {
 			err = db.SaveSettingItem(v)
 			if err != nil {
 				log.Fatalf("failed create setting: %+v", err)
 			}
-		} else {
+		} else if err != nil {
 			log.Fatalf("failed get setting: %+v", err)
 		}
 	}
@@ -94,7 +91,7 @@ func InitialSettings() []model.SettingItem {
 		"Google":"https://docs.google.com/gview?url=$e_url&embedded=true"
 	},
 	"pdf": {
-		"PDF.js":"https://alist.nn.ci/pdf.js/web/viewer.html?file=$e_url"
+		"PDF.js":"https://alist-org.github.io/pdf.js/web/viewer.html?file=$e_url"
 	}
 }`, Type: conf.TypeText, Group: model.PREVIEW},
 		//		{Key: conf.OfficeViewers, Value: `{

internal/bootstrap/db.go

@@ -53,6 +53,9 @@ func InitDB() {
 				dsn := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=utf8mb4&parseTime=True&loc=Local&tls=%s",
 					database.User, database.Password, database.Host, database.Port, database.Name, database.SSLMode)
 				dB, err = gorm.Open(mysql.Open(dsn), gormConfig)
+				if err == nil {
+					dB = dB.Set("gorm:table_options", "ENGINE=InnoDB CHARSET=utf8mb4")
+				}
 			}
 		case "postgres":
 			{

internal/db/db.go

@@ -7,10 +7,10 @@ import (
 	"gorm.io/gorm"
 )
 
-var db gorm.DB
+var db *gorm.DB
 
 func Init(d *gorm.DB) {
-	db = *d
+	db = d
 	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/driver/driver.go

@@ -10,7 +10,7 @@ type Driver interface {
 	Meta
 	Reader
 	Writer
-	Other
+	//Other
 }
 
 type Meta interface {

internal/driver/item.go

@@ -28,11 +28,11 @@ type IRootId interface {
 }
 
 type RootPath struct {
-	RootFolderPath string `json:"root_folder_path" required:"true"`
+	RootFolderPath string `json:"root_folder_path"`
 }
 
 type RootID struct {
-	RootFolderID string `json:"root_folder_id" required:"true"`
+	RootFolderID string `json:"root_folder_id"`
 }
 
 func (r RootPath) GetRootPath() string {

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/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/driver.go

@@ -145,9 +145,12 @@ func getAdditionalItems(t reflect.Type, defaultRoot string) []driver.Item {
 		if tag.Get("type") != "" {
 			item.Type = tag.Get("type")
 		}
-		if (item.Name == "root_folder_id" || item.Name == "root_folder_path") && item.Default == "" {
+		if item.Name == "root_folder_id" || item.Name == "root_folder_path" {
+			if item.Default == "" {
 				item.Default = defaultRoot
 			}
+			item.Required = item.Default != ""
+		}
 		// set default type to string
 		if item.Type == "" {
 			item.Type = "string"

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,7 +50,7 @@ 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 {
 			return files, nil
@@ -142,7 +146,7 @@ func Link(ctx context.Context, storage driver.Driver, path string, args model.Li
 	if file.IsDir() {
 		return nil, nil, errors.WithStack(errs.NotFile)
 	}
-	key := stdpath.Join(storage.GetStorage().MountPath, path)
+	key := stdpath.Join(storage.GetStorage().MountPath, path) + ":" + args.IP
 	if link, ok := linkCache.Get(key); ok {
 		return link, file, nil
 	}
@@ -166,17 +170,22 @@ func Other(ctx context.Context, storage driver.Driver, args model.FsOtherArgs) (
 	if err != nil {
 		return nil, errors.WithMessagef(err, "failed to get obj")
 	}
-	return storage.Other(ctx, model.OtherArgs{
+	if o, ok := storage.(driver.Other); ok {
+		return o.Other(ctx, model.OtherArgs{
 			Obj:    obj,
 			Method: args.Method,
 			Data:   args.Data,
 		})
+	} else {
+		return nil, errs.NotImplement
+	}
 }
 
 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)
 	}
+	path = utils.StandardizePath(path)
 	// check if dir exists
 	f, err := Get(ctx, storage, path)
 	if err != nil {
@@ -191,7 +200,11 @@ func MakeDir(ctx context.Context, storage driver.Driver, path string) error {
 			if err != nil {
 				return errors.WithMessagef(err, "failed to get parent dir [%s]", parentPath)
 			}
-			return errors.WithStack(storage.MakeDir(ctx, parentDir, dirName))
+			err = storage.MakeDir(ctx, parentDir, dirName)
+			if err == nil {
+				ClearCache(storage, parentPath)
+			}
+			return errors.WithStack(err)
 		} else {
 			return errors.WithMessage(err, "failed to check if dir exists")
 		}
@@ -257,7 +270,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 {
@@ -304,12 +338,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/path.go

@@ -5,7 +5,6 @@ import (
 	"strings"
 
 	"github.com/alist-org/alist/v3/internal/driver"
-	"github.com/alist-org/alist/v3/internal/errs"
 	"github.com/alist-org/alist/v3/pkg/utils"
 	"github.com/pkg/errors"
 	log "github.com/sirupsen/logrus"
@@ -24,9 +23,10 @@ func ActualPath(storage driver.Additional, rawPath string) string {
 // for path: remove the mount path prefix and join the actual root folder if exists
 func GetStorageAndActualPath(rawPath string) (driver.Driver, string, error) {
 	rawPath = utils.StandardizePath(rawPath)
-	if strings.Contains(rawPath, "..") {
-		return nil, "", errors.WithStack(errs.RelativePath)
-	}
+	// why can remove this check? because reqPath has joined the base_path of user, no relative path
+	//if strings.Contains(rawPath, "..") {
+	//	return nil, "", errors.WithStack(errs.RelativePath)
+	//}
 	storage := GetBalancedStorage(rawPath)
 	if storage == nil {
 		return nil, "", errors.Errorf("can't find storage with rawPath: %s", rawPath)

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() {
+	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/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 {
@@ -34,16 +96,21 @@ func CreateNestedFile(path string) (*os.File, error) {
 
 // CreateTempFile create temp file from io.ReadCloser, and seek to 0
 func CreateTempFile(r io.ReadCloser) (*os.File, error) {
+	if f, ok := r.(*os.File); ok {
+		return f, nil
+	}
 	f, err := os.CreateTemp(conf.Conf.TempDir, "file-*")
 	if err != nil {
 		return nil, err
 	}
 	_, err = io.Copy(f, r)
 	if err != nil {
+		_ = os.Remove(f.Name())
 		return nil, err
 	}
 	_, err = f.Seek(0, io.SeekStart)
 	if err != nil {
+		_ = os.Remove(f.Name())
 		return nil, err
 	}
 	return f, nil
@@ -51,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/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}
+}

pkg/utils/ip.go

@@ -24,3 +24,26 @@ func ClientIP(r *http.Request) string {
 
 	return ""
 }
+
+func IsLocalIPAddr(ip string) bool {
+	return IsLocalIP(net.ParseIP(ip))
+}
+
+func IsLocalIP(ip net.IP) bool {
+	if ip == nil {
+		return false
+	}
+	if ip.IsLoopback() {
+		return true
+	}
+
+	ip4 := ip.To4()
+	if ip4 == nil {
+		return false
+	}
+
+	return ip4[0] == 10 || // 10.0.0.0/8
+		(ip4[0] == 172 && ip4[1] >= 16 && ip4[1] <= 31) || // 172.16.0.0/12
+		(ip4[0] == 169 && ip4[1] == 254) || // 169.254.0.0/16
+		(ip4[0] == 192 && ip4[1] == 168) // 192.168.0.0/16
+}

server/common/sign.go

@@ -5,8 +5,8 @@ import (
 	"github.com/alist-org/alist/v3/internal/sign"
 )
 
-func Sign(obj model.Obj) string {
-	if obj.IsDir() {
+func Sign(obj model.Obj, encrypt bool) string {
+	if obj.IsDir() || !encrypt {
 		return ""
 	}
 	return sign.Sign(obj.GetName())

server/handles/down.go

@@ -52,7 +52,7 @@ func Proxy(c *gin.Context) {
 		downProxyUrl := storage.GetStorage().DownProxyUrl
 		if downProxyUrl != "" {
 			_, ok := c.GetQuery("d")
-			if ok {
+			if !ok {
 				URL := fmt.Sprintf("%s%s?sign=%s",
 					strings.Split(downProxyUrl, "\n")[0],
 					utils.EncodePath(rawPath, true),
@@ -103,7 +103,7 @@ func shouldProxy(storage driver.Driver, filename string) bool {
 // 4. proxy_types
 // solution: text_file + shouldProxy()
 func canProxy(storage driver.Driver, filename string) bool {
-	if storage.Config().MustProxy() || storage.GetStorage().WebProxy {
+	if storage.Config().MustProxy() || storage.GetStorage().WebProxy || storage.GetStorage().WebdavProxy() {
 		return true
 	}
 	if utils.SliceContains(conf.TypesMap[conf.ProxyTypes], utils.Ext(filename)) {

server/handles/fsmanage.go

@@ -184,7 +184,7 @@ func FsRemove(c *gin.Context) {
 			return
 		}
 	}
-	fs.ClearCache(req.Dir)
+	//fs.ClearCache(req.Dir)
 	common.SuccessResp(c)
 }
 

server/handles/fsread.go

@@ -28,6 +28,7 @@ type ListReq struct {
 type DirReq struct {
 	Path      string `json:"path" form:"path"`
 	Password  string `json:"password" form:"password"`
+	ForceRoot bool   `json:"force_root" form:"force_root"`
 }
 
 type ObjResp struct {
@@ -79,7 +80,7 @@ func FsList(c *gin.Context) {
 	}
 	total, objs := pagination(objs, &req.PageReq)
 	common.SuccessResp(c, FsListResp{
-		Content: toObjResp(objs),
+		Content: toObjResp(objs, isEncrypt(meta, req.Path)),
 		Total:   int64(total),
 		Readme:  getReadme(meta, req.Path),
 		Write:   user.CanWrite() || canWrite(meta, req.Path),
@@ -93,7 +94,14 @@ func FsDirs(c *gin.Context) {
 		return
 	}
 	user := c.MustGet("user").(*model.User)
+	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) {
@@ -157,6 +165,16 @@ func canAccess(user *model.User, meta *model.Meta, path string, password string)
 	return meta.Password == password
 }
 
+func isEncrypt(meta *model.Meta, path string) bool {
+	if meta == nil || meta.Password == "" {
+		return false
+	}
+	if !utils.PathEqual(meta.Path, path) && !meta.PSub {
+		return false
+	}
+	return true
+}
+
 func pagination(objs []model.Obj, req *common.PageReq) (int, []model.Obj) {
 	pageIndex, pageSize := req.Page, req.PerPage
 	total := len(objs)
@@ -171,7 +189,7 @@ func pagination(objs []model.Obj, req *common.PageReq) (int, []model.Obj) {
 	return total, objs[start:end]
 }
 
-func toObjResp(objs []model.Obj) []ObjResp {
+func toObjResp(objs []model.Obj, encrypt bool) []ObjResp {
 	var resp []ObjResp
 	for _, obj := range objs {
 		thumb := ""
@@ -187,7 +205,7 @@ func toObjResp(objs []model.Obj) []ObjResp {
 			Size:     obj.GetSize(),
 			IsDir:    obj.IsDir(),
 			Modified: obj.ModTime(),
-			Sign:     common.Sign(obj),
+			Sign:     common.Sign(obj, encrypt),
 			Thumb:    thumb,
 			Type:     tp,
 		})
@@ -240,11 +258,7 @@ 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
@@ -258,9 +272,13 @@ func FsGet(c *gin.Context) {
 					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
@@ -270,23 +288,25 @@ func FsGet(c *gin.Context) {
 		}
 	}
 	var related []model.Obj
-	sameLevelFiles, err := fs.List(c, stdpath.Dir(req.Path))
+	parentPath := stdpath.Dir(req.Path)
+	sameLevelFiles, err := fs.List(c, parentPath)
 	if err == nil {
 		related = filterRelated(sameLevelFiles, obj)
 	}
+	parentMeta, _ := db.GetNearestMeta(parentPath)
 	common.SuccessResp(c, FsGetResp{
 		ObjResp: ObjResp{
 			Name:     obj.GetName(),
 			Size:     obj.GetSize(),
 			IsDir:    obj.IsDir(),
 			Modified: obj.ModTime(),
-			Sign:     common.Sign(obj),
+			Sign:     common.Sign(obj, isEncrypt(meta, req.Path)),
 			Type:     utils.GetFileType(obj.GetName()),
 		},
 		RawURL:   rawURL,
 		Readme:   getReadme(meta, req.Path),
 		Provider: provider,
-		Related:  toObjResp(related),
+		Related:  toObjResp(related, isEncrypt(parentMeta, parentPath)),
 	})
 }
 

server/middlewares/down.go

@@ -2,6 +2,7 @@ package middlewares
 
 import (
 	stdpath "path"
+	"strings"
 
 	"github.com/alist-org/alist/v3/internal/db"
 	"github.com/alist-org/alist/v3/internal/errs"
@@ -28,7 +29,7 @@ func Down(c *gin.Context) {
 	// verify sign
 	if needSign(meta, rawPath) {
 		s := c.Query("sign")
-		err = sign.Verify(filename, s)
+		err = sign.Verify(filename, strings.TrimSuffix(s, "/"))
 		if err != nil {
 			common.ErrorResp(c, err, 401)
 			c.Abort()

server/router.go

@@ -112,6 +112,7 @@ func admin(g *gin.RouterGroup) {
 func _fs(g *gin.RouterGroup) {
 	g.Any("/list", handles.FsList)
 	g.Any("/get", handles.FsGet)
+	g.Any("/other", handles.FsOther)
 	g.Any("/dirs", handles.FsDirs)
 	g.POST("/mkdir", handles.FsMkdir)
 	g.POST("/rename", handles.FsRename)

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
 }
 
@@ -597,7 +597,7 @@ func (h *Handler) handlePropfind(w http.ResponseWriter, r *http.Request) (status
 		if err != nil {
 			return err
 		}
-		href := path.Join(h.Prefix, reqPath)
+		href := path.Join(h.Prefix, strings.TrimPrefix(reqPath, user.BasePath))
 		if href != "/" && info.IsDir() {
 			href += "/"
 		}