feat(bos): 实现BOS获取单个对象 (#2)

package.json

@@ -10,8 +10,12 @@
     "lint": "eslint src",
     "build": "tsc -p tsconfig.build.json",
     "ci": "yarn install --immutable && npm run lint && npm run build",
-    "release": "standard-version"
+    "release": "standard-version",
+    "deploy": "npm publish --access public"
   },
+  "files": [
+    "dist"
+  ],
   "repository": {
     "type": "git",
     "url": "git+https://github.com/otakustay/bce-sdk.git"

src/bos.ts

@@ -72,4 +72,31 @@ export class BosClient {
         );
         return response;
     }
+
+    async getObject(bucketName: string, key: string) {
+        const response = await this.http.text(
+            'GET',
+            `/${key}`,
+            {headers: {host: `${bucketName}.${this.hostBase}`}}
+        );
+        return response;
+    }
+
+    async getObjectAsBlob(bucketName: string, key: string) {
+        const response = await this.http.blob(
+            'GET',
+            `/${key}`,
+            {headers: {host: `${bucketName}.${this.hostBase}`}}
+        );
+        return response;
+    }
+
+    async getObjectAsStream(bucketName: string, key: string) {
+        const response = await this.http.stream(
+            'GET',
+            `/${key}`,
+            {headers: {host: `${bucketName}.${this.hostBase}`}}
+        );
+        return response;
+    }
 }

src/http.ts

@@ -1,3 +1,5 @@
+import {Blob} from 'node:buffer';
+import {ReadableStream} from 'node:stream/web';
 import {fetch} from 'undici';
 import {fromPairs} from 'ramda';
 import {Authorization, BceCredential} from './authorization.js';
@@ -51,6 +53,21 @@ export class Http {
         return {headers, body: await response.text()};
     }
 
+    async blob(method: string, url: string, options: RequestOptions): Promise<ClientResponse<Blob>> {
+        const {headers, response} = await this.request(method, url, options);
+        return {headers, body: await response.blob()};
+    }
+
+    async stream(method: string, url: string, options: RequestOptions): Promise<ClientResponse<ReadableStream>> {
+        const {headers, response} = await this.request(method, url, options);
+
+        if (response.body) {
+            return {headers, body: response.body};
+        }
+
+        throw new Error(`No stream body in response of ${method} ${url}`);
+    }
+
     private async request(method: string, url: string, options: RequestOptions) {
         const {headers, params} = options;
         const timestamp = stringifyDate(new Date());