src/Subscriber/Cinema/CinemaSubscriber.php line 92

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Subscriber\Cinema;
  7. use App\Action\Query\Cinema\GetCinemaDetailList\GetCinemaDetailListQuery;
  8. use App\Event\Cinema\CinemaContextOnDemandEvent;
  9. use App\Event\Cinema\CinemaWsdlLocationChangedEvent;
  10. use App\Exception\Cinema\CinemaNotFoundException;
  11. use App\Model\Cinema;
  12. use App\Event\Cinema\CinemaContextChangedEvent;
  13. use App\Service\Context\ContextInterface;
  14. use App\Service\Factory\Client\CinemaClientFactory;
  15. use App\Ws\Cinema\CinemaClient;
  16. use App\WsProxy\WsProxy;
  17. use Ramsey\Uuid\Uuid;
  18. use Ramsey\Uuid\UuidInterface;
  19. use ReflectionClass;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. use Symfony\Component\Messenger\MessageBusInterface;
  22. use Symfony\Component\Messenger\Stamp\HandledStamp;
  23. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  25. class CinemaSubscriber implements EventSubscriberInterface
  26. {
  27.     private WsProxy $wsProxy;
  28.     private EventDispatcherInterface $eventDispatcher;
  29.     private UuidInterface $posTypeId;
  30.     private ContextInterface $context;
  31.     private CinemaClient $cinemaClient;
  32.     private MessageBusInterface $messageBus;
  33.     private CinemaClientFactory $factory;
  35.     public function __construct(
  36.         WsProxy                  $wsProxy,
  37.         EventDispatcherInterface $eventDispatcher,
  38.         string                   $posTypeId,
  39.         ContextInterface         $context,
  40.         CinemaClient             $cinemaClient,
  41.         MessageBusInterface      $messageBus,
  42.         CinemaClientFactory      $factory,
  43.     )
  44.     {
  45.         $this->wsProxy = $wsProxy;
  46.         $this->eventDispatcher = $eventDispatcher;
  47.         $this->posTypeId = Uuid::fromString($posTypeId);
  48.         $this->context = $context;
  49.         $this->cinemaClient = $cinemaClient;
  50.         $this->messageBus = $messageBus;
  51.         $this->factory = $factory;
  52.     }
  54.     public static function getSubscribedEvents()
  55.     {
  56.         return [
  57.             CinemaContextOnDemandEvent::class => 'onDemand',
  58.             CinemaWsdlLocationChangedEvent::class => 'onLocationChanged'
  59.         ];
  60.     }
  62.     public function onDemand(CinemaContextOnDemandEvent $event): void
  63.     {
  64.         $cinema = $this->messageBus->dispatch(new GetCinemaDetailListQuery())->last(HandledStamp::class)->getResult()->filter(
  65.             fn(Cinema $cinema) => strtolower((string)$cinema->getId()) === strtolower($event->getCinemaId())
  66.         )->first();
  68.         if ($cinema !== false) {
  69.             if ($cinema->getEndPointUrl() !== null) {
  70.                 $this->eventDispatcher->dispatch(new CinemaWsdlLocationChangedEvent($cinema->getEndPointUrl()));
  71.             }
  73.             $this->wsProxy->setCinemaUrl($cinema->getEndPointUrl());
  74.             $this->wsProxy->setPosTypeId($this->posTypeId);
  76.             $this->context->setCinemaId($cinema->getId());
  77.             $this->context->setPOSTypeId($this->posTypeId);
  79.             $this->eventDispatcher->dispatch(new CinemaContextChangedEvent(
  80.                 Uuid::fromString($event->getCinemaId()),
  81.                 $cinema->getEndPointUrl()
  82.             ));
  83.         } else {
  84.             throw new CinemaNotFoundException();
  85.         }
  86.     }
  88.     /**
  89.      * This method replace SOAP cinema client by client with new location (location get from Cinema object)
  90.      * It is solution instead of changeSoapLocation in old version of phpro/soap-client library
  91.      */
  92.     public function onLocationChanged(CinemaWsdlLocationChangedEvent $event): void
  93.     {
  94.         /** @var CinemaClient $client */
  95.         $client = $this->factory->createClient($event->getLocation());
  97.         $reflectionClass = new ReflectionClass(CinemaClient::class);
  98.         $callerProperty = $reflectionClass->getProperty('caller');
  99.         $callerProperty->setAccessible(true);
  100.         $callerProperty->setValue($this->cinemaClient, $callerProperty->getValue($client));
  101.     }
  102. }