Acme\App\Infrastructure\Persistence\Doctrine\DqlPersistenceService

Complexity

Total Complexity

14

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__invoke()	0	14	2
A	canHandle()	0	4	1
A	upsert()	0	4	1
A	delete()	0	4	1
A	startTransaction()	0	6	2
A	finishTransaction()	0	7	3
A	rollbackTransaction()	0	7	3

<?php

declare(strict_types=1);

/*
 * This file is part of the Explicit Architecture POC,
 * which is created on top of the Symfony Demo application.
 *
 * (c) Herberto Graça <herberto.graca@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Acme\App\Infrastructure\Persistence\Doctrine;

use Acme\App\Core\Port\Persistence\PersistenceServiceInterface;
use Acme\App\Core\Port\Persistence\QueryServiceInterface;
use Acme\App\Core\Port\Persistence\ResultCollection;
use Acme\App\Core\Port\Persistence\ResultCollectionInterface;
use Acme\App\Core\Port\Persistence\TransactionServiceInterface;
use Acme\PhpExtension\Helper\ClassHelper;
use Doctrine\DBAL\ConnectionException;
use Doctrine\ORM\EntityManagerInterface;

final class DqlPersistenceService implements QueryServiceInterface, PersistenceServiceInterface, TransactionServiceInterface
{
    /**
     * @var EntityManagerInterface
     */
    private $entityManager;

    /**
     * @var bool
     */
    private $autoCommit;

    public function __construct(EntityManagerInterface $entityManager, bool $autoCommit = true)
    {
        $this->entityManager = $entityManager;
        $this->autoCommit = $autoCommit;
    }

    public function __invoke(DqlQuery $dqlQuery): ResultCollectionInterface
    {
        $queryBuilder = $this->entityManager->createQueryBuilder();

        foreach ($dqlQuery->getFilters() as [$method, $arguments]) {
            $methodName = ClassHelper::extractCanonicalMethodName($method);

The variable $method does not exist. Did you forget to declare it?

            $queryBuilder->$methodName(...$arguments);

The variable $arguments does not exist. Did you forget to declare it?

        }

        $doctrineQuery = $queryBuilder->getQuery();
        $doctrineQuery->setHydrationMode($dqlQuery->getHydrationMode());

        return new ResultCollection($doctrineQuery->execute());
    }

    public function canHandle(): string
    {
        return DqlQuery::class;
    }

    public function upsert($entity): void
    {
        $this->entityManager->persist($entity);
    }

    public function delete($entity): void
    {
        $this->entityManager->remove($entity);
    }

    public function startTransaction(): void
    {
        if (!$this->autoCommit) {
            $this->entityManager->getConnection()->beginTransaction();
        }
    }

    /**
     * @throws ConnectionException
     */
    public function finishTransaction(): void
    {
        $this->entityManager->flush();
        if (!$this->autoCommit && $this->entityManager->getConnection()->isTransactionActive()) {
            $this->entityManager->getConnection()->commit();
        }
    }

    /**
     * @throws ConnectionException
     */
    public function rollbackTransaction(): void
    {
        if (!$this->autoCommit && $this->entityManager->getConnection()->isTransactionActive()) {
            $this->entityManager->getConnection()->rollBack();
        }
        $this->entityManager->clear();
    }
}