SfCod\EmailEngineBundle\Repository\DbRepository

Complexity

Total Complexity

10

Size/Duplication

Total Lines	125
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	connect()	0	14	3
A	getSubjectTemplate()	0	4	1
A	getBodyTemplate()	0	4	1
A	getSenderNameTemplate()	0	4	1
A	getSenderEmailTemplate()	0	4	1
A	applyArguments()	0	10	2

<?php

namespace SfCod\EmailEngineBundle\Repository;

use Doctrine\ORM\EntityManagerInterface;
use SfCod\EmailEngineBundle\Entity\EmailEntityInterface;
use SfCod\EmailEngineBundle\Exception\RepositoryUnavailableException;
use SfCod\EmailEngineBundle\Template\TemplateInterface;
use Twig_Environment;

/**
 * Class DbRepository
 *
 * @author Virchenko Maksim <muslim1992@gmail.com>
 *
 * @package SfCod\EmailEngineBundle\Repository
 */
class DbRepository implements RepositoryInterface
{
    /**
     * @var EmailEntityInterface
     */
    protected $email;

    /**
     * @var EntityManagerInterface
     */
    protected $em;

    /**
     * @var Twig_Environment
     */
    protected $twig;

    /**
     * DbRepository constructor.
     *
     * @param EntityManagerInterface $em
     * @param Twig_Environment $twig
     */
    public function __construct(EntityManagerInterface $em, Twig_Environment $twig)
    {
        $this->em = $em;
        $this->twig = $twig;
    }

    /**
     * Repository initialize
     *
     * @param TemplateInterface $template
     * @param array $arguments
     *
     * @throws RepositoryUnavailableException
     */
    public function connect(TemplateInterface $template, array $arguments = [])
    {
        if (false === isset($arguments['entity'], $arguments['attribute'])) {
            throw new RepositoryUnavailableException('DbRepository configuration incorrect, "entity" and "attribute" must be configured.');
        }

        $this->email = $this->em
            ->getRepository($arguments['entity'])
            ->findOneBy([$arguments['attribute'] => get_class($template)::getSlug()]);

The method getSlug cannot be called on get_class($template) (of type string).

        if (is_null($this->email)) {
            throw new RepositoryUnavailableException(sprintf('Record with slug "%s" does not exists.', get_class($template)::getSlug()));

The method getSlug cannot be called on get_class($template) (of type string).

        }
    }

    /**
     * Get subject template
     *
     * @param array $data
     *
     * @return string
     *
     * @throws \Throwable
     */
    public function getSubjectTemplate(array $data): string
    {
        return $this->applyArguments($this->email->getTitle(), $data);
    }

    /**
     * Get body template
     *
     * @param array $data
     *
     * @return string
     *
     * @throws \Throwable
     */
    public function getBodyTemplate(array $data): string
    {
        return $this->applyArguments($this->email->getBody(), $data);
    }

    /**
     * Get sender name template
     *
     * @param array $data
     *
     * @return string
     */
    public function getSenderNameTemplate(array $data): string
    {
        return getenv('SENDER_NAME');
    }

    /**
     * Get sender email template
     *
     * @param array $data
     *
     * @return string
     */
    public function getSenderEmailTemplate(array $data): string
    {
        return getenv('SENDER_EMAIL');
    }

    /**
     * Apply arguments to string
     *
     * @param string $str
     * @param array $args
     *
     * @return string
     *
     * @throws \Throwable
     */
    protected function applyArguments(string $str, array $args): string
    {
        try {
            return $this->twig
                ->createTemplate('{% autoescape false %}' . $str . '{% endautoescape %}')
                ->render($args);
        } catch (\Throwable $e) {
            throw new RepositoryUnavailableException($e->getMessage());
        }
    }
}