fix(search): allow indexed check (close #3103)

because it will result in failure to get admin's info

.github/ISSUE_TEMPLATE/bug_report.yml

@@ -43,8 +43,8 @@ body:
     attributes:
       label: Reproduction / 复现链接
       description: |
-        Please provide a link to a repo that can reproduce the problem you ran into.
-        请提供能复现此问题的链接
+        Please provide a link to a repo that can reproduce the problem you ran into. Please be aware that your issue may be closed directly if you don't provide it.
+        请提供能复现此问题的链接，请知悉如果不提供它你的issue可能会被直接关闭。
     validations:
       required: true
   - type: textarea

Dockerfile

@@ -2,7 +2,7 @@ FROM alpine:edge as builder
 LABEL stage=go-builder
 WORKDIR /app/
 COPY ./ ./
-RUN apk add --no-cache bash git go gcc musl-dev curl; \
+RUN apk add --no-cache bash curl gcc git go musl-dev; \
     bash build.sh release docker
 
 FROM alpine:edge
@@ -11,8 +11,8 @@ VOLUME /opt/alist/data/
 WORKDIR /opt/alist/
 COPY --from=builder /app/bin/alist ./
 COPY entrypoint.sh /entrypoint.sh
-RUN apk add ca-certificates bash su-exec; \
+RUN apk add --no-cache bash ca-certificates su-exec tzdata; \
     chmod +x /entrypoint.sh
-ENV PUID=1000 PGID=1000 UMASK=022
+ENV PUID=0 PGID=0 UMASK=022
 EXPOSE 5244
 ENTRYPOINT [ "/entrypoint.sh" ]

README.md

@@ -53,6 +53,7 @@ English | [中文](./README_cn.md) | [Contributing](./CONTRIBUTING.md) | [CODE_O
     - [x] FTP / SFTP
     - [x] [PikPak](https://www.mypikpak.com/)
     - [x] [S3](https://aws.amazon.com/s3/)
+    - [x] [Seafile](https://seafile.com/)
     - [x] [UPYUN Storage Service](https://www.upyun.com/products/file-storage)
     - [x] WebDav(Support OneDrive/SharePoint without API)
     - [x] Teambition([China](https://www.teambition.com/ ),[International](https://us.teambition.com/ ))
@@ -60,6 +61,7 @@ English | [中文](./README_cn.md) | [Contributing](./CONTRIBUTING.md) | [CODE_O
     - [x] [139yun](https://yun.139.com/) (Personal, Family)
     - [x] [YandexDisk](https://disk.yandex.com/)
     - [x] [BaiduNetdisk](http://pan.baidu.com/)
+    - [x] [Terabox](https://www.terabox.com/main)
     - [x] [Quark](https://pan.quark.cn)
     - [x] [Thunder](https://pan.xunlei.com)
     - [x] [Lanzou](https://www.lanzou.com/)
@@ -69,6 +71,7 @@ English | [中文](./README_cn.md) | [Contributing](./CONTRIBUTING.md) | [CODE_O
     - [x] [Baidu photo](https://photo.baidu.com/)
     - [x] SMB
     - [x] [115](https://115.com/)
+    - [X] Cloudreve
 - [x] Easy to deploy and out-of-the-box
 - [x] File preview (PDF, markdown, code, plain text, ...)
 - [x] Image preview in gallery mode

README_cn.md

@@ -53,6 +53,7 @@
     - [x] FTP / SFTP
     - [x] [PikPak](https://www.mypikpak.com/)
     - [x] [S3](https://aws.amazon.com/cn/s3/)
+    - [x] [Seafile](https://seafile.com/)
     - [x] [又拍云对象存储](https://www.upyun.com/products/file-storage)
     - [x] WebDav(支持无API的OneDrive/SharePoint)
     - [x] Teambition（[中国](https://www.teambition.com/ )，[国际](https://us.teambition.com/ )）
@@ -69,6 +70,7 @@
     - [x] [一刻相册](https://photo.baidu.com/)
     - [x] SMB
     - [x] [115](https://115.com/)
+    - [X] Cloudreve
 - [x] 部署方便，开箱即用
 - [x] 文件预览（PDF、markdown、代码、纯文本……）
 - [x] 画廊模式下的图像预览

docker-compose.yml

@@ -0,0 +1,15 @@
+version: '3.3'
+services:
+  alist:
+    restart: always
+    volumes:
+      - '/etc/alist:/opt/alist/data'
+    ports:
+      - '5244:5244'
+    environment:
+      - PUID=0
+      - PGID=0
+      - UMASK=022
+      - TZ=UTC
+    container_name: alist
+    image: 'xhofe/alist:latest'

drivers/139/driver.go

@@ -1,11 +1,9 @@
 package _139
 
 import (
-	"bytes"
 	"context"
 	"fmt"
 	"io"
-	"math"
 	"net/http"
 	"strconv"
 
@@ -229,10 +227,10 @@ func (d *Yun139) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 		"manualRename": 2,
 		"operation":    0,
 		"fileCount":    1,
-		"totalSize":    stream.GetSize(),
+		"totalSize":    0, // 去除上传大小限制
 		"uploadContentList": []base.Json{{
 			"contentName": stream.GetName(),
-			"contentSize": stream.GetSize(),
+			"contentSize": 0, // 去除上传大小限制
 			// "digest": "5a3231986ce7a6b46e408612d385bafa"
 		}},
 		"parentCatalogID": dstDir.GetID(),
@@ -250,10 +248,10 @@ func (d *Yun139) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 			"operation":    0,
 			"path":         "",
 			"seqNo":        "",
-			"totalSize":    stream.GetSize(),
+			"totalSize":    0,
 			"uploadContentList": []base.Json{{
 				"contentName": stream.GetName(),
-				"contentSize": stream.GetSize(),
+				"contentSize": 0,
 				// "digest": "5a3231986ce7a6b46e408612d385bafa"
 			}},
 		})
@@ -265,51 +263,47 @@ func (d *Yun139) Put(ctx context.Context, dstDir model.Obj, stream model.FileStr
 	if err != nil {
 		return err
 	}
+
+	// Progress
+	p := driver.NewProgress(stream.GetSize(), up)
+
 	var Default int64 = 104857600
-	part := int(math.Ceil(float64(stream.GetSize()) / float64(Default)))
-	var start int64 = 0
-	for i := 0; i < part; i++ {
+	part := (stream.GetSize() + Default - 1) / Default
+	for i := int64(0); i < part; i++ {
 		if utils.IsCanceled(ctx) {
 			return ctx.Err()
 		}
+
+		start := i * Default
 		byteSize := stream.GetSize() - start
 		if byteSize > Default {
 			byteSize = Default
 		}
-		byteData := make([]byte, byteSize)
-		_, err = io.ReadFull(stream, byteData)
-		if err != nil {
-			return err
-		}
-		req, err := http.NewRequest("POST", resp.Data.UploadResult.RedirectionURL, bytes.NewBuffer(byteData))
+
+		limitReader := io.LimitReader(stream, byteSize)
+		// Update Progress
+		r := io.TeeReader(limitReader, p)
+		req, err := http.NewRequest("POST", resp.Data.UploadResult.RedirectionURL, r)
 		if err != nil {
 			return err
 		}
+
 		req = req.WithContext(ctx)
-		headers := map[string]string{
-			"Accept":         "*/*",
-			"Content-Type":   "text/plain;name=" + unicode(stream.GetName()),
-			"contentSize":    strconv.FormatInt(stream.GetSize(), 10),
-			"range":          fmt.Sprintf("bytes=%d-%d", start, start+byteSize-1),
-			"content-length": strconv.FormatInt(byteSize, 10),
-			"uploadtaskID":   resp.Data.UploadResult.UploadTaskID,
-			"rangeType":      "0",
-			"Referer":        "https://yun.139.com/",
-			"User-Agent":     "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/95.0.4638.69 Safari/537.36 Edg/95.0.1020.44",
-			"x-SvcType":      "1",
-		}
-		for k, v := range headers {
-			req.Header.Set(k, v)
-		}
+		req.Header.Set("Content-Type", "text/plain;name="+unicode(stream.GetName()))
+		req.Header.Set("contentSize", strconv.FormatInt(stream.GetSize(), 10))
+		req.Header.Set("range", fmt.Sprintf("bytes=%d-%d", start, start+byteSize-1))
+		req.Header.Set("uploadtaskID", resp.Data.UploadResult.UploadTaskID)
+		req.Header.Set("rangeType", "0")
+		req.ContentLength = byteSize
+
 		res, err := base.HttpClient.Do(req)
 		if err != nil {
 			return err
 		}
 		log.Debugf("%+v", res)
 		res.Body.Close()
-		start += byteSize
-		up(i * 100 / part)
 	}
+
 	return nil
 }
 

drivers/139/util.go

@@ -28,12 +28,15 @@ func (d *Yun139) isFamily() bool {
 func encodeURIComponent(str string) string {
 	r := url.QueryEscape(str)
 	r = strings.Replace(r, "+", "%20", -1)
+	r = strings.Replace(r, "%21", "!", -1)
+	r = strings.Replace(r, "%27", "'", -1)
+	r = strings.Replace(r, "%28", "(", -1)
+	r = strings.Replace(r, "%29", ")", -1)
+	r = strings.Replace(r, "%2A", "*", -1)
 	return r
 }
 
 func calSign(body, ts, randStr string) string {
-	body = strings.ReplaceAll(body, "\n", "")
-	body = strings.ReplaceAll(body, " ", "")
 	body = encodeURIComponent(body)
 	strs := strings.Split(body, "")
 	sort.Strings(strs)

drivers/aliyundrive/util.go

@@ -29,6 +29,9 @@ func (d *AliDrive) refreshToken() error {
 	if e.Code != "" {
 		return fmt.Errorf("failed to refresh token: %s", e.Message)
 	}
+	if resp.RefreshToken == "" {
+		return errors.New("failed to refresh token: refresh token is empty")
+	}
 	d.RefreshToken, d.AccessToken = resp.RefreshToken, resp.AccessToken
 	op.MustSaveDriverStorage(d)
 	return nil

drivers/all.go

@@ -12,6 +12,7 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/aliyundrive_share"
 	_ "github.com/alist-org/alist/v3/drivers/baidu_netdisk"
 	_ "github.com/alist-org/alist/v3/drivers/baidu_photo"
+	_ "github.com/alist-org/alist/v3/drivers/cloudreve"
 	_ "github.com/alist-org/alist/v3/drivers/ftp"
 	_ "github.com/alist-org/alist/v3/drivers/google_drive"
 	_ "github.com/alist-org/alist/v3/drivers/google_photo"
@@ -24,9 +25,11 @@ import (
 	_ "github.com/alist-org/alist/v3/drivers/pikpak_share"
 	_ "github.com/alist-org/alist/v3/drivers/quark"
 	_ "github.com/alist-org/alist/v3/drivers/s3"
+	_ "github.com/alist-org/alist/v3/drivers/seafile"
 	_ "github.com/alist-org/alist/v3/drivers/sftp"
 	_ "github.com/alist-org/alist/v3/drivers/smb"
 	_ "github.com/alist-org/alist/v3/drivers/teambition"
+	_ "github.com/alist-org/alist/v3/drivers/terabox"
 	_ "github.com/alist-org/alist/v3/drivers/thunder"
 	_ "github.com/alist-org/alist/v3/drivers/uss"
 	_ "github.com/alist-org/alist/v3/drivers/virtual"

drivers/baidu_netdisk/driver.go

@@ -88,12 +88,11 @@ func (d *BaiduNetdisk) Rename(ctx context.Context, srcObj model.Obj, newName str
 }
 
 func (d *BaiduNetdisk) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
-	dest, newname := stdpath.Split(dstDir.GetPath())
 	data := []base.Json{
 		{
 			"path":    srcObj.GetPath(),
-			"dest":    dest,
-			"newname": newname,
+			"dest":    dstDir.GetPath(),
+			"newname": srcObj.GetName(),
 		},
 	}
 	_, err := d.manage("copy", data)
@@ -165,7 +164,8 @@ func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.F
 			return err
 		}
 	}
-	path := encodeURIComponent(stdpath.Join(dstDir.GetPath(), stream.GetName()))
+	rawPath := stdpath.Join(dstDir.GetPath(), stream.GetName())
+	path := encodeURIComponent(rawPath)
 	block_list_str := fmt.Sprintf("[%s]", strings.Join(block_list, ","))
 	data := fmt.Sprintf("path=%s&size=%d&isdir=0&autoinit=1&block_list=%s&content-md5=%s&slice-md5=%s",
 		path, stream.GetSize(),
@@ -223,7 +223,7 @@ func (d *BaiduNetdisk) Put(ctx context.Context, dstDir model.Obj, stream model.F
 			up(i * 100 / len(precreateResp.BlockList))
 		}
 	}
-	_, err = d.create(path, stream.GetSize(), 0, precreateResp.Uploadid, block_list_str)
+	_, err = d.create(rawPath, stream.GetSize(), 0, precreateResp.Uploadid, block_list_str)
 	return err
 }
 

drivers/baidu_photo/help.go

@@ -8,10 +8,10 @@ import (
 	"strings"
 	"time"
 
-	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/pkg/utils"
 )
 
-//Tid生成
+// Tid生成
 func getTid() string {
 	return fmt.Sprintf("3%d%.0f", time.Now().Unix(), math.Floor(9000000*rand.Float64()+1000000))
 }
@@ -26,82 +26,52 @@ func toTime(t int64) *time.Time {
 	return &tm
 }
 
-func fsidsFormat(ids ...string) string {
-	var buf []string
-	for _, id := range ids {
-		e := splitID(id)
-		buf = append(buf, fmt.Sprintf(`{"fsid":%s,"uk":%s}`, e[0], e[3]))
-	}
+func fsidsFormatNotUk(ids ...int64) string {
+	buf := utils.MustSliceConvert(ids, func(id int64) string {
+		return fmt.Sprintf(`{"fsid":%d}`, id)
+	})
 	return fmt.Sprintf("[%s]", strings.Join(buf, ","))
 }
 
-func fsidsFormatNotUk(ids ...string) string {
-	var buf []string
-	for _, id := range ids {
-		buf = append(buf, fmt.Sprintf(`{"fsid":%s}`, splitID(id)[0]))
-	}
-	return fmt.Sprintf("[%s]", strings.Join(buf, ","))
-}
-
-/*
-结构
-
-{fsid} 文件
-
-{album_id}|{tid} 相册
-
-{fsid}|{album_id}|{tid}|{uk} 相册文件
-*/
-func splitID(id string) []string {
-	return strings.SplitN(id, "|", 4)[:4]
-}
-
-/*
-结构
-
-{fsid} 文件
-
-{album_id}|{tid} 相册
-
-{fsid}|{album_id}|{tid}|{uk} 相册文件
-*/
-func joinID(ids ...interface{}) string {
-	idsStr := make([]string, 0, len(ids))
-	for _, id := range ids {
-		idsStr = append(idsStr, fmt.Sprint(id))
-	}
-	return strings.Join(idsStr, "|")
-}
-
 func getFileName(path string) string {
 	return path[strings.LastIndex(path, "/")+1:]
 }
 
-// 相册
-func IsAlbum(obj model.Obj) bool {
-	return obj.IsDir() && obj.GetPath() == "album"
-}
-
-// 根目录
-func IsRoot(obj model.Obj) bool {
-	return obj.IsDir() && obj.GetPath() == "" && obj.GetID() == ""
-}
-
-// 以相册为根目录
-func IsAlbumRoot(obj model.Obj) bool {
-	return obj.IsDir() && obj.GetPath() == "" && obj.GetID() != ""
-}
-
-// 根文件
-func IsFile(obj model.Obj) bool {
-	return !obj.IsDir() && obj.GetPath() == "file"
-}
-
-// 相册文件
-func IsAlbumFile(obj model.Obj) bool {
-	return !obj.IsDir() && obj.GetPath() == "albumfile"
-}
-
 func MustString(str string, err error) string {
 	return str
 }
+
+/*
+*	处理文件变化
+*	最大程度利用重复数据
+**/
+func copyFile(file *AlbumFile, cf *CopyFile) *File {
+	return &File{
+		Fsid:     cf.Fsid,
+		Path:     cf.Path,
+		Ctime:    cf.Ctime,
+		Mtime:    cf.Ctime,
+		Size:     file.Size,
+		Thumburl: file.Thumburl,
+	}
+}
+
+func moveFileToAlbumFile(file *File, album *Album, uk int64) *AlbumFile {
+	return &AlbumFile{
+		File:    *file,
+		AlbumID: album.AlbumID,
+		Tid:     album.Tid,
+		Uk:      uk,
+	}
+}
+
+func renameAlbum(album *Album, newName string) *Album {
+	return &Album{
+		AlbumID:    album.AlbumID,
+		Tid:        album.Tid,
+		JoinTime:   album.JoinTime,
+		CreateTime: album.CreateTime,
+		Title:      newName,
+		Mtime:      time.Now().Unix(),
+	}
+}

drivers/baidu_photo/meta.go

@@ -14,10 +14,6 @@ type Addition struct {
 	ClientSecret string `json:"client_secret" required:"true" default:"jXiFMOPVPCWlO2M5CwWQzffpNPaGTRBG"`
 }
 
-func (a Addition) GetRootId() string {
-	return a.AlbumID
-}
-
 var config = driver.Config{
 	Name:      "BaiduPhoto",
 	LocalSort: true,

drivers/baidu_photo/types.go

@@ -3,6 +3,8 @@ package baiduphoto
 import (
 	"fmt"
 	"time"
+
+	"github.com/alist-org/alist/v3/internal/model"
 )
 
 type TokenErrResp struct {
@@ -19,6 +21,12 @@ type Erron struct {
 	RequestID int `json:"request_id"`
 }
 
+// 用户信息
+type UInfo struct {
+	// uk
+	YouaID string `json:"youa_id"`
+}
+
 type Page struct {
 	HasMore int    `json:"has_more"`
 	Cursor  string `json:"cursor"`
@@ -28,6 +36,8 @@ func (p Page) HasNextPage() bool {
 	return p.HasMore == 1
 }
 
+type Root = model.Object
+
 type (
 	FileListResp struct {
 		Page
@@ -55,8 +65,8 @@ func (c *File) ModTime() time.Time {
 	return *c.parseTime
 }
 func (c *File) IsDir() bool     { return false }
-func (c *File) GetID() string   { return joinID(c.Fsid) }
-func (c *File) GetPath() string { return "file" }
+func (c *File) GetID() string   { return "" }
+func (c *File) GetPath() string { return "" }
 func (c *File) Thumb() string {
 	if len(c.Thumburl) > 0 {
 		return c.Thumburl[0]
@@ -108,11 +118,8 @@ func (a *Album) ModTime() time.Time {
 	return *a.parseTime
 }
 func (a *Album) IsDir() bool     { return true }
-func (a *Album) GetID() string   { return joinID(a.AlbumID, a.Tid) }
-func (a *Album) GetPath() string { return "album" }
-
-func (af *AlbumFile) GetID() string  { return joinID(af.Fsid, af.AlbumID, af.Tid, af.Uk) }
-func (c *AlbumFile) GetPath() string { return "albumfile" }
+func (a *Album) GetID() string   { return "" }
+func (a *Album) GetPath() string { return "" }
 
 type (
 	CopyFileResp struct {
@@ -120,7 +127,8 @@ type (
 	}
 	CopyFile struct {
 		FromFsid  int64  `json:"from_fsid"` // 源ID
-		Fsid      int64  `json:"fsid"`      // 目标ID
+		Ctime     int64  `json:"ctime"`
+		Fsid      int64  `json:"fsid"` // 目标ID
 		Path      string `json:"path"`
 		ShootTime int    `json:"shoot_time"`
 	}
@@ -134,8 +142,8 @@ type (
 		Md5            string `json:"md5"`
 		ServerFilename string `json:"server_filename"`
 		Path           string `json:"path"`
-		Ctime          int    `json:"ctime"`
-		Mtime          int    `json:"mtime"`
+		Ctime          int64  `json:"ctime"`
+		Mtime          int64  `json:"mtime"`
 		Isdir          int    `json:"isdir"`
 		Category       int    `json:"category"`
 		ServerMd5      string `json:"server_md5"`
@@ -158,6 +166,18 @@ type (
 	}
 )
 
+func (f *UploadFile) toFile() *File {
+	return &File{
+		Fsid:     f.FsID,
+		Path:     f.Path,
+		Size:     f.Size,
+		Ctime:    f.Ctime,
+		Mtime:    f.Mtime,
+		Thumburl: nil,
+	}
+}
+
+/* 共享相册部分 */
 type InviteResp struct {
 	Pdata struct {
 		// 邀请码
@@ -167,3 +187,9 @@ type InviteResp struct {
 		ShareID    string `json:"share_id"`
 	} `json:"pdata"`
 }
+
+/* 加入相册部分 */
+type JoinOrCreateAlbumResp struct {
+	AlbumID       string `json:"album_id"`
+	AlreadyExists int    `json:"already_exists"`
+}

drivers/cloudreve/driver.go

@@ -0,0 +1,184 @@
+package cloudreve
+
+import (
+	"context"
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/pkg/utils"
+	"github.com/go-resty/resty/v2"
+	"io"
+	"net/http"
+	"strconv"
+
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/model"
+)
+
+type Cloudreve struct {
+	model.Storage
+	Addition
+	Cookie string
+}
+
+func (d *Cloudreve) Config() driver.Config {
+	return config
+}
+
+func (d *Cloudreve) GetAddition() driver.Additional {
+	return &d.Addition
+}
+
+func (d *Cloudreve) Init(ctx context.Context) error {
+	return d.login()
+}
+
+func (d *Cloudreve) Drop(ctx context.Context) error {
+	d.Cookie = ""
+	return nil
+}
+
+func (d *Cloudreve) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
+	var r DirectoryResp
+	err := d.request(http.MethodGet, "/directory"+dir.GetPath(), nil, &r)
+	if err != nil {
+		return nil, err
+	}
+
+	return utils.SliceConvert(r.Objects, func(src Object) (model.Obj, error) {
+		return objectToObj(src), nil
+	})
+}
+
+func (d *Cloudreve) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error) {
+	var dUrl string
+	err := d.request(http.MethodPut, "/file/download/"+file.GetID(), nil, &dUrl)
+	if err != nil {
+		return nil, err
+	}
+	return &model.Link{
+		URL: dUrl,
+	}, nil
+}
+
+func (d *Cloudreve) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error {
+	return d.request(http.MethodPut, "/directory", func(req *resty.Request) {
+		req.SetBody(base.Json{
+			"path": parentDir.GetPath() + "/" + dirName,
+		})
+	}, nil)
+}
+
+func (d *Cloudreve) Move(ctx context.Context, srcObj, dstDir model.Obj) error {
+	body := base.Json{
+		"action":  "move",
+		"src_dir": srcObj.GetPath(),
+		"dst":     dstDir.GetPath(),
+		"src":     convertSrc(srcObj),
+	}
+	return d.request(http.MethodPatch, "/object", func(req *resty.Request) {
+		req.SetBody(body)
+	}, nil)
+}
+
+func (d *Cloudreve) Rename(ctx context.Context, srcObj model.Obj, newName string) error {
+	body := base.Json{
+		"action":   "rename",
+		"new_name": newName,
+		"src":      convertSrc(srcObj),
+	}
+	return d.request(http.MethodPatch, "/object/rename", func(req *resty.Request) {
+		req.SetBody(body)
+	}, nil)
+}
+
+func (d *Cloudreve) Copy(ctx context.Context, srcObj, dstDir model.Obj) error {
+	body := base.Json{
+		"src_dir": srcObj.GetPath(),
+		"dst":     dstDir.GetPath(),
+		"src":     convertSrc(srcObj),
+	}
+	return d.request(http.MethodPost, "/object/copy", func(req *resty.Request) {
+		req.SetBody(body)
+	}, nil)
+}
+
+func (d *Cloudreve) Remove(ctx context.Context, obj model.Obj) error {
+	body := convertSrc(obj)
+	err := d.request(http.MethodDelete, "/object", func(req *resty.Request) {
+		req.SetBody(body)
+	}, nil)
+	return err
+}
+
+func (d *Cloudreve) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error {
+	if stream.GetReadCloser() == http.NoBody {
+		return d.create(ctx, dstDir, stream)
+	}
+	var r DirectoryResp
+	err := d.request(http.MethodGet, "/directory"+dstDir.GetPath(), nil, &r)
+	if err != nil {
+		return err
+	}
+	uploadBody := base.Json{
+		"path":          dstDir.GetPath(),
+		"size":          stream.GetSize(),
+		"name":          stream.GetName(),
+		"policy_id":     r.Policy.Id,
+		"last_modified": stream.ModTime().Unix(),
+	}
+	var u UploadInfo
+	err = d.request(http.MethodPut, "/file/upload", func(req *resty.Request) {
+		req.SetBody(uploadBody)
+	}, &u)
+	if err != nil {
+		return err
+	}
+	var chunkSize = u.ChunkSize
+	var buf []byte
+	var chunk int
+	for {
+		var n int
+		buf = make([]byte, chunkSize)
+		n, err = io.ReadAtLeast(stream, buf, chunkSize)
+		if err != nil && err != io.ErrUnexpectedEOF {
+			if err == io.EOF {
+				return nil
+			}
+			return err
+		}
+
+		if n == 0 {
+			break
+		}
+		buf = buf[:n]
+		err = d.request(http.MethodPost, "/file/upload/"+u.SessionID+"/"+strconv.Itoa(chunk), func(req *resty.Request) {
+			req.SetHeader("Content-Type", "application/octet-stream")
+			req.SetHeader("Content-Length", strconv.Itoa(n))
+			req.SetBody(buf)
+		}, nil)
+		if err != nil {
+			break
+		}
+		chunk++
+
+	}
+	return err
+}
+
+func (d *Cloudreve) create(ctx context.Context, dir model.Obj, file model.Obj) error {
+	body := base.Json{"path": dir.GetPath() + "/" + file.GetName()}
+	if file.IsDir() {
+		err := d.request(http.MethodPut, "directory", func(req *resty.Request) {
+			req.SetBody(body)
+		}, nil)
+		return err
+	}
+	return d.request(http.MethodPost, "/file/create", func(req *resty.Request) {
+		req.SetBody(body)
+	}, nil)
+}
+
+//func (d *Cloudreve) Other(ctx context.Context, args model.OtherArgs) (interface{}, error) {
+//	return nil, errs.NotSupport
+//}
+
+var _ driver.Driver = (*Cloudreve)(nil)

drivers/cloudreve/meta.go

@@ -0,0 +1,26 @@
+package cloudreve
+
+import (
+	"github.com/alist-org/alist/v3/internal/driver"
+	"github.com/alist-org/alist/v3/internal/op"
+)
+
+type Addition struct {
+	// Usually one of two
+	driver.RootPath
+	// define other
+	Address  string `json:"address" required:"true"`
+	Username string `json:"username" required:"true"`
+	Password string `json:"password" required:"true"`
+}
+
+var config = driver.Config{
+	Name:        "Cloudreve",
+	DefaultRoot: "/",
+}
+
+func init() {
+	op.RegisterDriver(func() driver.Driver {
+		return &Cloudreve{}
+	})
+}

drivers/cloudreve/types.go

@@ -0,0 +1,54 @@
+package cloudreve
+
+import (
+	"github.com/alist-org/alist/v3/internal/model"
+	"time"
+)
+
+type Resp struct {
+	Code int         `json:"code"`
+	Msg  string      `json:"msg"`
+	Data interface{} `json:"data"`
+}
+
+type Policy struct {
+	Id       string   `json:"id"`
+	Name     string   `json:"name"`
+	Type     string   `json:"type"`
+	MaxSize  int      `json:"max_size"`
+	FileType []string `json:"file_type"`
+}
+
+type UploadInfo struct {
+	SessionID string `json:"sessionID"`
+	ChunkSize int    `json:"chunkSize"`
+	Expires   int    `json:"expires"`
+}
+
+type DirectoryResp struct {
+	Parent  string   `json:"parent"`
+	Objects []Object `json:"objects"`
+	Policy  Policy   `json:"policy"`
+}
+
+type Object struct {
+	Id            string    `json:"id"`
+	Name          string    `json:"name"`
+	Path          string    `json:"path"`
+	Pic           string    `json:"pic"`
+	Size          int       `json:"size"`
+	Type          string    `json:"type"`
+	Date          time.Time `json:"date"`
+	CreateDate    time.Time `json:"create_date"`
+	SourceEnabled bool      `json:"source_enabled"`
+}
+
+func objectToObj(f Object) *model.Object {
+	return &model.Object{
+		ID:       f.Id,
+		Name:     f.Name,
+		Size:     int64(f.Size),
+		Modified: f.Date,
+		IsFolder: f.Type == "dir",
+	}
+}

drivers/cloudreve/util.go

@@ -0,0 +1,96 @@
+package cloudreve
+
+import (
+	"errors"
+	"github.com/alist-org/alist/v3/drivers/base"
+	"github.com/alist-org/alist/v3/internal/model"
+	"github.com/alist-org/alist/v3/pkg/cookie"
+	"github.com/go-resty/resty/v2"
+	json "github.com/json-iterator/go"
+	"net/http"
+)
+
+// do others that not defined in Driver interface
+
+const loginPath = "/user/session"
+
+func (d *Cloudreve) request(method string, path string, callback base.ReqCallback, out interface{}) error {
+	u := d.Address + "/api/v3" + path
+	req := base.RestyClient.R()
+	req.SetHeaders(map[string]string{
+		"Cookie":     "cloudreve-session=" + d.Cookie,
+		"Accept":     "application/json, text/plain, */*",
+		"User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/108.0.0.0 Safari/537.36",
+	})
+
+	var r Resp
+
+	req.SetResult(&r)
+
+	if callback != nil {
+		callback(req)
+	}
+
+	resp, err := req.Execute(method, u)
+	if err != nil {
+		return err
+	}
+	if !resp.IsSuccess() {
+		return errors.New(resp.String())
+	}
+
+	if r.Code != 0 {
+
+		// 刷新 cookie
+		if r.Code == http.StatusUnauthorized && path != loginPath {
+			err = d.login()
+			if err != nil {
+				return err
+			}
+			return d.request(method, path, callback, out)
+		}
+
+		return errors.New(r.Msg)
+	}
+	sess := cookie.GetCookie(resp.Cookies(), "cloudreve-session")
+	if sess != nil {
+		d.Cookie = sess.Value
+	}
+	if out != nil && r.Data != nil {
+		var marshal []byte
+		marshal, err = json.Marshal(r.Data)
+		if err != nil {
+			return err
+		}
+		err = json.Unmarshal(marshal, out)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+func (d *Cloudreve) login() error {
+	return d.request(http.MethodPost, loginPath, func(req *resty.Request) {
+		req.SetBody(base.Json{
+			"username":    d.Addition.Username,
+			"Password":    d.Addition.Password,
+			"captchaCode": "",
+		})
+	}, nil)
+}
+
+func convertSrc(obj model.Obj) map[string]interface{} {
+	m := make(map[string]interface{})
+	var dirs []string
+	var items []string
+	if obj.IsDir() {
+		dirs = append(dirs, obj.GetID())
+	} else {
+		items = append(items, obj.GetID())
+	}
+	m["dirs"] = dirs
+	m["items"] = items
+	return m
+}