QueueMiddleware::__construct() - Code Metrics - lamoda/tactician-queue - Measure and Improve Code Quality continuously with Scrutinizer

QueueMiddleware::__construct() A
last analyzed 2020-02-05 16:33 UTC

↳ Parent: QueueMiddleware

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	7
ccs	4
cts	4
cp	1
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	2
crap	1

<?php

declare(strict_types=1);

namespace Lamoda\TacticianQueue\Middleware;

use Lamoda\QueueBundle\Factory\PublisherFactory;
use Lamoda\TacticianQueue\Middleware\Command\ReceivedCommand;
use Lamoda\TacticianQueue\Middleware\QueueProducerStrategy\QueueProducerStrategyInterface;
use League\Tactician\Middleware;

final class QueueMiddleware implements Middleware
{
    /**
     * @var PublisherFactory
     */
    private $publisherFactory;
    /**
     * @var QueueProducerStrategyInterface
     */
    private $queueProducerStrategy;

    public function __construct(
        PublisherFactory $publisherFactory,
        QueueProducerStrategyInterface $queueProducerStrategy
    ) {
        $this->publisherFactory = $publisherFactory;
        $this->queueProducerStrategy = $queueProducerStrategy;
    }

    public function execute($command, callable $next)
    {
        if ($command instanceof ReceivedCommand) {
            $command = $command->getCommand();

            return $next($command);
        }

        if (!empty($queues = $this->queueProducerStrategy->produceQueues($command))) {
            foreach ($queues as $queue) {
                $this->publisherFactory->publish($queue);
            }

            return null;
        }

        return $next($command);
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Lamoda\TacticianQueue\Middleware;
6
7		use Lamoda\QueueBundle\Factory\PublisherFactory;
8		use Lamoda\TacticianQueue\Middleware\Command\ReceivedCommand;
9		use Lamoda\TacticianQueue\Middleware\QueueProducerStrategy\QueueProducerStrategyInterface;
10		use League\Tactician\Middleware;
11
12		final class QueueMiddleware implements Middleware
13		{
14		/**
15		* @var PublisherFactory
16		*/
17		private $publisherFactory;
18		/**
19		* @var QueueProducerStrategyInterface
20		*/
21		private $queueProducerStrategy;
22
23	3	public function __construct(
24		PublisherFactory $publisherFactory,
25		QueueProducerStrategyInterface $queueProducerStrategy
26		) {
27	3	$this->publisherFactory = $publisherFactory;
28	3	$this->queueProducerStrategy = $queueProducerStrategy;
29	3	}
30
31	3	public function execute($command, callable $next)
32		{
33	3	if ($command instanceof ReceivedCommand) {
34	1	$command = $command->getCommand();
35
36	1	return $next($command);
37		}
38
39	2	if (!empty($queues = $this->queueProducerStrategy->produceQueues($command))) {
40	1	foreach ($queues as $queue) {
41	1	$this->publisherFactory->publish($queue);
42		}
43
44	1	return null;
45		}
46
47	1	return $next($command);
48		}
49		}
50

lamoda / tactician-queue

QueueMiddleware::__construct() A last analyzed 2020-02-05 16:33 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

QueueMiddleware::__construct() A
last analyzed 2020-02-05 16:33 UTC