vendor/shopware/core/Content/Mail/Service/MailFactory.php line 114

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Mail\Service;
  5. use League\Flysystem\FilesystemInterface;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\ConstraintBuilder;
  7. use Shopware\Core\Framework\Feature;
  8. use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
  9. use Shopware\Core\Framework\Validation\Exception\ConstraintViolationException;
  10. use Symfony\Component\Mime\Email;
  11. use Symfony\Component\Validator\ConstraintViolationList;
  12. use Symfony\Component\Validator\Validator\ValidatorInterface;
  14. class MailFactory extends AbstractMailFactory
  15. {
  16.     /**
  17.      * @var ValidatorInterface
  18.      */
  19.     private $validator;
  21.     /**
  22.      * @var FilesystemInterface
  23.      */
  24.     private $filesystem;
  26.     /**
  27.      * @internal
  28.      */
  29.     public function __construct(ValidatorInterface $validator, FilesystemInterface $filesystem)
  30.     {
  31.         $this->validator = $validator;
  32.         $this->filesystem = $filesystem;
  33.     }
  35.     public function create(
  36.         string $subject,
  37.         array $sender,
  38.         array $recipients,
  39.         array $contents,
  40.         array $attachments,
  41.         array $additionalData,
  42.         ?array $binAttachments = null
  43.     ): Email {
  44.         $this->assertValidAddresses(array_keys($recipients));
  46.         $mail = (new Email())
  47.             ->subject($subject)
  48.             ->from(...$this->formatMailAddresses($sender))
  49.             ->to(...$this->formatMailAddresses($recipients));
  51.         foreach ($contents as $contentType => $data) {
  52.             if ($contentType === 'text/html') {
  53.                 $mail->html($data);
  54.             } else {
  55.                 $mail->text($data);
  56.             }
  57.         }
  59.         $attach = Feature::isActive('v6.5.0.0') ? 'attach' : 'embed';
  61.         foreach ($attachments as $url) {
  62.             $mail->$attach($this->filesystem->read($url) ?: '', basename($url), $this->filesystem->getMimetype($url) ?: null);
  63.         }
  65.         if (isset($binAttachments)) {
  66.             foreach ($binAttachments as $binAttachment) {
  67.                 $mail->$attach(
  68.                     $binAttachment['content'],
  69.                     $binAttachment['fileName'],
  70.                     $binAttachment['mimeType']
  71.                 );
  72.             }
  73.         }
  75.         foreach ($additionalData as $key => $value) {
  76.             switch ($key) {
  77.                 case 'recipientsCc':
  78.                     $mail->addCc(...$this->formatMailAddresses([$value => $value]));
  80.                     break;
  81.                 case 'recipientsBcc':
  82.                     $mail->addBcc(...$this->formatMailAddresses([$value => $value]));
  84.                     break;
  85.                 case 'replyTo':
  86.                     $mail->addReplyTo(...$this->formatMailAddresses([$value => $value]));
  88.                     break;
  89.                 case 'returnPath':
  90.                     $mail->returnPath(...$this->formatMailAddresses([$value => $value]));
  91.             }
  92.         }
  94.         return $mail;
  95.     }
  97.     public function getDecorated(): AbstractMailFactory
  98.     {
  99.         throw new DecorationPatternException(self::class);
  100.     }
  102.     /**
  103.      * @throws ConstraintViolationException
  104.      */
  105.     private function assertValidAddresses(array $addresses): void
  106.     {
  107.         $constraints = (new ConstraintBuilder())
  108.             ->isNotBlank()
  109.             ->isEmail()
  110.             ->getConstraints();
  112.         $violations = new ConstraintViolationList();
  113.         foreach ($addresses as $address) {
  114.             $violations->addAll($this->validator->validate($address, $constraints));
  115.         }
  117.         if ($violations->count() > 0) {
  118.             throw new ConstraintViolationException($violations, $addresses);
  119.         }
  120.     }
  122.     private function formatMailAddresses(array $addresses): array
  123.     {
  124.         $formattedAddresses = [];
  125.         foreach ($addresses as $mail => $name) {
  126.             $formattedAddresses[] = $name . ' <' . $mail . '>';
  127.         }
  129.         return $formattedAddresses;
  130.     }
  131. }