Dtc\QueueBundle\Doctrine\BaseDoctrineJobManager

Complexity

Total Complexity

14

Size/Duplication

Total Lines	94
Duplicated Lines	0 %

Test Coverage

Coverage

89.47%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getObjectManager()	0	3	1
A	deleteJob()	0	3	1
A	getRepository()	0	3	1
A	flush()	0	3	1
A	__construct()	0	9	1
A	getSaveCount()	0	11	3
A	getFetchCount()	0	11	3
A	addWorkerNameMethod()	0	7	3

<?php

namespace Dtc\QueueBundle\Doctrine;

use Doctrine\Common\Persistence\ObjectManager;
use Doctrine\Common\Persistence\ObjectRepository;
use Dtc\QueueBundle\Manager\ArchivableJobManager;
use Dtc\QueueBundle\Manager\JobTimingManager;
use Dtc\QueueBundle\Manager\RunManager;

abstract class BaseDoctrineJobManager extends ArchivableJobManager
{
    /** Number of jobs to prune / reset / gather at a time */
    const FETCH_COUNT_MIN = 100;
    const FETCH_COUNT_MAX = 500;
    const SAVE_COUNT_MIN = 10;
    const SAVE_COUNT_MAX = 100;

    /**
     * @var ObjectManager
     */
    protected $objectManager;

    /**
     * DoctrineJobManager constructor.
     *
     * @param RunManager       $runManager
     * @param JobTimingManager $jobTimingManager
     * @param ObjectManager    $objectManager
     * @param $jobClass
     * @param $jobArchiveClass
     */
    public function __construct(
        RunManager $runManager,
        JobTimingManager $jobTimingManager,
        ObjectManager $objectManager,
        $jobClass,
        $jobArchiveClass
    ) {
        $this->objectManager = $objectManager;
        parent::__construct($runManager, $jobTimingManager, $jobClass, $jobArchiveClass);
    }

    protected function getFetchCount($totalCount)
    {
        $fetchCount = intval($totalCount / 10);
        if ($fetchCount < self::FETCH_COUNT_MIN) {
            $fetchCount = self::FETCH_COUNT_MIN;
        }
        if ($fetchCount > self::FETCH_COUNT_MAX) {
            $fetchCount = self::FETCH_COUNT_MAX;
        }

        return $fetchCount;
    }

    protected function getSaveCount($totalCount)
    {
        $saveCount = intval($totalCount / 10);
        if ($saveCount < self::SAVE_COUNT_MIN) {
            $saveCount = self::SAVE_COUNT_MIN;
        }
        if ($saveCount > self::SAVE_COUNT_MAX) {
            $saveCount = self::SAVE_COUNT_MAX;
        }

        return $saveCount;
    }

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

    /**
     * @return ObjectRepository
     */
    public function getRepository()
    {
        return $this->getObjectManager()->getRepository($this->getJobClass());
    }

    protected function flush()
    {
        $this->getObjectManager()->flush();
    }

    public function deleteJob(\Dtc\QueueBundle\Model\Job $job)
    {
        $this->persist($job, 'remove');
    }

    abstract protected function persist($object, $action = 'persist');

    protected function addWorkerNameMethod(array &$criterion, $workerName = null, $method = null)
    {
        if (null !== $workerName) {
            $criterion['workerName'] = $workerName;
        }
        if (null !== $method) {
            $criterion['method'] = $method;
        }
    }
}