Spaces:
No application file
No application file
File size: 2,229 Bytes
d2897cd |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 |
<?php
declare(strict_types=1);
namespace Mautic\EmailBundle\Tests\Helper\Transport;
use Mautic\EmailBundle\Mailer\Message\MauticMessage;
use Mautic\EmailBundle\Mailer\Transport\TokenTransportInterface;
use Mautic\EmailBundle\Mailer\Transport\TokenTransportTrait;
use Symfony\Component\Mailer\Exception\TransportException;
use Symfony\Component\Mailer\SentMessage;
use Symfony\Component\Mailer\Transport\AbstractTransport;
class BatchTransport extends AbstractTransport implements TokenTransportInterface
{
use TokenTransportTrait;
/**
* @var array<string, mixed>
*/
private $transports = []; // @phpstan-ignore-line
private $metadatas = [];
/**
* @var string[]
*/
private array $fromAddresses = [];
/**
* @var string[]
*/
private array $fromNames = [];
public function __construct(private bool $validate = false, private int $maxRecipients = 4, private int $numberToFail = 1)
{
$this->transports['main'] = $this;
}
public function __toString(): string
{
return 'batch://';
}
protected function doSend(SentMessage $message): void
{
$message = $message->getOriginalMessage();
if (!$message instanceof MauticMessage) {
return;
}
$this->metadatas[] = $message->getMetadata();
if ($this->validate && $this->numberToFail) {
--$this->numberToFail;
if (!$message->getSubject()) {
throw new TransportException('Subject empty');
}
}
$this->fromAddresses[] = !empty($message->getFrom()) ? $message->getFrom()[0]->getAddress() : null;
$this->fromNames[] = !empty($message->getFrom()) ? $message->getFrom()[0]->getName() : null;
}
public function getMaxBatchLimit(): int
{
return $this->maxRecipients;
}
public function getMetadatas(): array
{
return $this->metadatas;
}
/**
* @return string[]
*/
public function getFromAddresses(): array
{
return $this->fromAddresses;
}
/**
* @return string[]
*/
public function getFromNames(): array
{
return $this->fromNames;
}
}
|