MessagingMiddleware::handle() - Code Metrics - Inspection of "implemented and tested a dispatcher and its middle..." - blixit/event-sourcing - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 3112ca...a45803 )

by Blixit

created 2019-04-22 23:35 UTC

MessagingMiddleware::handle() B

↳ Parent: MessagingMiddleware

Complexity

Conditions	9
Paths	6

Size

Total Lines	23
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	9
eloc	15
nc	6
nop	1
dl	0
loc	23
rs	8.0555
c	0
b	0
f	0

<?php

declare(strict_types=1);

namespace Blixit\EventSourcing\Messaging;

use function get_class;
use function is_array;
use function is_callable;

class MessagingMiddleware implements MessagingMiddlewareInterface
{
    /** To handle any message */
    protected const ALL = MessageInterface::class;

    /** @var mixed[] $handlers */
    protected $handlers;

    /**
     * @param mixed[] $handlers
     */
    public function __construct(array $handlers)
    {
        $this->handlers = $handlers;
    }

    public function handle(MessageInterface $message) : void
    {
        $class = get_class($message);
        if (! $this->supports($class)) {
            return;
        }

        foreach ($this->handlers as $key => $locatedHandler) {
            if ($key !== self::ALL && $class !== $key) {
                continue;
            }
            if (is_callable($locatedHandler)) {
                $locatedHandler($message);
                continue;
            }
            if (! is_array($locatedHandler)) {
                continue;
            }
            foreach ($locatedHandler as $handler) {
                if (! is_callable($handler)) {
                    continue;
                }
                $handler($message);
            }
        }
    }

    public function supports(string $class) : bool
    {
        return isset($this->handlers[$class]);
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Blixit\EventSourcing\Messaging;
6
7			use function get_class;
8			use function is_array;
9			use function is_callable;
10
11			class MessagingMiddleware implements MessagingMiddlewareInterface
12			{
13			/** To handle any message */
14			protected const ALL = MessageInterface::class;
15
16			/** @var mixed[] $handlers */
17			protected $handlers;
18
19			/**
20			* @param mixed[] $handlers
21			*/
22			public function __construct(array $handlers)
23			{
24			$this->handlers = $handlers;
25			}
26
27			public function handle(MessageInterface $message) : void
28			{
29			$class = get_class($message);
30			if (! $this->supports($class)) {
31			return;
32			}
33
34			foreach ($this->handlers as $key => $locatedHandler) {
35			if ($key !== self::ALL && $class !== $key) {
36			continue;
37			}
38			if (is_callable($locatedHandler)) {
39			$locatedHandler($message);
40			continue;
41			}
42			if (! is_array($locatedHandler)) {
43			continue;
44			}
45			foreach ($locatedHandler as $handler) {
46			if (! is_callable($handler)) {
47			continue;
48			}
49			$handler($message);
50			}
51			}
52			}
53
54			public function supports(string $class) : bool
55			{
56			return isset($this->handlers[$class]);
57			}
58			}
59

blixit / event-sourcing

Push — master ( 3112ca...a45803 )

MessagingMiddleware::handle() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like