QueueVoterResolver::resolveQueueName() - Code Metrics - mgdigital/BusQue - Measure and Improve Code Quality continuously with Scrutinizer

QueueVoterResolver::resolveQueueName() A
last analyzed 2016-09-06 14:50 UTC

↳ Parent: QueueVoterResolver

Complexity

Conditions	2
Paths	2

Size

Total Lines	8
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	2.032

Importance

Changes

Metric	Value
dl	0
loc	8
ccs	4
cts	5
cp	0.8
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	5
nc	2
nop	1
crap	2.032

<?php

namespace MGDigital\BusQue\QueueResolver;

use MGDigital\BusQue\Exception\QueueResolverException;
use MGDigital\BusQue\QueueResolverInterface;

class QueueVoterResolver implements QueueResolverInterface
{

    /**
     * @var QueueVoterInterface[]
     */
    private $voters = [ ];

    public function __construct(array $voters)
    {
        array_walk($voters, function (QueueVoterInterface $voter) {
            $this->voters[ ] = $voter;
        });
    }

    public function resolveQueueName($command): string
    {
        $votes = $this->getVotes($command);
        if (!isset($votes[ 0 ])) {
            throw new QueueResolverException;
        }
        return $votes[ 0 ]->getQueueName();
    }

    /**
     * @param mixed $command
     * @return QueueVote[]
     */
    public function getVotes($command): array
    {
        $votes = [ ];
        foreach ($this->voters as $voter) {
            $vote = $voter->getVote($command);
            if ($vote instanceof QueueVote) {
                $votes[ ] = $vote;
            }
        }
        usort($votes, function (QueueVote $voteA, QueueVote $voteB) {
            return $voteB->getConfidence() <=> $voteA->getConfidence();
        });
        return $votes;
    }
}


1		<?php
2
3		namespace MGDigital\BusQue\QueueResolver;
4
5		use MGDigital\BusQue\Exception\QueueResolverException;
6		use MGDigital\BusQue\QueueResolverInterface;
7
8		class QueueVoterResolver implements QueueResolverInterface
9		{
10
11		/**
12		* @var QueueVoterInterface[]
13		*/
14		private $voters = [ ];
15
16	4	public function __construct(array $voters)
17		{
18		array_walk($voters, function (QueueVoterInterface $voter) {
19	4	$this->voters[ ] = $voter;
20	4	});
21	4	}
22
23	2	public function resolveQueueName($command): string
24		{
25	2	$votes = $this->getVotes($command);
26	2	if (!isset($votes[ 0 ])) {
27		throw new QueueResolverException;
28		}
29	2	return $votes[ 0 ]->getQueueName();
30		}
31
32		/**
33		* @param mixed $command
34		* @return QueueVote[]
35		*/
36	2	public function getVotes($command): array
37		{
38	2	$votes = [ ];
39	2	foreach ($this->voters as $voter) {
40	2	$vote = $voter->getVote($command);
41	2	if ($vote instanceof QueueVote) {
42	2	$votes[ ] = $vote;
43		}
44		}
45	2	usort($votes, function (QueueVote $voteA, QueueVote $voteB) {
46	2	return $voteB->getConfidence() <=> $voteA->getConfidence();
47	2	});
48	2	return $votes;
49		}
50		}
51

mgdigital / BusQue

QueueVoterResolver::resolveQueueName() A last analyzed 2016-09-06 14:50 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

QueueVoterResolver::resolveQueueName() A
last analyzed 2016-09-06 14:50 UTC