src/EventListener/SalesChannelListener.php line 96

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace App\EventListener;
  6. use App\Contracts\HttpFoundation\RequestInfoInterface;
  7. use EightPoints\Bundle\GuzzleBundle\Events\GuzzleEventListenerInterface;
  8. use EightPoints\Bundle\GuzzleBundle\Events\PreTransactionEvent;
  9. use Psr\Http\Message\RequestInterface;
  10. use Symfony\Component\HttpKernel\Event\RequestEvent;
  12. class SalesChannelListener implements GuzzleEventListenerInterface
  13. {
  14.     const BASE_URL = '/WSVistaWebClient';
  16.     /**
  17.      * @var string
  18.      */
  19.     private $serviceName;
  21.     /**
  22.      * @var string[]
  23.      */
  24.     private $urlStack = [
  25.         '/RESTBooking.svc',
  26.         '/RESTLoyalty.svc/member/transactions',
  27.         '/RESTTicketing.svc/order',
  28.         '/orders',
  29.         '/RESTLoyalty.svc/member/validate',
  30.         '/RESTData.svc/concession-items'
  31.     ];
  33.     /** @var string[] */
  34.     private $excludeUrlStack = [
  35.         '/RESTTicketing.svc/order/cancel'
  36.     ];
  38.     /**
  39.      * @var RequestInfoInterface
  40.      */
  41.     private $requestInfo;
  43.     public function __construct(RequestInfoInterface $requestInfo)
  44.     {
  45.         $this->requestInfo = $requestInfo;
  46.     }
  48.     /**
  49.      * @inheritDoc
  50.      */
  51.     public function setServiceName($serviceName)
  52.     {
  53.         $this->serviceName = $serviceName;
  54.         return $this;
  55.     }
  57.     /**
  58.      * @return string
  59.      */
  60.     public function getServiceName()
  61.     {
  62.         return $this->serviceName;
  63.     }
  65.     private function match(string $url, array $urlStack): bool
  66.     {
  67.         foreach ($urlStack as $match) {
  68.             if (false !== strpos($url, $this::BASE_URL . $match)) {
  69.                 return true;
  70.             }
  71.         }
  73.         return false;
  74.     }
  76.     /**
  77.      * @see https://jira.scnsoft.com/browse/VAPCTCKETINGSUITE-325
  78.      *
  79.      * @param RequestInterface $transaction
  80.      *
  81.      * @return string
  82.      */
  83.     private function getPlatform(RequestInterface $transaction): ?string
  84.     {
  85.         if ($this->match($transaction->getUri()->getPath(), $this->excludeUrlStack)) {
  86.             return null;
  87.         }
  89.         if ($this->match($transaction->getUri()->getPath(), $this->urlStack)) {
  90.             return $this->requestInfo->getPlatformName();
  91.         }
  93.         return null;
  94.     }
  96.     public function onKernelRequest(RequestEvent $event)
  97.     {
  98.         $request = $event->getRequest();
  99.         $request->attributes->set($this->requestInfo::PLATFORM_ATTRIBUTE, $this->requestInfo->getPlatformName());
  100.     }
  102.     public function onPreTransaction(PreTransactionEvent $event)
  103.     {
  104.         if ($event->getServiceName() !== $this->getServiceName()) {
  105.             return null;
  106.         }
  108.         $transaction = $event->getTransaction();
  109.         if ($transaction->hasHeader('OptionalClientId') || $transaction->hasHeader('connectapitoken')) {
  110.             return null;
  111.         }
  113.         switch ($this->getPlatform($transaction)) {
  114.             case $this->requestInfo::WEB_PLATFORM:
  115.                 $modifiedRequest = $transaction
  116.                     ->withHeader('Saleschannel', getenv('VISTA_WEB_CHANNEL'))
  117.                     ->withHeader('OptionalClientId', getenv('VISTA_WEB_CLIENT_ID'))
  118.                     ->withHeader('connectapitoken', getenv('VISTA_WEB_TOKEN'));
  119.                 break;
  120.             case $this->requestInfo::MOBILE_PLATFORM:
  121.                 $modifiedRequest = $transaction
  122.                     ->withHeader('Saleschannel', getenv('VISTA_MOBILE_CHANNEL'))
  123.                     ->withHeader('OptionalClientId', getenv('VISTA_MOBILE_CLIENT_ID'))
  124.                     ->withHeader('connectapitoken', getenv('VISTA_MOBILE_TOKEN'));
  125.                 break;
  126.             default:
  127.                 $modifiedRequest = $transaction
  128.                     ->withHeader('Saleschannel', getenv('VISTA_MOBILE_CHANNEL'))
  129.                     ->withHeader('OptionalClientId', getenv('VISTA_CLIENT_ID'))
  130.                     ->withHeader('connectapitoken', getenv('VISTA_TOKEN'));
  131.                 break;
  132.         }
  133.         $event->setTransaction($modifiedRequest);
  134.     }
  135. }