Softonic\AmqpConsumer\AmqpHandler

Complexity

Total Complexity

7

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	handle()	0	8	2
A	getMessageHandlers()	0	13	3
A	getRoutingKeysRegex()	0	11	1

<?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 . '/';
    }
}