Dtc\QueueBundle\Tests\ORM\RunManagerTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	99
Duplicated Lines	55.56 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

<?php
class RunManagerTest extends TestCase
{
    protected static $runManager;

    public static function setUpBeforeClass()
    {
        JobManagerTest::setUpBeforeClass();
        $jobManager = JobManagerTest::$jobManager;
        $runClass = \Dtc\QueueBundle\Entity\Run::class;
        $runArchiveClass = \Dtc\QueueBundle\Entity\RunArchive::class;
        $runManager = new \Dtc\QueueBundle\ORM\RunManager($jobManager->getObjectManager(), $runClass, RunArchive::class);
        self::$runManager = $runManager;
    }

    public function testPruneStaleRuns()
    {
        /** @var RunManager $runManager */
        $runManager = self::$runManager;
        $runClass = $runManager->getRunClass();
        $objectManager = $runManager->getObjectManager();
        $runRepository = $objectManager->getRepository($runClass);
        self::assertEmpty($runRepository->findAll());
        $runArchiveRepository = $objectManager->getRepository($runManager->getRunArchiveClass());
        self::assertEmpty($runArchiveRepository->findAll());

        $run = new $runClass();
        $time = time() - 96400;
        $date = new \DateTime("@$time");

        $run->setStartedAt($date);
        $run->setLastHeartbeatAt($date);
        $objectManager->persist($run);
        $objectManager->flush($run);
        self::assertCount(1, $runRepository->findAll());

        $count = $runManager->pruneStalledRuns();
        self::assertEquals(1, $count);
        self::assertEmpty($runRepository->findAll());
        $count = $runManager->pruneStalledRuns();
        self::assertEquals(0, $count);
    }

    public function testCloseEm()
    {
        /** @var RunManager $runManager */
        $runManager = self::$runManager;

        $factory = new LazyLoadingValueHolderFactory();
        /** @var ContainerInterface $container */
        $container = new ContainerExtended();
        $objectManager = $runManager->getObjectManager();
        $container->set(
            'doctrine.orm.default_entity_manager',
            $factory->createProxy(
                EntityManager::class,
                function (&$wrappedObject, $proxy, $method, $parameters, &$initializer) use ($objectManager) {
                    $wrappedObject = $objectManager;
                    $initializer = null;
                }
            )
        );
        $registry = new Registry($container, [], ['default' => 'doctrine.orm.default_entity_manager'], null, 'default');
        $runManager->setRegistry($registry);
        $runManager->setEntityManagerName('default');

        $run = $runManager->runStart($start = microtime(true));
        $runManager->getObjectManager()->close();
        $runManager->runStop($run, $start);
    }

    public function testCloseEm2()
    {
        /** @var RunManager $runManager */
        $runManager = self::$runManager;

        $factory = new LazyLoadingValueHolderFactory();
        /** @var ContainerInterface $container */
        $container = new ContainerExtended();
        $objectManager = $runManager->getObjectManager();
        $container->set(
            'doctrine.orm.default_entity_manager',
            $factory->createProxy(
                EntityManager::class,
                function (&$wrappedObject, $proxy, $method, $parameters, &$initializer) use ($objectManager) {
                    $wrappedObject = $objectManager;
                    $initializer = null;
                }
            )
        );
        $registry = new Registry($container, [], ['default' => 'doctrine.orm.default_entity_manager'], null, 'default');
        $runManager->setRegistry($registry);
        $runManager->setEntityManagerName('default');

        $run = $runManager->runStart($start = microtime(true));
        $runManager->getObjectManager()->close();
        $registry->resetManager('default');
        $runManager->runStop($run, $start);
    }
}