newsletterConfig->isActive()) { throw new LocalizedException(__('Abonarea la newsletter nu este disponibila momentan.')); } if (!$this->emailValidator->isValid($email)) { throw new LocalizedException(__('Please enter a valid email address.')); } if ((int)$this->scopeConfig->getValue(Subscriber::XML_PATH_ALLOW_GUEST_SUBSCRIBE_FLAG, ScopeInterface::SCOPE_STORE) !== 1 && !$this->customerSession->isLoggedIn() ) { throw new LocalizedException(__( 'Sorry, but the administrator denied subscription for guests. Please register.', $this->customerUrl->getRegisterUrl() )); } $websiteId = (int)$this->storeManager->getStore()->getWebsiteId(); if ($this->customerSession->isLoggedIn() && $this->customerSession->getCustomerDataObject()->getEmail() !== $email && !$this->accountManagement->isEmailAvailable($email, $websiteId) ) { throw new LocalizedException(__('This email address is already assigned to another user.')); } $subscriber = $this->subscriberFactory->create()->loadBySubscriberEmail($email, $websiteId); if ($subscriber->getId() && (int)$subscriber->getSubscriberStatus() === Subscriber::STATUS_SUBSCRIBED) { return (string)__('Thank you for your subscription.'); } $storeId = (int)$this->storeManager->getStore()->getId(); $customerId = $this->getCustomerId($email, $websiteId); $subscriber = $customerId ? $this->subscriptionManager->subscribeCustomer($customerId, $storeId) : $this->subscriptionManager->subscribe($email, $storeId); return (int)$subscriber->getSubscriberStatus() === Subscriber::STATUS_NOT_ACTIVE ? (string)__('The confirmation request has been sent.') : (string)__('Thank you for your subscription.'); } private function getCustomerId(string $email, int $websiteId): ?int { try { return (int)$this->customerRepository->get($email, $websiteId)->getId(); } catch (NoSuchEntityException) { return null; } } }