platform/src/Core/Checkout/Customer/Subscriber/CustomerTokenSubscriber.php line 42

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Checkout\Customer\Subscriber;
  5. use Shopware\Core\Checkout\Customer\CustomerEvents;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  8. use Shopware\Core\PlatformRequest;
  9. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextPersister;
  10. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\RequestStack;
  14. class CustomerTokenSubscriber implements EventSubscriberInterface
  15. {
  16.     /**
  17.      * @var SalesChannelContextPersister
  18.      */
  19.     private $contextPersister;
  21.     /**
  22.      * @var RequestStack
  23.      */
  24.     private $requestStack;
  26.     public function __construct(
  27.         SalesChannelContextPersister $contextPersister,
  28.         RequestStack $requestStack
  29.     ) {
  30.         $this->contextPersister = $contextPersister;
  31.         $this->requestStack = $requestStack;
  32.     }
  34.     public static function getSubscribedEvents()
  35.     {
  36.         return [
  37.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWritten',
  38.             CustomerEvents::CUSTOMER_DELETED_EVENT => 'onCustomerDeleted',
  39.         ];
  40.     }
  42.     public function onCustomerWritten(EntityWrittenEvent $event): void
  43.     {
  44.         $master = $this->requestStack->getMainRequest();
  46.         if (!$master) {
  47.             return;
  48.         }
  50.         if (!$master->attributes->has(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT)) {
  51.             return;
  52.         }
  54.         /** @var SalesChannelContext $context */
  55.         $context = $master->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  56.         $token = $context->getToken();
  58.         $payloads = $event->getPayloads();
  60.         foreach ($payloads as $payload) {
  61.             if ($this->customerCredentialsChanged($payload)) {
  62.                 $newToken = $this->contextPersister->replace($token, $context);
  64.                 $context->assign([
  65.                     'token' => $newToken,
  66.                 ]);
  68.                 if (!$master->hasSession()) {
  69.                     return;
  70.                 }
  72.                 $session = $master->getSession();
  73.                 $session->migrate();
  74.                 $session->set('sessionId', $session->getId());
  76.                 $session->set(PlatformRequest::HEADER_CONTEXT_TOKEN, $newToken);
  77.                 $master->headers->set(PlatformRequest::HEADER_CONTEXT_TOKEN, $newToken);
  79.                 return;
  80.             }
  81.         }
  82.     }
  84.     public function onCustomerDeleted(EntityDeletedEvent $event): void
  85.     {
  86.         $master = $this->requestStack->getMainRequest();
  88.         if (!$master) {
  89.             return;
  90.         }
  92.         $customerIds = $event->getIds();
  94.         foreach ($customerIds as $customerId) {
  95.             $this->contextPersister->revokeAllCustomerTokens($customerId);
  96.         }
  97.     }
  99.     private function customerCredentialsChanged(array $payload): bool
  100.     {
  101.         return isset($payload['password']);
  102.     }
  103. }