Task\TaskBundle\Storage\DoctrineStorage

Complexity

Total Complexity

7

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	2

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	store()	0	8	1
A	findScheduled()	0	9	1
A	findAll()	0	9	1
A	persist()	0	8	1
A	clear()	0	5	1
A	setTask()	0	7	1

<?php

namespace Task\TaskBundle\Storage;

use Doctrine\ORM\EntityManagerInterface;
use Task\Storage\StorageInterface;
use Task\TaskBundle\Entity\Task as TaskEntity;
use Task\TaskBundle\Entity\TaskRepository;
use Task\TaskInterface;

class DoctrineStorage implements StorageInterface
{
    /**
     * @var EntityManagerInterface
     */
    private $entityManager;

    /**
     * @var TaskRepository
     */
    private $taskRepository;

    public function __construct(EntityManagerInterface $entityManager, TaskRepository $taskRepository)
    {
        $this->entityManager = $entityManager;
        $this->taskRepository = $taskRepository;
    }

    /**
     * {@inheritdoc}
     */
    public function store(TaskInterface $task)
    {
        $entity = new TaskEntity();
        $this->setTask($entity, $task);

        $this->entityManager->persist($entity);
        $this->entityManager->flush();
    }

    /**
     * {@inheritdoc}
     */
    public function findScheduled()
    {
        return array_map(
            function (TaskEntity $entity) {
                return $entity->getTask();
            },
            $this->taskRepository->findScheduled()
        );
    }

    /**
     * {@inheritdoc}
     */
    public function findAll()
    {
        return array_map(
            function (TaskEntity $entity) {
                return $entity->getTask();
            },
            $this->taskRepository->findAll()
        );
    }

    /**
     * {@inheritdoc}
     */
    public function persist(TaskInterface $task)
    {
        $entity = $this->taskRepository->findByUuid($task->getUuid());
        $this->setTask($entity, $task);

        $this->entityManager->persist($entity);
        $this->entityManager->flush();
    }

    /**
     * {@inheritdoc}
     */
    public function clear()
    {
        $this->taskRepository->deleteAll();
        $this->entityManager->flush();
    }

    private function setTask(TaskEntity $entity, TaskInterface $task)
    {
        $entity->setTask($task);
        $entity->setUuid($task->getUuid());
        $entity->setCompleted($task->isCompleted());
        $entity->setExecutionDate($task->getExecutionDate());
    }
}