Sonata\NotificationBundle\Consumer\SwiftMailerConsumer

Complexity

Total Complexity

11

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	process()	0	19	4
B	sendEmail()	0	29	6

<?php

/*
 * This file is part of the Sonata Project package.
 *
 * (c) Thomas Rabaix <thomas.rabaix@sonata-project.org>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Sonata\NotificationBundle\Consumer;

use Sonata\NotificationBundle\Model\MessageInterface;

class SwiftMailerConsumer implements ConsumerInterface
{
    /**
     * @var \Swift_Mailer
     */
    protected $mailer;

    /**
     * @param \Swift_Mailer $mailer
     */
    public function __construct(\Swift_Mailer $mailer)
    {
        $this->mailer = $mailer;
    }

    /**
     * {@inheritdoc}
     */
    public function process(ConsumerEvent $event)
    {
        if (!$this->mailer->getTransport()->isStarted()) {
            $this->mailer->getTransport()->start();
        }

        $exception = false;
        try {
            $this->sendEmail($event->getMessage());
        } catch (\Exception $e) {
            $exception = $e;
        }

        $this->mailer->getTransport()->stop();

        if ($exception) {
            throw $exception;
        }
    }

    /**
     * @param MessageInterface $message
     */
    private function sendEmail(MessageInterface $message)
    {
        $mail = $this->mailer->createMessage()
            ->setSubject($message->getValue('subject'))
            ->setFrom(array($message->getValue(array('from', 'email')) => $message->getValue(array('from', 'name'))))
            ->setTo($message->getValue('to'));

        if ($replyTo = $message->getValue('replyTo')) {
            $mail->setReplyTo($replyTo);
        }

        if ($cc = $message->getValue('cc')) {
            $mail->setCc($cc);
        }

        if ($bcc = $message->getValue('bcc')) {
            $mail->setBcc($bcc);
        }

        if ($text = $message->getValue(array('message', 'text'))) {
            $mail->addPart($text, 'text/plain');
        }

        if ($html = $message->getValue(array('message', 'html'))) {
            $mail->addPart($html, 'text/html');
        }

        $this->mailer->send($mail);
    }
}