Dtc\QueueBundle\Tests\Beanstalkd\JobManagerTest

Complexity

Total Complexity

6

Size/Duplication

Total Lines	47
Duplicated Lines	23.4 %

Coupling/Cohesion

Components	1
Dependencies	10

Importance

Changes

0

<?php
class JobManagerTest extends BaseJobManagerTest
{
    use AutoRetryTrait;
    use RetryableTrait;
    public static $beanstalkd;

    public static function setUpBeforeClass()
    {
        $host = getenv('BEANSTALKD_HOST');
        $className = 'Dtc\QueueBundle\Beanstalkd\Job';
        $jobTimingClass = 'Dtc\QueueBundle\Model\JobTiming';
        $runClass = 'Dtc\QueueBundle\Model\Run';

        self::$beanstalkd = new Pheanstalk($host);
        self::$jobTimingManager = new JobTimingManager($jobTimingClass, false);
        self::$runManager = new RunManager($runClass);
        self::$jobManager = new JobManager(self::$runManager, self::$jobTimingManager, $className);
        self::$jobManager->setBeanstalkd(self::$beanstalkd);
        self::$worker = new FibonacciWorker();

        $drained = 0;
        do {
            $beanJob = self::$beanstalkd->reserve(1);
            if ($beanJob) {
                self::$beanstalkd->delete($beanJob);
                ++$drained;
            }
        } while ($beanJob);

        if ($drained) {
            echo "\nbeanstalkd: drained $drained prior to test\n";
        }
        parent::setUpBeforeClass();
    }

    public function testGetJobByWorker()
    {
        $failed = false;
        try {
            self::$jobManager->getJob(self::$worker->getName());
            $failed = true;
        } catch (\Exception $exception) {
            self::assertTrue(true);
        }
        self::assertFalse($failed);
    }
}