Sylius\Behat\Service\EmailChecker

Complexity

Total Complexity

16

Size/Duplication

Total Lines	125
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	hasRecipient()	0	13	3
A	hasMessageTo()	0	15	4
A	countMessagesTo()	0	15	3
A	getSpoolDirectory()	0	4	1
A	isMessageTo()	0	4	1
A	assertRecipientIsValid()	0	10	1
A	getMessages()	0	14	2

<?php

/*
 * This file is part of the Sylius package.
 *
 * (c) Paweł Jędrzejewski
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Sylius\Behat\Service;

use Symfony\Component\Finder\Finder;
use Symfony\Component\Finder\SplFileInfo;
use Webmozart\Assert\Assert;

/**
 * @author Arkadiusz Krakowiak <arkadiusz.krakowiak@lakion.com>
 * @author Jan Góralski <jan.goralski@lakion.com>
 */
final class EmailChecker implements EmailCheckerInterface
{
    /**
     * @var string
     */
    private $spoolDirectory;

    /**
     * @param string $spoolDirectory
     */
    public function __construct($spoolDirectory)
    {
        $this->spoolDirectory = $spoolDirectory;
    }

    /**
     * {@inheritdoc}
     */
    public function hasRecipient($recipient)
    {
        $this->assertRecipientIsValid($recipient);

        $messages = $this->getMessages($this->spoolDirectory);
        foreach ($messages as $message) {
            if ($this->isMessageTo($message, $recipient)) {
                return true;
            }
        }

        return false;
    }

    /**
     * {@inheritdoc}
     */
    public function hasMessageTo($message, $recipient)
    {
        $this->assertRecipientIsValid($recipient);

        $messages = $this->getMessages($this->spoolDirectory);
        foreach ($messages as $sentMessage) {
            if ($this->isMessageTo($sentMessage, $recipient)) {
                if (false !== strpos($sentMessage->getBody(), $message)) {
                    return true;
                }
            }
        }

        return false;
    }

    /**
     * {@inheritdoc}
     */
    public function countMessagesTo($recipient)
    {
        $this->assertRecipientIsValid($recipient);

        $messagesCount = 0;

        $messages = $this->getMessages($this->spoolDirectory);
        foreach ($messages as $message) {
            if ($this->isMessageTo($message, $recipient)) {
                ++$messagesCount;
            }
        }

        return $messagesCount;
    }

    /**
     * {@inheritdoc}
     */
    public function getSpoolDirectory()
    {
        return $this->spoolDirectory;
    }

    /**
     * @param \Swift_Message $message
     * @param string $recipient
     *
     * @return bool
     */
    private function isMessageTo($message, $recipient)
    {
        return array_key_exists($recipient, $message->getTo());
    }

    /**
     * @param string $recipient
     *
     * @throws /InvalidArgumentException
     */
    private function assertRecipientIsValid($recipient)
    {
        Assert::notEmpty($recipient, 'The recipient cannot be empty.');
        Assert::string($recipient, sprintf('The recipient must be a string, %s given.', gettype($recipient)));
        Assert::notEq(
            false,
            filter_var($recipient, FILTER_VALIDATE_EMAIL),
            'Given recipient is not a valid email address.'
        );
    }

    /**
     * @param string $directory
     *
     * @return \Swift_Message[]
     */
    private function getMessages($directory)
    {
        $finder = new Finder();
        $finder->files()->name('*.message')->in($directory);
        Assert::notEq($finder->count(), 0, sprintf('No message files found in %s.', $directory));
        $messages = [];

        /** @var SplFileInfo $file */
        foreach ($finder as $file) {
            $messages[] = unserialize($file->getContents());
        }

        return $messages;
    }
}