Lamoda\TacticianQueue\Handler\CommandHandler

Complexity

Total Complexity

4

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	handle()	0	9	1
A	assertCommandJob()	0	6	2

<?php

declare(strict_types=1);

namespace Lamoda\TacticianQueue\Handler;

use Lamoda\QueueBundle\Handler\HandlerInterface;
use Lamoda\QueueBundle\QueueInterface;
use Lamoda\TacticianQueue\Exception\CanNotHandleJobException;
use Lamoda\TacticianQueue\Job\CommandJob;
use Lamoda\TacticianQueue\Middleware\Command\ReceivedCommand;
use League\Tactician\CommandBus;

final class CommandHandler implements HandlerInterface
{
    /**
     * @var CommandBus
     */
    private $commandBus;

    public function __construct(CommandBus $commandBus)
    {
        $this->commandBus = $commandBus;
    }

    public function handle(QueueInterface $job)
    {
        /* @var CommandJob $job */
        $this->assertCommandJob($job);

        $receivedCommand = new ReceivedCommand($job->getCommand());

        $this->commandBus->handle($receivedCommand);
    }

    private function assertCommandJob(QueueInterface $job): void
    {
        if (!$job instanceof CommandJob) {
            throw CanNotHandleJobException::becauseJobShouldInstanceOf(CommandJob::class);
        }
    }
}