Lines 100.00% 6 / 6
Functions and Methods 100.00% 2 / 2
Classes and Traits 100.00% 1 / 1
Name Lines Functions and Methods CRAP Classes and Traits
BrokerMessageDispatcher 100.00% 6 / 6 100.00% 2 / 2 3 100.00% 1 / 1
 __construct 100.00% 1 / 1 100.00% 1 / 1 1
 dispatch 100.00% 5 / 5 100.00% 1 / 1 2
1<?php
2
3declare(strict_types=1);
4
5namespace Stewart\Runtime\Worker\Message;
6
7use Psr\Log\LoggerInterface;
8use Stewart\Runtime\Exception\ContainerException;
9use Stewart\Runtime\Ipc\Message\BrokerMessage;
10use Stewart\Runtime\Ipc\MessageHandlerIndex;
11
12final readonly class BrokerMessageDispatcher
13{
14    /** @var MessageHandlerIndex<BrokerMessageHandler<*>> */
15    private MessageHandlerIndex $handlers;
16
17    /**
18     * @param iterable<BrokerMessageHandler<*>> $handlers
19     *
20     * @throws ContainerException
21     */
22    public function __construct(
23        iterable $handlers,
24        private LoggerInterface $logger,
25    ) {
26        $this->handlers = MessageHandlerIndex::fromHandlers($handlers);
27    }
28
29    public function dispatch(BrokerMessage $message): void
30    {
31        /** @var BrokerMessageHandler<BrokerMessage>|null $handler */
32        $handler = $this->handlers->findHandlerFor($message);
33
34        if ($handler === null) {
35            $this->logger->warning('Ignoring an unknown broker message', ['message' => $message::class]);
36
37            return;
38        }
39
40        $handler->handle($message);
41    }
42}