Fix bug where extra normalization headers were not dropped

This bug was not caught due to a separate bug in the test logic, which is also fixed in this commit.

diff --git a/src/normalization.js b/src/normalization.js
index 62288327442630fe580481514251c576b43bdaa1..8ddbfbf17a2ca78e86e7e7ab4fe06b4c56d050e5 100644 (file)
--- a/src/normalization.js
+++ b/src/normalization.js
@@ -154,7 +154,7 @@ export class CSVNormalizer extends TransformStream {
         }
         i++;
       }
-      this.#columns.filter(c => c.index !== null); // Drop columns provided in the headers input but not in the CSV
+      this.#columns = this.#columns.filter(c => c.index !== null); // Drop columns provided in the headers input but not in the CSV
       this.#firstChunk = false;
       return;
     }

diff --git a/test/utils.js b/test/utils.js
index 45f2531defcb528856ba73a9f44a75d01fee6ee2..a56f73966f23fcb3131ec54f27e4d881275009c2 100644 (file)
--- a/test/utils.js
+++ b/test/utils.js
@@ -20,6 +20,7 @@ export function csvStreamEqualWritable(csv) {
   return new WritableStream({
     write(chunk) {
       const row = JSON.parse(chunk);
+      deepStrictEqual(row.length, csv[i].length);
       for (let j = 0; j < csv[i].length; j++) {
         deepStrictEqual(row[j], csv[i][j]);
       }