vendor/crehler/inspirations/src/Subscriber/ProductDeleteSubscriber.php line 42

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * @copyright 2020 Crehler Sp. z o. o. <https://crehler.com>
  4.  *
  5.  * @author    Jakub Medyński <jme@crehler.com>
  6.  * @support   Crehler <support@crehler.com>
  7.  * @created   25 wrz 2020
  8.  *
  9.  * For the full copyright and license information, please view the LICENSE
  10.  * file that was distributed with this source code.
  11.  */
  13. namespace Crehler\Inspirations\Subscriber;
  15. use Crehler\Inspirations\Message\DeleteInspirationProductMessage;
  16. use Crehler\MojeBambinoEngine\Service\CrehlerContextService;
  17. use Enqueue\MessengerAdapter\EnvelopeItem\TransportConfiguration;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  20. use Symfony\Component\HttpKernel\KernelEvents;
  21. use Symfony\Component\Messenger\MessageBusInterface;
  23. class ProductDeleteSubscriber implements EventSubscriberInterface
  24. {
  25.     private MessageBusInterface $messageBus;
  27.     private CrehlerContextService $crehlerContext;
  29.     public function __construct(MessageBusInterface $messageBus, CrehlerContextService $crehlerContext)
  30.     {
  31.         $this->messageBus = $messageBus;
  32.         $this->crehlerContext = $crehlerContext;
  33.     }
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             KernelEvents::RESPONSE => 'onKernelResponse',
  39.         ];
  40.     }
  42.     public function onKernelResponse(ResponseEvent $event)
  43.     {
  44.         $uri = $event->getRequest()->getRequestUri();
  45.         $method = $event->getRequest()->getMethod();
  47.         if('DELETE' == $method)
  48.         {
  49.             $uri = explode("/", $uri);
  51.             if (in_array('api', $uri) && in_array('inspiration', $uri) && in_array('inspiration-products', $uri))
  52.             {
  53.                 $inspiration = $uri[4];
  54.                 $context = $event->getRequest()->attributes->get('sw-context');
  56.                 $message = new DeleteInspirationProductMessage();
  58.                 $message->withContext($context);
  59.                 $message->setInspirationId($inspiration);
  61.                 $this->messageBus->dispatch($message, [new TransportConfiguration(['topic' => 'crehlerinspirations'])]);
  62.             }
  63.         }
  64.     }
  65. }