ContainerHandlerProvider::getHandlerForMessage() - Code Metrics - Inspection of "Merge pull request #2 from ICanBoogie/2.0" - ICanBoogie/MessageBus - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Branch — master (893f23)

by Olivier

created 2022-04-25 20:41 UTC

ContainerHandlerProvider::getHandlerForMessage() A

↳ Parent: ContainerHandlerProvider

Complexity

Conditions	3
Paths	3

Size

Total Lines	13
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	3
eloc	8
nc	3
nop	1
dl	0
loc	13
rs	10
c	0
b	0
f	0

<?php

/*
 * This file is part of the ICanBoogie package.
 *
 * (c) Olivier Laviale <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace ICanBoogie\MessageBus\PSR;

use ICanBoogie\MessageBus\HandlerProvider;
use ICanBoogie\MessageBus\NotFound;
use Psr\Container\ContainerInterface;
use Psr\Container\NotFoundExceptionInterface;

use function get_class;

class ContainerHandlerProvider implements HandlerProvider
{
    /**
     * @param array<string, string> $handlers
     *     Where _key_ is a message class and _value_ the service identifier of its handler.
     */
    public function __construct(
        private ContainerInterface $container,
        private array $handlers
    ) {
        $this->container = $container;
        $this->handlers = $handlers;
    }

    public function getHandlerForMessage(object $message): callable
    {
        $class = get_class($message);
        $id = $this->handlers[$class] ?? null;

        if (!$id) {
            throw new NotFound("No handler for messages of type `$class`.");
        }

        try {
            return $this->container->get($id); // @phpstan-ignore-line
        } catch (NotFoundExceptionInterface $e) {
            throw new NotFound("No handler for messages of type `$class`.", $e);
        }
    }
}


1			<?php
2
3			/*
4			* This file is part of the ICanBoogie package.
5			*
6			* (c) Olivier Laviale <[email protected]>
7			*
8			* For the full copyright and license information, please view the LICENSE
9			* file that was distributed with this source code.
10			*/
11
12			namespace ICanBoogie\MessageBus\PSR;
13
14			use ICanBoogie\MessageBus\HandlerProvider;
15			use ICanBoogie\MessageBus\NotFound;
16			use Psr\Container\ContainerInterface;
17			use Psr\Container\NotFoundExceptionInterface;
18
19			use function get_class;
20
21			class ContainerHandlerProvider implements HandlerProvider
22			{
23			/**
24			* @param array<string, string> $handlers
25			* Where _key_ is a message class and _value_ the service identifier of its handler.
26			*/
27			public function __construct(
28			private ContainerInterface $container,
29			private array $handlers
30			) {
31			$this->container = $container;
32			$this->handlers = $handlers;
33			}
34
35			public function getHandlerForMessage(object $message): callable
36			{
37			$class = get_class($message);
38			$id = $this->handlers[$class] ?? null;
39
40			if (!$id) {
41			throw new NotFound("No handler for messages of type `$class`.");
42			}
43
44			try {
45			return $this->container->get($id); // @phpstan-ignore-line
46			} catch (NotFoundExceptionInterface $e) {
47			throw new NotFound("No handler for messages of type `$class`.", $e);
48			}
49			}
50			}
51

ICanBoogie / MessageBus

Branch — master (893f23)

ContainerHandlerProvider::getHandlerForMessage() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like