custom/plugins/SwagB2bPlatform/components/StoreFrontAuthentication/BridgePlatform/LoginSubscriber.php line 84

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\B2B\StoreFrontAuthentication\BridgePlatform;
  5. use Shopware\B2B\Address\Framework\AddressEntity;
  6. use Shopware\B2B\Common\Repository\NotFoundException;
  7. use Shopware\B2B\StoreFrontAuthentication\Framework\AuthStorageAdapterInterface;
  8. use Shopware\B2B\StoreFrontAuthentication\Framework\CredentialsBuilderInterface;
  9. use Shopware\B2B\StoreFrontAuthentication\Framework\Identity;
  10. use Shopware\B2B\StoreFrontAuthentication\Framework\LoginService;
  11. use Shopware\Core\Checkout\Customer\Event\CustomerBeforeLoginEvent;
  12. use Shopware\Core\Checkout\Customer\Event\CustomerLoginEvent;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpFoundation\RequestStack;
  16. class LoginSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var LoginService
  20.      */
  21.     private $loginService;
  23.     /**
  24.      * @var UserRepository
  25.      */
  26.     private $userRepository;
  28.     /**
  29.      * @var CredentialsBuilderInterface
  30.      */
  31.     private $credentialsBuilder;
  33.     /**
  34.      * @var RequestStack
  35.      */
  36.     private $requestStack;
  38.     /**
  39.      * @var AuthStorageAdapterInterface
  40.      */
  41.     private $authStorageAdapter;
  43.     public function __construct(
  44.         LoginService $loginService,
  45.         UserRepository $userRepository,
  46.         CredentialsBuilderInterface $credentialsBuilder,
  47.         RequestStack $requestStack,
  48.         AuthStorageAdapterInterface $authStorageAdapter
  49.     ) {
  50.         $this->loginService = $loginService;
  51.         $this->userRepository = $userRepository;
  52.         $this->credentialsBuilder = $credentialsBuilder;
  53.         $this->requestStack = $requestStack;
  54.         $this->authStorageAdapter = $authStorageAdapter;
  55.     }
  57.     public static function getSubscribedEvents(): array
  58.     {
  59.         return [
  60.             CustomerBeforeLoginEvent::class => ['syncUserData', 10],
  61.             CustomerLoginEvent::class => 'storeIdentity',
  62.         ];
  63.     }
  65.     public function syncUserData(CustomerBeforeLoginEvent $event): void
  66.     {
  67.         if ($this->isGuestCustomerRegistration()) {
  68.             return;
  69.         }
  71.         $credentials = $this->credentialsBuilder
  72.             ->createCredentialsByEmail($event->getEmail());
  74.         try {
  75.             $userData = $this->loginService
  76.                 ->getUserDataBeforeLogin($credentials);
  77.         } catch (NotFoundException $e) {
  78.             return;
  79.         }
  81.         $this->userRepository->syncUser($userData);
  82.     }
  84.     public function storeIdentity(CustomerLoginEvent $event): void
  85.     {
  86.         $customer = $event->getCustomer();
  87.         if ($customer->getGuest()) {
  88.             return;
  89.         }
  91.         $credentials = $this->credentialsBuilder->createCredentialsByEmail($customer->getEmail());
  93.         try {
  94.             $identity = $this->loginService->getIdentityByCredentials($credentials);
  95.         } catch (NotFoundException $e) {
  96.             return;
  97.         }
  99.         $this->checkBillingAddress($identity);
  100.         $this->checkShippingAddress($identity);
  102.         $this->authStorageAdapter->setIdentity($identity);
  103.     }
  105.     /**
  106.      * @protected
  107.      */
  108.     protected function checkBillingAddress(Identity $identity): void
  109.     {
  110.         $billingAddressId = $identity->getMainBillingAddress()->id;
  111.         $this->userRepository->checkAddress(
  112.             $billingAddressId,
  113.             AddressEntity::TYPE_BILLING,
  114.             $identity->getOwnershipContext()
  115.         );
  116.     }
  118.     /**
  119.      * @protected
  120.      */
  121.     protected function checkShippingAddress(Identity $identity): void
  122.     {
  123.         $shippingAddressId = $identity->getMainShippingAddress()->id;
  124.         $this->userRepository->checkAddress(
  125.             $shippingAddressId,
  126.             AddressEntity::TYPE_SHIPPING,
  127.             $identity->getOwnershipContext()
  128.         );
  129.     }
  131.     /**
  132.      * @internal
  133.      */
  134.     protected function isGuestCustomerRegistration(): bool
  135.     {
  136.         $request = $this->requestStack->getMasterRequest();
  138.         return $request && (bool) $request->get('guest', false);
  139.     }
  140. }