vendor/shopware/core/Checkout/Customer/Subscriber/CustomerFlowEventsSubscriber.php line 45

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\Checkout\Customer\Event\CustomerChangedPaymentMethodEvent;
  7. use Shopware\Core\Checkout\Customer\Event\CustomerRegisterEvent;
  8. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  10. use Shopware\Core\Framework\Validation\DataBag\RequestDataBag;
  11. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextRestorer;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  15. /**
  16.  * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  17.  */
  18. class CustomerFlowEventsSubscriber implements EventSubscriberInterface
  19. {
  20.     private EventDispatcherInterface $dispatcher;
  22.     private SalesChannelContextRestorer $restorer;
  24.     /**
  25.      * @internal
  26.      */
  27.     public function __construct(
  28.         EventDispatcherInterface $dispatcher,
  29.         SalesChannelContextRestorer $restorer
  30.     ) {
  31.         $this->dispatcher = $dispatcher;
  32.         $this->restorer = $restorer;
  33.     }
  35.     /**
  36.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  37.      */
  38.     public static function getSubscribedEvents()
  39.     {
  40.         return [
  41.             CustomerEvents::CUSTOMER_WRITTEN_EVENT => 'onCustomerWritten',
  42.         ];
  43.     }
  45.     public function onCustomerWritten(EntityWrittenEvent $event): void
  46.     {
  47.         if ($event->getContext()->getSource() instanceof SalesChannelApiSource) {
  48.             return;
  49.         }
  51.         $payloads = $event->getPayloads();
  53.         foreach ($payloads as $payload) {
  54.             if (!empty($payload['defaultPaymentMethodId']) && empty($payload['createdAt'])) {
  55.                 $this->dispatchCustomerChangePaymentMethodEvent($payload['id'], $event);
  57.                 continue;
  58.             }
  60.             if (!empty($payload['createdAt'])) {
  61.                 $this->dispatchCustomerRegisterEvent($payload['id'], $event);
  62.             }
  63.         }
  64.     }
  66.     private function dispatchCustomerRegisterEvent(string $customerId, EntityWrittenEvent $event): void
  67.     {
  68.         $context = $event->getContext();
  69.         $salesChannelContext = $this->restorer->restoreByCustomer($customerId, $context);
  71.         if (!$customer = $salesChannelContext->getCustomer()) {
  72.             return;
  73.         }
  75.         $customerCreated = new CustomerRegisterEvent(
  76.             $salesChannelContext,
  77.             $customer
  78.         );
  80.         $this->dispatcher->dispatch($customerCreated);
  81.     }
  83.     private function dispatchCustomerChangePaymentMethodEvent(string $customerId, EntityWrittenEvent $event): void
  84.     {
  85.         $context = $event->getContext();
  86.         $salesChannelContext = $this->restorer->restoreByCustomer($customerId, $context);
  88.         if (!$customer = $salesChannelContext->getCustomer()) {
  89.             return;
  90.         }
  92.         $customerChangePaymentMethodEvent = new CustomerChangedPaymentMethodEvent(
  93.             $salesChannelContext,
  94.             $customer,
  95.             new RequestDataBag()
  96.         );
  98.         $this->dispatcher->dispatch($customerChangePaymentMethodEvent);
  99.     }
  100. }