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

<?php
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->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->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'
        );
    }
}