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

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

↳ Parent: QueueVoterResolver

Complexity

Conditions	3
Paths	3

Size

Total Lines	14
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	10
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	14
ccs	10
cts	10
cp	1
rs	9.4285
c	0
b	0
f	0
cc	3
eloc	9
nc	3
nop	1
crap	3

<?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::getVotes() A last analyzed 2016-09-06 14:50 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

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