fix: allow oss put empty file (#34)

src/client/Oss.ts

@@ -47,7 +47,9 @@ export default class Oss extends API {
   }
 
   private async* putObjectIterator(request: PutObjectRequest): AsyncGenerator<PutObjectInput> {
+    let hasChunk = false;
     for await (const chunk of request.body) {
+      hasChunk = true;
       const req = new PutObjectInput();
       req.setStoreName(request.storeName);
       req.setBucket(request.bucket);
@@ -80,6 +82,40 @@ export default class Oss extends API {
       req.setBody(chunk);
       yield req;
     }
+
+    if (!hasChunk) {
+      // put empty file
+      const req = new PutObjectInput();
+      req.setStoreName(request.storeName);
+      req.setBucket(request.bucket);
+      req.setKey(request.key);
+      req.setContentLength(request.contentLength);
+      if (request.acl) {
+        req.setAcl(request.acl);
+      }
+      if (request.bucketKeyEnabled) {
+        req.setBucketKeyEnabled(request.bucketKeyEnabled);
+      }
+      if (request.cacheControl) {
+        req.setCacheControl(request.cacheControl);
+      }
+      if (request.contentDisposition) {
+        req.setContentDisposition(request.contentDisposition);
+      }
+      if (request.contentEncoding) {
+        req.setContentEncoding(request.contentEncoding);
+      }
+      if (request.expires) {
+        req.setExpires(request.expires);
+      }
+      if (request.serverSideEncryption) {
+        req.setServerSideEncryption(request.serverSideEncryption);
+      }
+      if (request.signedUrl) {
+        req.setSignedUrl(request.signedUrl);
+      }
+      yield req;
+    }
   }
 
   async put(request: PutObjectRequest): Promise<PutObjectOutput.AsObject> {

test/unit/client/Oss.test.ts

@@ -1,5 +1,7 @@
-import assert from 'node:assert';
+import { strict as assert } from 'node:assert';
 import { Readable } from 'node:stream';
+import { createReadStream } from 'node:fs';
+import path from 'node:path';
 import crypto from 'node:crypto';
 import { Client } from '../../../src';
 
@@ -27,6 +29,29 @@ describe.skip('client/Oss.test.ts', () => {
     assert(data === 'hello world');
   });
 
+  it('test put empty file', async () => {
+    const fileStream = createReadStream(path.join(__dirname, 'fixtures/empty-file.txt'));
+    const hello = await client.oss.put({
+      storeName: 'oss_demo',
+      bucket: 'antsys-tnpmbuild',
+      key: 'test-empty-file.txt',
+      body: fileStream,
+      contentLength: 0,
+    });
+    assert(hello);
+    const res = await client.oss.get({
+      storeName: 'oss_demo',
+      bucket: 'antsys-tnpmbuild',
+      key: 'test-empty-file.txt',
+    });
+    const buf: Uint8Array[] = [];
+    for await (const chunk of res.object) {
+      buf.push(chunk);
+    }
+    const data = Buffer.concat(buf).toString();
+    assert.equal(data, '');
+  });
+
   it('test put large object', async () => {
     const buf = new Array(1024);
     buf.fill(Buffer.alloc(1024).fill('a'));