Dtc\QueueBundle\Doctrine\DoctrineJobTimingManager

Complexity

Total Complexity

5

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

88.89%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getObjectManager()	0	4	1
A	performRecording()	0	14	2
	removeOlderThan()	0	1	?
A	pruneJobTimings()	0	4	1

<?php

namespace Dtc\QueueBundle\Doctrine;

use Doctrine\Common\Persistence\ObjectManager;
use Dtc\QueueBundle\Model\JobTiming;
use Dtc\QueueBundle\Manager\JobTimingManager;

abstract class DoctrineJobTimingManager extends JobTimingManager
{
    /** @var ObjectManager */
    protected $objectManager;

    public function __construct(ObjectManager $objectManager, $jobTimingClass, $recordTimings)
    {
        $this->objectManager = $objectManager;
        parent::__construct($jobTimingClass, $recordTimings);
    }

    /**
     * @return ObjectManager
     */
    public function getObjectManager()
    {
        return $this->objectManager;
    }

    public function performRecording($status, \DateTime $finishedAt = null)
    {
        if (null === $finishedAt) {
            $finishedAt = \Dtc\QueueBundle\Util\Util::getMicrotimeDateTime();
        }

        /** @var JobTiming $jobTiming */
        $jobTiming = new $this->jobTimingClass();
        $jobTiming->setFinishedAt($finishedAt);
        $jobTiming->setStatus($status);
        $objectManager = $this->getObjectManager();
        $objectManager->persist($jobTiming);
        $objectManager->flush();
    }

    abstract protected function removeOlderThan($objectName, $field, \DateTime $olderThan);

    public function pruneJobTimings(\DateTime $olderThan)
    {
        return $this->removeOlderThan($this->getJobTimingClass(), 'createdAt', $olderThan);
    }
}