vendor/store.shopware.com/swagb2bplatform/components/StoreFrontAuthentication/BridgePlatform/LoginSubscriber.php line 69

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.     private LoginService $loginService;
  20.     private UserRepository $userRepository;
  22.     private CredentialsBuilderInterface $credentialsBuilder;
  24.     private RequestStack $requestStack;
  26.     private AuthStorageAdapterInterface $authStorageAdapter;
  28.     public function __construct(
  29.         LoginService $loginService,
  30.         UserRepository $userRepository,
  31.         CredentialsBuilderInterface $credentialsBuilder,
  32.         RequestStack $requestStack,
  33.         AuthStorageAdapterInterface $authStorageAdapter
  34.     ) {
  35.         $this->loginService = $loginService;
  36.         $this->userRepository = $userRepository;
  37.         $this->credentialsBuilder = $credentialsBuilder;
  38.         $this->requestStack = $requestStack;
  39.         $this->authStorageAdapter = $authStorageAdapter;
  40.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             CustomerBeforeLoginEvent::class => ['syncUserData', 10],
  46.             CustomerLoginEvent::class => 'storeIdentity',
  47.         ];
  48.     }
  50.     public function syncUserData(CustomerBeforeLoginEvent $event): void
  51.     {
  52.         if ($this->isGuestCustomerRegistration()) {
  53.             return;
  54.         }
  56.         $credentials = $this->credentialsBuilder
  57.             ->createCredentialsByEmail($event->getEmail());
  59.         try {
  60.             $userData = $this->loginService
  61.                 ->getUserDataBeforeLogin($credentials);
  62.         } catch (NotFoundException $e) {
  63.             return;
  64.         }
  66.         $this->userRepository->syncUser($userData);
  67.     }
  69.     public function storeIdentity(CustomerLoginEvent $event): void
  70.     {
  71.         $customer = $event->getCustomer();
  72.         if ($customer->getGuest()) {
  73.             return;
  74.         }
  76.         $credentials = $this->credentialsBuilder->createCredentialsByEmail($customer->getEmail());
  78.         try {
  79.             $identity = $this->loginService->getIdentityByCredentials($credentials);
  80.         } catch (NotFoundException $e) {
  81.             return;
  82.         }
  84.         $this->checkBillingAddress($identity);
  85.         $this->checkShippingAddress($identity);
  87.         $this->authStorageAdapter->setIdentity($identity);
  88.     }
  90.     /**
  91.      * @protected
  92.      */
  93.     protected function checkBillingAddress(Identity $identity): void
  94.     {
  95.         $billingAddressId = $identity->getMainBillingAddress()->id;
  96.         $this->userRepository->checkAddress(
  97.             $billingAddressId,
  98.             AddressEntity::TYPE_BILLING,
  99.             $identity->getOwnershipContext()
  100.         );
  101.     }
  103.     /**
  104.      * @protected
  105.      */
  106.     protected function checkShippingAddress(Identity $identity): void
  107.     {
  108.         $shippingAddressId = $identity->getMainShippingAddress()->id;
  109.         $this->userRepository->checkAddress(
  110.             $shippingAddressId,
  111.             AddressEntity::TYPE_SHIPPING,
  112.             $identity->getOwnershipContext()
  113.         );
  114.     }
  116.     /**
  117.      * @internal
  118.      */
  119.     protected function isGuestCustomerRegistration(): bool
  120.     {
  121.         $request = $this->requestStack->getMasterRequest();
  123.         return $request && (bool) $request->get('guest', false);
  124.     }
  125. }