vendor/shopware/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->getMasterRequest();
  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.                 $this->contextPersister->revokeAllCustomerTokens($payload['id'], $token);
  63.             }
  64.         }
  65.     }
  67.     public function onCustomerDeleted(EntityDeletedEvent $event): void
  68.     {
  69.         $master = $this->requestStack->getMasterRequest();
  71.         if (!$master) {
  72.             return;
  73.         }
  75.         $customerIds = $event->getIds();
  77.         foreach ($customerIds as $customerId) {
  78.             $this->contextPersister->revokeAllCustomerTokens($customerId);
  79.         }
  80.     }
  82.     private function customerCredentialsChanged(array $payload): bool
  83.     {
  84.         return isset($payload['password']);
  85.     }
  86. }