feat: support Node.js >= 14.21.3

.github/workflows/nodejs.yml

@@ -40,7 +40,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        node-version: [16, 18, 20]
+        node-version: [14, 16, 18, 20]
         os: [ubuntu-latest]
 
     steps:

package.json

@@ -43,6 +43,7 @@
     "@eggjs/tsconfig": "^1.0.0",
     "@types/google-protobuf": "^3.15.5",
     "@types/jest": "^27.0.2",
+    "@types/pump": "^1.1.1",
     "eslint": "^8.31.0",
     "eslint-config-egg": "^12.1.0",
     "git-contributor": "^1.1.0",
@@ -56,9 +57,10 @@
   },
   "dependencies": {
     "@grpc/grpc-js": "^1.4.1",
-    "google-protobuf": "^3.19.0"
+    "google-protobuf": "^3.19.0",
+    "pump": "^3.0.0"
   },
   "engines": {
-    "node": ">=16.0.0"
+    "node": ">=14.21.3"
   }
 }

src/client/File.ts

@@ -14,7 +14,7 @@
  */
 import { debuglog } from 'node:util';
 import { Transform, Readable } from 'node:stream';
-import { pipeline as pipelinePromise } from 'node:stream/promises';
+import { pipelinePromise } from '../utils';
 import {
   GetFileRequest as GetFileRequestPB,
   GetFileResponse as GetFileResponsePB,

src/client/Oss.ts

@@ -1,5 +1,5 @@
 import { Readable, PassThrough, Writable } from 'node:stream';
-import { pipeline as pipelinePromise } from 'node:stream/promises';
+import { pipelinePromise } from '../utils';
 import {
   CopyObjectRequest,
   DeleteObjectRequest,

src/utils.ts

@@ -12,12 +12,25 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import { setTimeout } from 'node:timers/promises';
+import stream from 'node:stream';
+import pump from 'pump';
 import { Map as MapPB } from 'google-protobuf';
 import { KV } from './types/common';
 
-export async function sleep(ms: number) {
-  await setTimeout(ms);
+// impl promise pipeline on Node.js 14
+export const pipelinePromise = stream.promises?.pipeline ?? function pipeline(...args: any[]) {
+  return new Promise<void>((resolve, reject) => {
+    pump(...args, (err?: Error) => {
+      if (err) return reject(err);
+      resolve();
+    });
+  });
+};
+
+export function sleep(ms: number) {
+  return new Promise(resolve => {
+    setTimeout(resolve, ms);
+  });
 }
 
 // jspb.Message

test/unit/client/File.test.ts

@@ -16,9 +16,9 @@ import { strict as assert } from 'node:assert';
 import { tmpdir } from 'node:os';
 import { existsSync, createWriteStream, createReadStream } from 'node:fs';
 import { mkdtemp, rm } from 'node:fs/promises';
-import { pipeline } from 'node:stream/promises';
 import { join } from 'node:path';
 import { Client, utils } from '../../../src';
+import { pipelinePromise as pipeline } from '../../../src/utils';
 
 describe.skip('client/File.test.ts', () => {
   let client: Client;