Stu\Orm\Transaction\ReopeningEntityManager

Complexity

Total Complexity

12

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Test Coverage

Coverage

60.71%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	beginTransaction()	0	12	3
A	flush()	0	7	2
A	getRepository()	0	7	1
A	reset()	0	3	1
A	__construct()	0	7	1
A	rollback()	0	6	2
A	commit()	0	6	2

<?php

namespace Stu\Orm\Transaction;

use Doctrine\ORM\Configuration;
use Doctrine\ORM\Decorator\EntityManagerDecorator;
use Doctrine\ORM\EntityRepository;
use Override;

The type Override was not found. Maybe you did not declare it correctly or list all dependencies?

use Stu\Module\Logging\LoggerUtilFactoryInterface;
use Stu\Module\Logging\LoggerUtilInterface;
use Stu\Orm\Transaction\EntityManagerFactoryInterface;

class ReopeningEntityManager extends EntityManagerDecorator
{
    private LoggerUtilInterface $logger;

    public function __construct(
        private EntityManagerFactoryInterface $entityManagerFactory,
        private Configuration $configuration,
        LoggerUtilFactoryInterface $loggerUtilFactory
    ) {
        parent::__construct($entityManagerFactory->createEntityManager());
        $this->logger = $loggerUtilFactory->getLoggerUtil(true);
    }

    private function reset(): void
    {
        $this->wrapped = $this->entityManagerFactory->createEntityManager();

It seems like $this->entityManagerFactory->createEntityManager() of type Doctrine\ORM\EntityManagerInterface is incompatible with the declared type Doctrine\Persistence\TObjectManager of property $wrapped.

    }

    #[Override]
    public function getRepository(string $className): EntityRepository
    {
        return $this
            ->configuration
            ->getRepositoryFactory()
            ->getRepository($this, $className);
    }

    #[Override]
    public function beginTransaction(): void
    {
        if (!$this->wrapped->isOpen()) {
            $this->logger->log('!!! TRANSACTION_CLOSED: now resetting!');
            $this->reset();
            $this->logger->log('!!! TRANSACTION_RESETTED');
        }

        if (!$this->wrapped->getConnection()->isTransactionActive()) {
            //$this->logger->log('BEGIN_TRANSACTION');
            $this->wrapped->beginTransaction();
        }
    }

    #[Override]
    public function flush(): void
    {
        if ($this->wrapped->isOpen()) {
            $this->wrapped->flush();
        } else {
            throw new TransactionException('entity manager is closed.');
        }
    }

    #[Override]
    public function commit(): void
    {
        if ($this->wrapped->getConnection()->isTransactionActive()) {
            //$this->logger->log('COMMIT_TRANSACTION');
            $this->wrapped->commit();
        }
    }

    #[Override]
    public function rollback(): void
    {
        if ($this->wrapped->getConnection()->isTransactionActive()) {
            $this->logger->log('ROLLBACK_TRANSACTION');
            $this->wrapped->rollback();
        }
    }
}