JobManagerTest::testGetJobByWorker() - Code Metrics - Inspection of "4.0 release" - mmucklo/DtcQueueBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#30)

by Matthew

created 2018-01-13 19:28 UTC

JobManagerTest::testGetJobByWorker() A

↳ Parent: JobManagerTest

Complexity

Conditions	2
Paths	2

Size

Total Lines	11
Code Lines	8

Duplication

Lines	11
Ratio	100 %

Importance

Changes

Metric	Value
dl	11
loc	11
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	8
nc	2
nop	0

<?php

namespace Dtc\QueueBundle\Tests\Redis;

use Dtc\QueueBundle\Model\BaseJob;
use Dtc\QueueBundle\Model\Job;
use Dtc\QueueBundle\Model\JobTiming;
use Dtc\QueueBundle\Manager\JobTimingManager;
use Dtc\QueueBundle\Model\Run;
use Dtc\QueueBundle\Manager\RunManager;
use Dtc\QueueBundle\Redis\JobManager;
use Dtc\QueueBundle\Redis\Predis;
use Dtc\QueueBundle\Tests\FibonacciWorker;
use Dtc\QueueBundle\Tests\Manager\AutoRetryTrait;
use Dtc\QueueBundle\Tests\Manager\BaseJobManagerTest;
use Dtc\QueueBundle\Tests\Manager\PriorityTestTrait;
use Predis\Client;

/**
 * @author David
 *
 * This test requires local beanstalkd running
 */
class JobManagerTest extends BaseJobManagerTest
{
    use PriorityTestTrait;
    use AutoRetryTrait;
    public static $connection;

    public static function setUpBeforeClass()
    {
        $host = getenv('REDIS_HOST');
        $port = getenv('REDIS_PORT') ?: 6379;
        $jobTimingClass = JobTiming::class;
        $runClass = Run::class;
        $predisClient = new Client(['scheme' => 'tcp', 'host' => $host, 'port' => $port]);
        $predisClient->flushall();
        $predis = new Predis($predisClient);

        self::$jobTimingManager = new JobTimingManager($jobTimingClass, false);
        self::$runManager = new RunManager($runClass);
        self::$jobManager = new JobManager(self::$runManager, self::$jobTimingManager, \Dtc\QueueBundle\Redis\Job::class, 'test_cache_key');
        self::$jobManager->setRedis($predis);
        self::$jobManager->setMaxPriority(255);
        self::$worker = new FibonacciWorker();

        parent::setUpBeforeClass();
    }

    public function testConstructor()

    {
        $test = null;
        try {
            $test = new JobManager(self::$runManager, self::$jobTimingManager, Job::class, 'something');
        } catch (\Exception $exception) {
            self::fail("shouldn't get here");
        }
        self::assertNotNull($test);
    }

    public function testGetJobByWorker()

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

    public function testExpiredJob()

    {
        $job = new self::$jobClass(self::$worker, false, null);
        $time = time() - 1;
        $job->setExpiresAt(new \DateTime("@$time"))->fibonacci(1);
        self::assertNotNull($job->getId(), 'Job id should be generated');

        $jobInQueue = self::$jobManager->getJob();
        self::assertNull($jobInQueue, 'The job should have been dropped...');

        $job = new self::$jobClass(self::$worker, false, null);
        $time = time() - 1;
        $job->setExpiresAt(new \DateTime("@$time"))->fibonacci(1);

        $job = new self::$jobClass(self::$worker, false, null);
        $time = time() - 1;
        $job->setExpiresAt(new \DateTime("@$time"))->fibonacci(5);

        $job = new self::$jobClass(self::$worker, false, null);
        $time = time() - 1;
        $job->setExpiresAt(new \DateTime("@$time"))->fibonacci(2);

        $job = new self::$jobClass(self::$worker, false, null);
        $job->fibonacci(1);
        $jobInQueue = self::$jobManager->getJob();
        self::assertNotNull($jobInQueue, 'There should be a job.');
        self::assertEquals(
            $job->getId(),
            $jobInQueue->getId(),
            'Job id returned by manager should be the same'
        );
    }

    public function testSaveJob()

    {
        // Make sure a job proper type
        $failed = false;
        try {
            $job = new Job();
            self::$jobManager->save($job);
            $failed = true;
        } catch (\Exception $exception) {
            self::assertTrue(true);
        }
        self::assertFalse($failed);

        $job = new self::$jobClass(self::$worker, false, null);
        try {
            $job->setPriority(256)->fibonacci(1);
            $failed = true;
        } catch (\Exception $exception) {
            self::assertTrue(true);
        }
        self::assertFalse($failed);

        $job = new self::$jobClass(self::$worker, false, null);
        $job->setPriority(100)->fibonacci(1);
        self::assertNotNull($job->getId(), 'Job id should be generated');

        $jobInQueue = self::$jobManager->getJob();
        self::assertNotNull($jobInQueue, 'There should be a job.');
        self::$jobManager->saveHistory($jobInQueue);

        $job = new self::$jobClass(self::$worker, false, null);
        $job->fibonacci(1);
        self::assertNotNull($job->getId(), 'Job id should be generated');

        $failed = false;
        try {
            self::$jobManager->getJob('fibonacci');
            $failed = true;
        } catch (\Exception $exception) {
            self::assertTrue(true);
        }
        self::assertFalse($failed);

        $failed = false;
        try {
            self::$jobManager->getJob(null, 'fibonacci');
            $failed = true;
        } catch (\Exception $exception) {
            self::assertTrue(true);
        }
        self::assertFalse($failed);

        $jobInQueue = self::$jobManager->getJob();
        self::assertNotNull($jobInQueue, 'There should be a job.');
        self::assertEquals(
            $job->getId(),
            $jobInQueue->getId(),
            'Job id returned by manager should be the same'
        );

        $job->setStatus(BaseJob::STATUS_SUCCESS);
        $badJob = new Job();
        $failed = false;
        try {
            self::$jobManager->saveHistory($badJob);
            $failed = true;
        } catch (\Exception $exception) {
            self::assertTrue(true);
        }
        self::assertFalse($failed);
        self::$jobManager->saveHistory($jobInQueue);
    }
}


1		<?php
2
3		namespace Dtc\QueueBundle\Tests\Redis;
4
5		use Dtc\QueueBundle\Model\BaseJob;
6		use Dtc\QueueBundle\Model\Job;
7		use Dtc\QueueBundle\Model\JobTiming;
8		use Dtc\QueueBundle\Manager\JobTimingManager;
9		use Dtc\QueueBundle\Model\Run;
10		use Dtc\QueueBundle\Manager\RunManager;
11		use Dtc\QueueBundle\Redis\JobManager;
12		use Dtc\QueueBundle\Redis\Predis;
13		use Dtc\QueueBundle\Tests\FibonacciWorker;
14		use Dtc\QueueBundle\Tests\Manager\AutoRetryTrait;
15		use Dtc\QueueBundle\Tests\Manager\BaseJobManagerTest;
16		use Dtc\QueueBundle\Tests\Manager\PriorityTestTrait;
17		use Predis\Client;
18
19		/**
20		* @author David
21		*
22		* This test requires local beanstalkd running
23		*/
24		class JobManagerTest extends BaseJobManagerTest
25		{
26		use PriorityTestTrait;
27		use AutoRetryTrait;
28		public static $connection;
29
30		public static function setUpBeforeClass()
31		{
32		$host = getenv('REDIS_HOST');
33		$port = getenv('REDIS_PORT') ?: 6379;
34		$jobTimingClass = JobTiming::class;
35		$runClass = Run::class;
36		$predisClient = new Client(['scheme' => 'tcp', 'host' => $host, 'port' => $port]);
37		$predisClient->flushall();
38		$predis = new Predis($predisClient);
39
40		self::$jobTimingManager = new JobTimingManager($jobTimingClass, false);
41		self::$runManager = new RunManager($runClass);
42		self::$jobManager = new JobManager(self::$runManager, self::$jobTimingManager, \Dtc\QueueBundle\Redis\Job::class, 'test_cache_key');
43		self::$jobManager->setRedis($predis);
44		self::$jobManager->setMaxPriority(255);
45		self::$worker = new FibonacciWorker();
		0 ignored issues – show Documentation Bug introduced 2018-01-07 01:22 UTC by Report Bug Copy Issue Report It seems like `new \Dtc\QueueBundle\Tests\FibonacciWorker()` of type `object<Dtc\QueueBundle\Tests\FibonacciWorker>` is incompatible with the declared type `object<Dtc\QueueBundle\Manager\Worker>` of property `$worker`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
46		parent::setUpBeforeClass();
47		}
48
49	View Code Duplication	public function testConstructor()
		0 ignored issues – show Duplication introduced 2018-01-07 01:22 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
50		{
51		$test = null;
52		try {
53		$test = new JobManager(self::$runManager, self::$jobTimingManager, Job::class, 'something');
54		} catch (\Exception $exception) {
55		self::fail("shouldn't get here");
56		}
57		self::assertNotNull($test);
58		}
59
60	View Code Duplication	public function testGetJobByWorker()
		0 ignored issues – show Duplication introduced 2018-01-07 01:22 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
61		{
62		$failed = false;
63		try {
64		self::$jobManager->getJob(self::$worker->getName());
65		$failed = true;
66		} catch (\Exception $exception) {
67		self::assertTrue(true);
68		}
69		self::assertFalse($failed);
70		}
71
72	View Code Duplication	public function testExpiredJob()
		0 ignored issues – show Duplication introduced 2018-01-07 01:22 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
73		{
74		$job = new self::$jobClass(self::$worker, false, null);
75		$time = time() - 1;
76		$job->setExpiresAt(new \DateTime("@$time"))->fibonacci(1);
77		self::assertNotNull($job->getId(), 'Job id should be generated');
78
79		$jobInQueue = self::$jobManager->getJob();
80		self::assertNull($jobInQueue, 'The job should have been dropped...');
81
82		$job = new self::$jobClass(self::$worker, false, null);
83		$time = time() - 1;
84		$job->setExpiresAt(new \DateTime("@$time"))->fibonacci(1);
85
86		$job = new self::$jobClass(self::$worker, false, null);
87		$time = time() - 1;
88		$job->setExpiresAt(new \DateTime("@$time"))->fibonacci(5);
89
90		$job = new self::$jobClass(self::$worker, false, null);
91		$time = time() - 1;
92		$job->setExpiresAt(new \DateTime("@$time"))->fibonacci(2);
93
94		$job = new self::$jobClass(self::$worker, false, null);
95		$job->fibonacci(1);
96		$jobInQueue = self::$jobManager->getJob();
97		self::assertNotNull($jobInQueue, 'There should be a job.');
98		self::assertEquals(
99		$job->getId(),
100		$jobInQueue->getId(),
101		'Job id returned by manager should be the same'
102		);
103		}
104
105	View Code Duplication	public function testSaveJob()
		0 ignored issues – show Duplication introduced 2018-01-07 01:22 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
106		{
107		// Make sure a job proper type
108		$failed = false;
109		try {
110		$job = new Job();
111		self::$jobManager->save($job);
112		$failed = true;
113		} catch (\Exception $exception) {
114		self::assertTrue(true);
115		}
116		self::assertFalse($failed);
117
118		$job = new self::$jobClass(self::$worker, false, null);
119		try {
120		$job->setPriority(256)->fibonacci(1);
121		$failed = true;
122		} catch (\Exception $exception) {
123		self::assertTrue(true);
124		}
125		self::assertFalse($failed);
126
127		$job = new self::$jobClass(self::$worker, false, null);
128		$job->setPriority(100)->fibonacci(1);
129		self::assertNotNull($job->getId(), 'Job id should be generated');
130
131		$jobInQueue = self::$jobManager->getJob();
132		self::assertNotNull($jobInQueue, 'There should be a job.');
133		self::$jobManager->saveHistory($jobInQueue);
134
135		$job = new self::$jobClass(self::$worker, false, null);
136		$job->fibonacci(1);
137		self::assertNotNull($job->getId(), 'Job id should be generated');
138
139		$failed = false;
140		try {
141		self::$jobManager->getJob('fibonacci');
142		$failed = true;
143		} catch (\Exception $exception) {
144		self::assertTrue(true);
145		}
146		self::assertFalse($failed);
147
148		$failed = false;
149		try {
150		self::$jobManager->getJob(null, 'fibonacci');
151		$failed = true;
152		} catch (\Exception $exception) {
153		self::assertTrue(true);
154		}
155		self::assertFalse($failed);
156
157		$jobInQueue = self::$jobManager->getJob();
158		self::assertNotNull($jobInQueue, 'There should be a job.');
159		self::assertEquals(
160		$job->getId(),
161		$jobInQueue->getId(),
162		'Job id returned by manager should be the same'
163		);
164
165		$job->setStatus(BaseJob::STATUS_SUCCESS);
166		$badJob = new Job();
167		$failed = false;
168		try {
169		self::$jobManager->saveHistory($badJob);
170		$failed = true;
171		} catch (\Exception $exception) {
172		self::assertTrue(true);
173		}
174		self::assertFalse($failed);
175		self::$jobManager->saveHistory($jobInQueue);
176		}
177		}
178

mmucklo / DtcQueueBundle

Pull Request — master (#30)

JobManagerTest::testGetJobByWorker() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like