refactor(services/aliyun_drive): Move raw request to core

core/src/services/aliyun_drive/backend.rs

@@ -236,7 +236,7 @@ pub struct AliyunDriveBackend {
 }
 
 impl Access for AliyunDriveBackend {
-    type Reader = HttpBody;
+    type Reader = Buffer;
     type Writer = AliyunDriveWriter;
     type Lister = oio::PageLister<AliyunDriveLister>;
     type Deleter = oio::OneShotDeleter<AliyunDriveDeleter>;
@@ -370,23 +370,9 @@ impl Access for AliyunDriveBackend {
             serde_json::from_reader(res.reader()).map_err(new_json_serialize_error)?;
 
         let download_url = self.core.get_download_url(&file.file_id).await?;
-        let req = Request::get(&download_url)
-            .header(header::RANGE, args.range().to_header())
-            .body(Buffer::new())
-            .map_err(new_request_build_error)?;
-
-        let resp = self.core.info.http_client().fetch(req).await?;
-        let status = resp.status();
-        match status {
-            StatusCode::OK | StatusCode::PARTIAL_CONTENT => {
-                Ok((RpRead::default(), resp.into_body()))
-            }
-            _ => {
-                let (part, mut body) = resp.into_parts();
-                let buf = body.to_buffer().await?;
-                Err(parse_error(Response::from_parts(part, buf)))
-            }
-        }
+        let buf = self.core.download(&download_url, args.range()).await?;
+
+        Ok((RpRead::default(), buf))
     }
 
     async fn delete(&self) -> Result<(RpDelete, Self::Deleter)> {

core/src/services/aliyun_drive/core.rs

@@ -399,6 +399,14 @@ impl AliyunDriveCore {
         self.send(req, token.as_deref()).await
     }
 
+    pub async fn download(&self, download_url: &str, range: BytesRange) -> Result<Buffer> {
+        let req = Request::get(download_url)
+            .header(header::RANGE, range.to_header())
+            .body(Buffer::new())
+            .map_err(new_request_build_error)?;
+        self.send(req, None).await
+    }
+
     pub async fn upload(&self, upload_url: &str, body: Buffer) -> Result<Buffer> {
         let req = Request::put(upload_url)
             // Inject operation to the request.