first commit

vendor/symfony/mailer/Transport/Smtp/Stream/AbstractStream.php

@@ -0,0 +1,145 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <fabien@symfony.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\Component\Mailer\Transport\Smtp\Stream;
+
+use Symfony\Component\Mailer\Exception\TransportException;
+
+/**
+ * A stream supporting remote sockets and local processes.
+ *
+ * @author Fabien Potencier <fabien@symfony.com>
+ * @author Nicolas Grekas <p@tchwork.com>
+ * @author Chris Corbyn
+ *
+ * @internal
+ */
+abstract class AbstractStream
+{
+    /** @var resource|null */
+    protected $stream;
+    /** @var resource|null */
+    protected $in;
+    /** @var resource|null */
+    protected $out;
+    protected $err;
+
+    private string $debug = '';
+
+    public function write(string $bytes, bool $debug = true): void
+    {
+        if ($debug) {
+            foreach (explode("\n", trim($bytes)) as $line) {
+                $this->debug .= sprintf("> %s\n", $line);
+            }
+        }
+
+        $bytesToWrite = \strlen($bytes);
+        $totalBytesWritten = 0;
+        while ($totalBytesWritten < $bytesToWrite) {
+            $bytesWritten = @fwrite($this->in, substr($bytes, $totalBytesWritten));
+            if (false === $bytesWritten || 0 === $bytesWritten) {
+                throw new TransportException('Unable to write bytes on the wire.');
+            }
+
+            $totalBytesWritten += $bytesWritten;
+        }
+    }
+
+    /**
+     * Flushes the contents of the stream (empty it) and set the internal pointer to the beginning.
+     */
+    public function flush(): void
+    {
+        fflush($this->in);
+    }
+
+    /**
+     * Performs any initialization needed.
+     */
+    abstract public function initialize(): void;
+
+    public function terminate(): void
+    {
+        $this->stream = $this->err = $this->out = $this->in = null;
+    }
+
+    public function readLine(): string
+    {
+        if (feof($this->out)) {
+            return '';
+        }
+
+        $line = @fgets($this->out);
+        if ('' === $line || false === $line) {
+            $metas = stream_get_meta_data($this->out);
+            if ($metas['timed_out']) {
+                throw new TransportException(sprintf('Connection to "%s" timed out.', $this->getReadConnectionDescription()));
+            }
+            if ($metas['eof']) {
+                throw new TransportException(sprintf('Connection to "%s" has been closed unexpectedly.', $this->getReadConnectionDescription()));
+            }
+            if (false === $line) {
+                throw new TransportException(sprintf('Unable to read from connection to "%s": ', $this->getReadConnectionDescription()).error_get_last()['message']);
+            }
+        }
+
+        $this->debug .= sprintf('< %s', $line);
+
+        return $line;
+    }
+
+    public function getDebug(): string
+    {
+        $debug = $this->debug;
+        $this->debug = '';
+
+        return $debug;
+    }
+
+    public static function replace(string $from, string $to, iterable $chunks): \Generator
+    {
+        if ('' === $from) {
+            yield from $chunks;
+
+            return;
+        }
+
+        $carry = '';
+        $fromLen = \strlen($from);
+
+        foreach ($chunks as $chunk) {
+            if ('' === $chunk = $carry.$chunk) {
+                continue;
+            }
+
+            if (str_contains($chunk, $from)) {
+                $chunk = explode($from, $chunk);
+                $carry = array_pop($chunk);
+
+                yield implode($to, $chunk).$to;
+            } else {
+                $carry = $chunk;
+            }
+
+            if (\strlen($carry) > $fromLen) {
+                yield substr($carry, 0, -$fromLen);
+                $carry = substr($carry, -$fromLen);
+            }
+        }
+
+        if ('' !== $carry) {
+            yield $carry;
+        }
+    }
+
+    abstract protected function getReadConnectionDescription(): string;
+}