vendor/eightpoints/guzzle-bundle/src/Middleware/EventDispatchMiddleware.php line 58

Open in your IDE?
  1. <?php
  3. namespace EightPoints\Bundle\GuzzleBundle\Middleware;
  5. use EightPoints\Bundle\GuzzleBundle\Events\Event;
  6. use EightPoints\Bundle\GuzzleBundle\Events\PostTransactionEvent;
  7. use Exception;
  8. use GuzzleHttp\Exception\RequestException;
  9. use Psr\Http\Message\RequestInterface;
  10. use Psr\Http\Message\ResponseInterface;
  11. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  12. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface as ContractsEventDispatcherInterface;
  13. use EightPoints\Bundle\GuzzleBundle\Events\GuzzleEvents;
  14. use EightPoints\Bundle\GuzzleBundle\Events\PreTransactionEvent;
  16. /**
  17.  * Dispatches an Event using the Symfony Event Dispatcher.
  18.  * Dispatches a PRE_TRANSACTION event, before the transaction is sent
  19.  * Dispatches a POST_TRANSACTION event, when the remote hosts responds.
  20.  */
  21. class EventDispatchMiddleware
  22. {
  23.     /** @var \Symfony\Component\EventDispatcher\EventDispatcherInterface */
  24.     private $eventDispatcher;
  26.     /** @var string */
  27.     private $serviceName;
  29.     /**
  30.      * @param \Symfony\Component\EventDispatcher\EventDispatcherInterface $eventDispatcher
  31.      * @param string $serviceName
  32.      */
  33.     public function __construct(EventDispatcherInterface $eventDispatcher, string $serviceName)
  34.     {
  35.         $this->eventDispatcher = $eventDispatcher;
  36.         $this->serviceName = $serviceName;
  37.     }
  39.     /**
  40.      * @return \Closure
  41.      */
  42.     public function dispatchEvent() : \Closure
  43.     {
  44.         return function (callable $handler) {
  46.             return function (
  47.                 RequestInterface $request,
  48.                 array $options
  49.             ) use ($handler) {
  50.                 // Create the Pre Transaction event.
  51.                 $preTransactionEvent = new PreTransactionEvent($request, $this->serviceName);
  53.                 // Dispatch it through the symfony Dispatcher.
  54.                 $this->doDispatch($preTransactionEvent, GuzzleEvents::PRE_TRANSACTION);
  55.                 $this->doDispatch($preTransactionEvent, GuzzleEvents::preTransactionFor($this->serviceName));
  57.                 // Continue the handler chain.
  58.                 $promise = $handler($preTransactionEvent->getTransaction(), $options);
  60.                 // Handle the response form the server.
  61.                 return $promise->then(
  62.                     function (ResponseInterface $response) {
  63.                         // Create the Post Transaction event.
  64.                         $postTransactionEvent = new PostTransactionEvent($response, $this->serviceName);
  66.                         // Dispatch the event on the symfony event dispatcher.
  67.                         $this->doDispatch($postTransactionEvent, GuzzleEvents::POST_TRANSACTION);
  68.                         $this->doDispatch($postTransactionEvent, GuzzleEvents::postTransactionFor($this->serviceName));
  70.                         // Continue down the chain.
  71.                         return $postTransactionEvent->getTransaction();
  72.                     },
  73.                     function (Exception $reason) {
  74.                         // Get the response. The response in a RequestException can be null too.
  75.                         $response = $reason instanceof RequestException ? $reason->getResponse() : null;
  77.                         // Create the Post Transaction event.
  78.                         $postTransactionEvent = new PostTransactionEvent($response, $this->serviceName);
  80.                         // Dispatch the event on the symfony event dispatcher.
  81.                         $this->doDispatch($postTransactionEvent, GuzzleEvents::POST_TRANSACTION);
  82.                         $this->doDispatch($postTransactionEvent, GuzzleEvents::postTransactionFor($this->serviceName));
  84.                         // Continue down the chain.
  85.                         return \GuzzleHttp\Promise\Create::rejectionFor($reason);
  86.                     }
  87.                 );
  88.             };
  89.         };
  90.     }
  92.     private function doDispatch(Event $event, string $name): void
  93.     {
  94.         if ($this->eventDispatcher instanceof ContractsEventDispatcherInterface) {
  95.             $this->eventDispatcher->dispatch($event, $name);
  97.             return;
  98.         }
  100.         // BC compatibility
  101.         $this->eventDispatcher->dispatch($name, $event);
  102.     }
  103. }