Kozikaza\MindbazBundle\SwiftMailer\MindbazTransport

Complexity

Total Complexity

14

Size/Duplication

Total Lines	138
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	setCampaign()	0	6	1
A	setInsertMissingSubscribers()	0	6	1
A	isStarted()	0	4	1
A	start()	0	3	1
A	stop()	0	3	1
C	send()	0	32	7
A	registerPlugin()	0	4	1

<?php

/*
 * This file is part of the MindbazBundle package.
 *
 * (c) David DELEVOYE <david.delevoye@adeo.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Kozikaza\MindbazBundle\SwiftMailer;

use Kozikaza\MindbazBundle\Exception\InvalidCampaignException;
use Kozikaza\MindbazBundle\Exception\MissingSubscribersException;
use Kozikaza\MindbazBundle\Manager\MessageManager;
use Kozikaza\MindbazBundle\Manager\SubscriberManager;
use Kozikaza\MindbazBundle\Model\Subscriber;

/**
 * @author Vincent Chalamon <vincent@les-tilleuls.coop>
 */
class MindbazTransport implements \Swift_Transport
{
    /**
     * @var SubscriberManager
     */
    private $subscriberManager;

    /**
     * @var MessageManager
     */
    private $messageManager;

    /**
     * @var \Swift_Events_EventDispatcher
     */
    private $eventDispatcher;

    /**
     * @var array
     */
    private $campaigns;

    /**
     * @var bool
     */
    private $insertMissingSubscribers = false;

    /**
     * @var string|null
     */
    private $campaign;

    /**
     * @param SubscriberManager             $subscriberManager
     * @param MessageManager                $messageManager
     * @param \Swift_Events_EventDispatcher $eventDispatcher
     * @param array                         $campaigns
     * @param bool                          $insertMissingSubscribers
     */
    public function __construct(SubscriberManager $subscriberManager, MessageManager $messageManager, \Swift_Events_EventDispatcher $eventDispatcher, array $campaigns, $insertMissingSubscribers)
    {
        $this->subscriberManager = $subscriberManager;
        $this->messageManager = $messageManager;
        $this->eventDispatcher = $eventDispatcher;
        $this->campaigns = $campaigns;
        $this->insertMissingSubscribers = $insertMissingSubscribers;
    }

    /**
     * @param string|null $campaign
     *
     * @return MindbazTransport
     */
    public function setCampaign($campaign = null)
    {
        $this->campaign = $campaign;

        return $this;
    }

    /**
     * @param bool $insertMissingSubscribers
     *
     * @return MindbazTransport
     */
    public function setInsertMissingSubscribers($insertMissingSubscribers)
    {
        $this->insertMissingSubscribers = $insertMissingSubscribers;

        return $this;
    }

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

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

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

    /**
     * {@inheritdoc}
     */
    public function send(\Swift_Mime_Message $message, &$failedRecipients = null)
    {
        // Security: a valid campaign is required
        if (null === $this->campaign || !array_key_exists($this->campaign, $this->campaigns)) {
            throw new InvalidCampaignException();
        }

        // Find subscribers by email addresses
        $emails = array_map('strtolower', array_keys($message->getTo()));
        $subscribers = $this->subscriberManager->findByEmail($emails);

        $invalid = array_diff($emails, array_map(function (Subscriber $subscriber) {
            return $subscriber->getEmail();
        }, $subscribers));

        // Don't insert missing subscribers
        if (false === $this->insertMissingSubscribers && 0 < count($invalid)) {
            throw new MissingSubscribersException($invalid);
        }

        // Insert missing subscribers
        foreach ($invalid as $email) {
            $subscribers[] = $this->subscriberManager->create(['email' => $email]);
        }

        // Send email
        foreach ($subscribers as $subscriber) {
            $this->messageManager->send($this->campaigns[$this->campaign], $subscriber, $message);
        }

        return count($subscribers);
    }

    /**
     * {@inheritdoc}
     */
    public function registerPlugin(\Swift_Events_EventListener $plugin)
    {
        $this->eventDispatcher->bindEventListener($plugin);
    }
}