AmqpHandler::handle() - Code Metrics - softonic/laravel-amqp-consumer - Measure and Improve Code Quality continuously with Scrutinizer

AmqpHandler::handle() A
last analyzed 2020-11-05 10:43 UTC

↳ Parent: AmqpHandler

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	8
ccs	5
cts	5
cp	1
rs	10
c	0
b	0
f	0
cc	2
nc	2
nop	1
crap	2

<?php

namespace Softonic\AmqpConsumer;

use PhpAmqpLib\Message\AMQPMessage;

class AmqpHandler
{
    /**
     * @var array
     */
    protected $messageHandlers;

    public function __construct(array $messageHandlers)
    {
        $this->messageHandlers = $messageHandlers;
    }

    public function handle(AMQPMessage $message)
    {
        $messageHandlers = $this->getMessageHandlers($message->get('routing_key'));

        foreach ($messageHandlers as $messageHandler) {
            $messageHandler::dispatch($message);
        }
    }

    private function getMessageHandlers(string $routingKey): array
    {
        $messageHandlers = [];
        foreach ($this->messageHandlers as $job => $messageHandlerRoutingKeys) {
            $messageHandlerRoutingKeysRegex = $this->getRoutingKeysRegex($messageHandlerRoutingKeys);

            if (preg_match($messageHandlerRoutingKeysRegex, $routingKey)) {
                $messageHandlers[] = $job;
            }
        }

        return $messageHandlers;
    }

    private function getRoutingKeysRegex(array $messageHandlerRoutingKeys): string
    {
        $messageHandlerRoutingKeysFlattened = implode('|', $messageHandlerRoutingKeys);
        $messageHandlerRoutingKeysRegex     = preg_replace(
            ['/\./', '/#/'],
            ['\\.', '.*'],
            $messageHandlerRoutingKeysFlattened
        );

        return '/' . $messageHandlerRoutingKeysRegex . '/';
    }
}


1		<?php
2
3		namespace Softonic\AmqpConsumer;
4
5		use PhpAmqpLib\Message\AMQPMessage;
6
7		class AmqpHandler
8		{
9		/**
10		* @var array
11		*/
12		protected $messageHandlers;
13
14	6	public function __construct(array $messageHandlers)
15		{
16	6	$this->messageHandlers = $messageHandlers;
17	6	}
18
19	6	public function handle(AMQPMessage $message)
20		{
21	6	$messageHandlers = $this->getMessageHandlers($message->get('routing_key'));
22
23	6	foreach ($messageHandlers as $messageHandler) {
24	4	$messageHandler::dispatch($message);
25		}
26	6	}
27
28	6	private function getMessageHandlers(string $routingKey): array
29		{
30	6	$messageHandlers = [];
31	6	foreach ($this->messageHandlers as $job => $messageHandlerRoutingKeys) {
32	6	$messageHandlerRoutingKeysRegex = $this->getRoutingKeysRegex($messageHandlerRoutingKeys);
33
34	6	if (preg_match($messageHandlerRoutingKeysRegex, $routingKey)) {
35	4	$messageHandlers[] = $job;
36		}
37		}
38
39	6	return $messageHandlers;
40		}
41
42	6	private function getRoutingKeysRegex(array $messageHandlerRoutingKeys): string
43		{
44	6	$messageHandlerRoutingKeysFlattened = implode('\|', $messageHandlerRoutingKeys);
45	6	$messageHandlerRoutingKeysRegex = preg_replace(
46	6	['/\./', '/#/'],
47	6	['\\.', '.*'],
48	3	$messageHandlerRoutingKeysFlattened
49		);
50
51	6	return '/' . $messageHandlerRoutingKeysRegex . '/';
52		}
53		}
54

softonic / laravel-amqp-consumer

AmqpHandler::handle() A last analyzed 2020-11-05 10:43 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

AmqpHandler::handle() A
last analyzed 2020-11-05 10:43 UTC