vendor/crehler/arrangements/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\Arrangements\Subscriber;
  15. use Crehler\Arrangements\Message\DeleteArrangementProductMessage;
  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.     {
  45.         $uri = $event->getRequest()->getRequestUri();
  46.         $method = $event->getRequest()->getMethod();
  48.         if('DELETE' == $method)
  49.         {
  50.             $uri = explode("/", $uri);
  52.             if (in_array('api', $uri) && in_array('arrangement', $uri) && in_array('arrangement-products', $uri))
  53.             {
  54.                 $arrangement = $uri[4];
  55.                 $context = $event->getRequest()->attributes->get('sw-context');
  57.                 $message = new DeleteArrangementProductMessage();
  59.                 $message->withContext($context);
  60.                 $message->setArrangementId($arrangement);
  62.                 $this->messageBus->dispatch($message, [new TransportConfiguration(['topic' => 'crehlerarrangements'])]);
  63.             }
  64.         }
  65.     }
  66. }