chore(deps): update actions/setup-go action to v4 (#3858)

Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>

.github/workflows/auto_lang.yml

@@ -21,7 +21,7 @@ jobs:
     runs-on: ${{ matrix.platform }}
     steps:
       - name: Setup go
-        uses: actions/setup-go@v3
+        uses: actions/setup-go@v4
         with:
           go-version: ${{ matrix.go-version }}
 

.github/workflows/build.yml

@@ -16,7 +16,7 @@ jobs:
     runs-on: ${{ matrix.platform }}
     steps:
       - name: Setup Go
-        uses: actions/setup-go@v3
+        uses: actions/setup-go@v4
         with:
           go-version: ${{ matrix.go-version }}
 

.github/workflows/release.yml

@@ -21,7 +21,7 @@ jobs:
           prerelease: true
 
       - name: Setup Go
-        uses: actions/setup-go@v3
+        uses: actions/setup-go@v4
         with:
           go-version: ${{ matrix.go-version }}
 

Dockerfile

@@ -15,4 +15,4 @@ RUN apk add --no-cache bash ca-certificates su-exec tzdata; \
     chmod +x /entrypoint.sh
 ENV PUID=0 PGID=0 UMASK=022
 EXPOSE 5244
-ENTRYPOINT [ "/entrypoint.sh" ]
+CMD [ "/entrypoint.sh" ]

drivers/115/meta.go

@@ -6,8 +6,9 @@ import (
 )
 
 type Addition struct {
-	Cookie      string `json:"cookie"`
-	QRCodeToken string `json:"qrcode_token"`
+	Cookie      string `json:"cookie" type:"text" help:"one of QR code token and cookie required"`
+	QRCodeToken string `json:"qrcode_token" type:"text" help:"one of QR code token and cookie required"`
+	PageSize    int64  `json:"page_size" type:"number" default:"56" help:"list api per page size of 115 driver"`
 	driver.RootID
 }
 

drivers/115/util.go

@@ -7,7 +7,7 @@ import (
 	"github.com/pkg/errors"
 )
 
-var UserAgent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36 115Browser/23.9.3.2 115disk/30.1.0"
+var UserAgent = driver.UA115Desktop
 
 func (d *Pan115) login() error {
 	var err error
@@ -38,7 +38,10 @@ func (d *Pan115) login() error {
 
 func (d *Pan115) getFiles(fileId string) ([]driver.File, error) {
 	res := make([]driver.File, 0)
-	files, err := d.client.List(fileId)
+	if d.PageSize <= 0 {
+		d.PageSize = driver.FileListLimit
+	}
+	files, err := d.client.ListWithLimit(fileId, d.PageSize)
 	if err != nil {
 		return nil, err
 	}

drivers/alias/driver.go

@@ -0,0 +1,114 @@
+package alias
+
+import (
+	"context"
+	"errors"
+	"strings"
+
+	"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"
+)
+
+type Alias struct {
+	model.Storage
+	Addition
+	pathMap     map[string][]string
+	autoFlatten bool
+	oneKey      string
+}
+
+func (d *Alias) Config() driver.Config {
+	return config
+}
+
+func (d *Alias) GetAddition() driver.Additional {
+	return &d.Addition
+}
+
+func (d *Alias) Init(ctx context.Context) error {
+	if d.Paths == "" {
+		return errors.New("paths is required")
+	}
+	d.pathMap = make(map[string][]string)
+	for _, path := range strings.Split(d.Paths, "\n") {
+		path = strings.TrimSpace(path)
+		if path == "" {
+			continue
+		}
+		k, v := getPair(path)
+		d.pathMap[k] = append(d.pathMap[k], v)
+	}
+	if len(d.pathMap) == 1 {
+		for k := range d.pathMap {
+			d.oneKey = k
+		}
+		d.autoFlatten = true
+	}
+	return nil
+}
+
+func (d *Alias) Drop(ctx context.Context) error {
+	d.pathMap = nil
+	return nil
+}
+
+func (d *Alias) Get(ctx context.Context, path string) (model.Obj, error) {
+	if utils.PathEqual(path, "/") {
+		return &model.Object{
+			Name:     "Root",
+			IsFolder: true,
+			Path:     "/",
+		}, nil
+	}
+	root, sub := d.getRootAndPath(path)
+	dsts, ok := d.pathMap[root]
+	if !ok {
+		return nil, errs.ObjectNotFound
+	}
+	for _, dst := range dsts {
+		obj, err := d.get(ctx, path, dst, sub)
+		if err == nil {
+			return obj, nil
+		}
+	}
+	return nil, errs.ObjectNotFound
+}
+
+func (d *Alias) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	path := dir.GetPath()
+	if utils.PathEqual(path, "/") && !d.autoFlatten {
+		return d.listRoot(), nil
+	}
+	root, sub := d.getRootAndPath(path)
+	dsts, ok := d.pathMap[root]
+	if !ok {
+		return nil, errs.ObjectNotFound
+	}
+	var objs []model.Obj
+	for _, dst := range dsts {
+		tmp, err := d.list(ctx, dst, sub)
+		if err == nil {
+			objs = append(objs, tmp...)
+		}
+	}
+	return objs, nil
+}
+
+func (d *Alias) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	root, sub := d.getRootAndPath(file.GetPath())
+	dsts, ok := d.pathMap[root]
+	if !ok {
+		return nil, errs.ObjectNotFound
+	}
+	for _, dst := range dsts {
+		link, err := d.link(ctx, dst, sub, args)
+		if err == nil {
+			return link, nil
+		}
+	}
+	return nil, errs.ObjectNotFound
+}
+
+var _ driver.Driver = (*Alias)(nil)

drivers/alias/meta.go

@@ -0,0 +1,27 @@
+package alias
+
+import (
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/op"
+)
+
+type Addition struct {
+	// Usually one of two
+	// driver.RootPath
+	// define other
+	Paths string `json:"paths" required:"true" type:"text"`
+}
+
+var config = driver.Config{
+	Name:        "Alias",
+	LocalSort:   true,
+	NoCache:     true,
+	NoUpload:    true,
+	DefaultRoot: "/",
+}
+
+func init() {
+	op.RegisterDriver(func() driver.Driver {
+		return &Alias{}
+	})
+}

drivers/alias/types.go

@@ -0,0 +1 @@
+package alias

drivers/alias/util.go

@@ -0,0 +1,103 @@
+package alias
+
+import (
+	"context"
+	"fmt"
+	stdpath "path"
+	"strings"
+
+	"github.com/alist-org/alist/v3/internal/fs"
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/internal/sign"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/alist-org/alist/v3/server/common"
+)
+
+func (d *Alias) listRoot() []model.Obj {
+	var objs []model.Obj
+	for k, _ := range d.pathMap {
+		obj := model.Object{
+			Name:     k,
+			IsFolder: true,
+			Modified: d.Modified,
+		}
+		objs = append(objs, &obj)
+	}
+	return objs
+}
+
+// do others that not defined in Driver interface
+func getPair(path string) (string, string) {
+	//path = strings.TrimSpace(path)
+	if strings.Contains(path, ":") {
+		pair := strings.SplitN(path, ":", 2)
+		if !strings.Contains(pair[0], "/") {
+			return pair[0], pair[1]
+		}
+	}
+	return stdpath.Base(path), path
+}
+
+func (d *Alias) getRootAndPath(path string) (string, string) {
+	if d.autoFlatten {
+		return d.oneKey, path
+	}
+	path = strings.TrimPrefix(path, "/")
+	parts := strings.SplitN(path, "/", 2)
+	if len(parts) == 1 {
+		return parts[0], ""
+	}
+	return parts[0], parts[1]
+}
+
+func (d *Alias) get(ctx context.Context, path string, dst, sub string) (model.Obj, error) {
+	obj, err := fs.Get(ctx, stdpath.Join(dst, sub))
+	if err != nil {
+		return nil, err
+	}
+	return &model.Object{
+		Path:     path,
+		Name:     obj.GetName(),
+		Size:     obj.GetSize(),
+		Modified: obj.ModTime(),
+		IsFolder: obj.IsDir(),
+	}, nil
+}
+
+func (d *Alias) list(ctx context.Context, dst, sub string) ([]model.Obj, error) {
+	objs, err := fs.List(ctx, stdpath.Join(dst, sub))
+	// the obj must implement the model.SetPath interface
+	// return objs, err
+	if err != nil {
+		return nil, err
+	}
+	return utils.SliceConvert(objs, func(obj model.Obj) (model.Obj, error) {
+		return &model.Object{
+			Name:     obj.GetName(),
+			Size:     obj.GetSize(),
+			Modified: obj.ModTime(),
+			IsFolder: obj.IsDir(),
+		}, nil
+	})
+}
+
+func (d *Alias) link(ctx context.Context, dst, sub string, args model.LinkArgs) (*model.Link, error) {
+	reqPath := stdpath.Join(dst, sub)
+	storage, err := fs.GetStorage(reqPath)
+	if err != nil {
+		return nil, err
+	}
+	_, err = fs.Get(ctx, reqPath)
+	if err != nil {
+		return nil, err
+	}
+	if common.ShouldProxy(storage, stdpath.Base(sub)) {
+		return &model.Link{
+			URL: fmt.Sprintf("/p%s?sign=%s",
+				utils.EncodePath(reqPath, true),
+				sign.Sign(reqPath)),
+		}, nil
+	}
+	link, _, err := fs.Link(ctx, reqPath, args)
+	return link, err
+}

drivers/aliyundrive/driver.go

@@ -226,7 +226,7 @@ func (d *AliDrive) Put(ctx context.Context, dstDir model.Obj, stream model.FileS
 		delete(reqBody, "pre_hash")
 		h := sha1.New()
 		if localFile != nil {
-			if _, err = io.Copy(h, localFile); err != nil {
+			if err = utils.CopyWithCtx(ctx, h, localFile, 0, nil); err != nil {
 				return err
 			}
 			if _, err = localFile.Seek(0, io.SeekStart); err != nil {
@@ -241,7 +241,7 @@ func (d *AliDrive) Put(ctx context.Context, dstDir model.Obj, stream model.FileS
 				_ = tempFile.Close()
 				_ = os.Remove(tempFile.Name())
 			}()
-			if _, err = io.Copy(io.MultiWriter(tempFile, h), file); err != nil {
+			if err = utils.CopyWithCtx(ctx, io.MultiWriter(tempFile, h), file, 0, nil); err != nil {
 				return err
 			}
 			localFile = tempFile

drivers/aliyundrive_open/driver.go

@@ -5,6 +5,7 @@ import (
 	"io"
 	"math"
 	"net/http"
+	"strings"
 
 	"github.com/alist-org/alist/v3/drivers/base"
 	"github.com/alist-org/alist/v3/internal/driver"
@@ -170,7 +171,12 @@ func (d *AliyundriveOpen) Put(ctx context.Context, dstDir model.Obj, stream mode
 		if utils.IsCanceled(ctx) {
 			return ctx.Err()
 		}
-		req, err := http.NewRequest("PUT", partInfo.UploadUrl, io.LimitReader(stream, DEFAULT))
+		uploadUrl := partInfo.UploadUrl
+		if d.InternalUpload {
+			//Replace a known public Host with an internal Host
+			uploadUrl = strings.ReplaceAll(uploadUrl, "https://cn-beijing-data.aliyundrive.net/", "http://ccp-bj29-bj-1592982087.oss-cn-beijing-internal.aliyuncs.com/")
+		}
+		req, err := http.NewRequest("PUT", uploadUrl, io.LimitReader(stream, DEFAULT))
 		if err != nil {
 			return err
 		}

drivers/aliyundrive_open/meta.go

@@ -14,6 +14,7 @@ type Addition struct {
 	ClientID       string `json:"client_id" required:"false" help:"Keep it empty if you don't have one"`
 	ClientSecret   string `json:"client_secret" required:"false" help:"Keep it empty if you don't have one"`
 	RemoveWay      string `json:"remove_way" required:"true" type:"select" options:"trash,delete"`
+	InternalUpload bool   `json:"internal_upload" help:"If you are using Aliyun ECS in Beijing, you can turn it on to boost the upload speed"`
 }
 
 var config = driver.Config{

drivers/all.go

@@ -6,6 +6,7 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/139"
 	_ "github.com/alist-org/alist/v3/drivers/189"
 	_ "github.com/alist-org/alist/v3/drivers/189pc"
+	_ "github.com/alist-org/alist/v3/drivers/alias"
 	_ "github.com/alist-org/alist/v3/drivers/alist_v2"
 	_ "github.com/alist-org/alist/v3/drivers/alist_v3"
 	_ "github.com/alist-org/alist/v3/drivers/aliyundrive"
@@ -13,6 +14,7 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/aliyundrive_share"
 	_ "github.com/alist-org/alist/v3/drivers/baidu_netdisk"
 	_ "github.com/alist-org/alist/v3/drivers/baidu_photo"
+	_ "github.com/alist-org/alist/v3/drivers/baidu_share"
 	_ "github.com/alist-org/alist/v3/drivers/cloudreve"
 	_ "github.com/alist-org/alist/v3/drivers/ftp"
 	_ "github.com/alist-org/alist/v3/drivers/google_drive"
@@ -32,6 +34,7 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/teambition"
 	_ "github.com/alist-org/alist/v3/drivers/terabox"
 	_ "github.com/alist-org/alist/v3/drivers/thunder"
+	_ "github.com/alist-org/alist/v3/drivers/trainbit"
 	_ "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_share/driver.go

@@ -0,0 +1,153 @@
+package baidu_share
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"net/url"
+	"path"
+	"strconv"
+	"time"
+
+	"github.com/Xhofe/go-cache"
+	"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"
+)
+
+type BaiduShare struct {
+	model.Storage
+	Addition
+	config     map[string]string
+	dlinkCache cache.ICache[string]
+}
+
+func (d *BaiduShare) Config() driver.Config {
+	return config
+}
+
+func (d *BaiduShare) GetAddition() driver.Additional {
+	return &d.Addition
+}
+
+func (d *BaiduShare) Init(ctx context.Context) error {
+	// TODO login / refresh token
+	//op.MustSaveDriverStorage(d)
+	d.config = map[string]string{}
+	d.dlinkCache = cache.NewMemCache(cache.WithClearInterval[string](time.Duration(d.CacheExpiration) * time.Minute))
+	return nil
+}
+
+func (d *BaiduShare) Drop(ctx context.Context) error {
+	d.dlinkCache.Clear()
+	return nil
+}
+
+func (d *BaiduShare) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	// TODO return the files list
+	body := url.Values{
+		"shorturl": {d.Surl},
+		"dir":      {dir.GetPath()},
+		"root":     {"0"},
+		"pwd":      {d.Pwd},
+		"num":      {"1000"},
+		"order":    {"time"},
+	}
+	if body.Get("dir") == "" || body.Get("dir") == d.config["root"] {
+		body.Set("root", "1")
+	}
+	res := []model.Obj{}
+	var err error
+	var page int64 = 1
+	more := true
+	for more {
+		body.Set("page", strconv.FormatInt(page, 10))
+		req := base.RestyClient.R().
+			SetCookies([]*http.Cookie{{Name: "BDUSS", Value: d.BDUSS}}).
+			SetBody(body.Encode())
+		resp, e := req.Post("https://pan.baidu.com/share/wxlist?channel=weixin&version=2.2.2&clienttype=25&web=1")
+		err = e
+		jsonresp := jsonResp{}
+		if err == nil {
+			err = base.RestyClient.JSONUnmarshal(resp.Body(), &jsonresp)
+		}
+		if err == nil && jsonresp.Errno == 0 {
+			more = jsonresp.Data.More
+			page += 1
+			for _, v := range jsonresp.Data.List {
+				size, _ := v.Size.Int64()
+				mtime, _ := v.Time.Int64()
+				res = append(res, &model.Object{
+					ID:       v.ID.String(),
+					Path:     v.Path,
+					Name:     v.Name,
+					Size:     size,
+					Modified: time.Unix(mtime, 0),
+					IsFolder: v.Dir.String() == "1",
+				})
+				d.dlinkCache.Set(v.Path, v.Dlink, cache.WithEx[string](time.Duration(d.CacheExpiration/2)*time.Minute))
+			}
+			if len(res) > 0 && body.Get("root") == "1" {
+				d.config["root"] = path.Dir(res[0].GetPath())
+			}
+		} else {
+			if err == nil {
+				err = fmt.Errorf("errno:%d", jsonresp.Errno)
+			}
+			break
+		}
+	}
+	return res, err
+}
+
+func (d *BaiduShare) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	// TODO return link of file
+	var err error
+	req := base.RestyClient.R().SetCookies([]*http.Cookie{{Name: "BDUSS", Value: d.BDUSS}})
+	url, found := d.dlinkCache.Get(file.GetPath())
+	if !found {
+		_, err = d.List(ctx, &model.Object{Path: path.Dir(file.GetPath())}, model.ListArgs{})
+		url, found = d.dlinkCache.Get(file.GetPath())
+		if err == nil && !found {
+			err = errs.NotSupport
+		}
+	}
+	return &model.Link{URL: url, Header: req.Header}, err
+}
+
+func (d *BaiduShare) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error {
+	// TODO create folder
+	return errs.NotSupport
+}
+
+func (d *BaiduShare) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
+	// TODO move obj
+	return errs.NotSupport
+}
+
+func (d *BaiduShare) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
+	// TODO rename obj
+	return errs.NotSupport
+}
+
+func (d *BaiduShare) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
+	// TODO copy obj
+	return errs.NotSupport
+}
+
+func (d *BaiduShare) Remove(ctx context.Context, obj model.Obj) error {
+	// TODO remove obj
+	return errs.NotSupport
+}
+
+func (d *BaiduShare) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
+	// TODO upload file
+	return errs.NotSupport
+}
+
+//func (d *Template) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
+//	return nil, errs.NotSupport
+//}
+
+var _ driver.Driver = (*BaiduShare)(nil)

drivers/baidu_share/meta.go

@@ -0,0 +1,34 @@
+package baidu_share
+
+import (
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/op"
+)
+
+type Addition struct {
+	// Usually one of two
+	driver.RootPath
+	// driver.RootID
+	// define other
+	// Field string `json:"field" type:"select" required:"true" options:"a,b,c" default:"a"`
+	Surl  string `json:"surl"`
+	Pwd   string `json:"pwd"`
+	BDUSS string `json:"BDUSS"`
+}
+
+var config = driver.Config{
+	Name:        "BaiduShare",
+	LocalSort:   true,
+	OnlyLocal:   false,
+	OnlyProxy:   false,
+	NoCache:     false,
+	NoUpload:    true,
+	NeedMs:      false,
+	DefaultRoot: "",
+}
+
+func init() {
+	op.RegisterDriver(func() driver.Driver {
+		return &BaiduShare{}
+	})
+}

drivers/baidu_share/types.go

@@ -0,0 +1,19 @@
+package baidu_share
+
+import "encoding/json"
+
+type jsonResp struct {
+	Errno int64 `json:"errno"`
+	Data  struct {
+		More bool `json:"has_more"`
+		List []struct {
+			ID    json.Number `json:"fs_id"`
+			Dir   json.Number `json:"isdir"`
+			Path  string      `json:"path"`
+			Name  string      `json:"server_filename"`
+			Time  json.Number `json:"server_mtime"`
+			Size  json.Number `json:"size"`
+			Dlink string      `json:"dlink"`
+		} `json:"list"`
+	} `json:"data"`
+}

drivers/baidu_share/util.go

@@ -0,0 +1,3 @@
+package baidu_share
+
+// do others that not defined in Driver interface

drivers/ftp/driver.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	stdpath "path"
 
+	"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"
@@ -44,8 +45,7 @@ func (d *FTP) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]m
 		return nil, err
 	}
 	res := make([]model.Obj, 0)
-	for i, _ := range entries {
-		entry := entries[i]
+	for _, entry := range entries {
 		if entry.Name == "." || entry.Name == ".." {
 			continue
 		}
@@ -64,13 +64,13 @@ func (d *FTP) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*m
 	if err := d.login(); err != nil {
 		return nil, err
 	}
-	resp, err := d.conn.Retr(file.GetPath())
-	if err != nil {
-		return nil, err
+
+	r := NewFTPFileReader(d.conn, file.GetPath())
+	link := &model.Link{
+		Data: r,
 	}
-	return &model.Link{
-		Data: resp,
-	}, nil
+	base.HandleRange(link, r, args.Header, file.GetSize())
+	return link, nil
 }
 
 func (d *FTP) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error {

drivers/ftp/util.go

@@ -1,6 +1,13 @@
 package ftp
 
-import "github.com/jlaffaye/ftp"
+import (
+	"io"
+	"os"
+	"sync"
+	"time"
+
+	"github.com/jlaffaye/ftp"
+)
 
 // do others that not defined in Driver interface
 
@@ -11,7 +18,7 @@ func (d *FTP) login() error {
 			return nil
 		}
 	}
-	conn, err := ftp.Dial(d.Address)
+	conn, err := ftp.Dial(d.Address, ftp.DialWithShutTimeout(10*time.Second))
 	if err != nil {
 		return err
 	}
@@ -22,3 +29,81 @@ func (d *FTP) login() error {
 	d.conn = conn
 	return nil
 }
+
+// An FTP file reader that implements io.ReadSeekCloser for seeking.
+type FTPFileReader struct {
+	conn   *ftp.ServerConn
+	resp   *ftp.Response
+	offset int64
+	mu     sync.Mutex
+	path   string
+}
+
+func NewFTPFileReader(conn *ftp.ServerConn, path string) *FTPFileReader {
+	return &FTPFileReader{
+		conn: conn,
+		path: path,
+	}
+}
+
+func (r *FTPFileReader) Read(buf []byte) (n int, err error) {
+	r.mu.Lock()
+	defer r.mu.Unlock()
+
+	if r.resp == nil {
+		r.resp, err = r.conn.RetrFrom(r.path, uint64(r.offset))
+		if err != nil {
+			return 0, err
+		}
+	}
+
+	n, err = r.resp.Read(buf)
+	r.offset += int64(n)
+	return
+}
+
+func (r *FTPFileReader) Seek(offset int64, whence int) (int64, error) {
+	r.mu.Lock()
+	defer r.mu.Unlock()
+
+	oldOffset := r.offset
+	var newOffset int64
+	switch whence {
+	case io.SeekStart:
+		newOffset = offset
+	case io.SeekCurrent:
+		newOffset = oldOffset + offset
+	case io.SeekEnd:
+		size, err := r.conn.FileSize(r.path)
+		if err != nil {
+			return oldOffset, err
+		}
+		newOffset = offset + int64(size)
+	default:
+		return -1, os.ErrInvalid
+	}
+
+	if newOffset < 0 {
+		// offset out of range
+		return oldOffset, os.ErrInvalid
+	}
+	if newOffset == oldOffset {
+		// offset not changed, so return directly
+		return oldOffset, nil
+	}
+	r.offset = newOffset
+
+	if r.resp != nil {
+		// close the existing ftp data connection, otherwise the next read will be blocked
+		_ = r.resp.Close() // we do not care about whether it returns an error
+		r.resp = nil
+	}
+	return newOffset, nil
+}
+
+func (r *FTPFileReader) Close() error {
+	if r.resp != nil {
+		return r.resp.Close()
+	}
+	return nil
+}

drivers/local/driver.go

@@ -144,7 +144,7 @@ func (d *Local) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (
 			}
 			srcBuf = videoBuf
 		} else {
-			imgData, err := ioutil.ReadFile(fullPath)
+			imgData, err := os.ReadFile(fullPath)
 			if err != nil {
 				return nil, err
 			}

drivers/s3/driver.go

@@ -59,7 +59,8 @@ func (d *S3) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]mo
 
 func (d *S3) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
 	path := getKey(file.GetPath(), false)
-	disposition := fmt.Sprintf(`attachment;filename="%s"`, url.QueryEscape(stdpath.Base(path)))
+	filename := stdpath.Base(path)
+	disposition := fmt.Sprintf(`attachment; filename="%s"; filename*=UTF-8''%s`, filename, url.PathEscape(filename))
 	input := &s3.GetObjectInput{
 		Bucket: &d.Bucket,
 		Key:    &path,

drivers/smb/driver.go

@@ -5,7 +5,6 @@ import (
 	"errors"
 	"path/filepath"
 	"strings"
-	"time"
 
 	"github.com/alist-org/alist/v3/drivers/base"
 	"github.com/alist-org/alist/v3/internal/driver"
@@ -19,7 +18,7 @@ type SMB struct {
 	model.Storage
 	Addition
 	fs           *smb2.Share
-	lastConnTime time.Time
+	lastConnTime int64
 }
 
 func (d *SMB) Config() driver.Config {

drivers/smb/util.go

@@ -6,17 +6,22 @@ import (
 	"net"
 	"os"
 	"path/filepath"
+	"sync/atomic"
 	"time"
 
 	"github.com/hirochachacha/go-smb2"
 )
 
 func (d *SMB) updateLastConnTime() {
-	d.lastConnTime = time.Now()
+	atomic.StoreInt64(&d.lastConnTime, time.Now().Unix())
 }
 
 func (d *SMB) cleanLastConnTime() {
-	d.lastConnTime = time.Now().AddDate(0, 0, -1)
+	atomic.StoreInt64(&d.lastConnTime, 0)
+}
+
+func (d *SMB) getLastConnTime() time.Time {
+	return time.Unix(atomic.LoadInt64(&d.lastConnTime), 0)
 }
 
 func (d *SMB) initFS() error {
@@ -43,7 +48,7 @@ func (d *SMB) initFS() error {
 }
 
 func (d *SMB) checkConn() error {
-	if time.Since(d.lastConnTime) < 5*time.Minute {
+	if time.Since(d.getLastConnTime()) < 5*time.Minute {
 		return nil
 	}
 	if d.fs != nil {

drivers/teambition/driver.go

@@ -8,6 +8,7 @@ import (
 	"github.com/alist-org/alist/v3/drivers/base"
 	"github.com/alist-org/alist/v3/internal/driver"
 	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/pkg/utils"
 	"github.com/go-resty/resty/v2"
 )
 
@@ -124,11 +125,11 @@ func (d *Teambition) Remove(ctx context.Context, obj model.Obj) error {
 }
 
 func (d *Teambition) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
-	res, err := d.request("/projects", http.MethodGet, nil, nil)
+	res, err := d.request("/api/v2/users/me", http.MethodGet, nil, nil)
 	if err != nil {
 		return err
 	}
-	token := GetBetweenStr(string(res), "strikerAuth":"", "","phoneForLogin")
+	token := utils.Json.Get(res, "strikerAuth").ToString()
 	var newFile *FileUpload
 	if stream.GetSize() <= 20971520 {
 		// post upload

drivers/teambition/util.go

@@ -210,7 +210,7 @@ func (d *Teambition) finishUpload(file *FileUpload, parentId string) error {
 	return err
 }
 
-func GetBetweenStr(str, start, end string) string {
+func getBetweenStr(str, start, end string) string {
 	n := strings.Index(str, start)
 	if n == -1 {
 		return ""

drivers/template/driver.go

@@ -32,42 +32,42 @@ func (d *Template) Drop(ctx context.Context) error {
 }
 
 func (d *Template) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
-	// TODO return the files list
+	// TODO return the files list, required
 	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
+	// TODO return link of file, required
 	return nil, errs.NotImplement
 }
 
 func (d *Template) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error {
-	// TODO create folder
+	// TODO create folder, optional
 	return errs.NotImplement
 }
 
 func (d *Template) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
-	// TODO move obj
+	// TODO move obj, optional
 	return errs.NotImplement
 }
 
 func (d *Template) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
-	// TODO rename obj
+	// TODO rename obj, optional
 	return errs.NotImplement
 }
 
 func (d *Template) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
-	// TODO copy obj
+	// TODO copy obj, optional
 	return errs.NotImplement
 }
 
 func (d *Template) Remove(ctx context.Context, obj model.Obj) error {
-	// TODO remove obj
+	// TODO remove obj, optional
 	return errs.NotImplement
 }
 
 func (d *Template) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
-	// TODO upload file
+	// TODO upload file, optional
 	return errs.NotImplement
 }
 

drivers/template/meta.go

@@ -14,14 +14,17 @@ type Addition struct {
 }
 
 var config = driver.Config{
-	Name:        "Template",
-	LocalSort:   false,
-	OnlyLocal:   false,
-	OnlyProxy:   false,
-	NoCache:     false,
-	NoUpload:    false,
-	NeedMs:      false,
-	DefaultRoot: "root, / or other",
+	Name:              "Template",
+	LocalSort:         false,
+	OnlyLocal:         false,
+	OnlyProxy:         false,
+	NoCache:           false,
+	NoUpload:          false,
+	NeedMs:            false,
+	DefaultRoot:       "root, / or other",
+	CheckStatus:       false,
+	Alert:             "",
+	NoOverwriteUpload: false,
 }
 
 func init() {

drivers/trainbit/driver.go

@@ -0,0 +1,142 @@
+package trainbit
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"io"
+	"math"
+	"net/http"
+	"net/url"
+	"strings"
+
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/errs"
+	"github.com/alist-org/alist/v3/internal/model"
+)
+
+type Trainbit struct {
+	model.Storage
+	Addition
+}
+
+var apiExpiredate, guid string
+
+func (d *Trainbit) Config() driver.Config {
+	return config
+}
+
+func (d *Trainbit) GetAddition() driver.Additional {
+	return &d.Addition
+}
+
+func (d *Trainbit) Init(ctx context.Context) error {
+	http.DefaultClient.CheckRedirect = func(req *http.Request, via []*http.Request) error {
+		return http.ErrUseLastResponse
+	}
+	var err error
+	apiExpiredate, guid, err = getToken(d.ApiKey, d.AUSHELLPORTAL)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+func (d *Trainbit) Drop(ctx context.Context) error {
+	return nil
+}
+
+func (d *Trainbit) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	form := make(url.Values)
+	form.Set("parentid", strings.Split(dir.GetID(), "_")[0])
+	res, err := postForm("https://trainbit.com/lib/api/v1/listoffiles", form, apiExpiredate, d.ApiKey, d.AUSHELLPORTAL)
+	if err != nil {
+		return nil, err
+	}
+	data, err := io.ReadAll(res.Body)
+	if err != nil {
+		return nil, err
+	}
+	var jsonData any
+	json.Unmarshal(data, &jsonData)
+	if err != nil {
+		return nil, err
+	}
+	object, err := parseRawFileObject(jsonData.(map[string]any)["items"].([]any))
+	if err != nil {
+		return nil, err
+	}
+	return object, nil
+}
+
+func (d *Trainbit) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	res, err := get(fmt.Sprintf("https://trainbit.com/files/%s/", strings.Split(file.GetID(), "_")[0]), d.ApiKey, d.AUSHELLPORTAL)
+	if err != nil {
+		return nil, err
+	}
+	return &model.Link{
+		URL: res.Header.Get("Location"),
+	}, nil
+}
+
+func (d *Trainbit) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error {
+	form := make(url.Values)
+	form.Set("name", local2provider(dirName, true))
+	form.Set("parentid", strings.Split(parentDir.GetID(), "_")[0])
+	_, err := postForm("https://trainbit.com/lib/api/v1/createfolder", form, apiExpiredate, d.ApiKey, d.AUSHELLPORTAL)
+	return err
+}
+
+func (d *Trainbit) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
+	form := make(url.Values)
+	form.Set("sourceid", strings.Split(srcObj.GetID(), "_")[0])
+	form.Set("destinationid", strings.Split(dstDir.GetID(), "_")[0])
+	_, err := postForm("https://trainbit.com/lib/api/v1/move", form, apiExpiredate, d.ApiKey, d.AUSHELLPORTAL)
+	return err
+}
+
+func (d *Trainbit) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
+	form := make(url.Values)
+	form.Set("id", strings.Split(srcObj.GetID(), "_")[0])
+	form.Set("name", local2provider(newName, srcObj.IsDir()))
+	_, err := postForm("https://trainbit.com/lib/api/v1/edit", form, apiExpiredate, d.ApiKey, d.AUSHELLPORTAL)
+	return err
+}
+
+func (d *Trainbit) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
+	return errs.NotImplement
+}
+
+func (d *Trainbit) Remove(ctx context.Context, obj model.Obj) error {
+	form := make(url.Values)
+	form.Set("id", strings.Split(obj.GetID(), "_")[0])
+	_, err := postForm("https://trainbit.com/lib/api/v1/delete", form, apiExpiredate, d.ApiKey, d.AUSHELLPORTAL)
+	return err
+}
+
+func (d *Trainbit) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
+	endpoint, _ := url.Parse("https://tb28.trainbit.com/api/upload/send_raw/")
+	query := &url.Values{}
+	query.Add("q", strings.Split(dstDir.GetID(), "_")[1])
+	query.Add("guid", guid)
+	query.Add("name", url.QueryEscape(local2provider(stream.GetName(), false)))
+	endpoint.RawQuery = query.Encode()
+	var total int64
+	total = 0
+	progressReader := &ProgressReader{
+		stream,
+		func(byteNum int) {
+			total += int64(byteNum)
+			up(int(math.Round(float64(total) / float64(stream.GetSize()) * 100)))
+		},
+	}
+	req, err := http.NewRequest(http.MethodPost, endpoint.String(), progressReader)
+	if err != nil {
+		return err
+	}
+	req.Header.Set("Content-Type", "text/json; charset=UTF-8")
+	_, err = http.DefaultClient.Do(req)
+	return err
+}
+
+var _ driver.Driver = (*Trainbit)(nil)

drivers/trainbit/meta.go

@@ -0,0 +1,29 @@
+package trainbit
+
+import (
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/op"
+)
+
+type Addition struct {
+	driver.RootID
+	AUSHELLPORTAL string `json:"AUSHELLPORTAL" required:"true"`
+	ApiKey string `json:"apikey" required:"true"`
+}
+
+var config = driver.Config{
+	Name:          "Trainbit",
+	LocalSort:     false,
+	OnlyLocal:     false,
+	OnlyProxy:     false,
+	NoCache:       false,
+	NoUpload:      false,
+	NeedMs:        false,
+	DefaultRoot:   "0_000",
+}
+
+func init() {
+	op.RegisterDriver(func() driver.Driver {
+		return &Trainbit{}
+	})
+}

drivers/trainbit/types.go

@@ -0,0 +1 @@
+package trainbit

drivers/trainbit/util.go

@@ -0,0 +1,150 @@
+package trainbit
+
+import (
+	"io"
+	"net/http"
+	"net/url"
+	"regexp"
+	"strings"
+	"time"
+
+	"github.com/alist-org/alist/v3/internal/model"
+)
+
+type ProgressReader struct {
+	io.Reader
+	reporter func(byteNum int)
+}
+
+func (progressReader *ProgressReader) Read(data []byte) (int, error) {
+	byteNum, err := progressReader.Reader.Read(data)
+	progressReader.reporter(byteNum)
+	return byteNum, err
+}
+
+func get(url string, apiKey string, AUSHELLPORTAL string) (*http.Response, error) {
+	req, err := http.NewRequest(http.MethodGet, url, nil)
+	if err != nil {
+		return nil, err
+	}
+	req.AddCookie(&http.Cookie{
+		Name:   ".AUSHELLPORTAL",
+		Value:  AUSHELLPORTAL,
+		MaxAge: 2 * 60,
+	})
+	req.AddCookie(&http.Cookie{
+		Name:   "retkeyapi",
+		Value:  apiKey,
+		MaxAge: 2 * 60,
+	})
+	res, err := http.DefaultClient.Do(req)
+	return res, err
+}
+
+func postForm(endpoint string, data url.Values, apiExpiredate string, apiKey string, AUSHELLPORTAL string) (*http.Response, error) {
+	extData := make(url.Values)
+	for key, value := range data {
+		extData[key] = make([]string, len(value))
+		copy(extData[key], value)
+	}
+	extData.Set("apikey", apiKey)
+	extData.Set("expiredate", apiExpiredate)
+	req, err := http.NewRequest(http.MethodPost, endpoint, strings.NewReader(extData.Encode()))
+	if err != nil {
+		return nil, err
+	}
+	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
+	req.AddCookie(&http.Cookie{
+		Name:   ".AUSHELLPORTAL",
+		Value:  AUSHELLPORTAL,
+		MaxAge: 2 * 60,
+	})
+	req.AddCookie(&http.Cookie{
+		Name:   "retkeyapi",
+		Value:  apiKey,
+		MaxAge: 2 * 60,
+	})
+	res, err := http.DefaultClient.Do(req)
+	return res, err
+}
+
+func getToken(apiKey string, AUSHELLPORTAL string) (string, string, error) {
+	res, err := get("https://trainbit.com/files/", apiKey, AUSHELLPORTAL)
+	if err != nil {
+		return "", "", err
+	}
+	data, err := io.ReadAll(res.Body)
+	if err != nil {
+		return "", "", err
+	}
+	text := string(data)
+	apiExpiredateReg := regexp.MustCompile(`core.api.expiredate = '([^']*)';`)
+	result := apiExpiredateReg.FindAllStringSubmatch(text, -1)
+	apiExpiredate := result[0][1]
+	guidReg := regexp.MustCompile(`app.vars.upload.guid = '([^']*)';`)
+	result = guidReg.FindAllStringSubmatch(text, -1)
+	guid := result[0][1]
+	return apiExpiredate, guid, nil
+}
+
+func local2provider(filename string, isFolder bool) string {
+	filename = strings.Replace(filename, "%", url.QueryEscape("%"), -1)
+	filename = strings.Replace(filename, "/", url.QueryEscape("/"), -1)
+	filename = strings.Replace(filename, ":", url.QueryEscape(":"), -1)
+	filename = strings.Replace(filename, "*", url.QueryEscape("*"), -1)
+	filename = strings.Replace(filename, "?", url.QueryEscape("?"), -1)
+	filename = strings.Replace(filename, "\"", url.QueryEscape("\""), -1)
+	filename = strings.Replace(filename, "<", url.QueryEscape("<"), -1)
+	filename = strings.Replace(filename, ">", url.QueryEscape(">"), -1)
+	filename = strings.Replace(filename, "|", url.QueryEscape("|"), -1)
+	if isFolder {
+		return filename
+	}
+	return strings.Join([]string{filename, ".delete_suffix."}, "")
+}
+
+func provider2local(filename string) string {
+	index := strings.LastIndex(filename, ".delete_suffix.")
+	if index != -1 {
+		filename = filename[:index]
+	}
+	rawName := strings.Replace(filename, url.QueryEscape("/"), "/", -1)
+	rawName = strings.Replace(rawName, url.QueryEscape(":"), ":", -1)
+	rawName = strings.Replace(rawName, url.QueryEscape("*"), "*", -1)
+	rawName = strings.Replace(rawName, url.QueryEscape("?"), "?", -1)
+	rawName = strings.Replace(rawName, url.QueryEscape("\""), "\"", -1)
+	rawName = strings.Replace(rawName, url.QueryEscape("<"), "<", -1)
+	rawName = strings.Replace(rawName, url.QueryEscape(">"), ">", -1)
+	rawName = strings.Replace(rawName, url.QueryEscape("|"), "|", -1)
+	rawName = strings.Replace(rawName, url.QueryEscape("%"), "%", -1)
+	return rawName
+}
+
+func parseRawFileObject(rawObject []any) ([]model.Obj, error) {
+	objectList := make([]model.Obj, 0)
+	for _, each := range rawObject {
+		object := each.(map[string]any)
+		if object["id"].(string) == "0" {
+			continue
+		}
+		isFolder := int64(object["ty"].(float64)) == 1
+		var name string
+		if isFolder {
+			name = object["name"].(string)
+		} else {
+			name = strings.Join([]string{object["name"].(string), object["ext"].(string)}, ".")
+		}
+		modified, err := time.Parse("2006/01/02 15:04:05", object["modified"].(string))
+		if err != nil {
+			return nil, err
+		}
+		objectList = append(objectList, model.Obj(&model.Object{
+			ID:       strings.Join([]string{object["id"].(string), strings.Split(object["uploadurl"].(string), "=")[1]}, "_"),
+			Name:     provider2local(name),
+			Size:     int64(object["byte"].(float64)),
+			Modified: modified.Add(-210 * time.Minute),
+			IsFolder: isFolder,
+		}))
+	}
+	return objectList, nil
+}

go.mod

@@ -3,12 +3,12 @@ module github.com/alist-org/alist/v3
 go 1.19
 
 require (
-	github.com/SheltonZhu/115driver v1.0.13
+	github.com/SheltonZhu/115driver v1.0.14
 	github.com/Xhofe/go-cache v0.0.0-20220723083548-714439c8af9a
 	github.com/aws/aws-sdk-go v1.44.194
 	github.com/blevesearch/bleve/v2 v2.3.6
 	github.com/caarlos0/env/v7 v7.1.0
-	github.com/deckarep/golang-set/v2 v2.2.0
+	github.com/deckarep/golang-set/v2 v2.3.0
 	github.com/disintegration/imaging v1.6.2
 	github.com/dustinxie/ecc v0.0.0-20210511000915-959544187564
 	github.com/gin-contrib/cors v1.4.0

go.sum

@@ -2,8 +2,8 @@ github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ
 github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
 github.com/RoaringBitmap/roaring v0.9.4 h1:ckvZSX5gwCRaJYBNe7syNawCU5oruY9gQmjXlp4riwo=
 github.com/RoaringBitmap/roaring v0.9.4/go.mod h1:icnadbWcNyfEHlYdr+tDlOTih1Bf/h+rzPpv4sbomAA=
-github.com/SheltonZhu/115driver v1.0.13 h1:YEhQ3iMvd5TD6Xp1wKg+73KgdCMjc0pDoT1eCNXnA3M=
-github.com/SheltonZhu/115driver v1.0.13/go.mod h1:00ixivHH5HqDj4S7kAWbkuUrjtsJTxc7cGv5RMw3RVs=
+github.com/SheltonZhu/115driver v1.0.14 h1:uW3dl8J9KDMw+3gPxQdhTysoGhw0/uI1484GT9xhfU4=
+github.com/SheltonZhu/115driver v1.0.14/go.mod h1:00ixivHH5HqDj4S7kAWbkuUrjtsJTxc7cGv5RMw3RVs=
 github.com/Xhofe/go-cache v0.0.0-20220723083548-714439c8af9a h1:RenIAa2q4H8UcS/cqmwdT1WCWIAH5aumP8m8RpbqVsE=
 github.com/Xhofe/go-cache v0.0.0-20220723083548-714439c8af9a/go.mod h1:sSBbaOg90XwWKtpT56kVujF0bIeVITnPlssLclogS04=
 github.com/aead/ecdh v0.2.0 h1:pYop54xVaq/CEREFEcukHRZfTdjiWvYIsZDXXrBapQQ=
@@ -68,6 +68,8 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/deckarep/golang-set/v2 v2.2.0 h1:2pMQd3Soi6qfw7E5MMKaEh5W5ES18bW3AbFFnGl6LgQ=
 github.com/deckarep/golang-set/v2 v2.2.0/go.mod h1:VAky9rY/yGXJOLEDv3OMci+7wtDpOF4IN+y82NBOac4=
+github.com/deckarep/golang-set/v2 v2.3.0 h1:qs18EKUfHm2X9fA50Mr/M5hccg2tNnVqsiBImnyDs0g=
+github.com/deckarep/golang-set/v2 v2.3.0/go.mod h1:VAky9rY/yGXJOLEDv3OMci+7wtDpOF4IN+y82NBOac4=
 github.com/disintegration/imaging v1.6.2 h1:w1LecBlG2Lnp8B3jk5zSuNqd7b4DXhcjwek1ei82L+c=
 github.com/disintegration/imaging v1.6.2/go.mod h1:44/5580QXChDfwIclfc/PCwrr44amcmDAg8hxG0Ewe4=
 github.com/dustinxie/ecc v0.0.0-20210511000915-959544187564 h1:I6KUy4CI6hHjqnyJLNCEi7YHVMkwwtfSr2k9splgdSM=

internal/bootstrap/data/setting.go

@@ -158,6 +158,7 @@ func InitialSettings() []model.SettingItem {
 
 		// qbittorrent settings
 		{Key: conf.QbittorrentUrl, Value: "http://admin:adminadmin@localhost:8080/", Type: conf.TypeString, Group: model.SINGLE, Flag: model.PRIVATE},
+		{Key: conf.QbittorrentSeedtime, Value: "0", Type: conf.TypeNumber, Group: model.SINGLE, Flag: model.PRIVATE},
 	}
 	if flags.Dev {
 		initialSettingItems = append(initialSettingItems, []model.SettingItem{

internal/conf/const.go

@@ -61,7 +61,8 @@ const (
 	SSOLoginplatform = "sso_login_platform"
 
 	// qbittorrent
-	QbittorrentUrl = "qbittorrent_url"
+	QbittorrentUrl      = "qbittorrent_url"
+	QbittorrentSeedtime = "qbittorrent_seedtime"
 )
 
 const (

internal/fs/link.go

@@ -2,9 +2,12 @@ package fs
 
 import (
 	"context"
+	"strings"
 
 	"github.com/alist-org/alist/v3/internal/model"
 	"github.com/alist-org/alist/v3/internal/op"
+	"github.com/alist-org/alist/v3/server/common"
+	"github.com/gin-gonic/gin"
 	"github.com/pkg/errors"
 )
 
@@ -13,5 +16,14 @@ func link(ctx context.Context, path string, args model.LinkArgs) (*model.Link, m
 	if err != nil {
 		return nil, nil, errors.WithMessage(err, "failed get storage")
 	}
-	return op.Link(ctx, storage, actualPath, args)
+	l, obj, err := op.Link(ctx, storage, actualPath, args)
+	if err != nil {
+		return nil, nil, errors.WithMessage(err, "failed link")
+	}
+	if l.URL != "" && !strings.HasPrefix(l.URL, "http://") && !strings.HasPrefix(l.URL, "https://") {
+		if c, ok := ctx.(*gin.Context); ok {
+			l.URL = common.GetApiUrl(c.Request) + l.URL
+		}
+	}
+	return l, obj, nil
 }

internal/op/const.go

@@ -2,5 +2,6 @@ package op
 
 const (
 	WORK     = "work"
+	DISABLED = "disabled"
 	RootName = "root"
 )

internal/op/storage.go

@@ -142,6 +142,7 @@ func DisableStorage(ctx context.Context, id uint) error {
 	}
 	// delete the storage in the memory
 	storage.Disabled = true
+	storage.SetStatus(DISABLED)
 	err = db.UpdateStorage(storage)
 	if err != nil {
 		return errors.WithMessage(err, "failed update storage in db")

internal/qbittorrent/add.go

@@ -8,6 +8,7 @@ import (
 	"github.com/alist-org/alist/v3/internal/conf"
 	"github.com/alist-org/alist/v3/internal/errs"
 	"github.com/alist-org/alist/v3/internal/op"
+	"github.com/alist-org/alist/v3/internal/setting"
 	"github.com/alist-org/alist/v3/pkg/task"
 	"github.com/google/uuid"
 	"github.com/pkg/errors"
@@ -50,6 +51,7 @@ func AddURL(ctx context.Context, url string, dstDirPath string) error {
 				tsk:        tsk,
 				tempDir:    tempDir,
 				dstDirPath: dstDirPath,
+				seedtime:   setting.GetInt(conf.QbittorrentSeedtime, 0),
 			}
 			return m.Loop()
 		},

internal/qbittorrent/monitor.go

@@ -2,23 +2,26 @@ package qbittorrent
 
 import (
 	"fmt"
+	"io"
+	"os"
+	"path/filepath"
+	"sync"
+	"sync/atomic"
+	"time"
+
 	"github.com/alist-org/alist/v3/internal/model"
 	"github.com/alist-org/alist/v3/internal/op"
 	"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"
-	"os"
-	"path/filepath"
-	"sync"
-	"sync/atomic"
-	"time"
 )
 
 type Monitor struct {
 	tsk        *task.Task[string]
 	tempDir    string
 	dstDirPath string
+	seedtime   int
 	finish     chan struct{}
 }
 
@@ -114,17 +117,27 @@ func (m *Monitor) complete() error {
 	log.Debugf("files len: %d", len(files))
 	// delete qbittorrent task but do not delete the files before transferring to avoid qbittorrent
 	// accessing downloaded files and throw `cannot access the file because it is being used by another process` error
-	err = qbclient.Delete(m.tsk.ID, false)
-	if err != nil {
-		return err
-	}
+	// err = qbclient.Delete(m.tsk.ID, false)
+	// if err != nil {
+	// 	return err
+	// }
 	// upload files
 	var wg sync.WaitGroup
 	wg.Add(len(files))
 	go func() {
 		wg.Wait()
-		err := os.RemoveAll(m.tempDir)
 		m.finish <- struct{}{}
+		if m.seedtime < 0 {
+			log.Debugf("do not delete qb task %s", m.tsk.ID)
+			return
+		}
+		log.Debugf("delete qb task %s after %d minutes", m.tsk.ID, m.seedtime)
+		<-time.After(time.Duration(m.seedtime) * time.Minute)
+		err := qbclient.Delete(m.tsk.ID, true)
+		if err != nil {
+			log.Errorln(err.Error())
+		}
+		err = os.RemoveAll(m.tempDir)
 		if err != nil {
 			log.Errorf("failed to remove qbittorrent temp dir: %+v", err.Error())
 		}
@@ -151,7 +164,7 @@ func (m *Monitor) complete() error {
 						Modified: time.Now(),
 						IsFolder: false,
 					},
-					ReadCloser: f,
+					ReadCloser: struct{ io.ReadSeekCloser }{f},
 					Mimetype:   mimetype,
 				}
 				return op.Put(tsk.Ctx, storage, dstDir, stream, tsk.SetProgress)

pkg/task/manager.go

@@ -122,6 +122,10 @@ func (tm *Manager[K]) ClearDone() {
 	tm.RemoveByStates(SUCCEEDED, CANCELED, ERRORED)
 }
 
+func (tm *Manager[K]) ClearSucceeded() {
+	tm.RemoveByStates(SUCCEEDED)
+}
+
 func (tm *Manager[K]) RawTasks() *generic_sync.MapOf[K, *Task[K]] {
 	return &tm.tasks
 }

server/common/check.go

@@ -5,6 +5,8 @@ import (
 	"regexp"
 	"strings"
 
+	"github.com/alist-org/alist/v3/internal/conf"
+	"github.com/alist-org/alist/v3/internal/driver"
 	"github.com/alist-org/alist/v3/internal/model"
 	"github.com/alist-org/alist/v3/pkg/utils"
 )
@@ -20,7 +22,7 @@ func IsApply(metaPath, reqPath string, applySub bool) bool {
 	if utils.PathEqual(metaPath, reqPath) {
 		return true
 	}
-	return utils.IsSubPath(reqPath, metaPath) && applySub
+	return utils.IsSubPath(metaPath, reqPath) && applySub
 }
 
 func CanAccess(user *model.User, meta *model.Meta, reqPath string, password string) bool {
@@ -49,3 +51,18 @@ func CanAccess(user *model.User, meta *model.Meta, reqPath string, password stri
 	// validate password
 	return meta.Password == password
 }
+
+// ShouldProxy TODO need optimize
+// when should be proxy?
+// 1. config.MustProxy()
+// 2. storage.WebProxy
+// 3. proxy_types
+func ShouldProxy(storage driver.Driver, filename string) bool {
+	if storage.Config().MustProxy() || storage.GetStorage().WebProxy {
+		return true
+	}
+	if utils.SliceContains(conf.SlicesMap[conf.ProxyTypes], utils.Ext(filename)) {
+		return true
+	}
+	return false
+}

server/common/check_test.go

@@ -0,0 +1,24 @@
+package common
+
+import "testing"
+
+func TestIsApply(t *testing.T) {
+	datas := []struct {
+		metaPath string
+		reqPath  string
+		applySub bool
+		result   bool
+	}{
+		{
+			metaPath: "/",
+			reqPath:  "/test",
+			applySub: true,
+			result:   true,
+		},
+	}
+	for i, data := range datas {
+		if IsApply(data.metaPath, data.reqPath, data.applySub) != data.result {
+			t.Errorf("TestIsApply %d failed", i)
+		}
+	}
+}

server/common/proxy.go

@@ -26,8 +26,9 @@ func Proxy(w http.ResponseWriter, r *http.Request, link *model.Link, file model.
 		defer func() {
 			_ = link.Data.Close()
 		}()
+		filename := file.GetName()
 		w.Header().Set("Content-Type", "application/octet-stream")
-		w.Header().Set("Content-Disposition", fmt.Sprintf(`attachment; filename="%s"; filename*=UTF-8''%s`, file.GetName(), url.QueryEscape(file.GetName())))
+		w.Header().Set("Content-Disposition", fmt.Sprintf(`attachment; filename="%s"; filename*=UTF-8''%s`, filename, url.PathEscape(filename)))
 		w.Header().Set("Content-Length", strconv.FormatInt(file.GetSize(), 10))
 		if link.Header != nil {
 			// TODO clean header with blacklist or whitelist

server/handles/down.go

@@ -2,6 +2,7 @@ package handles
 
 import (
 	"fmt"
+	"io"
 	stdpath "path"
 	"strings"
 
@@ -14,6 +15,7 @@ import (
 	"github.com/alist-org/alist/v3/pkg/utils"
 	"github.com/alist-org/alist/v3/server/common"
 	"github.com/gin-gonic/gin"
+	log "github.com/sirupsen/logrus"
 )
 
 func Down(c *gin.Context) {
@@ -24,11 +26,10 @@ func Down(c *gin.Context) {
 		common.ErrorResp(c, err, 500)
 		return
 	}
-	if shouldProxy(storage, filename) {
+	if common.ShouldProxy(storage, filename) {
 		Proxy(c)
 		return
 	} else {
-
 		link, _, err := fs.Link(c, rawPath, model.LinkArgs{
 			IP:     c.ClientIP(),
 			Header: c.Request.Header,
@@ -38,6 +39,14 @@ func Down(c *gin.Context) {
 			common.ErrorResp(c, err, 500)
 			return
 		}
+		if link.Data != nil {
+			defer func(Data io.ReadCloser) {
+				err := Data.Close()
+				if err != nil {
+					log.Errorf("close data error: %s", err)
+				}
+			}(link.Data)
+		}
 		c.Header("Referrer-Policy", "no-referrer")
 		c.Header("Cache-Control", "max-age=0, no-cache, no-store, must-revalidate")
 		if setting.GetBool(conf.ForwardDirectLinkParams) {
@@ -102,21 +111,6 @@ func Proxy(c *gin.Context) {
 	}
 }
 
-// TODO need optimize
-// when should be proxy?
-// 1. config.MustProxy()
-// 2. storage.WebProxy
-// 3. proxy_types
-func shouldProxy(storage driver.Driver, filename string) bool {
-	if storage.Config().MustProxy() || storage.GetStorage().WebProxy {
-		return true
-	}
-	if utils.SliceContains(conf.SlicesMap[conf.ProxyTypes], utils.Ext(filename)) {
-		return true
-	}
-	return false
-}
-
 // TODO need optimize
 // when can be proxy?
 // 1. text file

server/handles/fsmanage.go

@@ -2,17 +2,21 @@ package handles
 
 import (
 	"fmt"
+	"io"
 	stdpath "path"
+	"regexp"
 
 	"github.com/alist-org/alist/v3/internal/errs"
 	"github.com/alist-org/alist/v3/internal/fs"
 	"github.com/alist-org/alist/v3/internal/model"
 	"github.com/alist-org/alist/v3/internal/op"
 	"github.com/alist-org/alist/v3/internal/sign"
+	"github.com/alist-org/alist/v3/pkg/generic"
 	"github.com/alist-org/alist/v3/pkg/utils"
 	"github.com/alist-org/alist/v3/server/common"
 	"github.com/gin-gonic/gin"
 	"github.com/pkg/errors"
+	log "github.com/sirupsen/logrus"
 )
 
 type MkdirOrLinkReq struct {
@@ -92,6 +96,93 @@ func FsMove(c *gin.Context) {
 	common.SuccessResp(c)
 }
 
+type RecursiveMoveReq struct {
+	SrcDir string `json:"src_dir"`
+	DstDir string `json:"dst_dir"`
+}
+
+func FsRecursiveMove(c *gin.Context) {
+	var req RecursiveMoveReq
+	if err := c.ShouldBind(&req); err != nil {
+		common.ErrorResp(c, err, 400)
+		return
+	}
+
+	user := c.MustGet("user").(*model.User)
+	if !user.CanMove() {
+		common.ErrorResp(c, errs.PermissionDenied, 403)
+		return
+	}
+	srcDir, err := user.JoinPath(req.SrcDir)
+	if err != nil {
+		common.ErrorResp(c, err, 403)
+		return
+	}
+	dstDir, err := user.JoinPath(req.DstDir)
+	if err != nil {
+		common.ErrorResp(c, err, 403)
+		return
+	}
+
+	meta, err := op.GetNearestMeta(srcDir)
+	if err != nil {
+		if !errors.Is(errors.Cause(err), errs.MetaNotFound) {
+			common.ErrorResp(c, err, 500, true)
+			return
+		}
+	}
+	c.Set("meta", meta)
+
+	rootFiles, err := fs.List(c, srcDir, false)
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+		return
+	}
+
+	// record the file path
+	filePathMap := make(map[model.Obj]string)
+	movingFiles := generic.NewQueue[model.Obj]()
+	for _, file := range rootFiles {
+		movingFiles.Push(file)
+		filePathMap[file] = srcDir
+	}
+
+	for !movingFiles.IsEmpty() {
+
+		movingFile := movingFiles.Pop()
+		movingFilePath := fmt.Sprintf("%s/%s", filePathMap[movingFile], movingFile.GetName())
+		if movingFile.IsDir() {
+			// directory, recursive move
+			subFilePath := movingFilePath
+			subFiles, err := fs.List(c, subFilePath, true)
+			if err != nil {
+				common.ErrorResp(c, err, 500)
+				return
+			}
+			for _, subFile := range subFiles {
+				movingFiles.Push(subFile)
+				filePathMap[subFile] = subFilePath
+			}
+		} else {
+
+			if movingFilePath == dstDir {
+				// same directory, don't move
+				continue
+			}
+
+			// move
+			err := fs.Move(c, movingFilePath, dstDir, movingFiles.IsEmpty())
+			if err != nil {
+				common.ErrorResp(c, err, 500)
+				return
+			}
+		}
+
+	}
+
+	common.SuccessResp(c)
+}
+
 func FsCopy(c *gin.Context) {
 	var req MoveCopyReq
 	if err := c.ShouldBind(&req); err != nil {
@@ -163,6 +254,67 @@ func FsRename(c *gin.Context) {
 	common.SuccessResp(c)
 }
 
+type RegexRenameReq struct {
+	SrcDir       string `json:"src_dir"`
+	SrcNameRegex string `json:"src_name_regex"`
+	NewNameRegex string `json:"new_name_regex"`
+}
+
+func FsRegexRename(c *gin.Context) {
+	var req RegexRenameReq
+	if err := c.ShouldBind(&req); err != nil {
+		common.ErrorResp(c, err, 400)
+		return
+	}
+	user := c.MustGet("user").(*model.User)
+	if !user.CanRename() {
+		common.ErrorResp(c, errs.PermissionDenied, 403)
+		return
+	}
+
+	reqPath, err := user.JoinPath(req.SrcDir)
+	if err != nil {
+		common.ErrorResp(c, err, 403)
+		return
+	}
+
+	meta, err := op.GetNearestMeta(reqPath)
+	if err != nil {
+		if !errors.Is(errors.Cause(err), errs.MetaNotFound) {
+			common.ErrorResp(c, err, 500, true)
+			return
+		}
+	}
+	c.Set("meta", meta)
+
+	srcRegexp, err := regexp.Compile(req.SrcNameRegex)
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+		return
+	}
+
+	files, err := fs.List(c, reqPath, false)
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+		return
+	}
+
+	for _, file := range files {
+
+		if srcRegexp.MatchString(file.GetName()) {
+			filePath := fmt.Sprintf("%s/%s", reqPath, file.GetName())
+			newFileName := srcRegexp.ReplaceAllString(file.GetName(), req.NewNameRegex)
+			if err := fs.Rename(c, filePath, newFileName); err != nil {
+				common.ErrorResp(c, err, 500)
+				return
+			}
+		}
+
+	}
+
+	common.SuccessResp(c)
+}
+
 type RemoveReq struct {
 	Dir   string   `json:"dir"`
 	Names []string `json:"names"`
@@ -229,6 +381,14 @@ func Link(c *gin.Context) {
 		common.ErrorResp(c, err, 500)
 		return
 	}
+	if link.Data != nil {
+		defer func(Data io.ReadCloser) {
+			err := Data.Close()
+			if err != nil {
+				log.Errorf("close link data error: %v", err)
+			}
+		}(link.Data)
+	}
 	common.SuccessResp(c, link)
 	return
 }

server/handles/qbittorrent.go

@@ -10,7 +10,8 @@ import (
 )
 
 type SetQbittorrentReq struct {
-	Url string `json:"url" form:"url"`
+	Url      string `json:"url" form:"url"`
+	Seedtime string `json:"seedtime" form:"seedtime"`
 }
 
 func SetQbittorrent(c *gin.Context) {
@@ -19,14 +20,11 @@ func SetQbittorrent(c *gin.Context) {
 		common.ErrorResp(c, err, 400)
 		return
 	}
-	item := &model.SettingItem{
-		Key:   conf.QbittorrentUrl,
-		Value: req.Url,
-		Type:  conf.TypeString,
-		Group: model.SINGLE,
-		Flag:  model.PRIVATE,
+	items := []model.SettingItem{
+		{Key: conf.QbittorrentUrl, Value: req.Url, Type: conf.TypeString, Group: model.SINGLE, Flag: model.PRIVATE},
+		{Key: conf.QbittorrentSeedtime, Value: req.Seedtime, Type: conf.TypeNumber, Group: model.SINGLE, Flag: model.PRIVATE},
 	}
-	if err := op.SaveSettingItem(item); err != nil {
+	if err := op.SaveSettingItems(items); err != nil {
 		common.ErrorResp(c, err, 500)
 		return
 	}

server/handles/task.go

@@ -92,10 +92,27 @@ func taskRoute[K comparable](g *gin.RouterGroup, manager *task.Manager[K], k2Str
 			common.SuccessResp(c)
 		}
 	})
+	g.POST("/retry", func(c *gin.Context) {
+		tid := c.Query("tid")
+		id, err := str2K(tid)
+		if err != nil {
+			common.ErrorResp(c, err, 400)
+			return
+		}
+		if err := manager.Retry(id); err != nil {
+			common.ErrorResp(c, err, 500)
+		} else {
+			common.SuccessResp(c)
+		}
+	})
 	g.POST("/clear_done", func(c *gin.Context) {
 		manager.ClearDone()
 		common.SuccessResp(c)
 	})
+	g.POST("/clear_succeeded", func(c *gin.Context) {
+		manager.ClearSucceeded()
+		common.SuccessResp(c)
+	})
 }
 
 func SetupTaskRoute(g *gin.RouterGroup) {

server/router.go

@@ -126,7 +126,9 @@ func _fs(g *gin.RouterGroup) {
 	g.Any("/dirs", handles.FsDirs)
 	g.POST("/mkdir", handles.FsMkdir)
 	g.POST("/rename", handles.FsRename)
+	g.POST("/regex_rename", handles.FsRegexRename)
 	g.POST("/move", handles.FsMove)
+	g.POST("/recursive_move", handles.FsRecursiveMove)
 	g.POST("/copy", handles.FsCopy)
 	g.POST("/remove", handles.FsRemove)
 	g.PUT("/put", middlewares.FsUp, handles.FsStream)