host = $host; $this->port = $port; $this->authentication = $authentication; $this->login = $login; $this->password = $password; $this->encryption = $encryption; $this->sender = $sender; $this->reply_to = $reply_to; $this->return_path = ($return_path) ? $return_path : $this->sender['from_email']; $this->mailer = $this->buildMailer(); $this->mailer_logger = new \Swift_Plugins_Loggers_ArrayLogger(); $this->mailer->registerPlugin(new \Swift_Plugins_LoggerPlugin($this->mailer_logger)); } function send($newsletter, $subscriber, $extra_params = array()) { try { $message = $this->createMessage($newsletter, $subscriber, $extra_params); $result = $this->mailer->send($message); } catch(\Exception $e) { return Mailer::formatMailerSendErrorResult( $this->processExceptionMessage($e->getMessage()) ); } return ($result === 1) ? Mailer::formatMailerSendSuccessResult() : Mailer::formatMailerSendErrorResult($this->processLogMessage($subscriber, $extra_params)); } function buildMailer() { $transport = \Swift_SmtpTransport::newInstance( $this->host, $this->port, $this->encryption); $transport->setTimeout(self::SMTP_CONNECTION_TIMEOUT); if($this->authentication) { $transport ->setUsername($this->login) ->setPassword($this->password); } $transport = Hooks::applyFilters('mailpoet_mailer_smtp_transport_agent', $transport); return \Swift_Mailer::newInstance($transport); } function createMessage($newsletter, $subscriber, $extra_params = array()) { $message = \Swift_Message::newInstance() ->setTo($this->processSubscriber($subscriber)) ->setFrom( array( $this->sender['from_email'] => $this->sender['from_name'] ) ) ->setSender($this->sender['from_email']) ->setReplyTo( array( $this->reply_to['reply_to_email'] => $this->reply_to['reply_to_name'] ) ) ->setReturnPath($this->return_path) ->setSubject($newsletter['subject']); if(!empty($extra_params['unsubscribe_url'])) { $headers = $message->getHeaders(); $headers->addTextHeader('List-Unsubscribe', '<' . $extra_params['unsubscribe_url'] . '>'); } if(!empty($newsletter['body']['html'])) { $message = $message->setBody($newsletter['body']['html'], 'text/html'); } if(!empty($newsletter['body']['text'])) { $message = $message->addPart($newsletter['body']['text'], 'text/plain'); } return $message; } function processSubscriber($subscriber) { preg_match('!(?P.*?)\s<(?P.*?)>!', $subscriber, $subscriber_data); if(!isset($subscriber_data['email'])) { $subscriber_data = array( 'email' => $subscriber, ); } return array( $subscriber_data['email'] => (isset($subscriber_data['name'])) ? $subscriber_data['name'] : '' ); } function processLogMessage($subscriber, $extra_params = array(), $log = false) { $log = ($log) ? $log : $this->mailer_logger->dump(); // extract error message from log preg_match('/!! (.*?)>>/ism', $log, $message); if(!empty($message[1])) { $message = $message[1]; // remove line breaks from the message due to how logger's dump() method works $message = preg_replace('/\r|\n/', '', $message); } else { $message = sprintf(__('%s has returned an unknown error.', 'mailpoet'), Mailer::METHOD_SMTP); } if(empty($extra_params['test_email'])) { $message .= sprintf(' %s: %s', __('Unprocessed subscriber', 'mailpoet'), $subscriber); } return $message; } function processExceptionMessage($message) { // remove redundant information appended by Swift logger to exception messages $message = explode(PHP_EOL, $message); return $message[0]; } }