Bernard\Router\ReceiverMapRouter

Complexity

Total Complexity

10

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

70.59%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	3
A	add()	0	8	2
A	route()	0	11	2
A	get()	0	4	2
A	getName()	0	4	1

<?php

namespace Bernard\Router;

use Bernard\Envelope;
use Bernard\Exception\ReceiverNotFoundException;
use Bernard\Router;

/**
 * Routes an Envelope to a Receiver based on an internal receiver map.
 */
class ReceiverMapRouter implements Router
{
    protected $receivers = [];

    private $receiverResolver;

    /**
     * @param array                 $receivers
     * @param ReceiverResolver|null $receiverResolver
     */
    public function __construct(array $receivers = [], ReceiverResolver $receiverResolver = null)
    {
        if ($receiverResolver === null) {
            $receiverResolver = new SimpleReceiverResolver();
        }

        $this->receiverResolver = $receiverResolver;

        foreach ($receivers as $name => $receiver) {
            $this->add($name, $receiver);
        }
    }

    /**
     * @param string $name
     * @param mixed  $receiver
     */
    private function add($name, $receiver)
    {
        if (!$this->receiverResolver->accepts($receiver)) {
            throw new \InvalidArgumentException(sprintf('Receiver "%s" is not supported.', $receiver));
        }

        $this->receivers[$name] = $receiver;
    }

    /**
     * {@inheritdoc}
     */
    public function route(Envelope $envelope)
    {
        $receiver = $this->get($this->getName($envelope));
        $receiver = $this->receiverResolver->resolve($receiver, $envelope);

        if (null === $receiver) {
            throw new ReceiverNotFoundException(sprintf('No receiver found with name "%s".', $envelope->getName()));
        }

        return $receiver;
    }

    /**
     * @param string $name
     *
     * @return mixed
     */
    protected function get($name)
    {
        return isset($this->receivers[$name]) ? $this->receivers[$name] : null;
    }

    /**
     * Returns the (message) name to look for in the receiver map.
     *
     * @param Envelope $envelope
     *
     * @return string
     */
    protected function getName(Envelope $envelope)
    {
        return $envelope->getName();
    }
}