MGDigital\BusQue\QueueResolver\QueueVoterResolver

Complexity

Total Complexity

6

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

94.74%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	resolveQueueName()	0	8	2
A	getVotes()	0	14	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;
    }
}