vendor/symfony/notifier/Transport/AbstractTransport.php line 37

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\Notifier\Transport;
  14. use Symfony\Component\HttpClient\HttpClient;
  15. use Symfony\Component\Notifier\Event\FailedMessageEvent;
  16. use Symfony\Component\Notifier\Event\MessageEvent;
  17. use Symfony\Component\Notifier\Event\SentMessageEvent;
  18. use Symfony\Component\Notifier\Exception\LogicException;
  19. use Symfony\Component\Notifier\Message\MessageInterface;
  20. use Symfony\Component\Notifier\Message\SentMessage;
  21. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  22. use Symfony\Contracts\HttpClient\HttpClientInterface;
  24. /**
  25.  * @author Fabien Potencier <fabien@symfony.com>
  26.  */
  27. abstract class AbstractTransport implements TransportInterface
  28. {
  29.     protected const HOST = 'localhost';
  31.     private ?EventDispatcherInterface $dispatcher;
  33.     protected $client;
  34.     protected $host;
  35.     protected $port;
  37.     public function __construct(HttpClientInterface $client = null, EventDispatcherInterface $dispatcher = null)
  38.     {
  39.         $this->client = $client;
  40.         if (null === $client) {
  41.             if (!class_exists(HttpClient::class)) {
  42.                 throw new LogicException(sprintf('You cannot use "%s" as the HttpClient component is not installed. Try running "composer require symfony/http-client".', __CLASS__));
  43.             }
  45.             $this->client = HttpClient::create();
  46.         }
  48.         $this->dispatcher = $dispatcher;
  49.     }
  51.     /**
  52.      * @return $this
  53.      */
  54.     public function setHost(?string $host): static
  55.     {
  56.         $this->host = $host;
  58.         return $this;
  59.     }
  61.     /**
  62.      * @return $this
  63.      */
  64.     public function setPort(?int $port): static
  65.     {
  66.         $this->port = $port;
  68.         return $this;
  69.     }
  71.     public function send(MessageInterface $message): SentMessage
  72.     {
  73.         if (null === $this->dispatcher) {
  74.             return $this->doSend($message);
  75.         }
  77.         $this->dispatcher->dispatch(new MessageEvent($message));
  79.         try {
  80.             $sentMessage = $this->doSend($message);
  81.         } catch (\Throwable $error) {
  82.             $this->dispatcher->dispatch(new FailedMessageEvent($message, $error));
  84.             throw $error;
  85.         }
  87.         $this->dispatcher->dispatch(new SentMessageEvent($sentMessage));
  89.         return $sentMessage;
  90.     }
  92.     abstract protected function doSend(MessageInterface $message): SentMessage;
  94.     protected function getEndpoint(): string
  95.     {
  96.         return ($this->host ?: $this->getDefaultHost()).($this->port ? ':'.$this->port : '');
  97.     }
  99.     protected function getDefaultHost(): string
  100.     {
  101.         return static::HOST;
  102.     }
  103. }