Dontdrinkandroot\Repository\TransactionalCrudRepository

Complexity

Total Complexity

11

Size/Duplication

Total Lines	118
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

80.95%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	2
A	persist()	0	8	1
A	merge()	0	8	1
A	remove()	0	8	1
A	removeById()	0	8	1
A	removeAll()	0	8	1
A	findPaginatedBy()	0	12	1
A	countAll()	0	8	1
A	getTransactionManager()	0	4	1
A	setTransactionManager()	0	4	1

<?php

namespace Dontdrinkandroot\Repository;

use Doctrine\ORM\EntityManagerInterface;
use Doctrine\ORM\Mapping;
use Doctrine\ORM\Tools\Pagination\Paginator;

/**
 * @author Philip Washington Sorst <philip@sorst.net>
 */
class TransactionalCrudRepository extends CrudRepository
{
    /**
     * @var TransactionManager
     */
    private $transactionManager;

    public function __construct(
        EntityManagerInterface $em,
        Mapping\ClassMetadata $class,
        ?TransactionManager $transactionManager = null
    ) {
        parent::__construct($em, $class);
        if (null === $transactionManager) {
            $this->transactionManager = new TransactionManager($this->getEntityManager());
        } else {
            $this->transactionManager = $transactionManager;
        }
    }

    /**
     * {@inheritdoc}
     */
    public function persist(object $entity, bool $flush = true): object
    {
        return $this->transactionManager->transactional(
            function () use ($entity, $flush) {
                return parent::persist($entity, $flush);
            }
        );
    }

    /**
     * {@inheritdoc}
     */
    public function merge(object $entity, $flush = false): object
    {
        return $this->transactionManager->transactional(
            function () use ($entity, $flush) {
                return parent::merge($entity, $flush);
            }
        );
    }

    /**
     * {@inheritdoc}
     */
    public function remove(object $entity, bool $flush = false): void
    {
        $this->transactionManager->transactional(
            function () use ($entity, $flush): void {
                parent::remove($entity, $flush);
            }
        );
    }

    /**
     * {@inheritdoc}
     */
    public function removeById($id, bool $flush = false): void
    {
        $this->transactionManager->transactional(
            function () use ($id, $flush): void {
                parent::removeById($id, $flush);
            }
        );
    }

    /**
     * {@inheritdoc}
     */
    public function removeAll(bool $flush = false, bool $iterate = true): void
    {
        $this->transactionManager->transactional(
            function () use ($flush, $iterate): void {
                parent::removeAll($flush, $iterate);
            }
        );
    }

    /**
     * {@inheritdoc}
     */
    public function findPaginatedBy(
        int $page = 1,
        int $perPage = 10,
        array $criteria = [],
        array $orderBy = null
    ): Paginator {
        return $this->transactionManager->transactional(
            function () use ($page, $perPage, $criteria, $orderBy): Paginator {
                return parent::findPaginatedBy($page, $perPage, $criteria, $orderBy);
            }
        );
    }

    /**
     * {@inheritdoc}
     */
    public function countAll(): int
    {
        return $this->transactionManager->transactional(
            function (): int {
                return parent::countAll();
            }
        );
    }

    public function getTransactionManager(): TransactionManager
    {
        return $this->transactionManager;
    }

    public function setTransactionManager(TransactionManager $transactionManager): void
    {
        $this->transactionManager = $transactionManager;
    }
}