123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174 |
- <?php
- namespace Grav\Plugin;
- use Grav\Common\Data\Data;
- use Grav\Common\Plugin;
- use Grav\Plugin\Email\Email;
- use RocketTheme\Toolbox\Event\Event;
- class EmailPlugin extends Plugin
- {
- /**
- * @var Email
- */
- protected $email;
- /**
- * @return array
- */
- public static function getSubscribedEvents()
- {
- return [
- 'onPluginsInitialized' => ['onPluginsInitialized', 0],
- 'onFormProcessed' => ['onFormProcessed', 0],
- 'onTwigTemplatePaths' => ['onTwigTemplatePaths', 0],
- 'onSchedulerInitialized' => ['onSchedulerInitialized', 0],
- 'onAdminSave' => ['onAdminSave', 0],
- ];
- }
- /**
- * Initialize emailing.
- */
- public function onPluginsInitialized()
- {
- require_once __DIR__ . '/vendor/autoload.php';
- $this->email = new Email();
- if ($this->email->enabled()) {
- $this->grav['Email'] = $this->email;
- }
- }
- /**
- * Add twig paths to plugin templates.
- */
- public function onTwigTemplatePaths()
- {
- $twig = $this->grav['twig'];
- $twig->twig_paths[] = __DIR__ . '/templates';
- }
- /**
- * Force compile during save if admin plugin save
- *
- * @param Event $event
- */
- public function onAdminSave(Event $event)
- {
- /** @var Data $obj */
- $obj = $event['object'];
- if ($obj instanceof Data && $obj->blueprints()->getFilename() === 'email/blueprints') {
- $current_pw = $this->grav['config']->get('plugins.email.mailer.smtp.password');
- $new_pw = $obj->get('mailer.smtp.password');
- if (!empty($current_pw) && empty($new_pw)) {
- $obj->set('mailer.smtp.password', $current_pw);
- }
- }
- }
- /**
- * Send email when processing the form data.
- *
- * @param Event $event
- */
- public function onFormProcessed(Event $event)
- {
- $form = $event['form'];
- $action = $event['action'];
- $params = $event['params'];
- if (!$this->email->enabled()) {
- return;
- }
- switch ($action) {
- case 'email':
- // Prepare Twig variables
- $vars = array(
- 'form' => $form
- );
- // Copy files now, we need those.
- // TODO: needs an update
- $form->legacyUploads();
- $form->copyFiles();
- $this->grav->fireEvent('onEmailSend', new Event(['params' => &$params, 'vars' => &$vars]));
- if ($this->isAssocArray($params)) {
- $this->sendFormEmail($form, $params, $vars);
- } else {
- foreach ($params as $email) {
- $this->sendFormEmail($form, $email, $vars);
- }
- }
- break;
- }
- }
- /**
- * Add index job to Grav Scheduler
- * Requires Grav 1.6.0 - Scheduler
- */
- public function onSchedulerInitialized(Event $e)
- {
- if ($this->config->get('plugins.email.queue.enabled')) {
- /** @var Scheduler $scheduler */
- $scheduler = $e['scheduler'];
- $at = $this->config->get('plugins.email.queue.flush_frequency');
- $logs = 'logs/email-queue.out';
- $job = $scheduler->addFunction('Grav\Plugin\Email\Email::flushQueue', [], 'email-flushqueue');
- $job->at($at);
- $job->output($logs);
- $job->backlink('/plugins/email');
- }
- }
- protected function sendFormEmail($form, $params, $vars)
- {
- // Build message
- $message = $this->email->buildMessage($params, $vars);
- if (isset($params['attachments'])) {
- $filesToAttach = (array)$params['attachments'];
- if ($filesToAttach) foreach ($filesToAttach as $fileToAttach) {
- $filesValues = $form->value($fileToAttach);
- if ($filesValues) foreach($filesValues as $fileValues) {
- if (isset($fileValues['file'])) {
- $filename = $fileValues['file'];
- } else {
- $filename = ROOT_DIR . $fileValues['path'];
- }
- try {
- $message->attach(\Swift_Attachment::fromPath($filename));
- } catch (\Exception $e) {
- // Log any issues
- $this->grav['log']->error($e->getMessage());
- }
- }
- }
- }
- // Send e-mail
- $this->email->send($message);
- }
- protected function isAssocArray(array $arr)
- {
- if (array() === $arr) return false;
- $keys = array_keys($arr);
- $index_keys = range(0, count($arr) - 1);
- return $keys !== $index_keys;
- }
- }
|