get('plugins.email.mailer.engine') !== 'none'; } /** * Returns true if debugging on emails has been enabled. * * @return bool */ public static function debug() { return Grav::instance()['config']->get('plugins.email.debug') == 'true'; } /** * Creates an email message. * * @param string $subject * @param string $body * @param string $contentType * @param string $charset * @return \Swift_Message */ public function message($subject = null, $body = null, $contentType = null, $charset = null) { return new \Swift_Message($subject, $body, $contentType, $charset); } /** * Creates an attachment. * * @param string $data * @param string $filename * @param string $contentType * @return \Swift_Attachment */ public function attachment($data = null, $filename = null, $contentType = null) { return new \Swift_Attachment($data, $filename, $contentType); } /** * Creates an embedded attachment. * * @param string $data * @param string $filename * @param string $contentType * @return \Swift_EmbeddedFile */ public function embedded($data = null, $filename = null, $contentType = null) { return new \Swift_EmbeddedFile($data, $filename, $contentType); } /** * Creates an image attachment. * * @param string $data * @param string $filename * @param string $contentType * @return \Swift_Image */ public function image($data = null, $filename = null, $contentType = null) { return new \Swift_Image($data, $filename, $contentType); } /** * Send email. * * @param \Swift_Message $message * @param array|null $failedRecipients * @return int */ public function send($message, &$failedRecipients = null) { $mailer = $this->getMailer(); $result = $mailer ? $mailer->send($message, $failedRecipients) : 0; // Check if emails and debugging are both enabled. if ($mailer && $this->debug()) { $log = new Logger('email'); $locator = Grav::instance()['locator']; $log_file = $locator->findResource('log://email.log', true, true); $log->pushHandler(new StreamHandler($log_file, Logger::DEBUG)); // Append the SwiftMailer log to the log. $log->addDebug($this->getLogs()); } return $result; } /** * Build e-mail message. * * @param array $params * @param array $vars * @return \Swift_Message */ public function buildMessage(array $params, array $vars = []) { /** @var Twig $twig */ $twig = Grav::instance()['twig']; $twig->init(); /** @var Config $config */ $config = Grav::instance()['config']; /** @var Language $language */ $language = Grav::instance()['language']; // Create message object. $message = $this->message(); // Extend parameters with defaults. $params += [ 'bcc' => $config->get('plugins.email.bcc', []), 'body' => $config->get('plugins.email.body', '{% include "forms/data.html.twig" %}'), 'cc' => $config->get('plugins.email.cc', []), 'cc_name' => $config->get('plugins.email.cc_name'), 'charset' => $config->get('plugins.email.charset', 'utf-8'), 'from' => $config->get('plugins.email.from'), 'from_name' => $config->get('plugins.email.from_name'), 'content_type' => $config->get('plugins.email.content_type', 'text/html'), 'reply_to' => $config->get('plugins.email.reply_to', []), 'reply_to_name' => $config->get('plugins.email.reply_to_name'), 'subject' => !empty($vars['form']) && $vars['form'] instanceof FormInterface ? $vars['form']->page()->title() : null, 'to' => $config->get('plugins.email.to'), 'to_name' => $config->get('plugins.email.to_name'), 'process_markdown' => false, 'template' => false, 'message' => $message ]; if (!$params['to']) { throw new \RuntimeException($language->translate('PLUGIN_EMAIL.PLEASE_CONFIGURE_A_TO_ADDRESS')); } if (!$params['from']) { throw new \RuntimeException($language->translate('PLUGIN_EMAIL.PLEASE_CONFIGURE_A_FROM_ADDRESS')); } // make email configuration available to templates $vars += [ 'email' => $params, ]; // Process parameters. foreach ($params as $key => $value) { switch ($key) { case 'body': if (is_string($value)) { if (strpos($value, '{{') !== false || strpos($value, '{%') !== false) { $body = $twig->processString($value, $vars); } else { $body = $value; } if ($params['process_markdown'] && $params['content_type'] === 'text/html') { $parsedown = new Parsedown(); $body = $parsedown->text($body); } if ($params['template']) { $body = $twig->processTemplate($params['template'], ['content' => $body] + $vars); } $content_type = !empty($params['content_type']) ? $twig->processString($params['content_type'], $vars) : null; $charset = !empty($params['charset']) ? $twig->processString($params['charset'], $vars) : null; $message->setBody($body, $content_type, $charset); } elseif (is_array($value)) { foreach ($value as $body_part) { $body_part += [ 'charset' => $params['charset'], 'content_type' => $params['content_type'], ]; $body = !empty($body_part['body']) ? $twig->processString($body_part['body'], $vars) : null; if ($params['process_markdown'] && $body_part['content_type'] === 'text/html') { $parsedown = new Parsedown(); $body = $parsedown->text($body); } if (isset($body_part['template'])) { $body = $twig->processTemplate($body_part['template'], ['content' => $body] + $vars); } $content_type = !empty($body_part['content_type']) ? $twig->processString($body_part['content_type'], $vars) : null; $charset = !empty($body_part['charset']) ? $twig->processString($body_part['charset'], $vars) : null; if (!$message->getBody()) { $message->setBody($body, $content_type, $charset); } else { $message->addPart($body, $content_type, $charset); } } } break; case 'subject': if ($value) { $message->setSubject($twig->processString($language->translate($value), $vars)); } break; case 'to': if (is_string($value) && !empty($params['to_name'])) { $value = [ 'mail' => $twig->processString($value, $vars), 'name' => $twig->processString($params['to_name'], $vars), ]; } foreach ($this->parseAddressValue($value, $vars) as $address) { $message->addTo($address->mail, $address->name); } break; case 'cc': if (is_string($value) && !empty($params['cc_name'])) { $value = [ 'mail' => $twig->processString($value, $vars), 'name' => $twig->processString($params['cc_name'], $vars), ]; } foreach ($this->parseAddressValue($value, $vars) as $address) { $message->addCc($address->mail, $address->name); } break; case 'bcc': foreach ($this->parseAddressValue($value, $vars) as $address) { $message->addBcc($address->mail, $address->name); } break; case 'from': if (is_string($value) && !empty($params['from_name'])) { $value = [ 'mail' => $twig->processString($value, $vars), 'name' => $twig->processString($params['from_name'], $vars), ]; } foreach ($this->parseAddressValue($value, $vars) as $address) { $message->addFrom($address->mail, $address->name); } break; case 'reply_to': if (is_string($value) && !empty($params['reply_to_name'])) { $value = [ 'mail' => $twig->processString($value, $vars), 'name' => $twig->processString($params['reply_to_name'], $vars), ]; } foreach ($this->parseAddressValue($value, $vars) as $address) { $message->addReplyTo($address->mail, $address->name); } break; } } return $message; } /** * Return parsed e-mail address value. * * @param string|string[] $value * @param array $vars * @return array */ public function parseAddressValue($value, array $vars = []) { $parsed = []; /** @var Twig $twig */ $twig = Grav::instance()['twig']; // Single e-mail address string if (is_string($value)) { $parsed[] = (object) [ 'mail' => $twig->processString($value, $vars), 'name' => null, ]; } else { // Cast value as array $value = (array) $value; // Single e-mail address array if (!empty($value['mail'])) { $parsed[] = (object) [ 'mail' => $twig->processString($value['mail'], $vars), 'name' => !empty($value['name']) ? $twig->processString($value['name'], $vars) : NULL, ]; } // Multiple addresses (either as strings or arrays) elseif (!(empty($value['mail']) && !empty($value['name']))) { foreach ($value as $y => $itemx) { $addresses = $this->parseAddressValue($itemx, $vars); if (($address = reset($addresses))) { $parsed[] = $address; } } } } return $parsed; } /** * Return debugging logs if enabled * * @return string */ public function getLogs() { if ($this->debug()) { return $this->logger->dump(); } return ''; } /** * @internal * @return null|\Swift_Mailer */ protected function getMailer() { if (!$this->enabled()) { return null; } if (!$this->mailer) { /** @var Config $config */ $config = Grav::instance()['config']; $queue_enabled = $config->get('plugins.email.queue.enabled'); $transport = $queue_enabled === true ? $this->getQueue() : $this->getTransport(); // Create the Mailer using your created Transport $this->mailer = new \Swift_Mailer($transport); // Register the logger if we're debugging. if ($this->debug()) { $this->logger = new \Swift_Plugins_Loggers_ArrayLogger(); $this->mailer->registerPlugin(new \Swift_Plugins_LoggerPlugin($this->logger)); } } return $this->mailer; } protected static function getQueuePath() { $queue_path = Grav::instance()['locator']->findResource('user://data', true) . '/email-queue'; if (!file_exists($queue_path)) { mkdir($queue_path); } return $queue_path; } protected static function getQueue() { $queue_path = static::getQueuePath(); $spool = new \Swift_FileSpool($queue_path); $transport = new \Swift_SpoolTransport($spool); return $transport; } public static function flushQueue() { $grav = Grav::instance(); $grav['debugger']->enabled(false); $config = $grav['config']->get('plugins.email.queue'); try { $queue = static::getQueue(); $spool = $queue->getSpool(); $spool->setMessageLimit($config['flush_msg_limit']); $spool->setTimeLimit($config['flush_time_limit']); $failures = []; $result = $spool->flushQueue(static::getTransport(), $failures); return $result . ' messages flushed from queue...'; } catch (\Exception $e) { $grav['log']->error($e->getMessage()); return $e->getMessage(); } } public static function clearQueueFailures() { $grav = Grav::instance(); $grav['debugger']->enabled(false); $preferences = \Swift_Preferences::getInstance(); $preferences->setTempDir(sys_get_temp_dir()); /** @var \Swift_Transport $transport */ $transport = static::getTransport(); if (!$transport->isStarted()) { $transport->start(); } $queue_path = static::getQueuePath(); foreach (new \GlobIterator($queue_path . '/*.sending') as $file) { $final_message = $file->getPathname(); /** @var \Swift_Message $message */ $message = unserialize(file_get_contents($final_message)); echo(sprintf( 'Retrying "%s" to "%s"', $message->getSubject(), implode(', ', array_keys($message->getTo())) ) . "\n"); try { $clean = static::cloneMessage($message); $transport->send($clean); echo("sent!\n"); // DOn't want to trip up any errors from sending too fast sleep(1); } catch (\Swift_TransportException $e) { echo("ERROR: Send failed - deleting spooled message\n"); } // Remove the file unlink($final_message); } } /** * Clean copy a message * * @param \Swift_Message $message */ public static function cloneMessage($message) { $clean = new \Swift_Message(); $clean->setBoundary($message->getBoundary()); $clean->setBcc($message->getBcc()); $clean->setBody($message->getBody()); $clean->setCharset($message->getCharset()); $clean->setChildren($message->getChildren()); $clean->setContentType($message->getContentType()); $clean->setCc($message->getCc()); $clean->setDate($message->getDate()); $clean->setDescription($message->getDescription()); $clean->setEncoder($message->getEncoder()); $clean->setFormat($message->getFormat()); $clean->setFrom($message->getFrom()); $clean->setId($message->getId()); $clean->setMaxLineLength($message->getMaxLineLength()); $clean->setPriority($message->getPriority()); $clean->setReplyTo($message->getReplyTo()); $clean->setReturnPath($message->getReturnPath()); $clean->setSender($message->getSender()); $clean->setSubject($message->getSubject()); $clean->setTo($message->getTo()); $clean->setAuthMode($message->getAuthMode()); return $clean; } protected static function getTransport() { /** @var Config $config */ $config = Grav::instance()['config']; $engine = $config->get('plugins.email.mailer.engine'); // Create the Transport and initialize it. switch ($engine) { case 'smtp': $transport = new \Swift_SmtpTransport(); $options = $config->get('plugins.email.mailer.smtp'); if (!empty($options['server'])) { $transport->setHost($options['server']); } if (!empty($options['port'])) { $transport->setPort($options['port']); } if (!empty($options['encryption']) && $options['encryption'] !== 'none') { $transport->setEncryption($options['encryption']); } if (!empty($options['user'])) { $transport->setUsername($options['user']); } if (!empty($options['password'])) { $transport->setPassword($options['password']); } if (!empty($options['auth_mode'])) { $transport->setAuthMode($options['auth_mode']); } break; case 'sendmail': default: $options = $config->get('plugins.email.mailer.sendmail'); $bin = !empty($options['bin']) ? $options['bin'] : '/usr/sbin/sendmail'; $transport = new \Swift_SendmailTransport($bin); break; } return $transport; } }