Bdf\QueueBundle\Tests\WithPrimeTest

Complexity

Total Complexity

10

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	4	2
A	test_host_missing()	0	7	1
A	isPrimeFailer()	0	14	3
A	test_prime_failer()	0	24	2
A	test_init_command()	0	7	1
A	test_table_name_missing()	0	7	1

<?php
namespace Bdf\QueueBundle\Tests;

require_once __DIR__.'/TestKernel.php';

use Bdf\Queue\Connection\Prime\PrimeConnection;

The type Bdf\Queue\Connection\Prime\PrimeConnection was not found. Maybe you did not declare it correctly or list all dependencies?

use Bdf\Queue\Console\Command\Failer\AbstractFailerCommand;
use Bdf\Queue\Console\Command\Failer\InitCommand;

The type Bdf\Queue\Console\Command\Failer\InitCommand was not found. Maybe you did not declare it correctly or list all dependencies?

use Bdf\Queue\Failer\DbFailedJobRepository;

The type Bdf\Queue\Failer\DbFailedJobRepository was not found. Maybe you did not declare it correctly or list all dependencies?

use Bdf\Queue\Failer\DbFailedJobStorage;

The type Bdf\Queue\Failer\DbFailedJobStorage was not found. Maybe you did not declare it correctly or list all dependencies?

use Bdf\Queue\Failer\FailedJobRepositoryAdapter;
use Bdf\Queue\Failer\FailedJobStorageInterface;
use PHPUnit\Framework\TestCase;
use Symfony\Bundle\FrameworkBundle\Console\Application;

class WithPrimeTest extends TestCase
{
    protected function setUp(): void
    {
        if (!class_exists(PrimeConnection::class)) {
            $this->markTestSkipped('b2pweb/bdf-queue-prime-adapter not installed');
        }
    }

    /**
     * @return void
     */
    public function test_prime_failer()
    {
        $kernel = new \TestKernel(__DIR__ . '/Fixtures/conf_with_prime_failer.yaml');
        $kernel->boot();
        $console = new Application($kernel);

        $command = $console->get('queue:failer:delete');

        $r = new \ReflectionProperty(AbstractFailerCommand::class, 'repository');
        $r->setAccessible(true);

        /** @var FailedJobStorageInterface $failer */
        $failer = $r->getValue($command);

        $this->assertTrue($this->isPrimeFailer($failer));

        if (class_exists(DbFailedJobRepository::class)) {
            $this->assertInstanceOf(DbFailedJobRepository::class, $failer);
            $this->assertEquals(DbFailedJobRepository::make($kernel->getContainer()->get('prime'), ['connection' => 'my_connection', 'table' => 'failed_jobs'], 15));

The call to PHPUnit\Framework\Assert::assertEquals() has too few arguments starting with actual.

        } else {
            $this->assertInstanceOf(FailedJobRepositoryAdapter::class, $failer);
            $this->assertEquals(
                FailedJobRepositoryAdapter::adapt(DbFailedJobStorage::make($kernel->getContainer()->get('prime'), ['connection' => 'my_connection', 'table' => 'failed_jobs'], 15)),
                $failer
            );
        }
    }

    /**
     * @return void
     */
    public function test_host_missing()
    {
        $this->expectException(\InvalidArgumentException::class);
        $this->expectExceptionMessage('The connection name is required on prime failer DSN');

        $kernel = new \TestKernel(__DIR__ . '/Fixtures/conf_with_prime_failer_missing_host.yaml');
        $kernel->boot();
    }

    /**
     * @return void
     */
    public function test_table_name_missing()
    {
        $this->expectException(\InvalidArgumentException::class);
        $this->expectExceptionMessage('The table name is required on prime failer DSN');

        $kernel = new \TestKernel(__DIR__ . '/Fixtures/conf_with_prime_failer_missing_table.yaml');
        $kernel->boot();
    }

    /**
     *
     */
    public function test_init_command()
    {
        $kernel = new \TestKernel(__DIR__ . '/Fixtures/conf_with_prime_failer.yaml');
        $kernel->boot();
        $console = new Application($kernel);

        $this->assertInstanceOf(InitCommand::class, $console->get('queue:prime:failer:init'));
    }

    private function isPrimeFailer($storage): bool
    {
        if ($storage instanceof DbFailedJobRepository) {
            return true;
        }

        if ($storage instanceof FailedJobRepositoryAdapter) {
            $r = new \ReflectionProperty(FailedJobRepositoryAdapter::class, 'storage');
            $r->setAccessible(true);

            return $r->getValue($storage) instanceof DbFailedJobStorage;
        }

        return false;
    }
}