Dtc\QueueBundle\Tests\Manager\WorkerManagerTest

Complexity

Total Complexity

6

Size/Duplication

Total Lines	92
Duplicated Lines	40.22 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setup()	0	10	1
A	testAddWorker()	0	15	2
A	testRun()	0	16	1
A	testErrorRun()	17	17	1
A	testRunJob()	20	20	1

<?php

namespace Dtc\QueueBundle\Tests\Manager;

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\Tests\FibonacciWorker;
use Dtc\QueueBundle\Tests\StaticJobManager;
use Dtc\QueueBundle\Manager\WorkerManager;
use Dtc\QueueBundle\EventDispatcher\EventDispatcher;
use PHPUnit\Framework\TestCase;

class WorkerManagerTest extends TestCase
{
    protected $jobManager;
    protected $worker;

    /** @var WorkerManager */
    protected $workerManager;
    protected $eventDispatcher;

    public function setup()
    {
        $jobTimingManager = new JobTimingManager(JobTiming::class, false);
        $runManager = new RunManager(Run::class);
        $this->jobManager = new StaticJobManager($runManager, $jobTimingManager, Job::class);
        $this->worker = new FibonacciWorker();
        $this->worker->setJobManager($this->jobManager);
        $this->eventDispatcher = new EventDispatcher();
        $this->workerManager = new WorkerManager($this->jobManager, $this->eventDispatcher);
    }

    public function testAddWorker()
    {
        $this->workerManager->addWorker($this->worker);
        $worker = $this->workerManager->getWorker($this->worker->getName());
        self::assertEquals($this->worker, $worker);

        $failed = false;
        try {
            $this->workerManager->addWorker($this->worker);
            $failed = true;
        } catch (\Exception $e) {
            self::assertTrue(true);
        }
        self::assertFalse($failed);
    }

    public function testRun()
    {
        $this->workerManager->addWorker($this->worker);
        // Create a job
        $this->worker->later()->fibonacci(20);

        // run the job
        $job = $this->workerManager->run();

        self::assertNotNull($job, 'Job object should not be null');
        self::assertEquals(
            BaseJob::STATUS_SUCCESS,
            $job->getStatus(),
                'Worker run should be successful'
        );
    }

    public function testErrorRun()

This method seems to be duplicated in your project.

    {
        $this->workerManager->addWorker($this->worker);
        // Create a job
        $this->worker->later()->exceptionThrown(20);

        // run the job
        $job = $this->workerManager->run();

        self::assertNotNull($job, 'Job object should not be null');
        self::assertEquals(
            BaseJob::STATUS_EXCEPTION,
            $job->getStatus(),
                'Worker run should be not successful'
        );
        self::assertNotEmpty($job->getMessage(), 'Error message should not be empty');
    }

    public function testRunJob()

This method seems to be duplicated in your project.

    {
        $this->workerManager->addWorker($this->worker);

        // Create a job
        $job = $this->worker->later()->fibonacciFile(20);
        $job = $this->workerManager->runJob($job);

        self::assertEquals(
            BaseJob::STATUS_SUCCESS,
            $job->getStatus(),
                'Worker run should be successful'
        );

        self::assertEquals(
            '20: 6765',
            file_get_contents($this->worker->getFilename()),
                'Result of fibonacciFile() must match'
        );
    }
}