Lines 100.00% 7 / 7
Methods 100.00% 2 / 2
Classes 100.00% 1 / 1
Covered by tests of size
Name Lines Methods CRAP
 __construct 100.00% 1 / 1 100.00% 1 / 1 1
 dispatch 100.00% 6 / 6 100.00% 1 / 1 2
25final readonly class DatabaseMessageBus
26{
27    public function __construct(
28        private DatabaseTransport $databaseTransport,
29    ) {
30    }
31
32    /**
33     * @param array<string, mixed> $headers
34     * @throws \JsonException
35     */
36    public function dispatch(object $message, string $queue = 'default', array $headers = []): int
37    {
38        $payload = $message instanceof QueueMessageInterface ? $message->toArray() : get_object_vars($message);
39
40        $encodedBody = json_encode([
41            'class' => $message::class,
42            'payload' => $payload,
43        ], JSON_THROW_ON_ERROR);
44
45        return $this->databaseTransport->enqueue($encodedBody, $headers, $queue);
46    }
47}