custom/static-plugins/GlobusSW6/src/Subscriber/App/SessionSubscriber.php line 53

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace GlobusSW6\Subscriber\App;
  5. use GlobusSW6\Service\App\AppFromRequestIdentifier;
  6. use GlobusSW6\Service\App\AppService;
  7. use Psr\Log\LoggerInterface;
  8. use Shopware\Core\Framework\Util\Random;
  9. use Shopware\Core\PlatformRequest;
  10. use Shopware\Core\SalesChannelRequest;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\HeaderBag;
  13. use Symfony\Component\HttpFoundation\RequestStack;
  14. use Symfony\Component\HttpKernel\KernelEvents;
  15. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  17. class SessionSubscriber implements EventSubscriberInterface
  18. {
  19.     private RequestStack $requestStack;
  21.     /** @var AppFromRequestIdentifier */
  22.     private $appIdentifier;
  24.     /** @var LoggerInterface */
  25.     private $logger;
  27.     /** @var AppService */
  28.     private $appService;
  30.     /**
  31.      * @param RequestStack $requestStack
  32.      * @param AppFromRequestIdentifier $appIdentifier
  33.      * @param LoggerInterface $logger
  34.      * @param AppService $appService
  35.      */
  36.     public function __construct(RequestStack $requestStack, AppFromRequestIdentifier $appIdentifier, LoggerInterface $logger, AppService $appService)
  37.     {
  38.         $this->requestStack = $requestStack;
  39.         $this->appIdentifier = $appIdentifier;
  40.         $this->logger = $logger;
  41.         $this->appService = $appService;
  42.     }
  44.     public static function getSubscribedEvents(): array
  45.     {
  46.         return [
  47.             KernelEvents::REQUEST => [ // Overwrite session functionality from Storefront Subscriber
  48.                 ['startSession', 39]
  49.             ]
  50.         ];
  51.     }
  53.     public function startSession()
  54.     {
  55.         try{
  57.             $master = $this->requestStack->getMainRequest();
  59.             if (!$master) {
  60.                 return;
  61.             }
  63.             if (!$master->hasSession()) {
  64.                 return;
  65.             }
  67.             /** @var SessionInterface $session */
  68.             $session = $master->getSession();
  70.             /** @var HeaderBag $header */
  71.             $header = $master->headers;
  73.             // If FBO-route /show-header : set ianeoCurrentStore for this route -> This will enforce the twig header to contain the desired id
  74.             try {
  75.                 if (strpos($master->getPathInfo(), '/show-header') !== false){
  76.                     if (!is_null($master->get('storeId'))) {
  77.                         $session->set('ianeoCurrentStore', $master->get('storeId'));
  78.                         return;
  79.                     }
  80.                 }
  81.             } catch (\Throwable $t){
  82.                 $this->logger->info('unable to set ianeoCurrentStore for /show-header: ' . $t->getMessage());
  83.             }
  85.             if (!$this->appIdentifier->isApp($master)){
  86.                 return;
  87.             }
  89.             $device_id = $header->get('x-globus-device-id');
  90.             if (is_null($master->headers->get(PlatformRequest::HEADER_CONTEXT_TOKEN))){
  91.                 $this->appService->saveDevice($device_id, Random::getAlphanumericString(32));
  92.             } else {
  93.                 $this->appService->saveDevice($device_id, $master->headers->get(PlatformRequest::HEADER_CONTEXT_TOKEN));
  94.             }
  95.             $device = $this->appService->getAppDeviceById($device_id);
  97.             if (!$master->attributes->get(SalesChannelRequest::ATTRIBUTE_IS_SALES_CHANNEL_REQUEST) && is_null($device)) {
  98.                 return;
  99.             }
  101.             // Check if request is from app and if session-token has right value for app - if not, set sw-context-token and selected store for app
  102.             if ($this->appIdentifier->isApp($master) && $session->get(PlatformRequest::HEADER_CONTEXT_TOKEN) !== $device->getSwContextToken()) {
  103.                 $session->set(PlatformRequest::HEADER_CONTEXT_TOKEN, $device->getSwContextToken());
  104.                 $session->set('x-globus-customer', $device->getCustomerId());
  105.                 $session->set('x-globus-device-id', $device->getDeviceId());
  107.                 if (!is_null($device->getStoreLegacyId())){
  108.                     $session->set('ianeoCurrentStore', $device->getStoreLegacyId());
  109.                 }
  111.                 $master->headers->set(
  112.                     PlatformRequest::HEADER_CONTEXT_TOKEN,
  113.                     $session->get(PlatformRequest::HEADER_CONTEXT_TOKEN)
  114.                 );
  115.             }
  116.         } catch (\Throwable $t) {
  117.             $this->logger->error(__CLASS__ . ":" . __FUNCTION__ . ":" . __LINE__ . ":\$exception->getMessage(): " . $t->getMessage());
  118.         }
  119.     }
  121. }