src/EventSubscriber/Vendor/VendorPostWriteSubscriber.php line 45

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: sebastiantovar
  5.  * Date: 2019-04-03
  6.  * Time: 16:47
  7.  */
  9. namespace App\EventSubscriber\Vendor;
  11. use ApiPlatform\Core\EventListener\EventPriorities;
  12. use App\Entity\App\User;
  13. use App\Entity\App\Vendor;
  14. use App\MessageHandler\Message;
  15. use App\Services\VendorService;
  16. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpFoundation\Request;
  19. use Symfony\Component\HttpKernel\Event\ViewEvent;
  20. use Symfony\Component\HttpKernel\KernelEvents;
  21. use Symfony\Component\Messenger\MessageBusInterface;
  22. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  24. class VendorPostWriteSubscriber implements EventSubscriberInterface
  25. {
  26.     private $vendorService;
  27.     private $messageBus;
  28.     private $parameterBag;
  29.     private $tokenStorage;
  31.     /**
  32.      * VendorPostWriteSubscriber constructor.
  33.      * @param TokenStorageInterface $tokenStorage
  34.      * @param ParameterBagInterface $parameterBag
  35.      * @param VendorService $vendorService
  36.      * @param MessageBusInterface $messageBus
  37.      */
  38.     public function __construct(   TokenStorageInterface $tokenStorage,ParameterBagInterface $parameterBag, VendorService $vendorService, MessageBusInterface $messageBus ) {
  39.         $this->vendorService = $vendorService;
  40.         $this->messageBus = $messageBus;
  41.         $this->parameterBag = $parameterBag;
  42.         $this->tokenStorage = $tokenStorage;
  43.     }
  45.     public function onKernelView(ViewEvent $event)
  46.     {
  47.         $vendor = $event->getControllerResult();
  48.         $request = $event->getRequest();
  49.         $method = $request->getMethod();
  50.         $route = $request->attributes->get('_route');
  52.         if (!($vendor instanceof Vendor))
  53.             return;
  55.         if (Request::METHOD_POST === $method) {
  56.             $data=[];
  57.             $userCurrent = $this->tokenStorage->getToken()->getUser();
  58.             $data['from'] = $this->parameterBag->has('ONBOARDING_FROM') ? $this->parameterBag->get('ONBOARDING_FROM') : null;
  59.             if(!is_null($data['from']) && $userCurrent instanceof User && in_array(trim($userCurrent->getEmail()),explode(",",$data['from']))) {
  60.                 $data["vendor"] = $vendor;
  61.                 $data["to"] = $this->parameterBag->has('ONBOARDING_TO') ? $this->parameterBag->get('ONBOARDING_TO') : null;
  62.                 $this->messageBus->dispatch(new Message(Message::NEW_VENDOR, $data));
  63.             }
  64.         }
  66.         if ('api_vendors_post_collection' == $route || 'api_vendors_put_item' == $route) {
  67.             $mediaContent = $vendor->getMediaContent();
  68.             if ($mediaContent !== null && $mediaContent !== 0)
  69.                 $this->vendorService->addMediaContent($vendor, $mediaContent);
  70.         }
  71.     }
  73.     public static function getSubscribedEvents()
  74.     {
  75.         return [
  76.             KernelEvents::VIEW => ['onKernelView', EventPriorities::POST_WRITE]
  77.         ];
  78.     }
  79. }