convert codebase to typescript

.eslintrc.json

@@ -0,0 +1,55 @@
+{
+  "root": true,
+  "extends": [
+    "eslint:recommended",
+    "plugin:import/recommended",
+    "plugin:import/typescript",
+    "plugin:node/recommended",
+    "plugin:@typescript-eslint/recommended",
+    "plugin:prettier/recommended"
+  ],
+  "parser": "@typescript-eslint/parser",
+  "parserOptions": {
+    "project": ["tsconfig.test.json"],
+    "sourceType": "module"
+  },
+  "settings": {
+    "import/resolver": {
+      "typescript": true,
+      "node": true
+    }
+  },
+  "plugins": [
+    "@typescript-eslint",
+    "mocha"
+  ],
+  "env": {
+    "node": true,
+    "es6": true,
+    "mocha": true
+  },
+  "rules": {
+    "quote-props": ["error", "consistent"],
+    "mocha/no-skipped-tests": "error",
+    "mocha/no-exclusive-tests": "error",
+    "node/no-unpublished-import": [
+      "error", {
+        "allowModules": ["slow-stream"]
+      }
+    ],
+    "node/no-unsupported-features/es-syntax": [
+      "error",
+      {
+        "version": ">=13.0.0",
+        "ignores": ["modules"]
+      }
+    ],
+    "node/no-missing-import": [
+      "error", {
+        "allowModules": [],
+        "resolvePaths": ["/path/to/a/modules/directory"],
+        "tryExtensions": [".js", ".ts"]
+      }
+    ]
+  }
+}

.mocharc.json

@@ -0,0 +1,4 @@
+{
+  "extension": ["ts"],
+  "node-option": ["loader=ts-node/esm"]
+}

.tools/build.sh

@@ -0,0 +1,27 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+readonly PROJECT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)/.."
+
+rm -rf "${PROJECT_DIR}/dist"
+
+cd "${PROJECT_DIR}"
+
+echo "Building oleoduc (esm version)..."
+tsc -p tsconfig.json
+cat >"./dist/mjs/package.json" <<!EOF
+{
+    "type": "module"
+}
+!EOF
+
+echo "Building oleoduc (cjs version)..."
+tsc -p tsconfig.cjs.json
+cat >"./dist/cjs/package.json" <<!EOF
+{
+    "type": "commonjs"
+}
+!EOF
+
+cd -
+

.tools/hooks.sh

@@ -0,0 +1,19 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+readonly PROJECT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)/.."
+readonly PRE_COMMIT_HOOK="${PROJECT_DIR}/.git/hooks/pre-commit"
+
+cat <<'EOF' >"${PRE_COMMIT_HOOK}"
+#!/usr/bin/env bash
+set -euo pipefail
+# Do not edit. This file has been generated by oleoduc
+
+npm test
+npm run lint
+npm run build
+
+EOF
+
+chmod +x "${PRE_COMMIT_HOOK}"
+echo "pre-push hooks installed in ${PRE_COMMIT_HOOK}"

README.md

@@ -169,7 +169,7 @@ oleoduc(
 
 ## compose(...streams, [options])
 
-Same as oleoduc but without promise stuff.
+Same as oleoduc but without promise stuff and stream composition capability
 
 #### Parameters
 
@@ -381,7 +381,7 @@ oleoduc(
 
 ## mergeStreams(...streams, [options])
 
-Allows streams to be merged into a single one.
+Allows chunks of multiple streams to be processed in no particular order.
 
 #### Parameters
 
@@ -432,8 +432,8 @@ await oleoduc(
 Pipe streams together, forwards errors and returns a promisified stream.
 
 It is same as nodejs
-core [pipeline](https://nodejs.org/api/stream.html#stream_stream_pipeline_source_transforms_destination_callback) but
-with better error handling and stream composition capability.
+core [pipeline](https://nodejs.org/api/stream.html#stream_stream_pipeline_source_transforms_destination_callback) 
+but with better error handling.
 
 If the last stream is readable, the returned stream will be iterable
 
@@ -554,6 +554,36 @@ Robert;Hue
 `
 ```
 
+Stream data as if it where a csv with options
+
+```js
+const { oleoduc, transformIntoCSV } = require("oleoduc");
+const { Readable } = require("stream");
+const { createWriteStream } = require("fs");
+
+const source = Readable.from([{ firstname: "John", lastname: "Doe" }, { firstname: "Robert", lastname: "Hue" }]);
+
+await oleoduc(
+  source,
+  transformIntoCSV({
+    sepatator: "|",
+    mapper: (v) => `"${v || ''}"`,//Values will be enclosed in double quotes
+    columns: {
+      fullname: (data) => `${data.firstName} ${data.lastName}`,
+      date: () => new Date().toISOString(),
+    },
+  }),
+  createWriteStream("/path/to/file")
+);
+
+// --> Output CSV file
+`
+fullname|date
+John Doe|2021-03-12T21:34:13.085Z
+Robert Hue|2021-03-12T21:34:13.085Z
+`
+```
+
 ## transformIntoJSON([options])
 
 Allows data to be streamed as if it were a json string
@@ -582,7 +612,6 @@ await oleoduc(
 
 // Json Output
 '[{ user: "John Doe" }, { user: "Robert Hue" }]'
-
 ```
 
 Stream data as if it where a json object with an array property inside
@@ -603,36 +632,6 @@ await oleoduc(
 '{ other: "data", users: [{ user: "John Doe" }, { user: "Robert Hue" }] }'
 ```
 
-Stream data as if it where a csv with options
-
-```js
-const { oleoduc, transformIntoCSV } = require("oleoduc");
-const { Readable } = require("stream");
-const { createWriteStream } = require("fs");
-
-const source = Readable.from([{ firstname: "John", lastname: "Doe" }, { firstname: "Robert", lastname: "Hue" }]);
-
-await oleoduc(
-  source,
-  transformIntoCSV({
-    sepatator: "|",
-    mapper: (v) => `"${v || ''}"`,//Values will be enclosed in double quotes
-    columns: {
-      fullname: (data) => `${data.firstName} ${data.lastName}`,
-      date: () => new Date().toISOString(),
-    },
-  }),
-  createWriteStream("/path/to/file")
-);
-
-// --> Output CSV file
-`
-fullname|date
-John Doe|2021-03-12T21:34:13.085Z
-Robert Hue|2021-03-12T21:34:13.085Z
-`
-```
-
 ## transformStream([options])
 
 Allows chunks of a sub-stream to be streamed as if each was part of the source