feat(cloudreve_v4): add ks3 support (#1828)

Signed-off-by: MadDogOwner <xiaoran@xrgzs.top>

Author: xrgzs

drivers/cloudreve_v4/driver.go

@@ -299,7 +299,9 @@ func (d *CloudreveV4) Put(ctx context.Context, dstDir model.Obj, file model.File
 		case "onedrive":
 			err = d.upOneDrive(ctx, file, u, up)
 		case "s3":
-			err = d.upS3(ctx, file, u, up)
+			err = d.upS3(ctx, file, u, up, "s3")
+		case "ks3":
+			err = d.upS3(ctx, file, u, up, "ks3")
 		default:
 			return errs.NotImplement
 		}

drivers/cloudreve_v4/util.go

@@ -529,7 +529,7 @@ func (d *CloudreveV4) upOneDrive(ctx context.Context, file model.FileStreamer, u
 	}, nil)
 }
 
-func (d *CloudreveV4) upS3(ctx context.Context, file model.FileStreamer, u FileUploadResp, up driver.UpdateProgress) error {
+func (d *CloudreveV4) upS3(ctx context.Context, file model.FileStreamer, u FileUploadResp, up driver.UpdateProgress, s3Type string) error {
 	DEFAULT := int64(u.ChunkSize)
 	ss, err := stream.NewStreamSectionReader(file, int(DEFAULT), &up)
 	if err != nil {
@@ -560,6 +560,9 @@ func (d *CloudreveV4) upS3(ctx context.Context, file model.FileStreamer, u FileU
 				}
 				req.ContentLength = byteSize
 				req.Header.Set("User-Agent", d.getUA())
+				if s3Type == "ks3" {
+					req.Header.Set("Content-Type", "application/octet-stream")
+				}
 				res, err := base.HttpClient.Do(req)
 				if err != nil {
 					return err
@@ -609,7 +612,11 @@ func (d *CloudreveV4) upS3(ctx context.Context, file model.FileStreamer, u FileU
 	if err != nil {
 		return err
 	}
-	req.Header.Set("Content-Type", "application/xml")
+	if s3Type == "ks3" {
+		req.Header.Set("Content-Type", "application/octet-stream")
+	} else {
+		req.Header.Set("Content-Type", "application/xml")
+	}
 	req.Header.Set("User-Agent", d.getUA())
 	res, err := base.HttpClient.Do(req)
 	if err != nil {
@@ -622,7 +629,5 @@ func (d *CloudreveV4) upS3(ctx context.Context, file model.FileStreamer, u FileU
 	}
 
 	// 上传成功发送回调请求
-	return d.request(http.MethodGet, "/callback/s3/"+u.SessionID+"/"+u.CallbackSecret, func(req *resty.Request) {
-		req.SetBody("{}")
-	}, nil)
+	return d.request(http.MethodGet, "/callback/"+s3Type+"/"+u.SessionID+"/"+u.CallbackSecret, nil, nil)
 }