JobQueue\Tests\Application\ManagerTest

Complexity

Total Complexity

10

Size/Duplication

Total Lines	180
Duplicated Lines	0 %

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	testEditCommand()	0	11	1
A	testShowCommand()	0	11	1
A	testListCommandWithTagFilter()	0	23	1
A	setUpBeforeClass()	0	4	1
A	testListCommand()	0	8	1
A	testAddCommand()	0	19	1
A	testListCommandWithProfileFilter()	0	10	1
A	testFlushCommand()	0	11	1
A	testRestoreCommand()	0	14	2

<?php

namespace JobQueue\Tests\Application;

use JobQueue\Application\Console\ManagerApplication;
use JobQueue\Domain\Task\Profile;
use JobQueue\Domain\Task\Queue;
use JobQueue\Domain\Task\Status;
use JobQueue\Domain\Task\Task;
use JobQueue\Infrastructure\ServiceContainer;
use JobQueue\Tests\Domain\Job\DummyJob;
use PHPUnit\Framework\TestCase;
use Ramsey\Uuid\Uuid;
use Symfony\Component\Console\Tester\CommandTester;

final class ManagerTest extends TestCase
{
    /**
     *
     * @var Queue
     */
    private static $queue;

    /**
     *
     * @var
     */
    private static $manager;

    public static function setUpBeforeClass()
    {
        self::$queue = ServiceContainer::getInstance()->queue;
        self::$manager = new ManagerApplication(self::$queue);
    }

    /**
     *
     * @return string
     */
    public function testAddCommand(): string
    {
        $commandTester = new CommandTester($command = self::$manager->get('add'));
        $commandTester->execute([
            'command' => $command->getName(),
            'profile' => 'foo',
            'job' => 'JobQueue\Tests\Domain\Job\DummyJob',
            'parameters' => [
                'param1:value1',
                'param2:value2',
            ],
            '--tags' => ['tag1', 'tag2'],
        ], ['decorated' => false]);

        $uuidPattern = rtrim(ltrim(Uuid::VALID_PATTERN, '^'), '$');

        $this->assertEquals(1, preg_match("/Identifier +: ($uuidPattern)/", $commandTester->getDisplay(), $matches));

        return $matches[1];
    }

    /**
     *
     * @depends testAddCommand
     * @param string $identifier
     */
    public function testShowCommand(string $identifier)
    {
        $commandTester = new CommandTester($command = self::$manager->get('show'));
        $commandTester->execute([
            'command' => $command->getName(),
            'identifier' => $identifier,
        ], ['decorated' => false]);

        $this->assertEquals(1, preg_match("/Identifier +: $identifier/", $commandTester->getDisplay()), 'Missing identifier');
        $this->assertEquals(1, preg_match('/Parameters +: 1\) param1: value1/', $commandTester->getDisplay()), 'Missing parameter');
        $this->assertEquals(1, preg_match('/Tags +: tag1/', $commandTester->getDisplay()), 'Missing tag');
    }

    /**
     *
     * @depends testAddCommand
     * @param string $identifier
     */
    public function testListCommand(string $identifier)
    {
        $commandTester = new CommandTester($command = self::$manager->get('list'));
        $commandTester->execute([
            'command' => $command->getName(),
        ], ['decorated' => false]);

        $this->assertEquals(1, preg_match("/$identifier/", $commandTester->getDisplay()), 'Missing identifier');
    }

    /**
     *
     * @depends testAddCommand
     * @param string $identifier
     */
    public function testListCommandWithTagFilter(string $identifier): string
    {
        self::$queue->add(new Task(
            new Profile('test'),
            new DummyJob,
            [], ['foo', 'bar']
        ), $task2 = new Task(
            new Profile('test2'),
            new DummyJob,
            [], ['bar', 'baz']
        ));

        $commandTester = new CommandTester($command = self::$manager->get('list'));
        $commandTester->execute([
            'command' => $command->getName(),
            '--tags' => ['tag1'],
            '--legend' => true,
        ], ['decorated' => false]);

        $this->assertEquals(1, preg_match("/$identifier/", $commandTester->getDisplay()), 'Missing identifier');
        $this->assertEquals(1, preg_match('/T1: tag "tag1"/', $commandTester->getDisplay()), 'Missing tag legend');

        return (string) $task2->getIdentifier();
    }

    /**
     *
     * @depends testListCommandWithTagFilter
     * @param string $identifier
     */
    public function testListCommandWithProfileFilter(string $identifier)
    {
        $commandTester = new CommandTester($command = self::$manager->get('list'));
        $commandTester->execute([
            'command' => $command->getName(),
            '--profile' => 'test2',
            '--legend' => true,
        ], ['decorated' => false]);

        $this->assertEquals(1, preg_match("/$identifier/", $commandTester->getDisplay()), 'Missing identifier');
    }

    /**
     *
     * @depends testAddCommand
     * @param string $identifier
     */
    public function testEditCommand(string $identifier)
    {
        $commandTester = new CommandTester($command = self::$manager->get('edit'));
        $commandTester->execute([
            'command' => $command->getName(),
            'identifier' => $identifier,
            'status' => $status = Status::FINISHED,
        ], ['decorated' => false]);

        $this->assertEquals(1, preg_match("/Identifier +: $identifier/", $commandTester->getDisplay()), 'Missing identifier');
        $this->assertEquals(1, preg_match("/Status +: $status/", $commandTester->getDisplay()), 'Missing status');
    }

    /**
     *
     * @depends testEditCommand
     */
    public function testRestoreCommand()
    {
        $commandTester = new CommandTester($command = self::$manager->get('restore'));
        $commandTester->execute([
            'command' => $command->getName(),
            '--force' => true,
        ], ['decorated' => false]);

        $tasks = self::$queue->search();

        foreach ($tasks as $task) {
            $this->assertTrue(in_array((string) $task->getStatus(), [
                Status::WAITING,
                Status::FINISHED,
            ]));
        }
    }

    /**
     *
     * @depends testRestoreCommand
     */
    public function testFlushCommand()
    {
        $commandTester = new CommandTester($command = self::$manager->get('flush'));
        $commandTester->execute([
            'command' => $command->getName(),
            '--force' => true,
        ], ['decorated' => false]);

        $tasks = self::$queue->search();

        $this->assertTrue(empty($tasks));
    }
}