feat(drivers/123open): support sha1 reuse api (#2089)

* feat(drivers/123open): support sha1 reuse api

* fix(drivers/123open): fix typos

Author: gdm257

drivers/123_open/driver.go

@@ -181,6 +181,22 @@ func (d *Open123) Put(ctx context.Context, dstDir model.Obj, file model.FileStre
 	if err != nil {
 		return nil, fmt.Errorf("parse parentFileID error: %v", err)
 	}
+
+	// 尝试 SHA1 秒传
+	sha1Hash := file.GetHash().GetHash(utils.SHA1)
+	if len(sha1Hash) == utils.SHA1.Width {
+		resp, err := d.sha1Reuse(parentFileId, file.GetName(), sha1Hash, file.GetSize(), 2)
+		if err == nil && resp.Data.Reuse {
+			return File{
+				FileName: file.GetName(),
+				Size:     file.GetSize(),
+				FileId:   resp.Data.FileID,
+				Type:     2,
+				SHA1:     sha1Hash,
+			}, nil
+		}
+	}
+
 	// etag 文件md5
 	etag := file.GetHash().GetHash(utils.MD5)
 	if len(etag) < utils.MD5.Width {

drivers/123_open/types.go

@@ -58,9 +58,13 @@ type File struct {
 	Category     int    `json:"category"`
 	Status       int    `json:"status"`
 	Trashed      int    `json:"trashed"`
+	SHA1         string
 }
 
 func (f File) GetHash() utils.HashInfo {
+	if len(f.SHA1) == utils.SHA1.Width && len(f.Etag) != utils.MD5.Width {
+		return utils.NewHashInfo(utils.SHA1, f.SHA1)
+	}
 	return utils.NewHashInfo(utils.MD5, f.Etag)
 }
 
@@ -190,6 +194,14 @@ type UploadCompleteResp struct {
 	} `json:"data"`
 }
 
+type SHA1ReuseResp struct {
+	BaseResp
+	Data struct {
+		FileID int64 `json:"fileID"`
+		Reuse  bool  `json:"reuse"`
+	} `json:"data"`
+}
+
 type OfflineDownloadResp struct {
 	BaseResp
 	Data struct {

drivers/123_open/upload.go

@@ -183,3 +183,21 @@ func (d *Open123) complete(preuploadID string) (*UploadCompleteResp, error) {
 	}
 	return &resp, nil
 }
+
+// SHA1 秒传
+func (d *Open123) sha1Reuse(parentFileID int64, filename string, sha1Hash string, size int64, duplicate int) (*SHA1ReuseResp, error) {
+	var resp SHA1ReuseResp
+	_, err := d.Request(UploadSHA1Reuse, http.MethodPost, func(req *resty.Request) {
+		req.SetBody(base.Json{
+			"parentFileID": parentFileID,
+			"filename":     filename,
+			"sha1":         strings.ToLower(sha1Hash),
+			"size":         size,
+			"duplicate":    duplicate,
+		})
+	}, &resp)
+	if err != nil {
+		return nil, err
+	}
+	return &resp, nil
+}

drivers/123_open/util.go

@@ -21,16 +21,17 @@ import (
 var ( // 不同情况下获取的AccessTokenQPS限制不同 如下模块化易于拓展
 	Api = "https://open-api.123pan.com"
 
-	UserInfo       = InitApiInfo(Api+"/api/v1/user/info", 1)
-	FileList       = InitApiInfo(Api+"/api/v2/file/list", 3)
-	DownloadInfo   = InitApiInfo(Api+"/api/v1/file/download_info", 5)
-	DirectLink     = InitApiInfo(Api+"/api/v1/direct-link/url", 5)
-	Mkdir          = InitApiInfo(Api+"/upload/v1/file/mkdir", 2)
-	Move           = InitApiInfo(Api+"/api/v1/file/move", 1)
-	Rename         = InitApiInfo(Api+"/api/v1/file/name", 1)
-	Trash          = InitApiInfo(Api+"/api/v1/file/trash", 2)
-	UploadCreate   = InitApiInfo(Api+"/upload/v2/file/create", 2)
-	UploadComplete = InitApiInfo(Api+"/upload/v2/file/upload_complete", 0)
+	UserInfo        = InitApiInfo(Api+"/api/v1/user/info", 1)
+	FileList        = InitApiInfo(Api+"/api/v2/file/list", 3)
+	DownloadInfo    = InitApiInfo(Api+"/api/v1/file/download_info", 5)
+	DirectLink      = InitApiInfo(Api+"/api/v1/direct-link/url", 5)
+	Mkdir           = InitApiInfo(Api+"/upload/v1/file/mkdir", 2)
+	Move            = InitApiInfo(Api+"/api/v1/file/move", 1)
+	Rename          = InitApiInfo(Api+"/api/v1/file/name", 1)
+	Trash           = InitApiInfo(Api+"/api/v1/file/trash", 2)
+	UploadCreate    = InitApiInfo(Api+"/upload/v2/file/create", 2)
+	UploadComplete  = InitApiInfo(Api+"/upload/v2/file/upload_complete", 0)
+	UploadSHA1Reuse = InitApiInfo(Api+"/upload/v2/file/sha1_reuse", 2)
 
 	OfflineDownload        = InitApiInfo(Api+"/api/v1/offline/download", 1)
 	OfflineDownloadProcess = InitApiInfo(Api+"/api/v1/offline/download/process", 5)