fix(csv-parse): preserve multi-byte record delimiter in raw output

packages/csv-parse/dist/cjs/index.cjs

@@ -1360,6 +1360,16 @@ const transform = function (original_options = {}) {
               pos,
             );
             if (recordDelimiterLength !== 0) {
+              // Only the first byte of the record delimiter was appended to
+              // the raw buffer above; append the remaining bytes so that
+              // multi-byte delimiters such as "\r\n" are preserved in full in
+              // `raw` instead of being truncated when `pos` skips past them
+              // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+              if (raw === true) {
+                for (let i = 1; i < recordDelimiterLength; i++) {
+                  rawBuffer.append(buf[pos + i]);
+                }
+              }
               // Do not emit comments which take a full line
               const skipCommentLine =
                 this.state.commenting &&

packages/csv-parse/dist/cjs/stream.cjs

@@ -1360,6 +1360,16 @@ const transform = function (original_options = {}) {
               pos,
             );
             if (recordDelimiterLength !== 0) {
+              // Only the first byte of the record delimiter was appended to
+              // the raw buffer above; append the remaining bytes so that
+              // multi-byte delimiters such as "\r\n" are preserved in full in
+              // `raw` instead of being truncated when `pos` skips past them
+              // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+              if (raw === true) {
+                for (let i = 1; i < recordDelimiterLength; i++) {
+                  rawBuffer.append(buf[pos + i]);
+                }
+              }
               // Do not emit comments which take a full line
               const skipCommentLine =
                 this.state.commenting &&

packages/csv-parse/dist/cjs/sync.cjs

@@ -1358,6 +1358,16 @@ const transform = function (original_options = {}) {
               pos,
             );
             if (recordDelimiterLength !== 0) {
+              // Only the first byte of the record delimiter was appended to
+              // the raw buffer above; append the remaining bytes so that
+              // multi-byte delimiters such as "\r\n" are preserved in full in
+              // `raw` instead of being truncated when `pos` skips past them
+              // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+              if (raw === true) {
+                for (let i = 1; i < recordDelimiterLength; i++) {
+                  rawBuffer.append(buf[pos + i]);
+                }
+              }
               // Do not emit comments which take a full line
               const skipCommentLine =
                 this.state.commenting &&

packages/csv-parse/dist/esm/index.js

@@ -6409,6 +6409,16 @@ const transform = function (original_options = {}) {
               pos,
             );
             if (recordDelimiterLength !== 0) {
+              // Only the first byte of the record delimiter was appended to
+              // the raw buffer above; append the remaining bytes so that
+              // multi-byte delimiters such as "\r\n" are preserved in full in
+              // `raw` instead of being truncated when `pos` skips past them
+              // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+              if (raw === true) {
+                for (let i = 1; i < recordDelimiterLength; i++) {
+                  rawBuffer.append(buf[pos + i]);
+                }
+              }
               // Do not emit comments which take a full line
               const skipCommentLine =
                 this.state.commenting &&

packages/csv-parse/dist/esm/sync.js

@@ -3328,6 +3328,16 @@ const transform = function (original_options = {}) {
               pos,
             );
             if (recordDelimiterLength !== 0) {
+              // Only the first byte of the record delimiter was appended to
+              // the raw buffer above; append the remaining bytes so that
+              // multi-byte delimiters such as "\r\n" are preserved in full in
+              // `raw` instead of being truncated when `pos` skips past them
+              // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+              if (raw === true) {
+                for (let i = 1; i < recordDelimiterLength; i++) {
+                  rawBuffer.append(buf[pos + i]);
+                }
+              }
               // Do not emit comments which take a full line
               const skipCommentLine =
                 this.state.commenting &&

packages/csv-parse/dist/iife/index.js

@@ -6412,6 +6412,16 @@ var csv_parse = (function (exports) {
                           pos,
                         );
                         if (recordDelimiterLength !== 0) {
+                          // Only the first byte of the record delimiter was appended to
+                          // the raw buffer above; append the remaining bytes so that
+                          // multi-byte delimiters such as "\r\n" are preserved in full in
+                          // `raw` instead of being truncated when `pos` skips past them
+                          // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+                          if (raw === true) {
+                            for (let i = 1; i < recordDelimiterLength; i++) {
+                              rawBuffer.append(buf[pos + i]);
+                            }
+                          }
                           // Do not emit comments which take a full line
                           const skipCommentLine =
                             this.state.commenting &&

packages/csv-parse/dist/iife/sync.js

@@ -3331,6 +3331,16 @@ var csv_parse_sync = (function (exports) {
                           pos,
                         );
                         if (recordDelimiterLength !== 0) {
+                          // Only the first byte of the record delimiter was appended to
+                          // the raw buffer above; append the remaining bytes so that
+                          // multi-byte delimiters such as "\r\n" are preserved in full in
+                          // `raw` instead of being truncated when `pos` skips past them
+                          // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+                          if (raw === true) {
+                            for (let i = 1; i < recordDelimiterLength; i++) {
+                              rawBuffer.append(buf[pos + i]);
+                            }
+                          }
                           // Do not emit comments which take a full line
                           const skipCommentLine =
                             this.state.commenting &&

packages/csv-parse/dist/umd/index.js

@@ -6415,6 +6415,16 @@
                           pos,
                         );
                         if (recordDelimiterLength !== 0) {
+                          // Only the first byte of the record delimiter was appended to
+                          // the raw buffer above; append the remaining bytes so that
+                          // multi-byte delimiters such as "\r\n" are preserved in full in
+                          // `raw` instead of being truncated when `pos` skips past them
+                          // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+                          if (raw === true) {
+                            for (let i = 1; i < recordDelimiterLength; i++) {
+                              rawBuffer.append(buf[pos + i]);
+                            }
+                          }
                           // Do not emit comments which take a full line
                           const skipCommentLine =
                             this.state.commenting &&

packages/csv-parse/dist/umd/sync.js

@@ -3334,6 +3334,16 @@
                           pos,
                         );
                         if (recordDelimiterLength !== 0) {
+                          // Only the first byte of the record delimiter was appended to
+                          // the raw buffer above; append the remaining bytes so that
+                          // multi-byte delimiters such as "\r\n" are preserved in full in
+                          // `raw` instead of being truncated when `pos` skips past them
+                          // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+                          if (raw === true) {
+                            for (let i = 1; i < recordDelimiterLength; i++) {
+                              rawBuffer.append(buf[pos + i]);
+                            }
+                          }
                           // Do not emit comments which take a full line
                           const skipCommentLine =
                             this.state.commenting &&

packages/csv-parse/lib/api/index.js

@@ -336,6 +336,16 @@ const transform = function (original_options = {}) {
               pos,
             );
             if (recordDelimiterLength !== 0) {
+              // Only the first byte of the record delimiter was appended to
+              // the raw buffer above; append the remaining bytes so that
+              // multi-byte delimiters such as "\r\n" are preserved in full in
+              // `raw` instead of being truncated when `pos` skips past them
+              // below (e.g. `raw: 'a,b\r'` instead of `raw: 'a,b\r\n'`). (#332)
+              if (raw === true) {
+                for (let i = 1; i < recordDelimiterLength; i++) {
+                  rawBuffer.append(buf[pos + i]);
+                }
+              }
               // Do not emit comments which take a full line
               const skipCommentLine =
                 this.state.commenting &&

packages/csv-parse/test/option.raw.ts

@@ -56,6 +56,19 @@ describe("Option `raw`", function () {
     });
   });
 
+  it("preserves windows (CRLF) record delimiters", function (next) {
+    // The `\n` of a `\r\n` record delimiter used to be dropped from `raw`,
+    // yielding `a,b\r` instead of `a,b\r\n`. (#332)
+    parse("a,b\r\nc,d\r\n", { raw: true }, (err, records) => {
+      if (err) return next(err);
+      const raws = (
+        records as unknown as { record: string[]; raw: string }[]
+      ).map((r) => r.raw);
+      raws.should.eql(["a,b\r\n", "c,d\r\n"]);
+      next();
+    });
+  });
+
   it("preserve columns", function (next) {
     parse(
       dedent`