src/Platform/MarketingBundle/Listeners/UpsellListener.php line 52

Open in your IDE?
  1. <?php
  3. namespace Platform\MarketingBundle\Listeners;
  5. use Cms\CoreBundle\Service\ContextManager;
  6. use Platform\MarketingBundle\Model\ProductControllerInterface;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpFoundation\Response;
  9. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  11. use Symfony\Component\Routing\RouterInterface;
  13. /**
  14.  * Class UpsellListener
  15.  * @package Platform\MarketingBundle\EventListener
  16.  */
  17. final class UpsellListener implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var ContextManager
  21.      */
  22.     protected ContextManager $cm;
  24.     /**
  25.      * @var RouterInterface
  26.      */
  27.     protected RouterInterface $router;
  29.     /**
  30.      * @param ContextManager $cm
  31.      * @param RouterInterface $router
  32.      */
  33.     public function __construct(ContextManager $cm, RouterInterface $router)
  34.     {
  35.         $this->cm = $cm;
  36.         $this->router = $router;
  37.     }
  39.     /**
  40.      * {@inheritdoc}
  41.      */
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             KernelEvents::CONTROLLER => ['productCheck'],
  46.         ];
  47.     }
  49.     /**
  50.      * @param ControllerEvent $event
  51.      */
  52.     public function productCheck(ControllerEvent $event): void
  53.     {
  54.         // get the controller
  55.         $controller = $event->getController();
  57.         // should be an array of object then method call
  58.         if (is_array($controller) && $controller[0] instanceof ProductControllerInterface) {
  59.             // must have a tenant
  60.             $tenant = $this->cm->getGlobalContext()->getTenant();
  61.             if (empty($tenant)) {
  62.                 return;
  63.             }
  65.             // we know that we can call the interface method, which is static, on the controller
  66.             try {
  67.                 $result = $controller[0]->productCheck(
  68.                     $tenant->getProducts()
  69.                 );
  70.                 if ( ! empty($result) && ! $result instanceof Response) {
  71.                     throw new \Exception();
  72.                 }
  73.             } catch (\Exception $e) {
  74.                 $result = $e;
  75.             }
  77.             // if we have a non-empty result, need to reset the controller
  78.             // also need to stop propagation
  79.             if ( ! empty($result)) {
  80.                 $event->stopPropagation();
  81.                 $event->setController(
  82.                     function () use ($result) {
  83.                         if ($result instanceof \Exception) {
  84.                             throw $result;
  85.                         }
  87.                         return $result;
  88.                     }
  89.                 );
  90.             }
  91.         }
  92.     }
  93. }