fix(deps): update module github.com/caarlos0/env/v9 to v11

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

drivers/115/driver.go

@@ -63,7 +63,7 @@ func (d *Pan115) Link(ctx context.Context, file model.Obj, args model.LinkArgs)
 	if err := d.WaitLimit(ctx); err != nil {
 		return nil, err
 	}
-	var userAgent = args.Header.Get("User-Agent")
+	userAgent := args.Header.Get("User-Agent")
 	downloadInfo, err := d.
 		DownloadWithUA(file.(*FileObj).PickCode, userAgent)
 	if err != nil {
@@ -179,7 +179,22 @@ func (d *Pan115) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 	}
 	// 分片上传
 	return d.UploadByMultipart(&fastInfo.UploadOSSParams, stream.GetSize(), stream, dirID)
+}
 
+func (d *Pan115) OfflineList(ctx context.Context) ([]*driver115.OfflineTask, error) {
+	resp, err := d.client.ListOfflineTask(0)
+	if err != nil {
+		return nil, err
+	}
+	return resp.Tasks, nil
+}
+
+func (d *Pan115) OfflineDownload(ctx context.Context, uris []string, dstDir model.Obj) ([]string, error) {
+	return d.client.AddOfflineTaskURIs(uris, dstDir.GetID())
+}
+
+func (d *Pan115) DeleteOfflineTasks(ctx context.Context, hashes []string, deleteFiles bool) error {
+	return d.client.DeleteOfflineTasks(hashes, deleteFiles)
 }
 
 var _ driver.Driver = (*Pan115)(nil)

drivers/123/driver.go

@@ -53,7 +53,7 @@ func (d *Pan123) Drop(ctx context.Context) error {
 }
 
 func (d *Pan123) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
-	files, err := d.getFiles(dir.GetID(), dir.GetName())
+	files, err := d.getFiles(ctx, dir.GetID(), dir.GetName())
 	if err != nil {
 		return nil, err
 	}
@@ -247,9 +247,6 @@ func (d *Pan123) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 		}
 		_, err = uploader.UploadWithContext(ctx, input)
 	}
-	if err != nil {
-		return err
-	}
 	_, err = d.request(UploadComplete, http.MethodPost, func(req *resty.Request) {
 		req.SetBody(base.Json{
 			"fileId": resp.Data.FileId,
@@ -258,11 +255,12 @@ func (d *Pan123) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 	return err
 }
 
-func (d *Pan123) APIRateLimit(api string) bool {
-	limiter, _ := d.apiRateLimit.LoadOrStore(api,
-		rate.NewLimiter(rate.Every(time.Millisecond*700), 1))
-	ins := limiter.(*rate.Limiter)
-	return ins.Allow()
+func (d *Pan123) APIRateLimit(ctx context.Context, api string) error {
+	value, _ := d.apiRateLimit.LoadOrStore(api,
+		rate.NewLimiter(rate.Every(700*time.Millisecond), 1))
+	limiter := value.(*rate.Limiter)
+
+	return limiter.Wait(ctx)
 }
 
 var _ driver.Driver = (*Pan123)(nil)

drivers/123/util.go

@@ -1,6 +1,7 @@
 package _123
 
 import (
+	"context"
 	"errors"
 	"fmt"
 	"hash/crc32"
@@ -14,7 +15,7 @@ import (
 
 	"github.com/alist-org/alist/v3/drivers/base"
 	"github.com/alist-org/alist/v3/pkg/utils"
-	resty "github.com/go-resty/resty/v2"
+	"github.com/go-resty/resty/v2"
 	jsoniter "github.com/json-iterator/go"
 	log "github.com/sirupsen/logrus"
 )
@@ -233,15 +234,14 @@ func (d *Pan123) request(url string, method string, callback base.ReqCallback, r
 	return body, nil
 }
 
-func (d *Pan123) getFiles(parentId string, name string) ([]File, error) {
+func (d *Pan123) getFiles(ctx context.Context, parentId string, name string) ([]File, error) {
 	page := 1
 	total := 0
 	res := make([]File, 0)
 	// 2024-02-06 fix concurrency by 123pan
 	for {
-		if !d.APIRateLimit(FileList) {
-			time.Sleep(time.Millisecond * 200)
-			continue
+		if err := d.APIRateLimit(ctx, FileList); err != nil {
+			return nil, err
 		}
 		var resp Files
 		query := map[string]string{

drivers/123_share/driver.go

@@ -45,7 +45,7 @@ func (d *Pan123Share) Drop(ctx context.Context) error {
 
 func (d *Pan123Share) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
 	// TODO return the files list, required
-	files, err := d.getFiles(dir.GetID())
+	files, err := d.getFiles(ctx, dir.GetID())
 	if err != nil {
 		return nil, err
 	}
@@ -150,11 +150,12 @@ func (d *Pan123Share) Put(ctx context.Context, dstDir model.Obj, stream model.Fi
 //	return nil, errs.NotSupport
 //}
 
-func (d *Pan123Share) APIRateLimit(api string) bool {
-	limiter, _ := d.apiRateLimit.LoadOrStore(api,
-		rate.NewLimiter(rate.Every(time.Millisecond*700), 1))
-	ins := limiter.(*rate.Limiter)
-	return ins.Allow()
+func (d *Pan123Share) APIRateLimit(ctx context.Context, api string) error {
+	value, _ := d.apiRateLimit.LoadOrStore(api,
+		rate.NewLimiter(rate.Every(700*time.Millisecond), 1))
+	limiter := value.(*rate.Limiter)
+
+	return limiter.Wait(ctx)
 }
 
 var _ driver.Driver = (*Pan123Share)(nil)

drivers/123_share/util.go

@@ -1,6 +1,7 @@
 package _123Share
 
 import (
+	"context"
 	"errors"
 	"fmt"
 	"hash/crc32"
@@ -80,13 +81,12 @@ func (d *Pan123Share) request(url string, method string, callback base.ReqCallba
 	return body, nil
 }
 
-func (d *Pan123Share) getFiles(parentId string) ([]File, error) {
+func (d *Pan123Share) getFiles(ctx context.Context, parentId string) ([]File, error) {
 	page := 1
 	res := make([]File, 0)
 	for {
-		if !d.APIRateLimit(FileList) {
-			time.Sleep(time.Millisecond * 200)
-			continue
+		if err := d.APIRateLimit(ctx, FileList); err != nil {
+			return nil, err
 		}
 		var resp Files
 		query := map[string]string{

drivers/all.go

@@ -29,6 +29,7 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/ilanzou"
 	_ "github.com/alist-org/alist/v3/drivers/ipfs_api"
 	_ "github.com/alist-org/alist/v3/drivers/lanzou"
+	_ "github.com/alist-org/alist/v3/drivers/lenovonas_share"
 	_ "github.com/alist-org/alist/v3/drivers/local"
 	_ "github.com/alist-org/alist/v3/drivers/mediatrack"
 	_ "github.com/alist-org/alist/v3/drivers/mega"
@@ -40,6 +41,7 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/pikpak"
 	_ "github.com/alist-org/alist/v3/drivers/pikpak_share"
 	_ "github.com/alist-org/alist/v3/drivers/quark_uc"
+	_ "github.com/alist-org/alist/v3/drivers/quark_uc_tv"
 	_ "github.com/alist-org/alist/v3/drivers/quqi"
 	_ "github.com/alist-org/alist/v3/drivers/s3"
 	_ "github.com/alist-org/alist/v3/drivers/seafile"

drivers/chaoxing/types.go

@@ -191,33 +191,33 @@ type UploadFileDataRsp struct {
 	Resid    int64  `json:"resid"`
 	Puid     int    `json:"puid"`
 	Data     struct {
-		DisableOpt       bool      `json:"disableOpt"`
-		Resid            int64     `json:"resid"`
-		Crc              string    `json:"crc"`
-		Puid             int       `json:"puid"`
-		Isfile           bool      `json:"isfile"`
-		Pantype          string    `json:"pantype"`
-		Size             int       `json:"size"`
-		Name             string    `json:"name"`
-		ObjectID         string    `json:"objectId"`
-		Restype          string    `json:"restype"`
-		UploadDate       time.Time `json:"uploadDate"`
-		ModifyDate       time.Time `json:"modifyDate"`
-		UploadDateFormat string    `json:"uploadDateFormat"`
-		Residstr         string    `json:"residstr"`
-		Suffix           string    `json:"suffix"`
-		Preview          string    `json:"preview"`
-		Thumbnail        string    `json:"thumbnail"`
-		Creator          int       `json:"creator"`
-		Duration         int       `json:"duration"`
-		IsImg            bool      `json:"isImg"`
-		PreviewURL       string    `json:"previewUrl"`
-		Filetype         string    `json:"filetype"`
-		Filepath         string    `json:"filepath"`
-		Sort             int       `json:"sort"`
-		Topsort          int       `json:"topsort"`
-		ResTypeValue     int       `json:"resTypeValue"`
-		Extinfo          string    `json:"extinfo"`
+		DisableOpt       bool   `json:"disableOpt"`
+		Resid            int64  `json:"resid"`
+		Crc              string `json:"crc"`
+		Puid             int    `json:"puid"`
+		Isfile           bool   `json:"isfile"`
+		Pantype          string `json:"pantype"`
+		Size             int    `json:"size"`
+		Name             string `json:"name"`
+		ObjectID         string `json:"objectId"`
+		Restype          string `json:"restype"`
+		UploadDate       int64  `json:"uploadDate"`
+		ModifyDate       int64  `json:"modifyDate"`
+		UploadDateFormat string `json:"uploadDateFormat"`
+		Residstr         string `json:"residstr"`
+		Suffix           string `json:"suffix"`
+		Preview          string `json:"preview"`
+		Thumbnail        string `json:"thumbnail"`
+		Creator          int    `json:"creator"`
+		Duration         int    `json:"duration"`
+		IsImg            bool   `json:"isImg"`
+		PreviewURL       string `json:"previewUrl"`
+		Filetype         string `json:"filetype"`
+		Filepath         string `json:"filepath"`
+		Sort             int    `json:"sort"`
+		Topsort          int    `json:"topsort"`
+		ResTypeValue     int    `json:"resTypeValue"`
+		Extinfo          string `json:"extinfo"`
 	} `json:"data"`
 }
 
@@ -225,33 +225,33 @@ type UploadDoneParam struct {
 	Cataid string `json:"cataid"`
 	Key    string `json:"key"`
 	Param  struct {
-		DisableOpt       bool      `json:"disableOpt"`
-		Resid            int64     `json:"resid"`
-		Crc              string    `json:"crc"`
-		Puid             int       `json:"puid"`
-		Isfile           bool      `json:"isfile"`
-		Pantype          string    `json:"pantype"`
-		Size             int       `json:"size"`
-		Name             string    `json:"name"`
-		ObjectID         string    `json:"objectId"`
-		Restype          string    `json:"restype"`
-		UploadDate       time.Time `json:"uploadDate"`
-		ModifyDate       time.Time `json:"modifyDate"`
-		UploadDateFormat string    `json:"uploadDateFormat"`
-		Residstr         string    `json:"residstr"`
-		Suffix           string    `json:"suffix"`
-		Preview          string    `json:"preview"`
-		Thumbnail        string    `json:"thumbnail"`
-		Creator          int       `json:"creator"`
-		Duration         int       `json:"duration"`
-		IsImg            bool      `json:"isImg"`
-		PreviewURL       string    `json:"previewUrl"`
-		Filetype         string    `json:"filetype"`
-		Filepath         string    `json:"filepath"`
-		Sort             int       `json:"sort"`
-		Topsort          int       `json:"topsort"`
-		ResTypeValue     int       `json:"resTypeValue"`
-		Extinfo          string    `json:"extinfo"`
+		DisableOpt       bool   `json:"disableOpt"`
+		Resid            int64  `json:"resid"`
+		Crc              string `json:"crc"`
+		Puid             int    `json:"puid"`
+		Isfile           bool   `json:"isfile"`
+		Pantype          string `json:"pantype"`
+		Size             int    `json:"size"`
+		Name             string `json:"name"`
+		ObjectID         string `json:"objectId"`
+		Restype          string `json:"restype"`
+		UploadDate       int64  `json:"uploadDate"`
+		ModifyDate       int64  `json:"modifyDate"`
+		UploadDateFormat string `json:"uploadDateFormat"`
+		Residstr         string `json:"residstr"`
+		Suffix           string `json:"suffix"`
+		Preview          string `json:"preview"`
+		Thumbnail        string `json:"thumbnail"`
+		Creator          int    `json:"creator"`
+		Duration         int    `json:"duration"`
+		IsImg            bool   `json:"isImg"`
+		PreviewURL       string `json:"previewUrl"`
+		Filetype         string `json:"filetype"`
+		Filepath         string `json:"filepath"`
+		Sort             int    `json:"sort"`
+		Topsort          int    `json:"topsort"`
+		ResTypeValue     int    `json:"resTypeValue"`
+		Extinfo          string `json:"extinfo"`
 	} `json:"param"`
 }
 

drivers/halalcloud/driver.go

@@ -147,7 +147,7 @@ func (d *HalalCloud) IsLogin() bool {
 	if err != nil {
 		return false
 	}
-	ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
+	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
 	defer cancel()
 	result, err := pbPublicUser.NewPubUserClient(serv.GetGrpcConnection()).Get(ctx, &pbPublicUser.User{
 		Identity: "",

drivers/halalcloud/meta.go

@@ -12,9 +12,9 @@ type Addition struct {
 	RefreshToken string `json:"refresh_token" required:"true" help:"login type is refresh_token,this is required"`
 	UploadThread string `json:"upload_thread" default:"3" help:"1 <= thread <= 32"`
 
-	AppID      string `json:"app_id" required:"true" default:"devDebugger/1.0"`
+	AppID      string `json:"app_id" required:"true" default:"alist/10001"`
 	AppVersion string `json:"app_version" required:"true" default:"1.0.0"`
-	AppSecret  string `json:"app_secret" required:"true" default:"Nkx3Y2xvZ2luLmNu"`
+	AppSecret  string `json:"app_secret" required:"true" default:"bR4SJwOkvnG5WvVJ"`
 }
 
 var config = driver.Config{

drivers/halalcloud/util.go

@@ -29,9 +29,9 @@ import (
 )
 
 const (
-	AppID      = "devDebugger/1.0"
+	AppID      = "alist/10001"
 	AppVersion = "1.0.0"
-	AppSecret  = "Nkx3Y2xvZ2luLmNu"
+	AppSecret  = "bR4SJwOkvnG5WvVJ"
 )
 
 const (
@@ -62,7 +62,7 @@ func (d *HalalCloud) NewAuthServiceWithOauth(options ...HalalOption) (*AuthServi
 	}
 	defer grpcConnection.Close()
 	userClient := pbPublicUser.NewPubUserClient(grpcConnection)
-	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
 	defer cancel()
 	stateString := uuid.New().String()
 	// queryValues.Add("callback", oauthToken.Callback)
@@ -179,16 +179,16 @@ func (s *AuthService) signContext(method string, ctx context.Context) context.Co
 	bufferedString := bytes.NewBufferString(method)
 	kvString = append(kvString, "timestamp", currentTimeStamp)
 	bufferedString.WriteString(currentTimeStamp)
-	kvString = append(kvString, "appid", AppID)
-	bufferedString.WriteString(AppID)
-	kvString = append(kvString, "appversion", AppVersion)
-	bufferedString.WriteString(AppVersion)
+	kvString = append(kvString, "appid", s.appID)
+	bufferedString.WriteString(s.appID)
+	kvString = append(kvString, "appversion", s.appVersion)
+	bufferedString.WriteString(s.appVersion)
 	if s.tr != nil && len(s.tr.AccessToken) > 0 {
 		authorization := "Bearer " + s.tr.AccessToken
 		kvString = append(kvString, "authorization", authorization)
 		bufferedString.WriteString(authorization)
 	}
-	bufferedString.WriteString(AppSecret)
+	bufferedString.WriteString(s.appSecret)
 	sign := GetMD5Hash(bufferedString.String())
 	kvString = append(kvString, "sign", sign)
 	return metadata.AppendToOutgoingContext(ctx, kvString...)

drivers/lanzou/driver.go

@@ -30,6 +30,9 @@ func (d *LanZou) GetAddition() driver.Additional {
 }
 
 func (d *LanZou) Init(ctx context.Context) (err error) {
+	if d.UserAgent == "" {
+		d.UserAgent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.39 (KHTML, like Gecko) Chrome/89.0.4389.111 Safari/537.39"
+	}
 	switch d.Type {
 	case "account":
 		_, err := d.Login()

drivers/lanzou/meta.go

@@ -16,7 +16,8 @@ type Addition struct {
 	driver.RootID
 	SharePassword  string `json:"share_password"`
 	BaseUrl        string `json:"baseUrl" required:"true" default:"https://pc.woozooo.com" help:"basic URL for file operation"`
-	ShareUrl       string `json:"shareUrl" required:"true" default:"https://pan.lanzouo.com" help:"used to get the sharing page"`
+	ShareUrl       string `json:"shareUrl" required:"true" default:"https://pan.lanzoui.com" help:"used to get the sharing page"`
+	UserAgent      string `json:"user_agent" required:"true" default:"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.39 (KHTML, like Gecko) Chrome/89.0.4389.111 Safari/537.39"`
 	RepairFileInfo bool   `json:"repair_file_info" help:"To use webdav, you need to enable it"`
 }
 

drivers/lanzou/util.go

@@ -106,7 +106,8 @@ func (d *LanZou) request(url string, method string, callback base.ReqCallback, u
 	}
 
 	req.SetHeaders(map[string]string{
-		"Referer": "https://pc.woozooo.com",
+		"Referer":    "https://pc.woozooo.com",
+		"User-Agent": d.UserAgent,
 	})
 
 	if d.Cookie != "" {

drivers/lenovonas_share/driver.go

@@ -0,0 +1,121 @@
+package LenovoNasShare
+
+import (
+	"context"
+	"net/http"
+
+	"github.com/go-resty/resty/v2"
+
+	"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 LenovoNasShare struct {
+	model.Storage
+	Addition
+	stoken string
+}
+
+func (d *LenovoNasShare) Config() driver.Config {
+	return config
+}
+
+func (d *LenovoNasShare) GetAddition() driver.Additional {
+	return &d.Addition
+}
+
+func (d *LenovoNasShare) Init(ctx context.Context) error {
+	if d.Host == "" {
+		d.Host = "https://siot-share.lenovo.com.cn"
+	}
+	query := map[string]string{
+		"code":     d.ShareId,
+		"password": d.SharePwd,
+	}
+	resp, err := d.request(d.Host+"/oneproxy/api/share/v1/access", http.MethodGet, func(req *resty.Request) {
+		req.SetQueryParams(query)
+	}, nil)
+	if err != nil {
+		return err
+	}
+	d.stoken = utils.Json.Get(resp, "data", "stoken").ToString()
+	return nil
+}
+
+func (d *LenovoNasShare) Drop(ctx context.Context) error {
+	return nil
+}
+
+func (d *LenovoNasShare) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	files := make([]File, 0)
+
+	var resp Files
+	query := map[string]string{
+		"code":   d.ShareId,
+		"num":    "5000",
+		"stoken": d.stoken,
+		"path":   dir.GetPath(),
+	}
+	_, err := d.request(d.Host+"/oneproxy/api/share/v1/files", http.MethodGet, func(req *resty.Request) {
+		req.SetQueryParams(query)
+	}, &resp)
+	if err != nil {
+		return nil, err
+	}
+	files = append(files, resp.Data.List...)
+
+	return utils.SliceConvert(files, func(src File) (model.Obj, error) {
+		return src, nil
+	})
+}
+
+func (d *LenovoNasShare) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	query := map[string]string{
+		"code":   d.ShareId,
+		"stoken": d.stoken,
+		"path":   file.GetPath(),
+	}
+	resp, err := d.request(d.Host+"/oneproxy/api/share/v1/file/link", http.MethodGet, func(req *resty.Request) {
+		req.SetQueryParams(query)
+	}, nil)
+	if err != nil {
+		return nil, err
+	}
+	downloadUrl := d.Host + "/oneproxy/api/share/v1/file/download?code=" + d.ShareId + "&dtoken=" + utils.Json.Get(resp, "data", "param", "dtoken").ToString()
+
+	link := model.Link{
+		URL: downloadUrl,
+		Header: http.Header{
+			"Referer": []string{"https://siot-share.lenovo.com.cn"},
+		},
+	}
+	return &link, nil
+}
+
+func (d *LenovoNasShare) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+func (d *LenovoNasShare) Move(ctx context.Context, srcObj, dstDir model.Obj) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+func (d *LenovoNasShare) Rename(ctx context.Context, srcObj model.Obj, newName string) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+func (d *LenovoNasShare) Copy(ctx context.Context, srcObj, dstDir model.Obj) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+func (d *LenovoNasShare) Remove(ctx context.Context, obj model.Obj) error {
+	return errs.NotImplement
+}
+
+func (d *LenovoNasShare) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+var _ driver.Driver = (*LenovoNasShare)(nil)

drivers/lenovonas_share/meta.go

@@ -0,0 +1,33 @@
+package LenovoNasShare
+
+import (
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/op"
+)
+
+type Addition struct {
+	driver.RootPath
+	ShareId  string `json:"share_id" required:"true" help:"The part after the last / in the shared link"`
+	SharePwd string `json:"share_pwd" required:"true" help:"The password of the shared link"`
+	Host     string `json:"host" required:"true" default:"https://siot-share.lenovo.com.cn" help:"You can change it to your local area network"`
+}
+
+var config = driver.Config{
+	Name:              "LenovoNasShare",
+	LocalSort:         true,
+	OnlyLocal:         false,
+	OnlyProxy:         false,
+	NoCache:           false,
+	NoUpload:          true,
+	NeedMs:            false,
+	DefaultRoot:       "",
+	CheckStatus:       false,
+	Alert:             "",
+	NoOverwriteUpload: false,
+}
+
+func init() {
+	op.RegisterDriver(func() driver.Driver {
+		return &LenovoNasShare{}
+	})
+}

drivers/lenovonas_share/types.go

@@ -0,0 +1,82 @@
+package LenovoNasShare
+
+import (
+	"encoding/json"
+	"time"
+
+	"github.com/alist-org/alist/v3/pkg/utils"
+
+	_ "github.com/alist-org/alist/v3/internal/model"
+)
+
+func (f *File) UnmarshalJSON(data []byte) error {
+	type Alias File
+	aux := &struct {
+		CreateAt int64 `json:"time"`
+		UpdateAt int64 `json:"chtime"`
+		*Alias
+	}{
+		Alias: (*Alias)(f),
+	}
+
+	if err := json.Unmarshal(data, aux); err != nil {
+		return err
+	}
+
+	f.CreateAt = time.Unix(aux.CreateAt, 0)
+	f.UpdateAt = time.Unix(aux.UpdateAt, 0)
+
+	return nil
+}
+
+type File struct {
+	FileName string    `json:"name"`
+	Size     int64     `json:"size"`
+	CreateAt time.Time `json:"time"`
+	UpdateAt time.Time `json:"chtime"`
+	Path     string    `json:"path"`
+	Type     string    `json:"type"`
+}
+
+func (f File) GetHash() utils.HashInfo {
+	return utils.HashInfo{}
+}
+
+func (f File) GetPath() string {
+	return f.Path
+}
+
+func (f File) GetSize() int64 {
+	return f.Size
+}
+
+func (f File) GetName() string {
+	return f.FileName
+}
+
+func (f File) ModTime() time.Time {
+	return f.UpdateAt
+}
+
+func (f File) CreateTime() time.Time {
+	return f.CreateAt
+}
+
+func (f File) IsDir() bool {
+	return f.Type == "dir"
+}
+
+func (f File) GetID() string {
+	return f.GetPath()
+}
+
+func (f File) Thumb() string {
+	return ""
+}
+
+type Files struct {
+	Data struct {
+		List    []File `json:"list"`
+		HasMore bool   `json:"has_more"`
+	} `json:"data"`
+}

drivers/lenovonas_share/util.go

@@ -0,0 +1,36 @@
+package LenovoNasShare
+
+import (
+	"errors"
+
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	jsoniter "github.com/json-iterator/go"
+)
+
+func (d *LenovoNasShare) request(url string, method string, callback base.ReqCallback, resp interface{}) ([]byte, error) {
+	req := base.RestyClient.R()
+	req.SetHeaders(map[string]string{
+		"origin":      "https://siot-share.lenovo.com.cn",
+		"referer":     "https://siot-share.lenovo.com.cn/",
+		"user-agent":  "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) alist-client",
+		"platform":    "web",
+		"app-version": "3",
+	})
+	if callback != nil {
+		callback(req)
+	}
+	if resp != nil {
+		req.SetResult(resp)
+	}
+	res, err := req.Execute(method, url)
+	if err != nil {
+		return nil, err
+	}
+	body := res.Body()
+	result := utils.Json.Get(body, "result").ToBool()
+	if !result {
+		return nil, errors.New(jsoniter.Get(body, "error", "msg").ToString())
+	}
+	return body, nil
+}

drivers/quark_uc_tv/driver.go

@@ -0,0 +1,174 @@
+package quark_uc_tv
+
+import (
+	"context"
+	"fmt"
+	"github.com/alist-org/alist/v3/internal/op"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/go-resty/resty/v2"
+	"strconv"
+	"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"
+)
+
+type QuarkUCTV struct {
+	*QuarkUCTVCommon
+	model.Storage
+	Addition
+	config driver.Config
+	conf   Conf
+}
+
+func (d *QuarkUCTV) Config() driver.Config {
+	return d.config
+}
+
+func (d *QuarkUCTV) GetAddition() driver.Additional {
+	return &d.Addition
+}
+
+func (d *QuarkUCTV) Init(ctx context.Context) error {
+
+	if d.Addition.DeviceID == "" {
+		d.Addition.DeviceID = utils.GetMD5EncodeStr(time.Now().String())
+	}
+	op.MustSaveDriverStorage(d)
+
+	if d.QuarkUCTVCommon == nil {
+		d.QuarkUCTVCommon = &QuarkUCTVCommon{
+			AccessToken: "",
+		}
+	}
+	ctx1, cancelFunc := context.WithTimeout(ctx, 5*time.Second)
+	defer cancelFunc()
+	if d.Addition.RefreshToken == "" {
+		if d.Addition.QueryToken == "" {
+			qrData, err := d.getLoginCode(ctx1)
+			if err != nil {
+				return err
+			}
+			// 展示二维码
+			qrTemplate := `<body>
+        <img src="data:image/jpeg;base64,%s"/>
+    </body>`
+			qrPage := fmt.Sprintf(qrTemplate, qrData)
+			return fmt.Errorf("need verify: \n%s", qrPage)
+		} else {
+			// 通过query token获取code -> refresh token
+			code, err := d.getCode(ctx1)
+			if err != nil {
+				return err
+			}
+			// 通过code获取refresh token
+			err = d.getRefreshTokenByTV(ctx1, code, false)
+			if err != nil {
+				return err
+			}
+		}
+	}
+	// 通过refresh token获取access token
+	if d.QuarkUCTVCommon.AccessToken == "" {
+		err := d.getRefreshTokenByTV(ctx1, d.Addition.RefreshToken, true)
+		if err != nil {
+			return err
+		}
+	}
+
+	// 验证 access token 是否有效
+	_, err := d.isLogin(ctx1)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+func (d *QuarkUCTV) Drop(ctx context.Context) error {
+	return nil
+}
+
+func (d *QuarkUCTV) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	files := make([]model.Obj, 0)
+	pageIndex := int64(0)
+	pageSize := int64(100)
+	for {
+		var filesData FilesData
+		_, err := d.request(ctx, "/file", "GET", func(req *resty.Request) {
+			req.SetQueryParams(map[string]string{
+				"method":     "list",
+				"parent_fid": dir.GetID(),
+				"order_by":   "3",
+				"desc":       "1",
+				"category":   "",
+				"source":     "",
+				"ex_source":  "",
+				"list_all":   "0",
+				"page_size":  strconv.FormatInt(pageSize, 10),
+				"page_index": strconv.FormatInt(pageIndex, 10),
+			})
+		}, &filesData)
+		if err != nil {
+			return nil, err
+		}
+		for i := range filesData.Data.Files {
+			files = append(files, &filesData.Data.Files[i])
+		}
+		if pageIndex*pageSize >= filesData.Data.TotalCount {
+			break
+		} else {
+			pageIndex++
+		}
+	}
+	return files, nil
+}
+
+func (d *QuarkUCTV) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	files := &model.Link{}
+	var fileLink FileLink
+	_, err := d.request(ctx, "/file", "GET", func(req *resty.Request) {
+		req.SetQueryParams(map[string]string{
+			"method":     "download",
+			"group_by":   "source",
+			"fid":        file.GetID(),
+			"resolution": "low,normal,high,super,2k,4k",
+			"support":    "dolby_vision",
+		})
+	}, &fileLink)
+	if err != nil {
+		return nil, err
+	}
+	files.URL = fileLink.Data.DownloadURL
+	return files, nil
+}
+
+func (d *QuarkUCTV) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+func (d *QuarkUCTV) Move(ctx context.Context, srcObj, dstDir model.Obj) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+func (d *QuarkUCTV) Rename(ctx context.Context, srcObj model.Obj, newName string) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+func (d *QuarkUCTV) Copy(ctx context.Context, srcObj, dstDir model.Obj) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+func (d *QuarkUCTV) Remove(ctx context.Context, obj model.Obj) error {
+	return errs.NotImplement
+}
+
+func (d *QuarkUCTV) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) (model.Obj, error) {
+	return nil, errs.NotImplement
+}
+
+type QuarkUCTVCommon struct {
+	AccessToken string
+}
+
+var _ driver.Driver = (*QuarkUCTV)(nil)

drivers/quark_uc_tv/meta.go

@@ -0,0 +1,67 @@
+package quark_uc_tv
+
+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.RootID
+	// define other
+	RefreshToken string `json:"refresh_token" required:"false" default:""`
+	// 必要且影响登录,由签名决定
+	DeviceID string `json:"device_id"  required:"false" default:""`
+	// 登陆所用的数据 无需手动填写
+	QueryToken string `json:"query_token" required:"false" default:"" help:"don't edit'"`
+}
+
+type Conf struct {
+	api      string
+	clientID string
+	signKey  string
+	appVer   string
+	channel  string
+	codeApi  string
+}
+
+func init() {
+	op.RegisterDriver(func() driver.Driver {
+		return &QuarkUCTV{
+			config: driver.Config{
+				Name:              "QuarkTV",
+				OnlyLocal:         false,
+				DefaultRoot:       "0",
+				NoOverwriteUpload: true,
+				NoUpload:          true,
+			},
+			conf: Conf{
+				api:      "https://open-api-drive.quark.cn",
+				clientID: "d3194e61504e493eb6222857bccfed94",
+				signKey:  "kw2dvtd7p4t3pjl2d9ed9yc8yej8kw2d",
+				appVer:   "1.5.6",
+				channel:  "CP",
+				codeApi:  "http://api.extscreen.com/quarkdrive",
+			},
+		}
+	})
+	op.RegisterDriver(func() driver.Driver {
+		return &QuarkUCTV{
+			config: driver.Config{
+				Name:              "UCTV",
+				OnlyLocal:         false,
+				DefaultRoot:       "0",
+				NoOverwriteUpload: true,
+				NoUpload:          true,
+			},
+			conf: Conf{
+				api:      "https://open-api-drive.uc.cn",
+				clientID: "5acf882d27b74502b7040b0c65519aa7",
+				signKey:  "l3srvtd7p42l0d0x1u8d7yc8ye9kki4d",
+				appVer:   "1.6.5",
+				channel:  "UCTVOFFICIALWEB",
+				codeApi:  "http://api.extscreen.com/ucdrive",
+			},
+		}
+	})
+}

drivers/quark_uc_tv/types.go

@@ -0,0 +1,102 @@
+package quark_uc_tv
+
+import (
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"time"
+)
+
+type Resp struct {
+	CommonRsp
+	Errno     int    `json:"errno"`
+	ErrorInfo string `json:"error_info"`
+}
+
+type CommonRsp struct {
+	Status int    `json:"status"`
+	ReqID  string `json:"req_id"`
+}
+
+type RefreshTokenAuthResp struct {
+	Code    int    `json:"code"`
+	Message string `json:"message"`
+	Data    struct {
+		Status       int    `json:"status"`
+		Errno        int    `json:"errno"`
+		ErrorInfo    string `json:"error_info"`
+		ReqID        string `json:"req_id"`
+		AccessToken  string `json:"access_token"`
+		RefreshToken string `json:"refresh_token"`
+		ExpiresIn    int    `json:"expires_in"`
+		Scope        string `json:"scope"`
+	} `json:"data"`
+}
+type Files struct {
+	Fid          string `json:"fid"`
+	ParentFid    string `json:"parent_fid"`
+	Category     int    `json:"category"`
+	Filename     string `json:"filename"`
+	Size         int64  `json:"size"`
+	FileType     string `json:"file_type"`
+	SubItems     int    `json:"sub_items,omitempty"`
+	Isdir        int    `json:"isdir"`
+	Duration     int    `json:"duration"`
+	CreatedAt    int64  `json:"created_at"`
+	UpdatedAt    int64  `json:"updated_at"`
+	IsBackup     int    `json:"is_backup"`
+	ThumbnailURL string `json:"thumbnail_url,omitempty"`
+}
+
+func (f *Files) GetSize() int64 {
+	return f.Size
+}
+
+func (f *Files) GetName() string {
+	return f.Filename
+}
+
+func (f *Files) ModTime() time.Time {
+	//return time.Unix(f.UpdatedAt, 0)
+	return time.Unix(0, f.UpdatedAt*int64(time.Millisecond))
+}
+
+func (f *Files) CreateTime() time.Time {
+	//return time.Unix(f.CreatedAt, 0)
+	return time.Unix(0, f.CreatedAt*int64(time.Millisecond))
+}
+
+func (f *Files) IsDir() bool {
+	return f.Isdir == 1
+}
+
+func (f *Files) GetHash() utils.HashInfo {
+	return utils.HashInfo{}
+}
+
+func (f *Files) GetID() string {
+	return f.Fid
+}
+
+func (f *Files) GetPath() string {
+	return ""
+}
+
+var _ model.Obj = (*Files)(nil)
+
+type FilesData struct {
+	CommonRsp
+	Data struct {
+		TotalCount int64   `json:"total_count"`
+		Files      []Files `json:"files"`
+	} `json:"data"`
+}
+
+type FileLink struct {
+	CommonRsp
+	Data struct {
+		Fid         string `json:"fid"`
+		FileName    string `json:"file_name"`
+		Size        int64  `json:"size"`
+		DownloadURL string `json:"download_url"`
+	} `json:"data"`
+}

drivers/quark_uc_tv/util.go

@@ -0,0 +1,211 @@
+package quark_uc_tv
+
+import (
+	"context"
+	"crypto/md5"
+	"crypto/sha256"
+	"encoding/hex"
+	"errors"
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/internal/op"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/go-resty/resty/v2"
+	"net/http"
+	"strconv"
+	"time"
+)
+
+const (
+	UserAgent    = "Mozilla/5.0 (Linux; U; Android 13; zh-cn; M2004J7AC Build/UKQ1.231108.001) AppleWebKit/533.1 (KHTML, like Gecko) Mobile Safari/533.1"
+	DeviceBrand  = "Xiaomi"
+	Platform     = "tv"
+	DeviceName   = "M2004J7AC"
+	DeviceModel  = "M2004J7AC"
+	BuildDevice  = "M2004J7AC"
+	BuildProduct = "M2004J7AC"
+	DeviceGpu    = "Adreno (TM) 550"
+	ActivityRect = "{}"
+)
+
+func (d *QuarkUCTV) request(ctx context.Context, pathname string, method string, callback base.ReqCallback, resp interface{}) ([]byte, error) {
+	u := d.conf.api + pathname
+	tm, token, reqID := d.generateReqSign(method, pathname, d.conf.signKey)
+	req := base.RestyClient.R()
+	req.SetContext(ctx)
+	req.SetHeaders(map[string]string{
+		"Accept":          "application/json, text/plain, */*",
+		"User-Agent":      UserAgent,
+		"x-pan-tm":        tm,
+		"x-pan-token":     token,
+		"x-pan-client-id": d.conf.clientID,
+	})
+	req.SetQueryParams(map[string]string{
+		"req_id":        reqID,
+		"access_token":  d.QuarkUCTVCommon.AccessToken,
+		"app_ver":       d.conf.appVer,
+		"device_id":     d.Addition.DeviceID,
+		"device_brand":  DeviceBrand,
+		"platform":      Platform,
+		"device_name":   DeviceName,
+		"device_model":  DeviceModel,
+		"build_device":  BuildDevice,
+		"build_product": BuildProduct,
+		"device_gpu":    DeviceGpu,
+		"activity_rect": ActivityRect,
+		"channel":       d.conf.channel,
+	})
+	if callback != nil {
+		callback(req)
+	}
+	if resp != nil {
+		req.SetResult(resp)
+	}
+	var e Resp
+	req.SetError(&e)
+	res, err := req.Execute(method, u)
+	if err != nil {
+		return nil, err
+	}
+	// 判断 是否需要 刷新 access_token
+	if e.Status == -1 && e.Errno == 10001 {
+		// token 过期
+		err = d.getRefreshTokenByTV(ctx, d.Addition.RefreshToken, true)
+		if err != nil {
+			return nil, err
+		}
+		ctx1, cancelFunc := context.WithTimeout(ctx, 10*time.Second)
+		defer cancelFunc()
+		return d.request(ctx1, pathname, method, callback, resp)
+	}
+
+	if e.Status >= 400 || e.Errno != 0 {
+		return nil, errors.New(e.ErrorInfo)
+	}
+	return res.Body(), nil
+}
+
+func (d *QuarkUCTV) getLoginCode(ctx context.Context) (string, error) {
+	// 获取登录二维码
+	pathname := "/oauth/authorize"
+	var resp struct {
+		CommonRsp
+		QrData     string `json:"qr_data"`
+		QueryToken string `json:"query_token"`
+	}
+	_, err := d.request(ctx, pathname, "GET", func(req *resty.Request) {
+		req.SetQueryParams(map[string]string{
+			"auth_type": "code",
+			"client_id": d.conf.clientID,
+			"scope":     "netdisk",
+			"qrcode":    "1",
+			"qr_width":  "460",
+			"qr_height": "460",
+		})
+	}, &resp)
+	if err != nil {
+		return "", err
+	}
+	// 保存query_token 用于后续登录
+	if resp.QueryToken != "" {
+		d.Addition.QueryToken = resp.QueryToken
+		op.MustSaveDriverStorage(d)
+	}
+	return resp.QrData, nil
+}
+
+func (d *QuarkUCTV) getCode(ctx context.Context) (string, error) {
+	// 通过query token获取code
+	pathname := "/oauth/code"
+	var resp struct {
+		CommonRsp
+		Code string `json:"code"`
+	}
+	_, err := d.request(ctx, pathname, "GET", func(req *resty.Request) {
+		req.SetQueryParams(map[string]string{
+			"client_id":   d.conf.clientID,
+			"scope":       "netdisk",
+			"query_token": d.Addition.QueryToken,
+		})
+	}, &resp)
+	if err != nil {
+		return "", err
+	}
+	return resp.Code, nil
+}
+
+func (d *QuarkUCTV) getRefreshTokenByTV(ctx context.Context, code string, isRefresh bool) error {
+	pathname := "/token"
+	_, _, reqID := d.generateReqSign("POST", pathname, d.conf.signKey)
+	u := d.conf.codeApi + pathname
+	var resp RefreshTokenAuthResp
+	body := map[string]string{
+		"req_id":        reqID,
+		"app_ver":       d.conf.appVer,
+		"device_id":     d.Addition.DeviceID,
+		"device_brand":  DeviceBrand,
+		"platform":      Platform,
+		"device_name":   DeviceName,
+		"device_model":  DeviceModel,
+		"build_device":  BuildDevice,
+		"build_product": BuildProduct,
+		"device_gpu":    DeviceGpu,
+		"activity_rect": ActivityRect,
+		"channel":       d.conf.channel,
+	}
+	if isRefresh {
+		body["refresh_token"] = code
+	} else {
+		body["code"] = code
+	}
+
+	_, err := base.RestyClient.R().
+		SetHeader("Content-Type", "application/json").
+		SetBody(body).
+		SetResult(&resp).
+		SetContext(ctx).
+		Post(u)
+	if err != nil {
+		return err
+	}
+	if resp.Code != 200 {
+		return errors.New(resp.Message)
+	}
+	if resp.Data.RefreshToken != "" {
+		d.Addition.RefreshToken = resp.Data.RefreshToken
+		op.MustSaveDriverStorage(d)
+		d.QuarkUCTVCommon.AccessToken = resp.Data.AccessToken
+	} else {
+		return errors.New("refresh token is empty")
+	}
+	return nil
+}
+
+func (d *QuarkUCTV) isLogin(ctx context.Context) (bool, error) {
+	_, err := d.request(ctx, "/user", http.MethodGet, func(req *resty.Request) {
+		req.SetQueryParams(map[string]string{
+			"method": "user_info",
+		})
+	}, nil)
+	return err == nil, err
+}
+
+func (d *QuarkUCTV) generateReqSign(method string, pathname string, key string) (string, string, string) {
+	//timestamp 13位时间戳
+	timestamp := strconv.FormatInt(time.Now().UnixNano()/int64(time.Millisecond), 10)
+	deviceID := d.Addition.DeviceID
+	if deviceID == "" {
+		deviceID = utils.GetMD5EncodeStr(timestamp)
+		d.Addition.DeviceID = deviceID
+		op.MustSaveDriverStorage(d)
+	}
+	// 生成req_id
+	reqID := md5.Sum([]byte(deviceID + timestamp))
+	reqIDHex := hex.EncodeToString(reqID[:])
+
+	// 生成x_pan_token
+	tokenData := method + "&" + pathname + "&" + timestamp + "&" + key
+	xPanToken := sha256.Sum256([]byte(tokenData))
+	xPanTokenHex := hex.EncodeToString(xPanToken[:])
+
+	return timestamp, xPanTokenHex, reqIDHex
+}

drivers/thunder_browser/driver.go

@@ -15,8 +15,8 @@ import (
 	"github.com/aws/aws-sdk-go/aws/session"
 	"github.com/aws/aws-sdk-go/service/s3/s3manager"
 	"github.com/go-resty/resty/v2"
+	"io"
 	"net/http"
-	"regexp"
 	"strings"
 )
 
@@ -309,7 +309,7 @@ type XunLeiBrowserCommon struct {
 }
 
 func (xc *XunLeiBrowserCommon) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
-	return xc.getFiles(ctx, dir.GetID(), args.ReqPath)
+	return xc.getFiles(ctx, dir, args.ReqPath)
 }
 
 func (xc *XunLeiBrowserCommon) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
@@ -317,17 +317,10 @@ func (xc *XunLeiBrowserCommon) Link(ctx context.Context, file model.Obj, args mo
 
 	params := map[string]string{
 		"_magic":         "2021",
-		"space":          "SPACE_BROWSER",
+		"space":          file.(*Files).GetSpace(),
 		"thumbnail_size": "SIZE_LARGE",
 		"with":           "url",
 	}
-	// 对 "迅雷云盘" 内的文件 特殊处理
-	if file.GetPath() == ThunderDriveFileID {
-		params = map[string]string{}
-	} else if file.GetPath() == ThunderBrowserDriveSafeFileID {
-		// 对 "超级保险箱" 内的文件 特殊处理
-		params["space"] = "SPACE_BROWSER_SAFE"
-	}
 
 	_, err := xc.Request(FILE_API_URL+"/{fileID}", http.MethodGet, func(r *resty.Request) {
 		r.SetContext(ctx)
@@ -361,22 +354,9 @@ func (xc *XunLeiBrowserCommon) MakeDir(ctx context.Context, parentDir model.Obj,
 		"kind":      FOLDER,
 		"name":      dirName,
 		"parent_id": parentDir.GetID(),
-		"space":     "SPACE_BROWSER",
-	}
-	if parentDir.GetPath() == ThunderDriveFileID {
-		js = base.Json{
-			"kind":      FOLDER,
-			"name":      dirName,
-			"parent_id": parentDir.GetID(),
-		}
-	} else if parentDir.GetPath() == ThunderBrowserDriveSafeFileID {
-		js = base.Json{
-			"kind":      FOLDER,
-			"name":      dirName,
-			"parent_id": parentDir.GetID(),
-			"space":     "SPACE_BROWSER_SAFE",
-		}
+		"space":     parentDir.(*Files).GetSpace(),
 	}
+
 	_, err := xc.Request(FILE_API_URL, http.MethodPost, func(r *resty.Request) {
 		r.SetContext(ctx)
 		r.SetBody(&js)
@@ -386,33 +366,14 @@ func (xc *XunLeiBrowserCommon) MakeDir(ctx context.Context, parentDir model.Obj,
 
 func (xc *XunLeiBrowserCommon) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
 
-	srcSpace := "SPACE_BROWSER"
-	dstSpace := "SPACE_BROWSER"
-
-	// 对 "超级保险箱" 内的文件 特殊处理
-	if srcObj.GetPath() == ThunderBrowserDriveSafeFileID {
-		srcSpace = "SPACE_BROWSER_SAFE"
-	}
-	if dstDir.GetPath() == ThunderBrowserDriveSafeFileID {
-		dstSpace = "SPACE_BROWSER_SAFE"
-	}
-
 	params := map[string]string{
-		"_from": dstSpace,
+		"_from": srcObj.(*Files).GetSpace(),
 	}
 	js := base.Json{
-		"to":    base.Json{"parent_id": dstDir.GetID(), "space": dstSpace},
-		"space": srcSpace,
+		"to":    base.Json{"parent_id": dstDir.GetID(), "space": dstDir.(*Files).GetSpace()},
+		"space": srcObj.(*Files).GetSpace(),
 		"ids":   []string{srcObj.GetID()},
 	}
-	// 对 "迅雷云盘" 内的文件 特殊处理
-	if srcObj.GetPath() == ThunderDriveFileID {
-		params = map[string]string{}
-		js = base.Json{
-			"to":  base.Json{"parent_id": dstDir.GetID()},
-			"ids": []string{srcObj.GetID()},
-		}
-	}
 
 	_, err := xc.Request(FILE_API_URL+":batchMove", http.MethodPost, func(r *resty.Request) {
 		r.SetContext(ctx)
@@ -425,16 +386,7 @@ func (xc *XunLeiBrowserCommon) Move(ctx context.Context, srcObj, dstDir model.Ob
 func (xc *XunLeiBrowserCommon) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
 
 	params := map[string]string{
-		"space": "SPACE_BROWSER",
-	}
-	// 对 "迅雷云盘" 内的文件 特殊处理
-	if srcObj.GetPath() == ThunderDriveFileID {
-		params = map[string]string{}
-	} else if srcObj.GetPath() == ThunderBrowserDriveSafeFileID {
-		// 对 "超级保险箱" 内的文件 特殊处理
-		params = map[string]string{
-			"space": "SPACE_BROWSER_SAFE",
-		}
+		"space": srcObj.(*Files).GetSpace(),
 	}
 
 	_, err := xc.Request(FILE_API_URL+"/{fileID}", http.MethodPatch, func(r *resty.Request) {
@@ -448,33 +400,14 @@ func (xc *XunLeiBrowserCommon) Rename(ctx context.Context, srcObj model.Obj, new
 
 func (xc *XunLeiBrowserCommon) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
 
-	srcSpace := "SPACE_BROWSER"
-	dstSpace := "SPACE_BROWSER"
-
-	// 对 "超级保险箱" 内的文件 特殊处理
-	if srcObj.GetPath() == ThunderBrowserDriveSafeFileID {
-		srcSpace = "SPACE_BROWSER_SAFE"
-	}
-	if dstDir.GetPath() == ThunderBrowserDriveSafeFileID {
-		dstSpace = "SPACE_BROWSER_SAFE"
-	}
-
 	params := map[string]string{
-		"_from": dstSpace,
+		"_from": srcObj.(*Files).GetSpace(),
 	}
 	js := base.Json{
-		"to":    base.Json{"parent_id": dstDir.GetID(), "space": dstSpace},
-		"space": srcSpace,
+		"to":    base.Json{"parent_id": dstDir.GetID(), "space": dstDir.(*Files).GetSpace()},
+		"space": srcObj.(*Files).GetSpace(),
 		"ids":   []string{srcObj.GetID()},
 	}
-	// 对 "迅雷云盘" 内的文件 特殊处理
-	if srcObj.GetPath() == ThunderDriveFileID {
-		params = map[string]string{}
-		js = base.Json{
-			"to":  base.Json{"parent_id": dstDir.GetID()},
-			"ids": []string{srcObj.GetID()},
-		}
-	}
 
 	_, err := xc.Request(FILE_API_URL+":batchCopy", http.MethodPost, func(r *resty.Request) {
 		r.SetContext(ctx)
@@ -488,30 +421,17 @@ func (xc *XunLeiBrowserCommon) Remove(ctx context.Context, obj model.Obj) error
 
 	js := base.Json{
 		"ids":   []string{obj.GetID()},
-		"space": "SPACE_BROWSER",
+		"space": obj.(*Files).GetSpace(),
 	}
-	// 对 "迅雷云盘" 内的文件 特殊处理
-	if obj.GetPath() == ThunderDriveFileID {
-		js = base.Json{
-			"ids": []string{obj.GetID()},
-		}
-	} else if obj.GetPath() == ThunderBrowserDriveSafeFileID {
-		// 对 "超级保险箱" 内的文件 特殊处理
-		js = base.Json{
-			"ids":   []string{obj.GetID()},
-			"space": "SPACE_BROWSER_SAFE",
-		}
-	}
-
 	// 先判断是否是特殊情况
-	if obj.GetPath() == ThunderDriveFileID {
+	if obj.(*Files).GetSpace() == ThunderDriveSpace {
 		_, 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
-	} else if obj.GetPath() == ThunderBrowserDriveSafeFileID {
+	} else if obj.(*Files).GetSpace() == ThunderBrowserDriveSafeSpace || obj.(*Files).GetSpace() == ThunderDriveSafeSpace {
 		_, err := xc.Request(FILE_API_URL+":batchDelete", http.MethodPost, func(r *resty.Request) {
 			r.SetContext(ctx)
 			r.SetBody(&js)
@@ -557,29 +477,7 @@ func (xc *XunLeiBrowserCommon) Put(ctx context.Context, dstDir model.Obj, stream
 		"size":        stream.GetSize(),
 		"hash":        gcid,
 		"upload_type": UPLOAD_TYPE_RESUMABLE,
-		"space":       "SPACE_BROWSER",
-	}
-	// 对 "迅雷云盘" 内的文件 特殊处理
-	if dstDir.GetPath() == ThunderDriveFileID {
-		js = base.Json{
-			"kind":        FILE,
-			"parent_id":   dstDir.GetID(),
-			"name":        stream.GetName(),
-			"size":        stream.GetSize(),
-			"hash":        gcid,
-			"upload_type": UPLOAD_TYPE_RESUMABLE,
-		}
-	} else if dstDir.GetPath() == ThunderBrowserDriveSafeFileID {
-		// 对 "超级保险箱" 内的文件 特殊处理
-		js = base.Json{
-			"kind":        FILE,
-			"parent_id":   dstDir.GetID(),
-			"name":        stream.GetName(),
-			"size":        stream.GetSize(),
-			"hash":        gcid,
-			"upload_type": UPLOAD_TYPE_RESUMABLE,
-			"space":       "SPACE_BROWSER_SAFE",
-		}
+		"space":       dstDir.(*Files).GetSpace(),
 	}
 
 	var resp UploadTaskResponse
@@ -610,58 +508,35 @@ func (xc *XunLeiBrowserCommon) Put(ctx context.Context, dstDir model.Obj, stream
 			Bucket:  aws.String(param.Bucket),
 			Key:     aws.String(param.Key),
 			Expires: aws.Time(param.Expiration),
-			Body:    stream,
+			Body:    io.TeeReader(stream, driver.NewProgress(stream.GetSize(), up)),
 		})
 		return err
 	}
 	return nil
 }
 
-func (xc *XunLeiBrowserCommon) getFiles(ctx context.Context, folderId string, path string) ([]model.Obj, error) {
+func (xc *XunLeiBrowserCommon) getFiles(ctx context.Context, dir model.Obj, path string) ([]model.Obj, error) {
 	files := make([]model.Obj, 0)
 	var pageToken string
 	for {
 		var fileList FileList
-		folderSpace := "SPACE_BROWSER"
+		folderSpace := ""
+		switch dirF := dir.(type) {
+		case *Files:
+			folderSpace = dirF.GetSpace()
+		default:
+			// 处理 根目录的情况
+			folderSpace = ThunderBrowserDriveSpace
+		}
 		params := map[string]string{
-			"parent_id":      folderId,
+			"parent_id":      dir.GetID(),
 			"page_token":     pageToken,
 			"space":          folderSpace,
 			"filters":        `{"trashed":{"eq":false}}`,
+			"with":           "url",
 			"with_audit":     "true",
 			"thumbnail_size": "SIZE_LARGE",
 		}
-		var fileType int8
-		// 处理特殊目录 “迅雷云盘” 设置特殊的 params 以便正常访问
-		pattern1 := fmt.Sprintf(`^/.*/%s(/.*)?$`, ThunderDriveFolderName)
-		thunderDriveMatch, _ := regexp.MatchString(pattern1, path)
-		// 处理特殊目录 “超级保险箱” 设置特殊的 params 以便正常访问
-		pattern2 := fmt.Sprintf(`^/.*/%s(/.*)?$`, ThunderBrowserDriveSafeFolderName)
-		thunderBrowserDriveSafeMatch, _ := regexp.MatchString(pattern2, path)
-
-		// 如果是 "迅雷云盘" 内的
-		if folderId == ThunderDriveFileID || thunderDriveMatch {
-			params = 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}}`,
-			}
-			// 如果不是 "迅雷云盘"的"根目录"
-			if folderId == ThunderDriveFileID {
-				params["parent_id"] = ""
-			}
-			fileType = ThunderDriveType
-		} else if thunderBrowserDriveSafeMatch {
-			// 如果是 "超级保险箱" 内的
-			fileType = ThunderBrowserDriveSafeType
-			params["space"] = "SPACE_BROWSER_SAFE"
-		}
 
 		_, err := xc.Request(FILE_API_URL, http.MethodGet, func(r *resty.Request) {
 			r.SetContext(ctx)
@@ -670,24 +545,13 @@ func (xc *XunLeiBrowserCommon) getFiles(ctx context.Context, folderId string, pa
 		if err != nil {
 			return nil, err
 		}
-		// 对文件夹也进行处理
-		fileList.FolderType = fileType
 
-		for i := 0; i < len(fileList.Files); i++ {
-			file := &fileList.Files[i]
-			// 标记 文件夹内的文件
-			file.FileType = fileList.FolderType
+		for i := range fileList.Files {
 			// 解决 "迅雷云盘" 重复出现问题————迅雷后端发送错误
-			if file.Name == ThunderDriveFolderName && file.ID == "" && file.FolderType == ThunderDriveFolderType && folderId != "" {
+			if fileList.Files[i].FolderType == ThunderDriveFolderType && fileList.Files[i].ID == "" && fileList.Files[i].Space == "" && dir.GetID() != "" {
 				continue
 			}
-			// 处理特殊目录 “迅雷云盘” 设置特殊的文件夹ID
-			if file.Name == ThunderDriveFolderName && file.ID == "" && file.FolderType == ThunderDriveFolderType {
-				file.ID = ThunderDriveFileID
-			} else if file.Name == ThunderBrowserDriveSafeFolderName && file.FolderType == ThunderBrowserDriveSafeFolderType {
-				file.FileType = ThunderBrowserDriveSafeType
-			}
-			files = append(files, file)
+			files = append(files, &fileList.Files[i])
 		}
 
 		if fileList.NextPageToken == "" {

drivers/thunder_browser/meta.go

@@ -25,7 +25,7 @@ type ExpertAddition struct {
 	SafePassword string `json:"safe_password" required:"true" help:"super safe password"` // 超级保险箱密码
 
 	// 签名方法1
-	Algorithms string `json:"algorithms" required:"true" help:"sign type is algorithms,this is required" default:"p+ExqPV,LwdwKlprzv7cQBQmxN5,vc08P1NwUBnbGsl58LzTW,VVNeXaXmZ8HH1SJEnp6YpVFSFU,pNAOJ,CNChvyDehAmUR1TDodfOusBAx,MS98NnX4Np8nxvEh6Ulv+SMMKMzKvD34C7lGWbb,9MpFF21GnVOYku0NM9Y/hzsK471UCUZ2o+,EY1QfeA06fXlw9wZNoZaXEED5zZPvNWI,,sciE,FIPqgQDUUW1e0GkiBFd5w7mCQ,zW,75XFdEO0Gi"`
+	Algorithms string `json:"algorithms" required:"true" help:"sign type is algorithms,this is required" default:"uWRwO7gPfdPB/0NfPtfQO+71,F93x+qPluYy6jdgNpq+lwdH1ap6WOM+nfz8/V,0HbpxvpXFsBK5CoTKam,dQhzbhzFRcawnsZqRETT9AuPAJ+wTQso82mRv,SAH98AmLZLRa6DB2u68sGhyiDh15guJpXhBzI,unqfo7Z64Rie9RNHMOB,7yxUdFADp3DOBvXdz0DPuKNVT35wqa5z0DEyEvf,RBG,ThTWPG5eC0UBqlbQ+04nZAptqGCdpv9o55A"`
 	// 签名方法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"`
@@ -37,7 +37,7 @@ type ExpertAddition struct {
 	DeviceID      string `json:"device_id"  required:"false" default:""`
 	ClientID      string `json:"client_id"  required:"true" default:"ZUBzD9J_XPXfn7f7"`
 	ClientSecret  string `json:"client_secret"  required:"true" default:"yESVmHecEe6F0aou69vl-g"`
-	ClientVersion string `json:"client_version"  required:"true" default:"1.0.8.2215"`
+	ClientVersion string `json:"client_version"  required:"true" default:"1.10.0.2633"`
 	PackageName   string `json:"package_name"  required:"true" default:"com.xunlei.browser"`
 
 	// 不影响登录,影响下载速度

drivers/thunder_browser/types.go

@@ -114,8 +114,8 @@ type Files struct {
 	ModifiedTime   CustomTime `json:"modified_time"`
 	IconLink       string     `json:"icon_link"`
 	ThumbnailLink  string     `json:"thumbnail_link"`
-	// Md5Checksum    string    `json:"md5_checksum"`
-	Hash string `json:"hash"`
+	Md5Checksum    string     `json:"md5_checksum"`
+	Hash           string     `json:"hash"`
 	// Links map[string]Link `json:"links"`
 	// Phase string          `json:"phase"`
 	// Audit struct {
@@ -153,12 +153,22 @@ type Files struct {
 	OriginalURL string `json:"original_url"`
 	//Params            struct{} `json:"params"`
 	//OriginalFileIndex int    `json:"original_file_index"`
-	//Space             string `json:"space"`
+	Space string `json:"space"`
 	//Apps              []interface{} `json:"apps"`
 	//Writable   bool   `json:"writable"`
 	FolderType string `json:"folder_type"`
 	//Collection interface{} `json:"collection"`
-	FileType int8
+	SortName         string     `json:"sort_name"`
+	UserModifiedTime CustomTime `json:"user_modified_time"`
+	//SpellName         []interface{} `json:"spell_name"`
+	//FileCategory      string        `json:"file_category"`
+	//Tags              []interface{} `json:"tags"`
+	//ReferenceEvents   []interface{} `json:"reference_events"`
+	//ReferenceResource interface{}   `json:"reference_resource"`
+	//Params0           struct {
+	//	PlatformIcon   string `json:"platform_icon"`
+	//	SmallThumbnail string `json:"small_thumbnail"`
+	//} `json:"params,omitempty"`
 }
 
 func (c *Files) GetHash() utils.HashInfo {
@@ -172,16 +182,19 @@ func (c *Files) ModTime() time.Time    { return c.ModifiedTime.Time }
 func (c *Files) IsDir() bool           { return c.Kind == FOLDER }
 func (c *Files) GetID() string         { return c.ID }
 func (c *Files) GetPath() string {
-	// 对特殊文件进行特殊处理
-	if c.FileType == ThunderDriveType {
-		return ThunderDriveFileID
-	} else if c.FileType == ThunderBrowserDriveSafeType {
-		return ThunderBrowserDriveSafeFileID
-	}
 	return ""
 }
 func (c *Files) Thumb() string { return c.ThumbnailLink }
 
+func (c *Files) GetSpace() string {
+	if c.Space != "" {
+		return c.Space
+	} else {
+		// "迅雷云盘" 文件夹内 Space 为空
+		return ""
+	}
+}
+
 /*
 * 上传
 **/

drivers/thunder_browser/util.go

@@ -23,29 +23,24 @@ const (
 )
 
 var Algorithms = []string{
-	"p+ExqPV",
-	"LwdwKlprzv7cQBQmxN5",
-	"vc08P1NwUBnbGsl58LzTW",
-	"VVNeXaXmZ8HH1SJEnp6YpVFSFU",
-	"pNAOJ",
-	"CNChvyDehAmUR1TDodfOusBAx",
-	"MS98NnX4Np8nxvEh6Ulv+SMMKMzKvD34C7lGWbb",
-	"9MpFF21GnVOYku0NM9Y/hzsK471UCUZ2o+",
-	"EY1QfeA06fXlw9wZNoZaXEED5zZPvNWI",
-	"",
-	"sciE",
-	"FIPqgQDUUW1e0GkiBFd5w7mCQ",
-	"zW",
-	"75XFdEO0Gi",
+	"uWRwO7gPfdPB/0NfPtfQO+71",
+	"F93x+qPluYy6jdgNpq+lwdH1ap6WOM+nfz8/V",
+	"0HbpxvpXFsBK5CoTKam",
+	"dQhzbhzFRcawnsZqRETT9AuPAJ+wTQso82mRv",
+	"SAH98AmLZLRa6DB2u68sGhyiDh15guJpXhBzI",
+	"unqfo7Z64Rie9RNHMOB",
+	"7yxUdFADp3DOBvXdz0DPuKNVT35wqa5z0DEyEvf",
+	"RBG",
+	"ThTWPG5eC0UBqlbQ+04nZAptqGCdpv9o55A",
 }
 
 const (
 	ClientID          = "ZUBzD9J_XPXfn7f7"
 	ClientSecret      = "yESVmHecEe6F0aou69vl-g"
-	ClientVersion     = "1.0.8.2215"
+	ClientVersion     = "1.10.0.2633"
 	PackageName       = "com.xunlei.browser"
 	DownloadUserAgent = "AndroidDownloadManager/13 (Linux; U; Android 13; M2004J7AC Build/SP1A.210812.016)"
-	SdkVersion        = "2.0.3.262"
+	SdkVersion        = "233100"
 )
 
 const (
@@ -62,12 +57,10 @@ const (
 )
 
 const (
-	ThunderDriveFileID                = "XXXXXXXXXXXXXXXXXXXXXXXXXX"
-	ThunderBrowserDriveSafeFileID     = "YYYYYYYYYYYYYYYYYYYYYYYYYY"
-	ThunderDriveFolderName            = "迅雷云盘"
-	ThunderBrowserDriveSafeFolderName = "超级保险箱"
-	ThunderDriveType                  = 1
-	ThunderBrowserDriveSafeType       = 2
+	ThunderDriveSpace                 = ""
+	ThunderDriveSafeSpace             = "SPACE_SAFE"
+	ThunderBrowserDriveSpace          = "SPACE_BROWSER"
+	ThunderBrowserDriveSafeSpace      = "SPACE_BROWSER_SAFE"
 	ThunderDriveFolderType            = "DEFAULT_ROOT"
 	ThunderBrowserDriveSafeFolderType = "BROWSER_SAFE"
 )

go.mod

@@ -3,15 +3,16 @@ module github.com/alist-org/alist/v3
 go 1.22.4
 
 require (
-	github.com/SheltonZhu/115driver v1.0.25
-	github.com/Xhofe/go-cache v0.0.0-20220723083548-714439c8af9a
+	github.com/SheltonZhu/115driver v1.0.26
+	github.com/Xhofe/go-cache v0.0.0-20240804043513-b1a71927bc21
 	github.com/Xhofe/rateg v0.0.0-20230728072201-251a4e1adad4
-	github.com/alist-org/gofakes3 v0.0.6
-	github.com/alist-org/times v0.0.0-20240721124318-c2e3da27cc69
+	github.com/alist-org/gofakes3 v0.0.7
+	github.com/alist-org/times v0.0.0-20240721124654-efa0c7d3ad92
 	github.com/aliyun/aliyun-oss-go-sdk v3.0.2+incompatible
 	github.com/avast/retry-go v3.0.0+incompatible
 	github.com/aws/aws-sdk-go v1.54.19
-	github.com/blevesearch/bleve/v2 v2.4.1
+	github.com/blevesearch/bleve/v2 v2.4.2
+	github.com/caarlos0/env/v11 v11.2.2
 	github.com/caarlos0/env/v9 v9.0.0
 	github.com/charmbracelet/bubbles v0.18.0
 	github.com/charmbracelet/bubbletea v0.26.6
@@ -21,7 +22,7 @@ require (
 	github.com/deckarep/golang-set/v2 v2.6.0
 	github.com/dhowden/tag v0.0.0-20240417053706-3d75831295e8
 	github.com/disintegration/imaging v1.6.2
-	github.com/dlclark/regexp2 v1.11.2
+	github.com/dlclark/regexp2 v1.11.4
 	github.com/dustinxie/ecc v0.0.0-20210511000915-959544187564
 	github.com/foxxorcat/mopan-sdk-go v0.1.6
 	github.com/foxxorcat/weiyun-sdk-go v0.1.3
@@ -37,7 +38,7 @@ require (
 	github.com/ipfs/go-ipfs-api v0.7.0
 	github.com/jlaffaye/ftp v0.2.0
 	github.com/json-iterator/go v1.1.12
-	github.com/larksuite/oapi-sdk-go/v3 v3.2.8
+	github.com/larksuite/oapi-sdk-go/v3 v3.3.1
 	github.com/maruel/natural v1.1.1
 	github.com/meilisearch/meilisearch-go v0.27.0
 	github.com/minio/sio v0.4.0
@@ -55,15 +56,15 @@ require (
 	github.com/u2takey/ffmpeg-go v0.5.0
 	github.com/upyun/go-sdk/v3 v3.0.4
 	github.com/winfsp/cgofuse v1.5.1-0.20230130140708-f87f5db493b5
-	github.com/xhofe/tache v0.1.1
+	github.com/xhofe/tache v0.1.2
 	github.com/xhofe/wopan-sdk-go v0.1.3
 	github.com/zzzhr1990/go-common-entity v0.0.0-20221216044934-fd1c571e3a22
-	golang.org/x/crypto v0.25.0
-	golang.org/x/exp v0.0.0-20240707233637-46b078467d37
+	golang.org/x/crypto v0.26.0
+	golang.org/x/exp v0.0.0-20240808152545-0cdaa3abc0fa
 	golang.org/x/image v0.18.0
-	golang.org/x/net v0.27.0
-	golang.org/x/oauth2 v0.21.0
-	golang.org/x/time v0.5.0
+	golang.org/x/net v0.28.0
+	golang.org/x/oauth2 v0.22.0
+	golang.org/x/time v0.6.0
 	google.golang.org/appengine v1.6.8
 	gopkg.in/ldap.v3 v3.1.0
 	gorm.io/driver/mysql v1.5.7
@@ -74,8 +75,8 @@ require (
 
 require (
 	github.com/BurntSushi/toml v0.3.1 // indirect
-	github.com/blevesearch/go-faiss v1.0.19 // indirect
-	github.com/blevesearch/zapx/v16 v16.1.4 // indirect
+	github.com/blevesearch/go-faiss v1.0.20 // indirect
+	github.com/blevesearch/zapx/v16 v16.1.5 // indirect
 	github.com/bytedance/sonic/loader v0.1.1 // indirect
 	github.com/charmbracelet/x/ansi v0.1.4 // indirect
 	github.com/charmbracelet/x/input v0.1.0 // indirect
@@ -102,12 +103,12 @@ require (
 	github.com/beorn7/perks v1.0.1 // indirect
 	github.com/bits-and-blooms/bitset v1.12.0 // indirect
 	github.com/blang/semver/v4 v4.0.0 // indirect
-	github.com/blevesearch/bleve_index_api v1.1.9 // indirect
+	github.com/blevesearch/bleve_index_api v1.1.10 // indirect
 	github.com/blevesearch/geo v0.1.20 // indirect
 	github.com/blevesearch/go-porterstemmer v1.0.3 // indirect
 	github.com/blevesearch/gtreap v0.1.1 // indirect
 	github.com/blevesearch/mmap-go v1.0.4 // indirect
-	github.com/blevesearch/scorch_segment_api/v2 v2.2.14 // indirect
+	github.com/blevesearch/scorch_segment_api/v2 v2.2.15 // indirect
 	github.com/blevesearch/segment v0.9.1 // indirect
 	github.com/blevesearch/snowballstem v0.9.0 // indirect
 	github.com/blevesearch/upsidedown_store_api v1.0.2 // indirect
@@ -219,11 +220,11 @@ require (
 	github.com/yusufpapurcu/wmi v1.2.4 // indirect
 	go.etcd.io/bbolt v1.3.8 // indirect
 	golang.org/x/arch v0.8.0 // indirect
-	golang.org/x/sync v0.7.0 // indirect
-	golang.org/x/sys v0.22.0 // indirect
-	golang.org/x/term v0.22.0 // indirect
-	golang.org/x/text v0.16.0 // indirect
-	golang.org/x/tools v0.23.0 // indirect
+	golang.org/x/sync v0.8.0 // indirect
+	golang.org/x/sys v0.23.0 // indirect
+	golang.org/x/term v0.23.0 // indirect
+	golang.org/x/text v0.17.0 // indirect
+	golang.org/x/tools v0.24.0 // indirect
 	google.golang.org/api v0.169.0 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20240528184218-531527333157 // indirect
 	google.golang.org/grpc v1.65.0

go.sum

@@ -7,22 +7,24 @@ github.com/Max-Sum/base32768 v0.0.0-20230304063302-18e6ce5945fd h1:nzE1YQBdx1bq9
 github.com/Max-Sum/base32768 v0.0.0-20230304063302-18e6ce5945fd/go.mod h1:C8yoIfvESpM3GD07OCHU7fqI7lhwyZ2Td1rbNbTAhnc=
 github.com/RoaringBitmap/roaring v1.9.3 h1:t4EbC5qQwnisr5PrP9nt0IRhRTb9gMUgQF4t4S2OByM=
 github.com/RoaringBitmap/roaring v1.9.3/go.mod h1:6AXUsoIEzDTFFQCe1RbGA6uFONMhvejWj5rqITANK90=
-github.com/SheltonZhu/115driver v1.0.25 h1:i101yanLKUwV1Pi7x+vgNOwgz7Hp9JbNmo6BCZ9/4wo=
-github.com/SheltonZhu/115driver v1.0.25/go.mod h1:e3fPOBANbH/FsTya8FquJwOR3ErhCQgEab3q6CVY2k4=
+github.com/SheltonZhu/115driver v1.0.26 h1:UDUEZffJoQLFYs2nxnyxqvxwSaocxP4LNaOycVY6syU=
+github.com/SheltonZhu/115driver v1.0.26/go.mod h1:e3fPOBANbH/FsTya8FquJwOR3ErhCQgEab3q6CVY2k4=
 github.com/Unknwon/goconfig v1.0.0 h1:9IAu/BYbSLQi8puFjUQApZTxIHqSwrj5d8vpP8vTq4A=
 github.com/Unknwon/goconfig v1.0.0/go.mod h1:wngxua9XCNjvHjDiTiV26DaKDT+0c63QR6H5hjVUUxw=
 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/Xhofe/go-cache v0.0.0-20240804043513-b1a71927bc21 h1:h6q5E9aMBhhdqouW81LozVPI1I+Pu6IxL2EKpfm5OjY=
+github.com/Xhofe/go-cache v0.0.0-20240804043513-b1a71927bc21/go.mod h1:sSBbaOg90XwWKtpT56kVujF0bIeVITnPlssLclogS04=
 github.com/Xhofe/rateg v0.0.0-20230728072201-251a4e1adad4 h1:WnvifFgYyogPz2ZFvaVLk4gI/Co0paF92FmxSR6U1zY=
 github.com/Xhofe/rateg v0.0.0-20230728072201-251a4e1adad4/go.mod h1:8pWlL2rpusvx7Xa6yYaIWOJ8bR3gPdFBUT7OystyGOY=
 github.com/abbot/go-http-auth v0.4.0 h1:QjmvZ5gSC7jm3Zg54DqWE/T5m1t2AfDu6QlXJT0EVT0=
 github.com/abbot/go-http-auth v0.4.0/go.mod h1:Cz6ARTIzApMJDzh5bRMSUou6UMSp0IEXg9km/ci7TJM=
 github.com/aead/ecdh v0.2.0 h1:pYop54xVaq/CEREFEcukHRZfTdjiWvYIsZDXXrBapQQ=
 github.com/aead/ecdh v0.2.0/go.mod h1:a9HHtXuSo8J1Js1MwLQx2mBhkXMT6YwUmVVEY4tTB8U=
-github.com/alist-org/gofakes3 v0.0.6 h1:kenkDSqOIJt5ZDJ9KW91YkwplFXpfToPDjP3Bd6GZRg=
-github.com/alist-org/gofakes3 v0.0.6/go.mod h1:6IyGtYGIX29fLvtXo+XZhtwX2P33KVYYj8uTgAHSu58=
-github.com/alist-org/times v0.0.0-20240721124318-c2e3da27cc69 h1:E9QJ4vVTu1KYRhelnCsQImCsbl7NlkH3Yxs3/L2ldDk=
-github.com/alist-org/times v0.0.0-20240721124318-c2e3da27cc69/go.mod h1:oPJwGY3sLmGgcJamGumz//0A35f4BwQRacyqLNcJTOU=
+github.com/alist-org/gofakes3 v0.0.7 h1:0cDGI7fLBrqumhCBto9T3ZYCL71AyGZ1l+xxJgjqe8s=
+github.com/alist-org/gofakes3 v0.0.7/go.mod h1:6IyGtYGIX29fLvtXo+XZhtwX2P33KVYYj8uTgAHSu58=
+github.com/alist-org/times v0.0.0-20240721124654-efa0c7d3ad92 h1:pIEI87zhv8ZzQcu65rTL7kqirrs8dR6HDiXrqWat2Fk=
+github.com/alist-org/times v0.0.0-20240721124654-efa0c7d3ad92/go.mod h1:oPJwGY3sLmGgcJamGumz//0A35f4BwQRacyqLNcJTOU=
 github.com/aliyun/aliyun-oss-go-sdk v3.0.2+incompatible h1:8psS8a+wKfiLt1iVDX79F7Y6wUM49Lcha2FMXt4UM8g=
 github.com/aliyun/aliyun-oss-go-sdk v3.0.2+incompatible/go.mod h1:T/Aws4fEfogEE9v+HPhhw+CntffsBHJ8nXQCwKr0/g8=
 github.com/andreburgaud/crypt2go v1.2.0 h1:oly/ENAodeqTYpUafgd4r3v+VKLQnmOKUyfpj+TxHbE=
@@ -48,12 +50,18 @@ github.com/blang/semver/v4 v4.0.0 h1:1PFHFE6yCCTv8C1TeyNNarDzntLi7wMI5i/pzqYIsAM
 github.com/blang/semver/v4 v4.0.0/go.mod h1:IbckMUScFkM3pff0VJDNKRiT6TG/YpiHIM2yvyW5YoQ=
 github.com/blevesearch/bleve/v2 v2.4.1 h1:8QWqsifq693mN3h6cSigKqkKUsUfv5hu0FDgz/4bFuA=
 github.com/blevesearch/bleve/v2 v2.4.1/go.mod h1:Ezmvsouspi+uVwnDzjIsCeUIT0WuBKlicP5JZnExWzo=
+github.com/blevesearch/bleve/v2 v2.4.2 h1:NooYP1mb3c0StkiY9/xviiq2LGSaE8BQBCc/pirMx0U=
+github.com/blevesearch/bleve/v2 v2.4.2/go.mod h1:ATNKj7Yl2oJv/lGuF4kx39bST2dveX6w0th2FFYLkc8=
 github.com/blevesearch/bleve_index_api v1.1.9 h1:Cpq0Lp3As0Gfk3+PmcoNDRKeI50C5yuFNpj0YlN/bOE=
 github.com/blevesearch/bleve_index_api v1.1.9/go.mod h1:PbcwjIcRmjhGbkS/lJCpfgVSMROV6TRubGGAODaK1W8=
+github.com/blevesearch/bleve_index_api v1.1.10 h1:PDLFhVjrjQWr6jCuU7TwlmByQVCSEURADHdCqVS9+g0=
+github.com/blevesearch/bleve_index_api v1.1.10/go.mod h1:PbcwjIcRmjhGbkS/lJCpfgVSMROV6TRubGGAODaK1W8=
 github.com/blevesearch/geo v0.1.20 h1:paaSpu2Ewh/tn5DKn/FB5SzvH0EWupxHEIwbCk/QPqM=
 github.com/blevesearch/geo v0.1.20/go.mod h1:DVG2QjwHNMFmjo+ZgzrIq2sfCh6rIHzy9d9d0B59I6w=
 github.com/blevesearch/go-faiss v1.0.19 h1:UKoP8hS7DVsVSRRloNJb4qPfe2UQ99pP4D3oXd23g2A=
 github.com/blevesearch/go-faiss v1.0.19/go.mod h1:jrxHrbl42X/RnDPI+wBoZU8joxxuRwedrxqswQ3xfU8=
+github.com/blevesearch/go-faiss v1.0.20 h1:AIkdTQFWuZ5LQmKQSebgMR4RynGNw8ZseJXaan5kvtI=
+github.com/blevesearch/go-faiss v1.0.20/go.mod h1:jrxHrbl42X/RnDPI+wBoZU8joxxuRwedrxqswQ3xfU8=
 github.com/blevesearch/go-porterstemmer v1.0.3 h1:GtmsqID0aZdCSNiY8SkuPJ12pD4jI+DdXTAn4YRcHCo=
 github.com/blevesearch/go-porterstemmer v1.0.3/go.mod h1:angGc5Ht+k2xhJdZi511LtmxuEf0OVpvUUNrwmM1P7M=
 github.com/blevesearch/gtreap v0.1.1 h1:2JWigFrzDMR+42WGIN/V2p0cUvn4UP3C4Q5nmaZGW8Y=
@@ -62,6 +70,8 @@ github.com/blevesearch/mmap-go v1.0.4 h1:OVhDhT5B/M1HNPpYPBKIEJaD0F3Si+CrEKULGCD
 github.com/blevesearch/mmap-go v1.0.4/go.mod h1:EWmEAOmdAS9z/pi/+Toxu99DnsbhG1TIxUoRmJw/pSs=
 github.com/blevesearch/scorch_segment_api/v2 v2.2.14 h1:fgMLMpGWR7u2TdRm7XSZVWhPvMAcdYHh25Lq1fQ6Fjo=
 github.com/blevesearch/scorch_segment_api/v2 v2.2.14/go.mod h1:B7+a7vfpY4NsjuTkpv/eY7RZ91Xr90VaJzT2t7upZN8=
+github.com/blevesearch/scorch_segment_api/v2 v2.2.15 h1:prV17iU/o+A8FiZi9MXmqbagd8I0bCqM7OKUYPbnb5Y=
+github.com/blevesearch/scorch_segment_api/v2 v2.2.15/go.mod h1:db0cmP03bPNadXrCDuVkKLV6ywFSiRgPFT1YVrestBc=
 github.com/blevesearch/segment v0.9.1 h1:+dThDy+Lvgj5JMxhmOVlgFfkUtZV2kw49xax4+jTfSU=
 github.com/blevesearch/segment v0.9.1/go.mod h1:zN21iLm7+GnBHWTao9I+Au/7MBiL8pPFtJBJTsk6kQw=
 github.com/blevesearch/snowballstem v0.9.0 h1:lMQ189YspGP6sXvZQ4WZ+MLawfV8wOmPoD/iWeNXm8s=
@@ -82,6 +92,8 @@ github.com/blevesearch/zapx/v15 v15.3.13 h1:6EkfaZiPlAxqXz0neniq35my6S48QI94W/wy
 github.com/blevesearch/zapx/v15 v15.3.13/go.mod h1:Turk/TNRKj9es7ZpKK95PS7f6D44Y7fAFy8F4LXQtGg=
 github.com/blevesearch/zapx/v16 v16.1.4 h1:TBQfG77g2UUXwfjOVcEtB9pXkg6JBmGXkeZKI67+TiA=
 github.com/blevesearch/zapx/v16 v16.1.4/go.mod h1:+Q+Z89Iv7ewhdX2jyE6Qs/RUnN4tZuokaQ0xvTaFmx8=
+github.com/blevesearch/zapx/v16 v16.1.5 h1:b0sMcarqNFxuXvjoXsF8WtwVahnxyhEvBSRJi/AUHjU=
+github.com/blevesearch/zapx/v16 v16.1.5/go.mod h1:J4mSF39w1QELc11EWRSBFkPeZuO7r/NPKkHzDCoiaI8=
 github.com/bluele/gcache v0.0.2 h1:WcbfdXICg7G/DGBh1PFfcirkWOQV+v077yF1pSy3DGw=
 github.com/bluele/gcache v0.0.2/go.mod h1:m15KV+ECjptwSPxKhOhQoAFQVtUFjTVkc3H8o0t/fp0=
 github.com/boombuler/barcode v1.0.1-0.20190219062509-6c824513bacc h1:biVzkmvwrH8WK8raXaxBx6fRVTlJILwEwQGL1I/ByEI=
@@ -90,6 +102,7 @@ github.com/bytedance/sonic v1.11.6 h1:oUp34TzMlL+OY1OUWxHqsdkgC/Zfc85zGqw9siXjrc
 github.com/bytedance/sonic v1.11.6/go.mod h1:LysEHSvpvDySVdC2f87zGWf6CIKJcAvqab1ZaiQtds4=
 github.com/bytedance/sonic/loader v0.1.1 h1:c+e5Pt1k/cy5wMveRDyk2X4B9hF4g7an8N3zCYjJFNM=
 github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU=
+github.com/caarlos0/env/v11 v11.2.2/go.mod h1:JBfcdeQiBoI3Zh1QRAWfe+tpiNTmDtcCj/hHHHMx0vc=
 github.com/caarlos0/env/v9 v9.0.0 h1:SI6JNsOA+y5gj9njpgybykATIylrRMklbs5ch6wO6pc=
 github.com/caarlos0/env/v9 v9.0.0/go.mod h1:ye5mlCVMYh6tZ+vCgrs/B95sj88cg5Tlnc0XIzgZ020=
 github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
@@ -140,6 +153,8 @@ github.com/disintegration/imaging v1.6.2 h1:w1LecBlG2Lnp8B3jk5zSuNqd7b4DXhcjwek1
 github.com/disintegration/imaging v1.6.2/go.mod h1:44/5580QXChDfwIclfc/PCwrr44amcmDAg8hxG0Ewe4=
 github.com/dlclark/regexp2 v1.11.2 h1:/u628IuisSTwri5/UKloiIsH8+qF2Pu7xEQX+yIKg68=
 github.com/dlclark/regexp2 v1.11.2/go.mod h1:DHkYz0B9wPfa6wondMfaivmHpzrQ3v9q8cnmRbL6yW8=
+github.com/dlclark/regexp2 v1.11.4 h1:rPYF9/LECdNymJufQKmri9gV604RvvABwgOA8un7yAo=
+github.com/dlclark/regexp2 v1.11.4/go.mod h1:DHkYz0B9wPfa6wondMfaivmHpzrQ3v9q8cnmRbL6yW8=
 github.com/dustinxie/ecc v0.0.0-20210511000915-959544187564 h1:I6KUy4CI6hHjqnyJLNCEi7YHVMkwwtfSr2k9splgdSM=
 github.com/dustinxie/ecc v0.0.0-20210511000915-959544187564/go.mod h1:yekO+3ZShy19S+bsmnERmznGy9Rfg6dWWWpiGJjNAz8=
 github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f h1:Y/CXytFA4m6baUTXGLOoWe4PQhGxaX0KpnayAqC48p4=
@@ -304,8 +319,10 @@ github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
-github.com/larksuite/oapi-sdk-go/v3 v3.2.8 h1:elbufnS+gQVOkzX9JLkS/N9u3ay/IAIE17nE4kNoYZ4=
-github.com/larksuite/oapi-sdk-go/v3 v3.2.8/go.mod h1:ZEplY+kwuIrj/nqw5uSCINNATcH3KdxSN7y+UxYY5fI=
+github.com/larksuite/oapi-sdk-go/v3 v3.3.0 h1:aCtFUiYgoRUW+aaWzVYw8jSzMe4A71rPEIn1DyHcNrY=
+github.com/larksuite/oapi-sdk-go/v3 v3.3.0/go.mod h1:ZEplY+kwuIrj/nqw5uSCINNATcH3KdxSN7y+UxYY5fI=
+github.com/larksuite/oapi-sdk-go/v3 v3.3.1 h1:DLQQEgHUAGZB6RVlceB1f6A94O206exxW2RIMH+gMUc=
+github.com/larksuite/oapi-sdk-go/v3 v3.3.1/go.mod h1:ZEplY+kwuIrj/nqw5uSCINNATcH3KdxSN7y+UxYY5fI=
 github.com/leodido/go-urn v1.2.1/go.mod h1:zt4jvISO2HfUBqxjfIshjdMTYS56ZS/qv49ictyFfxY=
 github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
 github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
@@ -506,6 +523,8 @@ github.com/xhofe/gsync v0.0.0-20230917091818-2111ceb38a25 h1:eDfebW/yfq9DtG9RO3K
 github.com/xhofe/gsync v0.0.0-20230917091818-2111ceb38a25/go.mod h1:fH4oNm5F9NfI5dLi0oIMtsLNKQOirUDbEMCIBb/7SU0=
 github.com/xhofe/tache v0.1.1 h1:O5QY4cVjIGELx3UGh6LbVAc18MWGXgRNQjMt72x6w/8=
 github.com/xhofe/tache v0.1.1/go.mod h1:iKumPFvywf30FRpAHHCt64G0JHLMzT0K+wyGedHsmTQ=
+github.com/xhofe/tache v0.1.2 h1:pHrXlrWcbTb4G7hVUDW7Rc+YTUnLJvnLBrdktVE1Fqg=
+github.com/xhofe/tache v0.1.2/go.mod h1:iKumPFvywf30FRpAHHCt64G0JHLMzT0K+wyGedHsmTQ=
 github.com/xhofe/wopan-sdk-go v0.1.3 h1:J58X6v+n25ewBZjb05pKOr7AWGohb+Rdll4CThGh6+A=
 github.com/xhofe/wopan-sdk-go v0.1.3/go.mod h1:dcY9yA28fnaoZPnXZiVTFSkcd7GnIPTpTIIlfSI5z5Q=
 github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e h1:JVG44RsyaB9T2KIHavMF/ppJZNG9ZpyihvCd0w101no=
@@ -548,8 +567,12 @@ golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDf
 golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8=
 golang.org/x/crypto v0.25.0 h1:ypSNr+bnYL2YhwoMt2zPxHFmbAN1KZs/njMG3hxUp30=
 golang.org/x/crypto v0.25.0/go.mod h1:T+wALwcMOSE0kXgUAnPAHqTLW+XHgcELELW8VaDgm/M=
-golang.org/x/exp v0.0.0-20240707233637-46b078467d37 h1:uLDX+AfeFCct3a2C7uIWBKMJIR3CJMhcgfrUAqjRK6w=
-golang.org/x/exp v0.0.0-20240707233637-46b078467d37/go.mod h1:M4RDyNAINzryxdtnbRXRL/OHtkFuWGRjvuhBJpk2IlY=
+golang.org/x/crypto v0.26.0 h1:RrRspgV4mU+YwB4FYnuBoKsUapNIL5cohGAmSH3azsw=
+golang.org/x/crypto v0.26.0/go.mod h1:GY7jblb9wI+FOo5y8/S2oY4zWP07AkOJ4+jxCqdqn54=
+golang.org/x/exp v0.0.0-20240719175910-8a7402abbf56 h1:2dVuKD2vS7b0QIHQbpyTISPd0LeHDbnYEryqj5Q1ug8=
+golang.org/x/exp v0.0.0-20240719175910-8a7402abbf56/go.mod h1:M4RDyNAINzryxdtnbRXRL/OHtkFuWGRjvuhBJpk2IlY=
+golang.org/x/exp v0.0.0-20240808152545-0cdaa3abc0fa h1:ELnwvuAXPNtPk1TJRuGkI9fDTwym6AYBu0qzT8AcHdI=
+golang.org/x/exp v0.0.0-20240808152545-0cdaa3abc0fa/go.mod h1:akd2r19cwCdwSwWeIdzYQGa/EZZyqcOdwWiwj5L5eKQ=
 golang.org/x/image v0.0.0-20191009234506-e7c1f5e7dbb8/go.mod h1:FeLwcggjj3mMvU+oOTbSwawSJRM1uh48EjtB4UJZlP0=
 golang.org/x/image v0.18.0 h1:jGzIakQa/ZXI1I0Fxvaa9W7yP25TqT6cHIHn+6CqvSQ=
 golang.org/x/image v0.18.0/go.mod h1:4yyo5vMFQjVjUcVk4jEQcU9MGy/rulF5WvUILseCM2E=
@@ -574,8 +597,12 @@ golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44=
 golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM=
 golang.org/x/net v0.27.0 h1:5K3Njcw06/l2y9vpGCSdcxWOYHOUk3dVNGDXN+FvAys=
 golang.org/x/net v0.27.0/go.mod h1:dDi0PyhWNoiUOrAS8uXv/vnScO4wnHQO4mj9fn/RytE=
+golang.org/x/net v0.28.0 h1:a9JDOJc5GMUJ0+UDqmLT86WiEy7iWyIhz8gz8E4e5hE=
+golang.org/x/net v0.28.0/go.mod h1:yqtgsTWOOnlGLG9GFRrK3++bGOUEkNBoHZc8MEDWPNg=
 golang.org/x/oauth2 v0.21.0 h1:tsimM75w1tF/uws5rbeHzIWxEqElMehnc+iW793zsZs=
 golang.org/x/oauth2 v0.21.0/go.mod h1:XYTD2NtWslqkgxebSiOHnXEap4TF09sJSc7H1sXbhtI=
+golang.org/x/oauth2 v0.22.0 h1:BzDx2FehcG7jJwgWLELCdmLuxk2i+x9UDpSiss2u0ZA=
+golang.org/x/oauth2 v0.22.0/go.mod h1:XYTD2NtWslqkgxebSiOHnXEap4TF09sJSc7H1sXbhtI=
 golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
@@ -583,6 +610,8 @@ golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJ
 golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.7.0 h1:YsImfSBoP9QPYL0xyKJPq0gcaJdG3rInoqxTWbfQu9M=
 golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sync v0.8.0 h1:3NFvSEYkUoMifnESzZl15y791HH1qU2xm6eCJU5ZPXQ=
+golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20190916202348-b4ddaad3f8a3/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -614,6 +643,8 @@ golang.org/x/sys v0.19.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/sys v0.22.0 h1:RI27ohtqKCnwULzJLqkv897zojh5/DwS/ENaMzUOaWI=
 golang.org/x/sys v0.22.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.23.0 h1:YfKFowiIMvtgl1UERQoTPPToxltDeZfbj4H7dVUCwmM=
+golang.org/x/sys v0.23.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
 golang.org/x/term v0.1.0/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
@@ -623,6 +654,8 @@ golang.org/x/term v0.17.0/go.mod h1:lLRBjIVuehSbZlaOtGMbcMncT+aqLLLmKrsjNrUguwk=
 golang.org/x/term v0.20.0/go.mod h1:8UkIAJTvZgivsXaD6/pH6U9ecQzZ45awqEOzuCvwpFY=
 golang.org/x/term v0.22.0 h1:BbsgPEJULsl2fV/AT3v15Mjva5yXKQDyKf+TbDz7QJk=
 golang.org/x/term v0.22.0/go.mod h1:F3qCibpT5AMpCRfhfT53vVJwhLtIVHhB9XDjfFvnMI4=
+golang.org/x/term v0.23.0 h1:F6D4vR+EHoL9/sWAWgAR1H2DcHr4PareCbAaCo1RpuU=
+golang.org/x/term v0.23.0/go.mod h1:DgV24QBUrK6jhZXl+20l6UWznPlwAHm1Q1mGHtydmSk=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
 golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
@@ -636,10 +669,14 @@ golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
 golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
 golang.org/x/text v0.16.0 h1:a94ExnEXNtEwYLGJSIUxnWoxoRz/ZcCsV63ROupILh4=
 golang.org/x/text v0.16.0/go.mod h1:GhwF1Be+LQoKShO3cGOHzqOgRrGaYc9AvblQOmPVHnI=
+golang.org/x/text v0.17.0 h1:XtiM5bkSOt+ewxlOE/aE/AKEHibwj/6gvWMl9Rsh0Qc=
+golang.org/x/text v0.17.0/go.mod h1:BuEKDfySbSR4drPmRPG/7iBdf8hvFMuRexcpahXilzY=
 golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 golang.org/x/time v0.0.0-20220722155302-e5dcc9cfc0b9/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 golang.org/x/time v0.5.0 h1:o7cqy6amK/52YcAKIPlM3a+Fpj35zvRj2TP+e1xFSfk=
 golang.org/x/time v0.5.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM=
+golang.org/x/time v0.6.0 h1:eTDhh4ZXt5Qf0augr54TN6suAUudPcawVZeIAPU7D4U=
+golang.org/x/time v0.6.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20181030221726-6c7e314b6563/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190829051458-42f498d34c4d/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
@@ -650,6 +687,8 @@ golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc
 golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU=
 golang.org/x/tools v0.23.0 h1:SGsXPZ+2l4JsgaCKkx+FQ9YZ5XEtA1GZYuoDjenLjvg=
 golang.org/x/tools v0.23.0/go.mod h1:pnu6ufv6vQkll6szChhK3C3L/ruaIv5eBeztNG8wtsI=
+golang.org/x/tools v0.24.0 h1:J1shsA93PJUEVaUSaay7UXAyE8aimq3GW0pjlolpa24=
+golang.org/x/tools v0.24.0/go.mod h1:YhNqVBIfWHdzvTLs0d8LCuMhkKUgSUKldakyV7W/WDQ=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=

internal/bootstrap/config.go

@@ -68,11 +68,7 @@ func InitConfig() {
 		}
 		conf.Conf.TempDir = absPath
 	}
-	err := os.RemoveAll(filepath.Join(conf.Conf.TempDir))
-	if err != nil {
-		log.Errorln("failed delete temp file:", err)
-	}
-	err = os.MkdirAll(conf.Conf.TempDir, 0o777)
+	err := os.MkdirAll(conf.Conf.TempDir, 0o777)
 	if err != nil {
 		log.Fatalf("create temp dir error: %+v", err)
 	}
@@ -104,3 +100,9 @@ func initURL() {
 	}
 	conf.URL = u
 }
+
+func CleanTempDir() {
+	if err := os.RemoveAll(conf.Conf.TempDir); err != nil {
+		log.Errorln("failed delete temp file: ", err)
+	}
+}

internal/bootstrap/data/data.go

@@ -5,6 +5,7 @@ import "github.com/alist-org/alist/v3/cmd/flags"
 func InitData() {
 	initUser()
 	initSettings()
+	initTasks()
 	if flags.Dev {
 		initDevData()
 		initDevDo()

internal/bootstrap/data/setting.go

@@ -34,6 +34,7 @@ func initSettings() {
 	// create or save setting
 	for i := range initialSettingItems {
 		item := &initialSettingItems[i]
+		item.Index = uint(i)
 		if item.PreDefault == "" {
 			item.PreDefault = item.Value
 		}

internal/bootstrap/data/task.go

@@ -0,0 +1,29 @@
+package data
+
+import (
+	"github.com/alist-org/alist/v3/internal/db"
+	"github.com/alist-org/alist/v3/internal/model"
+)
+
+var initialTaskItems []model.TaskItem
+
+func initTasks() {
+	InitialTasks()
+
+	for i := range initialTaskItems {
+		item := &initialTaskItems[i]
+		taskitem, _ := db.GetTaskDataByType(item.Key)
+		if taskitem == nil {
+			db.CreateTaskData(item)
+		}
+	}
+}
+
+func InitialTasks() []model.TaskItem {
+	initialTaskItems = []model.TaskItem{
+		{Key: "copy", PersistData: "[]"},
+		{Key: "download", PersistData: "[]"},
+		{Key: "transfer", PersistData: "[]"},
+	}
+	return initialTaskItems
+}

internal/bootstrap/task.go

@@ -2,14 +2,18 @@ package bootstrap
 
 import (
 	"github.com/alist-org/alist/v3/internal/conf"
+	"github.com/alist-org/alist/v3/internal/db"
 	"github.com/alist-org/alist/v3/internal/fs"
 	"github.com/alist-org/alist/v3/internal/offline_download/tool"
 	"github.com/xhofe/tache"
 )
 
 func InitTaskManager() {
-	fs.UploadTaskManager = tache.NewManager[*fs.UploadTask](tache.WithWorks(conf.Conf.Tasks.Upload.Workers), tache.WithMaxRetry(conf.Conf.Tasks.Upload.MaxRetry))
-	fs.CopyTaskManager = tache.NewManager[*fs.CopyTask](tache.WithWorks(conf.Conf.Tasks.Copy.Workers), tache.WithMaxRetry(conf.Conf.Tasks.Copy.MaxRetry))
-	tool.DownloadTaskManager = tache.NewManager[*tool.DownloadTask](tache.WithWorks(conf.Conf.Tasks.Download.Workers), tache.WithMaxRetry(conf.Conf.Tasks.Download.MaxRetry))
-	tool.TransferTaskManager = tache.NewManager[*tool.TransferTask](tache.WithWorks(conf.Conf.Tasks.Transfer.Workers), tache.WithMaxRetry(conf.Conf.Tasks.Transfer.MaxRetry))
+	fs.UploadTaskManager = tache.NewManager[*fs.UploadTask](tache.WithWorks(conf.Conf.Tasks.Upload.Workers), tache.WithMaxRetry(conf.Conf.Tasks.Upload.MaxRetry)) //upload will not support persist
+	fs.CopyTaskManager = tache.NewManager[*fs.CopyTask](tache.WithWorks(conf.Conf.Tasks.Copy.Workers), tache.WithPersistFunction(db.GetTaskDataFunc("copy", conf.Conf.Tasks.Copy.TaskPersistant), db.UpdateTaskDataFunc("copy", conf.Conf.Tasks.Copy.TaskPersistant)), tache.WithMaxRetry(conf.Conf.Tasks.Copy.MaxRetry))
+	tool.DownloadTaskManager = tache.NewManager[*tool.DownloadTask](tache.WithWorks(conf.Conf.Tasks.Download.Workers), tache.WithPersistFunction(db.GetTaskDataFunc("download", conf.Conf.Tasks.Download.TaskPersistant), db.UpdateTaskDataFunc("download", conf.Conf.Tasks.Download.TaskPersistant)), tache.WithMaxRetry(conf.Conf.Tasks.Download.MaxRetry))
+	tool.TransferTaskManager = tache.NewManager[*tool.TransferTask](tache.WithWorks(conf.Conf.Tasks.Transfer.Workers), tache.WithPersistFunction(db.GetTaskDataFunc("transfer", conf.Conf.Tasks.Transfer.TaskPersistant), db.UpdateTaskDataFunc("transfer", conf.Conf.Tasks.Transfer.TaskPersistant)), tache.WithMaxRetry(conf.Conf.Tasks.Transfer.MaxRetry))
+	if len(tool.TransferTaskManager.GetAll()) == 0 { //prevent offline downloaded files from being deleted
+		CleanTempDir()
+	}
 }

internal/conf/config.go

@@ -47,8 +47,9 @@ type LogConfig struct {
 }
 
 type TaskConfig struct {
-	Workers  int `json:"workers" env:"WORKERS"`
-	MaxRetry int `json:"max_retry" env:"MAX_RETRY"`
+	Workers        int  `json:"workers" env:"WORKERS"`
+	MaxRetry       int  `json:"max_retry" env:"MAX_RETRY"`
+	TaskPersistant bool `json:"task_persistant" env:"TASK_PERSISTANT"`
 }
 
 type TasksConfig struct {
@@ -130,19 +131,22 @@ func DefaultConfig() *Config {
 		TlsInsecureSkipVerify: true,
 		Tasks: TasksConfig{
 			Download: TaskConfig{
-				Workers:  5,
-				MaxRetry: 1,
+				Workers:        5,
+				MaxRetry:       1,
+				TaskPersistant: true,
 			},
 			Transfer: TaskConfig{
-				Workers:  5,
-				MaxRetry: 2,
+				Workers:        5,
+				MaxRetry:       2,
+				TaskPersistant: true,
 			},
 			Upload: TaskConfig{
 				Workers: 5,
 			},
 			Copy: TaskConfig{
-				Workers:  5,
-				MaxRetry: 2,
+				Workers:        5,
+				MaxRetry:       2,
+				TaskPersistant: true,
 			},
 		},
 		Cors: Cors{

internal/db/db.go

@@ -12,7 +12,7 @@ var db *gorm.DB
 
 func Init(d *gorm.DB) {
 	db = d
-	err := AutoMigrate(new(model.Storage), new(model.User), new(model.Meta), new(model.SettingItem), new(model.SearchNode))
+	err := AutoMigrate(new(model.Storage), new(model.User), new(model.Meta), new(model.SettingItem), new(model.SearchNode), new(model.TaskItem))
 	if err != nil {
 		log.Fatalf("failed migrate database: %s", err.Error())
 	}

internal/db/meta.go

@@ -34,7 +34,7 @@ func GetMetas(pageIndex, pageSize int) (metas []model.Meta, count int64, err err
 	if err = metaDB.Count(&count).Error; err != nil {
 		return nil, 0, errors.Wrapf(err, "failed get metas count")
 	}
-	if err = metaDB.Offset((pageIndex - 1) * pageSize).Limit(pageSize).Find(&metas).Error; err != nil {
+	if err = metaDB.Order(columnName("id")).Offset((pageIndex - 1) * pageSize).Limit(pageSize).Find(&metas).Error; err != nil {
 		return nil, 0, errors.Wrapf(err, "failed get find metas")
 	}
 	return metas, count, nil

internal/db/settingitem.go

@@ -49,7 +49,8 @@ func GetSettingItemsByGroup(group int) ([]model.SettingItem, error) {
 
 func GetSettingItemsInGroups(groups []int) ([]model.SettingItem, error) {
 	var settingItems []model.SettingItem
-	if err := db.Where(fmt.Sprintf("%s in ?", columnName("group")), groups).Find(&settingItems).Error; err != nil {
+	err := db.Order(columnName("index")).Where(fmt.Sprintf("%s in ?", columnName("group")), groups).Find(&settingItems).Error
+	if err != nil {
 		return nil, errors.WithStack(err)
 	}
 	return settingItems, nil

internal/db/storage.go

@@ -2,7 +2,6 @@ package db
 
 import (
 	"fmt"
-	"sort"
 
 	"github.com/alist-org/alist/v3/internal/model"
 	"github.com/pkg/errors"
@@ -36,7 +35,7 @@ func GetStorages(pageIndex, pageSize int) ([]model.Storage, int64, error) {
 		return nil, 0, errors.Wrapf(err, "failed get storages count")
 	}
 	var storages []model.Storage
-	if err := storageDB.Order(columnName("order")).Offset((pageIndex - 1) * pageSize).Limit(pageSize).Find(&storages).Error; err != nil {
+	if err := addStorageOrder(storageDB).Order(columnName("order")).Offset((pageIndex - 1) * pageSize).Limit(pageSize).Find(&storages).Error; err != nil {
 		return nil, 0, errors.WithStack(err)
 	}
 	return storages, count, nil
@@ -63,11 +62,9 @@ func GetStorageByMountPath(mountPath string) (*model.Storage, error) {
 
 func GetEnabledStorages() ([]model.Storage, error) {
 	var storages []model.Storage
-	if err := db.Where(fmt.Sprintf("%s = ?", columnName("disabled")), false).Find(&storages).Error; err != nil {
+	err := addStorageOrder(db).Where(fmt.Sprintf("%s = ?", columnName("disabled")), false).Find(&storages).Error
+	if err != nil {
 		return nil, errors.WithStack(err)
 	}
-	sort.Slice(storages, func(i, j int) bool {
-		return storages[i].Order < storages[j].Order
-	})
 	return storages, nil
 }

internal/db/tasks.go

@@ -0,0 +1,48 @@
+package db
+
+import (
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/pkg/errors"
+)
+
+func GetTaskDataByType(type_s string) (*model.TaskItem, error) {
+	task := model.TaskItem{Key: type_s}
+	if err := db.Where(task).First(&task).Error; err != nil {
+		return nil, errors.Wrapf(err, "failed find task")
+	}
+	return &task, nil
+}
+
+func UpdateTaskData(t *model.TaskItem) error {
+	return errors.WithStack(db.Model(&model.TaskItem{}).Where("key = ?", t.Key).Update("persist_data", t.PersistData).Error)
+}
+
+func CreateTaskData(t *model.TaskItem) error {
+	return errors.WithStack(db.Create(t).Error)
+}
+
+func GetTaskDataFunc(type_s string, enabled bool) func() ([]byte, error) {
+	if !enabled {
+		return nil
+	}
+	task, err := GetTaskDataByType(type_s)
+	if err != nil {
+		return nil
+	}
+	return func() ([]byte, error) {
+		return []byte(task.PersistData), nil
+	}
+}
+
+func UpdateTaskDataFunc(type_s string, enabled bool) func([]byte) error {
+	if !enabled {
+		return nil
+	}
+	return func(data []byte) error {
+		s := string(data)
+		if s == "null" || s == "" {
+			s = "[]"
+		}
+		return UpdateTaskData(&model.TaskItem{Key: type_s, PersistData: s})
+	}
+}

internal/db/user.go

@@ -54,7 +54,7 @@ func GetUsers(pageIndex, pageSize int) (users []model.User, count int64, err err
 	if err := userDB.Count(&count).Error; err != nil {
 		return nil, 0, errors.Wrapf(err, "failed get users count")
 	}
-	if err := userDB.Offset((pageIndex - 1) * pageSize).Limit(pageSize).Find(&users).Error; err != nil {
+	if err := userDB.Order(columnName("id")).Offset((pageIndex - 1) * pageSize).Limit(pageSize).Find(&users).Error; err != nil {
 		return nil, 0, errors.Wrapf(err, "failed get find users")
 	}
 	return users, count, nil

internal/db/util.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 
 	"github.com/alist-org/alist/v3/internal/conf"
+	"gorm.io/gorm"
 )
 
 func columnName(name string) string {
@@ -12,3 +13,7 @@ func columnName(name string) string {
 	}
 	return fmt.Sprintf("`%s`", name)
 }
+
+func addStorageOrder(db *gorm.DB) *gorm.DB {
+	return db.Order(fmt.Sprintf("%s, %s", columnName("order"), columnName("id")))
+}

internal/fs/copy.go

@@ -3,6 +3,9 @@ package fs
 import (
 	"context"
 	"fmt"
+	"net/http"
+	stdpath "path"
+
 	"github.com/alist-org/alist/v3/internal/conf"
 	"github.com/alist-org/alist/v3/internal/driver"
 	"github.com/alist-org/alist/v3/internal/model"
@@ -11,20 +14,21 @@ import (
 	"github.com/alist-org/alist/v3/pkg/utils"
 	"github.com/pkg/errors"
 	"github.com/xhofe/tache"
-	"net/http"
-	stdpath "path"
 )
 
 type CopyTask struct {
 	tache.Base
-	Status                 string `json:"status"`
-	srcStorage, dstStorage driver.Driver
-	srcObjPath, dstDirPath string
+	Status       string        `json:"-"` //don't save status to save space
+	SrcObjPath   string        `json:"src_path"`
+	DstDirPath   string        `json:"dst_path"`
+	srcStorage   driver.Driver `json:"-"`
+	dstStorage   driver.Driver `json:"-"`
+	SrcStorageMp string        `json:"src_storage_mp"`
+	DstStorageMp string        `json:"dst_storage_mp"`
 }
 
 func (t *CopyTask) GetName() string {
-	return fmt.Sprintf("copy [%s](%s) to [%s](%s)",
-		t.srcStorage.GetStorage().MountPath, t.srcObjPath, t.dstStorage.GetStorage().MountPath, t.dstDirPath)
+	return fmt.Sprintf("copy [%s](%s) to [%s](%s)", t.SrcStorageMp, t.SrcObjPath, t.DstStorageMp, t.DstDirPath)
 }
 
 func (t *CopyTask) GetStatus() string {
@@ -32,7 +36,17 @@ func (t *CopyTask) GetStatus() string {
 }
 
 func (t *CopyTask) Run() error {
-	return copyBetween2Storages(t, t.srcStorage, t.dstStorage, t.srcObjPath, t.dstDirPath)
+	var err error
+	if t.srcStorage == nil {
+		t.srcStorage, err = op.GetStorageByMountPath(t.SrcStorageMp)
+	}
+	if t.dstStorage == nil {
+		t.dstStorage, err = op.GetStorageByMountPath(t.DstStorageMp)
+	}
+	if err != nil {
+		return errors.WithMessage(err, "failed get storage")
+	}
+	return copyBetween2Storages(t, t.srcStorage, t.dstStorage, t.SrcObjPath, t.DstDirPath)
 }
 
 var CopyTaskManager *tache.Manager[*CopyTask]
@@ -79,10 +93,12 @@ func _copy(ctx context.Context, srcObjPath, dstDirPath string, lazyCache ...bool
 	}
 	// not in the same storage
 	t := &CopyTask{
-		srcStorage: srcStorage,
-		dstStorage: dstStorage,
-		srcObjPath: srcObjActualPath,
-		dstDirPath: dstDirActualPath,
+		srcStorage:   srcStorage,
+		dstStorage:   dstStorage,
+		SrcObjPath:   srcObjActualPath,
+		DstDirPath:   dstDirActualPath,
+		SrcStorageMp: srcStorage.GetStorage().MountPath,
+		DstStorageMp: dstStorage.GetStorage().MountPath,
 	}
 	CopyTaskManager.Add(t)
 	return t, nil
@@ -107,10 +123,12 @@ func copyBetween2Storages(t *CopyTask, srcStorage, dstStorage driver.Driver, src
 			srcObjPath := stdpath.Join(srcObjPath, obj.GetName())
 			dstObjPath := stdpath.Join(dstDirPath, srcObj.GetName())
 			CopyTaskManager.Add(&CopyTask{
-				srcStorage: srcStorage,
-				dstStorage: dstStorage,
-				srcObjPath: srcObjPath,
-				dstDirPath: dstObjPath,
+				srcStorage:   srcStorage,
+				dstStorage:   dstStorage,
+				SrcObjPath:   srcObjPath,
+				DstDirPath:   dstObjPath,
+				SrcStorageMp: srcStorage.GetStorage().MountPath,
+				DstStorageMp: dstStorage.GetStorage().MountPath,
 			})
 		}
 		t.Status = "src object is dir, added all copy tasks of objs"

internal/model/setting.go

@@ -29,6 +29,7 @@ type SettingItem struct {
 	Options    string `json:"options"`                                  // values for select
 	Group      int    `json:"group"`                                    // use to group setting in frontend
 	Flag       int    `json:"flag"`                                     // 0 = public, 1 = private, 2 = readonly, 3 = deprecated, etc.
+	Index      uint   `json:"index"`
 }
 
 func (s SettingItem) IsDeprecated() bool {

internal/model/task.go

@@ -0,0 +1,6 @@
+package model
+
+type TaskItem struct {
+	Key         string `json:"key"`
+	PersistData string `gorm:"type:text" json:"persist_data"`
+}

internal/offline_download/115/client.go

@@ -0,0 +1,124 @@
+package _115
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/alist-org/alist/v3/drivers/115"
+	"github.com/alist-org/alist/v3/internal/errs"
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/internal/offline_download/tool"
+	"github.com/alist-org/alist/v3/internal/op"
+)
+
+type Cloud115 struct {
+	refreshTaskCache bool
+}
+
+func (p *Cloud115) Name() string {
+	return "115 Cloud"
+}
+
+func (p *Cloud115) Items() []model.SettingItem {
+	return nil
+}
+
+func (p *Cloud115) Run(task *tool.DownloadTask) error {
+	return errs.NotSupport
+}
+
+func (p *Cloud115) Init() (string, error) {
+	p.refreshTaskCache = false
+	return "ok", nil
+}
+
+func (p *Cloud115) IsReady() bool {
+	return true
+}
+
+func (p *Cloud115) AddURL(args *tool.AddUrlArgs) (string, error) {
+	// 添加新任务刷新缓存
+	p.refreshTaskCache = true
+	// args.TempDir 已经被修改为了 DstDirPath
+	storage, actualPath, err := op.GetStorageAndActualPath(args.TempDir)
+	if err != nil {
+		return "", err
+	}
+	driver115, ok := storage.(*_115.Pan115)
+	if !ok {
+		return "", fmt.Errorf("unsupported storage driver for offline download, only 115 Cloud is supported")
+	}
+
+	ctx := context.Background()
+	parentDir, err := op.GetUnwrap(ctx, storage, actualPath)
+	if err != nil {
+		return "", err
+	}
+
+	hashs, err := driver115.OfflineDownload(ctx, []string{args.Url}, parentDir)
+	if err != nil || len(hashs) < 1 {
+		return "", fmt.Errorf("failed to add offline download task: %w", err)
+	}
+
+	return hashs[0], nil
+}
+
+func (p *Cloud115) Remove(task *tool.DownloadTask) error {
+	storage, _, err := op.GetStorageAndActualPath(task.DstDirPath)
+	if err != nil {
+		return err
+	}
+	driver115, ok := storage.(*_115.Pan115)
+	if !ok {
+		return fmt.Errorf("unsupported storage driver for offline download, only 115 Cloud is supported")
+	}
+
+	ctx := context.Background()
+	if err := driver115.DeleteOfflineTasks(ctx, []string{task.GID}, false); err != nil {
+		return err
+	}
+	return nil
+}
+
+func (p *Cloud115) Status(task *tool.DownloadTask) (*tool.Status, error) {
+	storage, _, err := op.GetStorageAndActualPath(task.DstDirPath)
+	if err != nil {
+		return nil, err
+	}
+	driver115, ok := storage.(*_115.Pan115)
+	if !ok {
+		return nil, fmt.Errorf("unsupported storage driver for offline download, only 115 Cloud is supported")
+	}
+
+	tasks, err := driver115.OfflineList(context.Background())
+	if err != nil {
+		return nil, err
+	}
+
+	s := &tool.Status{
+		Progress:  0,
+		NewGID:    "",
+		Completed: false,
+		Status:    "the task has been deleted",
+		Err:       nil,
+	}
+	for _, t := range tasks {
+		if t.InfoHash == task.GID {
+			s.Progress = t.Percent
+			s.Status = t.GetStatus()
+			s.Completed = t.IsDone()
+			if t.IsFailed() {
+				s.Err = fmt.Errorf(t.GetStatus())
+			}
+			return s, nil
+		}
+	}
+	s.Err = fmt.Errorf("the task has been deleted")
+	return nil, nil
+}
+
+var _ tool.Tool = (*Cloud115)(nil)
+
+func init() {
+	tool.Tools.Add(&Cloud115{})
+}

internal/offline_download/all.go

@@ -1,6 +1,7 @@
 package offline_download
 
 import (
+	_ "github.com/alist-org/alist/v3/internal/offline_download/115"
 	_ "github.com/alist-org/alist/v3/internal/offline_download/aria2"
 	_ "github.com/alist-org/alist/v3/internal/offline_download/http"
 	_ "github.com/alist-org/alist/v3/internal/offline_download/pikpak"

internal/offline_download/tool/add.go

@@ -66,16 +66,24 @@ func AddURL(ctx context.Context, args *AddURLArgs) (tache.TaskWithInfo, error) {
 	uid := uuid.NewString()
 	tempDir := filepath.Join(conf.Conf.TempDir, args.Tool, uid)
 	deletePolicy := args.DeletePolicy
-	if args.Tool == "pikpak" {
+
+	switch args.Tool {
+	case "115 Cloud":
+		tempDir = args.DstDirPath
+		// 防止将下载好的文件删除
+		deletePolicy = DeleteNever
+	case "pikpak":
 		tempDir = args.DstDirPath
 		// 防止将下载好的文件删除
 		deletePolicy = DeleteNever
 	}
+	
 	t := &DownloadTask{
 		Url:          args.URL,
 		DstDirPath:   args.DstDirPath,
 		TempDir:      tempDir,
 		DeletePolicy: deletePolicy,
+		Toolname:     args.Tool,
 		tool:         tool,
 	}
 	DownloadTaskManager.Add(t)

internal/offline_download/tool/download.go

@@ -14,19 +14,26 @@ import (
 
 type DownloadTask struct {
 	tache.Base
-	Url          string       `json:"url"`
-	DstDirPath   string       `json:"dst_dir_path"`
-	TempDir      string       `json:"temp_dir"`
-	DeletePolicy DeletePolicy `json:"delete_policy"`
-
-	Status            string   `json:"status"`
-	Signal            chan int `json:"-"`
-	GID               string   `json:"-"`
+	Url               string       `json:"url"`
+	DstDirPath        string       `json:"dst_dir_path"`
+	TempDir           string       `json:"temp_dir"`
+	DeletePolicy      DeletePolicy `json:"delete_policy"`
+	Toolname          string       `json:"toolname"`
+	Status            string       `json:"-"`
+	Signal            chan int     `json:"-"`
+	GID               string       `json:"-"`
 	tool              Tool
 	callStatusRetried int
 }
 
 func (t *DownloadTask) Run() error {
+	if t.tool == nil {
+		tool, err := Tools.Get(t.Toolname)
+		if err != nil {
+			return errors.WithMessage(err, "failed get tool")
+		}
+		t.tool = tool
+	}
 	if err := t.tool.Run(t); !errs.IsNotSupportError(err) {
 		if err == nil {
 			return t.Complete()
@@ -47,9 +54,7 @@ func (t *DownloadTask) Run() error {
 		return err
 	}
 	t.GID = gid
-	var (
-		ok bool
-	)
+	var ok bool
 outer:
 	for {
 		select {
@@ -74,6 +79,15 @@ outer:
 	if t.tool.Name() == "pikpak" {
 		return nil
 	}
+	if t.tool.Name() == "115 Cloud" {
+		// hack for 115
+		<-time.After(time.Second * 1)
+		err := t.tool.Remove(t)
+		if err != nil {
+			log.Errorln(err.Error())
+		}
+		return nil
+	}
 	t.Status = "offline download completed, maybe transferring"
 	// hack for qBittorrent
 	if t.tool.Name() == "qBittorrent" {
@@ -129,6 +143,9 @@ func (t *DownloadTask) Complete() error {
 	if t.tool.Name() == "pikpak" {
 		return nil
 	}
+	if t.tool.Name() == "115 Cloud" {
+		return nil
+	}
 	if getFileser, ok := t.tool.(GetFileser); ok {
 		files = getFileser.GetFiles(t)
 	} else {
@@ -142,9 +159,10 @@ func (t *DownloadTask) Complete() error {
 		file := files[i]
 		TransferTaskManager.Add(&TransferTask{
 			file:         file,
-			dstDirPath:   t.DstDirPath,
-			tempDir:      t.TempDir,
-			deletePolicy: t.DeletePolicy,
+			DstDirPath:   t.DstDirPath,
+			TempDir:      t.TempDir,
+			DeletePolicy: t.DeletePolicy,
+			FileDir:      file.Path,
 		})
 	}
 	return nil
@@ -158,6 +176,4 @@ func (t *DownloadTask) GetStatus() string {
 	return t.Status
 }
 
-var (
-	DownloadTaskManager *tache.Manager[*DownloadTask]
-)
+var DownloadTaskManager *tache.Manager[*DownloadTask]

internal/offline_download/tool/transfer.go

@@ -2,6 +2,9 @@ package tool
 
 import (
 	"fmt"
+	"os"
+	"path/filepath"
+
 	"github.com/alist-org/alist/v3/internal/model"
 	"github.com/alist-org/alist/v3/internal/op"
 	"github.com/alist-org/alist/v3/internal/stream"
@@ -9,21 +12,27 @@ import (
 	"github.com/pkg/errors"
 	log "github.com/sirupsen/logrus"
 	"github.com/xhofe/tache"
-	"os"
-	"path/filepath"
 )
 
 type TransferTask struct {
 	tache.Base
+	FileDir      string       `json:"file_dir"`
+	DstDirPath   string       `json:"dst_dir_path"`
+	TempDir      string       `json:"temp_dir"`
+	DeletePolicy DeletePolicy `json:"delete_policy"`
 	file         File
-	dstDirPath   string
-	tempDir      string
-	deletePolicy DeletePolicy
 }
 
 func (t *TransferTask) Run() error {
 	// check dstDir again
-	storage, dstDirActualPath, err := op.GetStorageAndActualPath(t.dstDirPath)
+	var err error
+	if (t.file == File{}) {
+		t.file, err = GetFile(t.FileDir)
+		if err != nil {
+			return errors.Wrapf(err, "failed to get file %s", t.FileDir)
+		}
+	}
+	storage, dstDirActualPath, err := op.GetStorageAndActualPath(t.DstDirPath)
 	if err != nil {
 		return errors.WithMessage(err, "failed get storage")
 	}
@@ -44,7 +53,7 @@ func (t *TransferTask) Run() error {
 		Mimetype: mimetype,
 		Closers:  utils.NewClosers(rc),
 	}
-	relDir, err := filepath.Rel(t.tempDir, filepath.Dir(t.file.Path))
+	relDir, err := filepath.Rel(t.TempDir, filepath.Dir(t.file.Path))
 	if err != nil {
 		log.Errorf("find relation directory error: %v", err)
 	}
@@ -53,7 +62,7 @@ func (t *TransferTask) Run() error {
 }
 
 func (t *TransferTask) GetName() string {
-	return fmt.Sprintf("transfer %s to [%s]", t.file.Path, t.dstDirPath)
+	return fmt.Sprintf("transfer %s to [%s]", t.file.Path, t.DstDirPath)
 }
 
 func (t *TransferTask) GetStatus() string {
@@ -61,7 +70,7 @@ func (t *TransferTask) GetStatus() string {
 }
 
 func (t *TransferTask) OnSucceeded() {
-	if t.deletePolicy == DeleteOnUploadSucceed || t.deletePolicy == DeleteAlways {
+	if t.DeletePolicy == DeleteOnUploadSucceed || t.DeletePolicy == DeleteAlways {
 		err := os.Remove(t.file.Path)
 		if err != nil {
 			log.Errorf("failed to delete file %s, error: %s", t.file.Path, err.Error())
@@ -70,7 +79,7 @@ func (t *TransferTask) OnSucceeded() {
 }
 
 func (t *TransferTask) OnFailed() {
-	if t.deletePolicy == DeleteOnUploadFailed || t.deletePolicy == DeleteAlways {
+	if t.DeletePolicy == DeleteOnUploadFailed || t.DeletePolicy == DeleteAlways {
 		err := os.Remove(t.file.Path)
 		if err != nil {
 			log.Errorf("failed to delete file %s, error: %s", t.file.Path, err.Error())

internal/offline_download/tool/util.go

@@ -26,3 +26,16 @@ func GetFiles(dir string) ([]File, error) {
 	}
 	return files, nil
 }
+
+func GetFile(path string) (File, error) {
+	info, err := os.Stat(path)
+	if err != nil {
+		return File{}, err
+	}
+	return File{
+		Name:     info.Name(),
+		Size:     info.Size(),
+		Path:     path,
+		Modified: info.ModTime(),
+	}, nil
+}

internal/op/fs.go

@@ -466,6 +466,9 @@ func Remove(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)
 	}
+	if utils.PathEqual(path, "/") {
+		return errors.New("delete root folder is not allowed, please goto the manage page to delete the storage instead")
+	}
 	path = utils.FixAndCleanPath(path)
 	rawObj, err := Get(ctx, storage, path)
 	if err != nil {

server/common/auth.go

@@ -3,6 +3,7 @@ package common
 import (
 	"time"
 
+	"github.com/Xhofe/go-cache"
 	"github.com/alist-org/alist/v3/internal/conf"
 	"github.com/alist-org/alist/v3/internal/model"
 	"github.com/golang-jwt/jwt/v4"
@@ -17,6 +18,8 @@ type UserClaims struct {
 	jwt.RegisteredClaims
 }
 
+var validTokenCache = cache.NewMemCache[bool]()
+
 func GenerateToken(user *model.User) (tokenString string, err error) {
 	claim := UserClaims{
 		Username: user.Username,
@@ -28,6 +31,10 @@ func GenerateToken(user *model.User) (tokenString string, err error) {
 		}}
 	token := jwt.NewWithClaims(jwt.SigningMethodHS256, claim)
 	tokenString, err = token.SignedString(SecretKey)
+	if err != nil {
+		return "", err
+	}
+	validTokenCache.Set(tokenString, true)
 	return tokenString, err
 }
 
@@ -35,6 +42,9 @@ func ParseToken(tokenString string) (*UserClaims, error) {
 	token, err := jwt.ParseWithClaims(tokenString, &UserClaims{}, func(token *jwt.Token) (interface{}, error) {
 		return SecretKey, nil
 	})
+	if IsTokenInvalidated(tokenString) {
+		return nil, errors.New("token is invalidated")
+	}
 	if err != nil {
 		if ve, ok := err.(*jwt.ValidationError); ok {
 			if ve.Errors&jwt.ValidationErrorMalformed != 0 {
@@ -53,3 +63,16 @@ func ParseToken(tokenString string) (*UserClaims, error) {
 	}
 	return nil, errors.New("couldn't handle this token")
 }
+
+func InvalidateToken(tokenString string) error {
+	if tokenString == "" {
+		return nil // don't invalidate empty guest token
+	}
+	validTokenCache.Del(tokenString)
+	return nil
+}
+
+func IsTokenInvalidated(tokenString string) bool {
+	_, ok := validTokenCache.Get(tokenString)
+	return !ok
+}

server/handles/auth.go

@@ -181,3 +181,12 @@ func Verify2FA(c *gin.Context) {
 		common.SuccessResp(c)
 	}
 }
+
+func LogOut(c *gin.Context) {
+	err := common.InvalidateToken(c.GetHeader("Authorization"))
+	if err != nil {
+		common.ErrorResp(c, err, 500)
+	} else {
+		common.SuccessResp(c)
+	}
+}

server/router.go

@@ -54,6 +54,7 @@ func Init(e *gin.Engine) {
 	auth.POST("/me/update", handles.UpdateCurrent)
 	auth.POST("/auth/2fa/generate", handles.Generate2FA)
 	auth.POST("/auth/2fa/verify", handles.Verify2FA)
+	auth.GET("/auth/logout", handles.LogOut)
 
 	// auth
 	api.GET("/auth/sso", handles.SSOLoginRedirect)

server/s3/backend.go

@@ -267,8 +267,19 @@ func (b *s3Backend) PutObject(
 	}
 	bucketPath := bucket.Path
 
+	isDir := strings.HasSuffix(objectName, "/")
+	log.Debugf("isDir: %v", isDir)
+
 	fp := path.Join(bucketPath, objectName)
-	reqPath := path.Dir(fp)
+	log.Debugf("fp: %s, bucketPath: %s, objectName: %s", fp, bucketPath, objectName)
+
+	var reqPath string
+	if isDir {
+		reqPath = fp + "/"
+	} else {
+		reqPath = path.Dir(fp)
+	}
+	log.Debugf("reqPath: %s", reqPath)
 	fmeta, _ := op.GetNearestMeta(fp)
 	ctx = context.WithValue(ctx, "meta", fmeta)
 
@@ -285,6 +296,10 @@ func (b *s3Backend) PutObject(
 		}
 	}
 
+	if isDir {
+		return result, nil
+	}
+
 	var ti time.Time
 
 	if val, ok := meta["X-Amz-Meta-Mtime"]; ok {