| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110 |
- <?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\Mime;
- use Symfony\Component\Mime\Exception\LogicException;
- /**
- * @author Fabien Potencier <fabien@symfony.com>
- */
- class RawMessage
- {
- private bool $isGeneratorClosed;
- /**
- * @param iterable<string>|string|resource $message
- */
- public function __construct(
- private $message,
- ) {
- }
- public function __destruct()
- {
- if (\is_resource($this->message)) {
- fclose($this->message);
- }
- }
- public function toString(): string
- {
- if (\is_string($this->message)) {
- return $this->message;
- }
- if (\is_resource($this->message)) {
- return stream_get_contents($this->message, -1, 0);
- }
- $message = '';
- foreach ($this->message as $chunk) {
- $message .= $chunk;
- }
- return $this->message = $message;
- }
- public function toIterable(): iterable
- {
- if ($this->isGeneratorClosed ?? false) {
- throw new LogicException('Unable to send the email as its generator is already closed.');
- }
- if (\is_string($this->message)) {
- yield $this->message;
- return;
- }
- if (\is_resource($this->message)) {
- rewind($this->message);
- while ($line = fgets($this->message)) {
- yield $line;
- }
- return;
- }
- if ($this->message instanceof \Generator) {
- $message = fopen('php://temp', 'w+');
- foreach ($this->message as $chunk) {
- fwrite($message, $chunk);
- yield $chunk;
- }
- $this->isGeneratorClosed = !$this->message->valid();
- $this->message = $message;
- return;
- }
- foreach ($this->message as $chunk) {
- yield $chunk;
- }
- }
- /**
- * @throws LogicException if the message is not valid
- */
- public function ensureValidity(): void
- {
- }
- public function __serialize(): array
- {
- return [$this->toString()];
- }
- public function __unserialize(array $data): void
- {
- [$this->message] = $data;
- }
- }
|