Support custom EOL character on PHP 8.1+

Author: clue

.github/workflows/ci.yml

@@ -10,6 +10,7 @@ jobs:
     strategy:
       matrix:
         php:
+          - 8.1
           - 8.0
           - 7.4
           - 7.3

README.md

@@ -317,9 +317,10 @@ test,1,24
 ```
 
 The `Encoder` supports the same optional parameters as the underlying
-[`fputcsv()`](https://www.php.net/fputcsv) function.
+[`fputcsv()`](https://www.php.net/manual/en/function.fputcsv.php) function.
 This means that, by default, CSV fields will be delimited by a comma (`,`), will
-use a quote enclosure character (`"`) and a backslash escape character (`\`).
+use a quote enclosure character (`"`), a backslash escape character (`\`), and
+a Unix-style EOL (`\n` or `LF`).
 This behavior can be controlled through the optional constructor parameters:
 
 ```php
@@ -385,7 +386,7 @@ See also the [CHANGELOG](CHANGELOG.md) for details about version upgrades.
 This project aims to run on any platform and thus does not require any PHP
 extensions and supports running on legacy PHP 5.3 through current PHP 8+ and
 HHVM.
-It's *highly recommended to use PHP 7+* for this project.
+It's *highly recommended to use the latest supported PHP version PHP 7+* for this project.
 
 ## Tests
 

src/Encoder.php

@@ -17,26 +17,31 @@ class Encoder extends EventEmitter implements WritableStreamInterface
     private $delimiter;
     private $enclosure;
     private $escapeChar;
+    private $eol;
 
     /**
      * @param WritableStreamInterface $output
      * @param string                  $delimiter
      * @param string                  $enclosure
      * @param string                  $escapeChar
+     * @param string                  $eol
      * @throws \BadMethodCallException
      */
-    public function __construct(WritableStreamInterface $output, $delimiter = ',', $enclosure = '"', $escapeChar = '\\')
+    public function __construct(WritableStreamInterface $output, $delimiter = ',', $enclosure = '"', $escapeChar = '\\', $eol = "\n")
     {
-        // @codeCoverageIgnoreStart
         if ($escapeChar !== '\\' && PHP_VERSION_ID < 50504) {
-            throw new \BadMethodCallException('Custom escape character only supported on PHP 5.5.4+');
+            throw new \BadMethodCallException('Custom escape character only supported on PHP 5.5.4+'); // @codeCoverageIgnore
+        }
+
+        if ($eol !== "\n" && PHP_VERSION_ID < 80100) {
+            throw new \BadMethodCallException('Custom EOL character only supported on PHP 8.1+'); // @codeCoverageIgnore
         }
-        // @codeCoverageIgnoreEnd
 
         $this->output = $output;
         $this->delimiter = $delimiter;
         $this->enclosure = $enclosure;
         $this->escapeChar = $escapeChar;
+        $this->eol = $eol;
 
         if (!$output->isWritable()) {
             $this->close();
@@ -58,12 +63,14 @@ public function write($data)
 
         $written = false;
         if (is_array($data)) {
-            // custom escape character requires PHP 5.5.4+ (see constructor check)
+            // custom escape character requires PHP 5.5.4+, custom EOL requires PHP 8.1+ (see constructor check)
             // @codeCoverageIgnoreStart
-            if ($this->escapeChar === '\\') {
+            if ($this->escapeChar === '\\' && $this->eol === "\n") {
                 $written = fputcsv($this->temp, $data, $this->delimiter, $this->enclosure);
-            } else {
+            } elseif ($this->eol === "\n") {
                 $written = fputcsv($this->temp, $data, $this->delimiter, $this->enclosure, $this->escapeChar);
+            } else {
+                $written = fputcsv($this->temp, $data, $this->delimiter, $this->enclosure, $this->escapeChar, $this->eol);
             }
             // @codeCoverageIgnoreEnd
         }

tests/EncoderTest.php

@@ -44,6 +44,20 @@ public function testWriteArrayWithCustomDelimiter()
         $this->encoder->write(array('hello', 'world'));
     }
 
+    /**
+     * @requires PHP 8.1
+     */
+    public function testWriteArrayWithCustomEolForWindows()
+    {
+        $this->output = $this->getMockBuilder('React\Stream\WritableStreamInterface')->getMock();
+        $this->output->expects($this->once())->method('isWritable')->willReturn(true);
+        $this->encoder = new Encoder($this->output, ',', '"', '\\', "\r\n");
+
+        $this->output->expects($this->once())->method('write')->with("hello,world\r\n");
+
+        $this->encoder->write(array('hello', 'world'));
+    }
+
     public function testWriteArrayTwiceWillSeparateWithNewlineAfterEachWrite()
     {
         $this->output = $this->getMockBuilder('React\Stream\WritableStreamInterface')->getMock();