custom/plugins/AcrisPersistentCartCS/src/Subscriber/ResponseSubscriber.php line 38

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Acris\PersistentCart\Subscriber;
  5. use Acris\PersistentCart\Framework\Cookie\PersistentCartCookieProvider;
  6. use Shopware\Core\Framework\Event\BeforeSendResponseEvent;
  7. use Shopware\Core\PlatformRequest;
  8. use Shopware\Core\SalesChannelRequest;
  9. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  10. use Shopware\Storefront\Framework\Cache\CacheResponseSubscriber;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\Cookie;
  13. use Symfony\Component\HttpFoundation\RequestStack;
  14. use Symfony\Component\HttpKernel\KernelEvents;
  16. class ResponseSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var RequestStack
  20.      */
  21.     private $requestStack;
  23.     public function __construct(RequestStack $requestStack)
  24.     {
  25.         $this->requestStack = $requestStack;
  26.     }
  28.     public static function getSubscribedEvents()
  29.     {
  30.         return [
  31.             KernelEvents::REQUEST => [
  32.                 ['setSessionToken', 60]
  33.             ],
  34.             BeforeSendResponseEvent::class => 'setAcrisPersistentCartResponseCookie'
  35.         ];
  36.     }
  38.     public function setAcrisPersistentCartResponseCookie(BeforeSendResponseEvent $responseEvent)
  39.     {
  40.         $request = $responseEvent->getRequest();
  41.         $response = $responseEvent->getResponse();
  43.         if($response->isCacheable() !== false) {
  44.             return;
  45.         }
  47.         if(strpos($request->getPathInfo(), '/account/logout') !== false) {
  48.             $response->headers->clearCookie(PersistentCartCookieProvider::ACRIS_PERSISTENT_CART_TOKEN_COOKIE_NAME);
  49.             return;
  50.         }
  52.         if($request->headers->has(PlatformRequest::HEADER_CONTEXT_TOKEN)) {
  54.             if($request->cookies->get(PersistentCartCookieProvider::ACRIS_PERSISTENT_CART_SW_COOKIE_NAME)
  55.                 || $request->cookies->get(PersistentCartCookieProvider::ACRIS_PERSISTENT_CART_COOKIE_NAMES_COOKIE_PLUGIN)) {
  56.                 $response->headers->setCookie(
  57.                     new Cookie(
  58.                         PersistentCartCookieProvider::ACRIS_PERSISTENT_CART_TOKEN_COOKIE_NAME,
  59.                         $request->headers->get(PlatformRequest::HEADER_CONTEXT_TOKEN),
  60.                         time() + (PersistentCartCookieProvider::ACRIS_PERSISTENT_CART_COOKIE_EXPIRATION * 60 * 60 * 24)
  61.                     )
  62.                 );
  63.                 // override sw cache hash cookie expire date
  64.                 if($request->cookies->has(CacheResponseSubscriber::CONTEXT_CACHE_COOKIE)) {
  65.                     $response->headers->setCookie(
  66.                         new Cookie(
  67.                             CacheResponseSubscriber::CONTEXT_CACHE_COOKIE,
  68.                             $request->cookies->get(CacheResponseSubscriber::CONTEXT_CACHE_COOKIE),
  69.                             time() + (PersistentCartCookieProvider::ACRIS_PERSISTENT_CART_COOKIE_EXPIRATION * 60 * 60 * 24)
  70.                         )
  71.                     );
  72.                 }
  73.             } else {
  74.                 $response->headers->clearCookie(PersistentCartCookieProvider::ACRIS_PERSISTENT_CART_TOKEN_COOKIE_NAME);
  75.             }
  76.         }
  77.     }
  79.     public function setSessionToken()
  80.     {
  81.         $master = $this->requestStack->getMasterRequest();
  83.         if (!$master) {
  84.             return;
  85.         }
  86.         if (!$master->attributes->get(SalesChannelRequest::ATTRIBUTE_IS_SALES_CHANNEL_REQUEST)) {
  87.             return;
  88.         }
  90.         if (!$master->hasSession()) {
  91.             return;
  92.         }
  94.         $session = $master->getSession();
  95.         $applicationId = $master->attributes->get(PlatformRequest::ATTRIBUTE_OAUTH_CLIENT_ID);
  97.         if (!$session->isStarted()) {
  98.             $session->setName('session-' . $applicationId);
  99.             $session->start();
  100.             $session->set('sessionId', $session->getId());
  101.         }
  103.         $salesChannelId = $master->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_ID);
  104.         if ($salesChannelId === null) {
  105.             /** @var SalesChannelContext|null $salesChannelContext */
  106.             $salesChannelContext = $master->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  107.             if ($salesChannelContext !== null) {
  108.                 $salesChannelId = $salesChannelContext->getSalesChannel()->getId();
  109.             }
  110.         }
  112.         $token = $master->cookies->get(PersistentCartCookieProvider::ACRIS_PERSISTENT_CART_TOKEN_COOKIE_NAME);
  113.         if(empty($token) !== true && (!$session->has(PlatformRequest::HEADER_CONTEXT_TOKEN) || $session->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_ID) !== $salesChannelId)) {
  114.             $master->headers->set(PlatformRequest::HEADER_CONTEXT_TOKEN, $token);
  115.             $session->set(PlatformRequest::HEADER_CONTEXT_TOKEN, $token);
  116.             $session->set(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_ID, $salesChannelId);
  118.             $master->headers->set(
  119.                 PlatformRequest::HEADER_CONTEXT_TOKEN,
  120.                 $session->get(PlatformRequest::HEADER_CONTEXT_TOKEN)
  121.             );
  122.         }
  123.     }
  124. }