WIP TypeScript code refactor

package.json

@@ -85,13 +85,13 @@
     "async": "^3.2.4",
     "block-stream2": "^2.1.0",
     "browser-or-node": "^2.1.1",
-    "buffer-crc32": "^0.2.13",
+    "crc-32": "^1.2.2",
     "fast-xml-parser": "^4.2.2",
     "ipaddr.js": "^2.0.1",
-    "json-stream": "^1.0.0",
     "lodash": "^4.17.21",
     "mime-types": "^2.1.35",
-    "query-string": "^7.1.3",
+    "query-string": "^7.1.1",
+    "stream-json": "^1.7.5",
     "through2": "^4.0.2",
     "web-encoding": "^1.1.5",
     "xml": "^1.0.1",
@@ -105,9 +105,11 @@
     "@babel/register": "^7.21.0",
     "@nodelib/fs.walk": "^1.2.8",
     "@types/async": "^3.2.20",
+    "@types/block-stream2": "^2.1.0",
     "@types/lodash": "^4.14.194",
     "@types/mime-types": "^2.1.1",
     "@types/node": "^20.1.0",
+    "@types/stream-json": "^1.7.3",
     "@types/through2": "^2.0.38",
     "@types/xml": "^1.0.8",
     "@types/xml2js": "^0.4.11",
@@ -125,6 +127,7 @@
     "eslint-plugin-simple-import-sort": "^10.0.0",
     "eslint-plugin-unicorn": "^47.0.0",
     "eslint-plugin-unused-imports": "^2.0.0",
+    "eventemitter3": "^5.0.1",
     "husky": "^8.0.3",
     "lint-staged": "^13.2.2",
     "mocha": "^10.2.0",

src/errors.ts

@@ -114,6 +114,7 @@ export class InvalidXMLError extends ExtendableError {}
  */
 export class S3Error extends ExtendableError {
   code?: string
+  region?: string
 }
 
 export class IsValidBucketNameError extends ExtendableError {}

src/internal/as-callback.ts

@@ -0,0 +1,32 @@
+import { isFunction } from './helper.ts'
+
+export function asCallback<T = void>(
+  cb: undefined | ((err: unknown | null, result: T) => void),
+  promise: Promise<T>,
+): Promise<T> | void {
+  if (cb === undefined) {
+    return promise
+  }
+
+  if (!isFunction(cb)) {
+    throw new TypeError(`callback should be of type "function", got ${cb}`)
+  }
+
+  promise.then(
+    (result) => {
+      cb(null, result)
+    },
+    (err) => {
+      // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+      // @ts-ignore
+      cb(err)
+    },
+  )
+}
+
+export function asCallbackFn<T = void>(
+  cb: undefined | ((err: unknown | null, result: T) => void),
+  asyncFn: () => Promise<T>,
+): Promise<T> | void {
+  return asCallback(cb, asyncFn())
+}

src/internal/async.ts

@@ -0,0 +1,14 @@
+// promise helper for stdlib
+
+import * as fs from 'node:fs'
+import * as stream from 'node:stream'
+import { promisify } from 'node:util'
+
+// TODO: use "node:fs/promise" directly after we stop testing on nodejs 12
+export { promises as fsp } from 'node:fs'
+export const streamPromise = {
+  // node:stream/promises Added in: v15.0.0
+  pipeline: promisify(stream.pipeline),
+}
+
+export const fstat = promisify(fs.fstat)

src/internal/helper.ts

@@ -234,6 +234,16 @@ export function isFunction(arg: unknown): arg is AnyFunction {
   return typeof arg === 'function'
 }
 
+/**
+ * check if typeof arg function or undefined
+ */
+export function isOptionalFunction(arg: unknown): arg is undefined | AnyFunction {
+  if (arg === undefined) {
+    return true
+  }
+  return typeof arg === 'function'
+}
+
 /**
  * check if typeof arg string
  */