OwlCyberSecurity - MANAGER
Edit File: ConfirmationEmailMailer.php
<?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing namespace MailPoet\Subscribers; if (!defined('ABSPATH')) exit; use MailPoet\Cron\Workers\SendingQueue\Tasks\Shortcodes; use MailPoet\Entities\SegmentEntity; use MailPoet\Entities\SubscriberEntity; use MailPoet\Mailer\MailerError; use MailPoet\Mailer\MailerFactory; use MailPoet\Mailer\MailerLog; use MailPoet\Mailer\MetaInfo; use MailPoet\Services\AuthorizedEmailsController; use MailPoet\Services\Bridge; use MailPoet\Settings\SettingsController; use MailPoet\Subscription\SubscriptionUrlFactory; use MailPoet\Util\Helpers; use MailPoet\WP\Functions as WPFunctions; use MailPoetVendor\Html2Text\Html2Text; class ConfirmationEmailMailer { const MAX_CONFIRMATION_EMAILS = 3; /** @var MailerFactory */ private $mailerFactory; /** @var WPFunctions */ private $wp; /** @var SettingsController */ private $settings; /** @var MetaInfo */ private $mailerMetaInfo; /** @var SubscribersRepository */ private $subscribersRepository; /** @var SubscriptionUrlFactory */ private $subscriptionUrlFactory; /** @var ConfirmationEmailCustomizer */ private $confirmationEmailCustomizer; /** @var array Cache for confirmation emails sent within a request */ private $sentEmails = []; public function __construct( MailerFactory $mailerFactory, WPFunctions $wp, SettingsController $settings, SubscribersRepository $subscribersRepository, SubscriptionUrlFactory $subscriptionUrlFactory, ConfirmationEmailCustomizer $confirmationEmailCustomizer ) { $this->mailerFactory = $mailerFactory; $this->wp = $wp; $this->settings = $settings; $this->mailerMetaInfo = new MetaInfo; $this->subscriptionUrlFactory = $subscriptionUrlFactory; $this->subscribersRepository = $subscribersRepository; $this->confirmationEmailCustomizer = $confirmationEmailCustomizer; } /** * Use this method if you want to make sure the confirmation email * is not sent multiple times within a single request * e.g. if sending confirmation emails from hooks * @throws \Exception if unable to send the email. */ public function sendConfirmationEmailOnce(SubscriberEntity $subscriber): bool { if (isset($this->sentEmails[$subscriber->getId()])) { return true; } return $this->sendConfirmationEmail($subscriber); } public function clearSentEmailsCache(): void { $this->sentEmails = []; } public function buildEmailData(string $subject, string $html, string $text): array { return [ 'subject' => $subject, 'body' => [ 'html' => $html, 'text' => $text, ], ]; } public function getMailBody(array $signupConfirmation, SubscriberEntity $subscriber, array $segmentNames): array { $body = nl2br($signupConfirmation['body']); // replace list of segments shortcode $body = str_replace( '[lists_to_confirm]', '<strong>' . join(', ', $segmentNames) . '</strong>', $body ); // replace activation link $body = Helpers::replaceLinkTags( $body, $this->subscriptionUrlFactory->getConfirmationUrl($subscriber), ['target' => '_blank'], 'activation_link' ); $subject = Shortcodes::process($signupConfirmation['subject'], null, null, $subscriber, null); $body = Shortcodes::process($body, null, null, $subscriber, null); //create a text version. @ is important here, Html2Text throws warnings $text = @Html2Text::convert( (mb_detect_encoding($body, 'UTF-8', true)) ? $body : mb_convert_encoding($body, 'UTF-8', mb_list_encodings()), true ); return $this->buildEmailData($subject, $body, $text); } public function getMailBodyWithCustomizer(SubscriberEntity $subscriber, array $segmentNames): array { $newsletter = $this->confirmationEmailCustomizer->getNewsletter(); $renderedNewsletter = $this->confirmationEmailCustomizer->render($newsletter); $stringBody = Helpers::joinObject($renderedNewsletter); // replace list of segments shortcode $body = (string)str_replace( '[lists_to_confirm]', join(', ', $segmentNames), $stringBody ); // replace activation link $body = (string)str_replace( [ 'http://[activation_link]', // See MAILPOET-5253 '[activation_link]', ], $this->subscriptionUrlFactory->getConfirmationUrl($subscriber), $body ); [ $html, $text, $subject, ] = Helpers::splitObject(Shortcodes::process($body, null, $newsletter, $subscriber, null)); return $this->buildEmailData($subject, $html, $text); } /** * @throws \Exception if unable to send the email. */ public function sendConfirmationEmail(SubscriberEntity $subscriber) { $signupConfirmation = $this->settings->get('signup_confirmation'); if ((bool)$signupConfirmation['enabled'] === false) { return false; } if (!$this->wp->isUserLoggedIn() && $subscriber->getConfirmationsCount() >= self::MAX_CONFIRMATION_EMAILS) { return false; } $authorizationEmailsValidation = $this->settings->get(AuthorizedEmailsController::AUTHORIZED_EMAIL_ADDRESSES_ERROR_SETTING); $unauthorizedSenderEmail = isset($authorizationEmailsValidation['invalid_sender_address']); if (Bridge::isMPSendingServiceEnabled() && $unauthorizedSenderEmail) { return false; } $segments = $subscriber->getSegments()->toArray(); $segmentNames = array_map(function(SegmentEntity $segment) { return $segment->getName(); }, $segments); $IsConfirmationEmailCustomizerEnabled = (bool)$this->settings->get(ConfirmationEmailCustomizer::SETTING_ENABLE_EMAIL_CUSTOMIZER, false); $email = $IsConfirmationEmailCustomizerEnabled ? $this->getMailBodyWithCustomizer($subscriber, $segmentNames) : $this->getMailBody($signupConfirmation, $subscriber, $segmentNames); // send email $extraParams = [ 'meta' => $this->mailerMetaInfo->getConfirmationMetaInfo($subscriber), ]; // Don't attempt to send confirmation email when sending is paused $confirmationEmailErrorMessage = __('There was an error when sending a confirmation email for your subscription. Please contact the website owner.', 'mailpoet'); if (MailerLog::isSendingPaused()) { throw new \Exception($confirmationEmailErrorMessage); } try { $defaultMailer = $this->mailerFactory->getDefaultMailer(); $result = $defaultMailer->send($email, $subscriber, $extraParams); } catch (\Exception $e) { MailerLog::processTransactionalEmailError(MailerError::OPERATION_CONNECT, $e->getMessage(), $e->getCode()); throw new \Exception($confirmationEmailErrorMessage); } if ($result['response'] === false) { if ($result['error'] instanceof MailerError && $result['error']->getLevel() === MailerError::LEVEL_HARD) { MailerLog::processTransactionalEmailError($result['error']->getOperation(), (string)$result['error']->getMessage()); } throw new \Exception($confirmationEmailErrorMessage); }; // E-mail was successfully sent we need to update the MailerLog MailerLog::incrementSentCount(); if (!$this->wp->isUserLoggedIn()) { $subscriber->setConfirmationsCount($subscriber->getConfirmationsCount() + 1); $this->subscribersRepository->persist($subscriber); $this->subscribersRepository->flush(); } $this->sentEmails[$subscriber->getId()] = true; return true; } }