Dtc\QueueBundle\ODM\RunManagerTest::testPruneArchivedRuns()

Complexity

Conditions	1
Paths	1

Size

Total Lines	35
Code Lines	28

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function testPruneArchivedRuns()
    {
        JobManagerTest::setUpBeforeClass();
        $jobManager = JobManagerTest::$jobManager;
        $runClass = \Dtc\QueueBundle\Document\Run::class;
        $runArchiveClass = \Dtc\QueueBundle\Document\RunArchive::class;
        $runManager = new \Dtc\QueueBundle\ODM\RunManager($runClass);
        $runManager->setRunArchiveClass($runArchiveClass);
        $runManager->setObjectManager($jobManager->getObjectManager());
        $objectManager = $runManager->getObjectManager();
        $runRepository = $objectManager->getRepository($runClass);
        self::assertEmpty($runRepository->findAll());
        $runArchiveRepository = $objectManager->getRepository($runArchiveClass);
        self::assertEmpty($runArchiveRepository->findAll());

        $run = new $runClass();
        $time = time() - 86400;

        $run->setStartedAt(new \DateTime("@$time"));
        $objectManager->persist($run);
        $objectManager->flush($run);
        self::assertCount(1, $runRepository->findAll());

        $run->setEndedAt(new \DateTime("@$time"));
        $objectManager->remove($run);
        $objectManager->flush();

        self::assertEmpty($runRepository->findAll());
        self::assertCount(1, $runArchiveRepository->findAll());

        $time1 = $time + 1;
        $runManager->pruneArchivedRuns(new \DateTime("@$time1"));
        self::assertEmpty($runArchiveRepository->findAll());
        self::assertEmpty($runRepository->findAll());
    }
}