Merge branch 'master' into pr/wdavidw/464-on_record-types

wdavidw · web-flow · commit 3f091457f599 · 2025-10-06T14:03:48.000+02:00
diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/csv-generate/CHANGELOG.md b/packages/csv-generate/CHANGELOG.md
@@ -258,7 +258,7 @@ New features and bug fixes:
 
 ## Version 2.0.1
 
-- package: es5 backward compatiblity
+- package: es5 backward compatibility
 - package: ignore yarn lock file
 
 ## 2.0.0
diff --git a/packages/csv-generate/package.json b/packages/csv-generate/package.json
@@ -17,7 +17,6 @@
     "@types/mocha": "^10.0.10",
     "@types/node": "^22.15.30",
     "dedent": "^1.6.0",
-    "each": "^2.7.2",
     "mocha": "~11.5.0",
     "prettier": "^3.5.3",
     "rollup": "^4.41.1",
diff --git a/packages/csv-generate/test/api.end.js b/packages/csv-generate/test/api.end.js
@@ -10,7 +10,7 @@ describe("api end", function () {
     generator.on("readable", () => {
       while (generator.read()) {
         if (end) {
-          generator.emit("error", Error("Record emited after end"));
+          generator.emit("error", Error("Record emitted after end"));
         }
         if (count++ === 5) {
           end = true;
@@ -29,7 +29,7 @@ describe("api end", function () {
     generator.on("readable", () => {
       while (generator.read()) {
         if (end) {
-          generator.emit("error", Error("Record emited after end"));
+          generator.emit("error", Error("Record emitted after end"));
         }
         if (count++ === 5) {
           end = true;
diff --git a/packages/csv-generate/test/api.sync.js b/packages/csv-generate/test/api.sync.js
@@ -2,7 +2,7 @@ import "should";
 import { generate } from "../lib/sync.js";
 
 describe("api sync", function () {
-  it("throw error if options isnt provided", function () {
+  it("throw error if options isn't provided", function () {
     (() => generate()).should.throw(
       "Invalid Argument: options must be an object or an integer",
     );
@@ -11,7 +11,7 @@ describe("api sync", function () {
     );
   });
 
-  it("throw error if length isnt provided", function () {
+  it("throw error if length isn't provided", function () {
     (() => generate({})).should.throw(
       "Invalid Argument: length is not defined",
     );
diff --git a/packages/csv-generate/test/options.sleep.js b/packages/csv-generate/test/options.sleep.js
@@ -13,7 +13,7 @@ describe("Option `sleep`", function () {
   });
 
   it("sleep combined with length and objectMode false", function (next) {
-    // Fix bug where chuncks where emited after end when sleep is activated
+    // Fix bug where chunks where emitted after end when sleep is activated
     this.timeout(10000);
     const records = [];
     generate({
diff --git a/packages/csv-parse/CHANGELOG.md b/packages/csv-parse/CHANGELOG.md
@@ -320,7 +320,7 @@ See also [CSV package for Node.js version 6 (11/15/2021)](https://www.adaltas.co
 
 ## Version 4.16.0
 
-- fix: info print the number of encountered line when emited
+- fix: info print the number of encountered line when emitted
 - feat: cast expose context.empty_lines
 - fix: handle empty column names properly
 - feat: enforce usage of columns with columns_duplicates_to_array
@@ -430,7 +430,7 @@ New feature:
 
 Project management:
 
-- samples: new file recipie
+- samples: new file recipe
 
 ## Version 4.9.1
 
diff --git a/packages/csv-parse/lib/api/index.js b/packages/csv-parse/lib/api/index.js
@@ -306,7 +306,7 @@ const transform = function (original_options = {}) {
                 this.info.comment_lines++;
                 // Skip full comment line
               } else {
-                // Activate records emition if above from_line
+                // Activate records emission if above from_line
                 if (
                   this.state.enabled === false &&
                   this.info.lines +
diff --git a/packages/csv-parse/lib/index.d.ts b/packages/csv-parse/lib/index.d.ts
@@ -56,7 +56,7 @@ export interface Info {
 
 export interface InfoCallback extends Info {
   /**
-   * Normalized verion of `options.columns` when `options.columns` is true, boolean otherwise.
+   * Normalized version of `options.columns` when `options.columns` is true, boolean otherwise.
    */
   readonly columns: boolean | { name: string }[] | { disabled: true }[];
 }
@@ -178,7 +178,7 @@ export interface OptionsNormalized<T = string[], U = T> {
    */
   ltrim: boolean;
   /**
-   * Maximum numer of characters to be contained in the field and line buffers before an exception is raised,
+   * Maximum number of characters to be contained in the field and line buffers before an exception is raised,
    * used to guard against a wrong delimiter or record_delimiter,
    * default to 128000 characters.
    */
@@ -354,7 +354,7 @@ export interface Options<T = string[], U = T> {
    */
   ltrim?: boolean | null;
   /**
-   * Maximum numer of characters to be contained in the field and line buffers before an exception is raised,
+   * Maximum number of characters to be contained in the field and line buffers before an exception is raised,
    * used to guard against a wrong delimiter or record_delimiter,
    * default to 128000 characters.
    */
@@ -370,7 +370,7 @@ export interface Options<T = string[], U = T> {
   on_record?: (record: U, context: InfoRecord) => T | null | undefined | U;
   onRecord?: (record: U, context: InfoRecord) => T | null | undefined | U;
   /**
-   * Function called when an error occured if the `skip_records_with_error`
+   * Function called when an error occurred if the `skip_records_with_error`
    * option is activated.
    */
   on_skip?: (err: CsvError | undefined, raw: string | undefined) => undefined;
diff --git a/packages/csv-parse/lib/index.js b/packages/csv-parse/lib/index.js
@@ -124,7 +124,7 @@ const parse = function () {
       parser.write(data);
       parser.end();
     };
-    // Support Deno, Rollup doesnt provide a shim for setImmediate
+    // Support Deno, Rollup doesn't provide a shim for setImmediate
     if (typeof setImmediate === "function") {
       setImmediate(writer);
     } else {
diff --git a/packages/csv-parse/samples/async.iterator.coffee b/packages/csv-parse/samples/async.iterator.coffee
@@ -9,7 +9,7 @@ import { parse } from 'csv-parse'
     high_water_mark: 64 * 64
     length: 1000
   ).pipe parse()
-  # Intialise count
+  # Initialise count
   count = 0
   # Report start
   process.stdout.write 'start\n'
diff --git a/packages/csv-parse/samples/async.iterator.js b/packages/csv-parse/samples/async.iterator.js
@@ -8,7 +8,7 @@ import { parse } from "csv-parse";
     high_water_mark: 64 * 64,
     length: 100,
   }).pipe(parse());
-  // Intialise count
+  // Initialise count
   let count = 0;
   // Report start
   process.stdout.write("start\n");
diff --git a/packages/csv-parse/samples/option.cast.context.js b/packages/csv-parse/samples/option.cast.context.js
@@ -7,7 +7,7 @@ const data = dedent`
   2050-11-27,date2
 `;
 const records = parse(data, {
-  // The cast option exect a function which
+  // The cast option expect a function which
   // is called with two arguments,
   // the parsed value and a context object
   cast: function (value, context) {
diff --git a/packages/csv-parse/samples/option.cast.js b/packages/csv-parse/samples/option.cast.js
@@ -7,7 +7,7 @@ const data = dedent`
   4,5,6
 `;
 const records = parse(data, {
-  // The cast option exect a function which
+  // The cast option expect a function which
   // is called with two arguments,
   // the parsed value and a context object
   cast: function (value, context) {
diff --git a/packages/csv-parse/test/api.assert_error.ts b/packages/csv-parse/test/api.assert_error.ts
@@ -96,9 +96,9 @@ describe("API assert_error", function () {
     (() => {
       assert_error(err, {
         code: "CSV_UNKNOWN_ERROR",
-        message: "Another mesage",
+        message: "Another message",
       });
-    }).should.throw("expected 'A message' to equal 'Another mesage'");
+    }).should.throw("expected 'A message' to equal 'Another message'");
   });
 
   it("validate a null value", function () {
diff --git a/packages/csv-parse/test/api.stream.destroy.ts b/packages/csv-parse/test/api.stream.destroy.ts
@@ -25,7 +25,7 @@ describe("API destroy", function () {
       next();
     });
     parser.on("end", () => {
-      next(Error("End event shouldnt be called"));
+      next(Error("End event shouldn't be called"));
     });
     // Note, removing =nextTick trigger both the error and end events
     process.nextTick(() => {
@@ -48,14 +48,14 @@ describe("API destroy", function () {
         next();
       });
       parser.on("end", () => {
-        next(Error("End event shouldnt be called"));
+        next(Error("End event shouldn't be called"));
       });
       fs.createReadStream(`${os.tmpdir()}/data.csv`).pipe(parser);
     });
   });
 
   it("inside readable with generator input stream", function (next) {
-    // csv-generate emit data synchronously, it cant detect error on time
+    // csv-generate emit data synchronously, it can't detect error on time
     const parser = parse() as Parser & ParserPrivate;
     parser.on("readable", function () {
       while (parser.read()) {
diff --git a/packages/csv-parse/test/api.stream.iterator.ts b/packages/csv-parse/test/api.stream.iterator.ts
@@ -12,7 +12,7 @@ describe("API stream.iterator", function () {
     records.length.should.eql(10);
   });
 
-  it("with iteractor stoped in between", async function () {
+  it("with iterator stopped in between", async function () {
     // See https://github.com/adaltas/node-csv/issues/333
     // See https://github.com/adaltas/node-csv/issues/410
     // Prevent `Error [ERR_STREAM_PREMATURE_CLOSE]: Premature close`
diff --git a/packages/csv-parse/test/api.sync.ts b/packages/csv-parse/test/api.sync.ts
@@ -95,7 +95,7 @@ describe("API sync", function () {
       records.should.eql([["1"], ["2"]]);
     });
   });
-
+  
   describe("errors", function () {
     it("catch errors", function () {
       try {
diff --git a/packages/csv-parse/test/info.comment_lines.js b/packages/csv-parse/test/info.comment_lines.js
@@ -87,7 +87,7 @@ describe("info comment_lines", function () {
     );
   });
 
-  it("one line a the begining", function (next) {
+  it("one line at the beginning", function (next) {
     parse(
       "# comment\na,b,c\nd,e,f",
       {
diff --git a/packages/csv-parse/test/option.cast.ts b/packages/csv-parse/test/option.cast.ts
@@ -47,7 +47,7 @@ describe("Option `cast`", function () {
       );
     });
 
-    it("ints isnt exposed to DOS vulnerabilities, npm security issue 69742", function (next) {
+    it("int isn't exposed to DOS vulnerabilities, npm security issue 69742", function (next) {
       const data =
         Array.from({ length: 3000000 })
           .map(() => "1")
diff --git a/packages/csv-parse/test/option.from_line.js b/packages/csv-parse/test/option.from_line.js
@@ -43,7 +43,7 @@ describe("Option `from_line`", function () {
     );
   });
 
-  it("records with quoted line at the begining of line", function (next) {
+  it("records with quoted line at the beginning of line", function (next) {
     parse(
       dedent`1,2,"
 
diff --git a/packages/csv-parse/test/option.from_line.ts b/packages/csv-parse/test/option.from_line.ts
@@ -61,7 +61,7 @@ describe("Option `from_line`", function () {
     );
   });
 
-  it("records with quoted line at the begining of line", function (next) {
+  it("records with quoted line at the beginning of line", function (next) {
     parse(
       dedent`1,2,"
 
diff --git a/packages/csv-parse/test/option.info.ts b/packages/csv-parse/test/option.info.ts
@@ -13,7 +13,7 @@ describe("Option `info`", function () {
         `,
         { info: true },
         (err, records) => {
-          // @todo: improve type definition, setting option.info as true shal
+          // @todo: improve type definition, setting option.info as true shall
           // be reflected in the return records array.
           (records as unknown as { record: string[]; info: Info }[]).map(
             ({ record, info }) => {
diff --git a/packages/csv-parse/test/option.record_delimiter.ts b/packages/csv-parse/test/option.record_delimiter.ts
@@ -112,7 +112,7 @@ describe("Option `record_delimiter`", function () {
       parser.end();
     });
 
-    it("ensure that delimiter and record_delimiter doesnt match", function (next) {
+    it("ensure that delimiter and record_delimiter doesn't match", function (next) {
       parse(
         "a;b\n11;22;\n33;33;\n",
         {
diff --git a/packages/csv-parse/test/option.relax_column_count.ts b/packages/csv-parse/test/option.relax_column_count.ts
@@ -103,7 +103,7 @@ describe("Option `relax_column_count`", function () {
     );
   });
 
-  it("with columns and from, doesnt break count and relying options like from", function (next) {
+  it("with columns and from, doesn't break count and relying options like from", function (next) {
     parse(
       dedent`
         1,2,3
diff --git a/packages/csv-stringify/CHANGELOG.md b/packages/csv-stringify/CHANGELOG.md
@@ -249,7 +249,7 @@ See [Conventional Commits](https://conventionalcommits.org) for commit guideline
 ## Version 5.6.1
 
 - fix: memory leak in sync
-- refactor: remove unsused values
+- refactor: remove unused values
 - fix: add browserify dev dep
 
 ## Version 5.6.0
@@ -486,7 +486,7 @@ Cleanup
 
 ## Version 2.0.3
 
-- package: es5 backward compatiblity
+- package: es5 backward compatibility
 - package: ignore yarn lock file
 
 ## Version 2.0.2
diff --git a/packages/csv-stringify/lib/index.d.ts b/packages/csv-stringify/lib/index.d.ts
@@ -64,7 +64,7 @@ export interface OptionsNormalized extends stream.TransformOptions {
   /**
    * List of fields, applied when `transform` returns an object
    * order matters
-   * read the transformer documentation for additionnal information
+   * read the transformer documentation for additional information
    * columns are auto discovered in the first record when the user write objects
    * can refer to nested properties of the input JSON
    * see the "header" option on how to print columns names on the first line
@@ -114,7 +114,7 @@ export interface OptionsNormalized extends stream.TransformOptions {
    */
   record_delimiter: RecordDelimiter;
   /**
-   * Boolean, default to false, if true, fields that begin with `=`, `+`, `-`, `@`, `\t`, or `\r` will be prepended with a `'` to protected agains csv injection attacks
+   * Boolean, default to false, if true, fields that begin with `=`, `+`, `-`, `@`, `\t`, or `\r` will be prepended with a `'` to protect against csv injection attacks
    */
   escape_formulas: boolean;
 }
@@ -141,7 +141,7 @@ export interface Options extends stream.TransformOptions {
   /**
    * List of fields, applied when `transform` returns an object
    * order matters
-   * read the transformer documentation for additionnal information
+   * read the transformer documentation for additional information
    * columns are auto discovered in the first record when the user write objects
    * can refer to nested properties of the input JSON
    * see the "header" option on how to print columns names on the first line
@@ -191,7 +191,7 @@ export interface Options extends stream.TransformOptions {
    */
   record_delimiter?: RecordDelimiter;
   /**
-   * Boolean, default to false, if true, fields that begin with `=`, `+`, `-`, `@`, `\t`, or `\r` will be prepended with a `'` to protected agains csv injection attacks
+   * Boolean, default to false, if true, fields that begin with `=`, `+`, `-`, `@`, `\t`, or `\r` will be prepended with a `'` to protect against csv injection attacks
    */
   escape_formulas?: boolean;
 }
diff --git a/packages/csv-stringify/lib/index.js b/packages/csv-stringify/lib/index.js
@@ -105,7 +105,7 @@ const stringify = function () {
       }
       stringifier.end();
     };
-    // Support Deno, Rollup doesnt provide a shim for setImmediate
+    // Support Deno, Rollup doesn't provide a shim for setImmediate
     if (typeof setImmediate === "function") {
       setImmediate(writer);
     } else {
diff --git a/packages/csv-stringify/package.json b/packages/csv-stringify/package.json
@@ -16,7 +16,6 @@
     "@types/node": "^22.15.30",
     "csv-generate": "^4.5.0",
     "dedent": "^1.6.0",
-    "each": "^2.7.2",
     "express": "^5.1.0",
     "mocha": "~11.5.0",
     "prettier": "^3.5.3",
diff --git a/packages/csv/package.json b/packages/csv/package.json
@@ -32,7 +32,6 @@
     "@rollup/plugin-node-resolve": "^16.0.1",
     "@types/mocha": "^10.0.10",
     "@types/node": "^22.15.30",
-    "each": "^2.7.2",
     "mocha": "~11.5.0",
     "prettier": "^3.5.3",
     "rollup": "^4.41.1",
diff --git a/packages/stream-transform/lib/index.js b/packages/stream-transform/lib/index.js
diff --git a/packages/stream-transform/lib/sync.js b/packages/stream-transform/lib/sync.js
diff --git a/packages/stream-transform/package.json b/packages/stream-transform/package.json
diff --git a/packages/stream-transform/test/api.sync.js b/packages/stream-transform/test/api.sync.js
diff --git a/packages/stream-transform/test/handler.mode.sync.js b/packages/stream-transform/test/handler.mode.sync.js
