Method upRemote

drivers/cloudreve_v4/util.go:412–482

(ctx context.Context, file model.FileStreamer, u FileUploadResp, up driver.UpdateProgress)

}

func (d *CloudreveV4) upRemote(ctx context.Context, file model.FileStreamer, u FileUploadResp, up driver.UpdateProgress) error {
	DEFAULT := int64(u.ChunkSize)
	ss, err := stream.NewStreamSectionReader(file, int(DEFAULT), &up)
	if err != nil {
		return err
	}

	uploadUrl := u.UploadUrls[0]
	credential := u.Credential
	var finish int64 = 0
	var chunk int = 0
	for finish < file.GetSize() {
		if utils.IsCanceled(ctx) {
			return ctx.Err()
		}
		left := file.GetSize() - finish
		byteSize := min(left, DEFAULT)
		utils.Log.Debugf("[CloudreveV4-Remote] upload range: %d-%d/%d", finish, finish+byteSize-1, file.GetSize())
		rd, err := ss.GetSectionReader(finish, byteSize)
		if err != nil {
			return err
		}
		err = retry.Do(
			func() error {
				rd.Seek(0, io.SeekStart)
				req, err := http.NewRequestWithContext(ctx, http.MethodPost, uploadUrl+"?chunk="+strconv.Itoa(chunk),
					driver.NewLimitedUploadStream(ctx, rd))
				if err != nil {
					return err
				}

				req.ContentLength = byteSize
				req.Header.Set("Authorization", fmt.Sprint(credential))
				req.Header.Set("User-Agent", d.getUA())
				res, err := base.HttpClient.Do(req)
				if err != nil {
					return err
				}
				defer res.Body.Close()
				if res.StatusCode != 200 {
					return fmt.Errorf("server error: %d", res.StatusCode)
				}
				body, err := io.ReadAll(res.Body)
				if err != nil {
					return err
				}
				var up Resp
				err = json.Unmarshal(body, &up)
				if err != nil {
					return err
				}
				if up.Code != 0 {
					return errors.New(up.Msg)
				}
				return nil
			},
			retry.Context(ctx),
			retry.Attempts(3),