izumi\spoolmailer\MailerTransport

Complexity

Total Complexity

9

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Test Coverage

Coverage

95.45%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	registerPlugin()	0	3	1
A	isStarted()	0	3	1
A	start()	0	2	1
A	ping()	0	3	1
A	__construct()	0	3	1
A	stop()	0	2	1
A	send()	0	13	3

<?php
/**
 * @link https://github.com/Izumi-kun/yii2-spoolmailer
 * @copyright Copyright (c) 2017 Viktor Khokhryakov
 * @license http://opensource.org/licenses/BSD-3-Clause
 */

namespace izumi\spoolmailer;

use Swift_Events_EventListener;
use Swift_Message;
use Swift_Mime_SimpleMessage;
use Swift_Transport;
use yii\base\InvalidParamException;
use yii\base\NotSupportedException;
use yii\mail\MailerInterface;

/**
 * Sends Messages using the `MailerInterface`.
 *
 * @author Viktor Khokhryakov <viktor.khokhryakov@gmail.com>
 */
class MailerTransport implements Swift_Transport
{
    /**
     * @var MailerInterface
     */
    protected $mailer;

    /**
     * FileTransport constructor.
     * @param MailerInterface $mailer
     */
    public function __construct(MailerInterface $mailer)
    {
        $this->mailer = $mailer;
    }

    /**
     * @inheritdoc
     */
    public function send(Swift_Mime_SimpleMessage $message, &$failedRecipients = null)
    {
        if (!$message instanceof Swift_Message) {
            throw new InvalidParamException('The message should be an instance of "Swift_Message".');
        }
        $failedRecipients = (array) $failedRecipients;
        $importedMessage = new ImportedMessage($message);

        if ($this->mailer->send($importedMessage)) {
            return count($importedMessage->getTo());
        } else {
            $failedRecipients = (array) $importedMessage->getTo();
            return 0;
        }
    }

    /**
     * @inheritdoc
     */
    public function isStarted()
    {
        return true;
    }

    /**
     * @inheritdoc
     */
    public function start()
    {
    }

    /**
     * @inheritdoc
     */
    public function stop()
    {
    }

    /**
     * @inheritdoc
     */
    public function registerPlugin(Swift_Events_EventListener $plugin)
    {
        throw new NotSupportedException();
    }

    /**
     * @inheritdoc
     */
    public function ping()
    {
        return true;
    }
}