BenTools\MercurePHP\Transport\PHP\PHPTransport

Complexity

Total Complexity

4

Size/Duplication

Total Lines	24
Duplicated Lines	0 %

Test Coverage

Coverage

91.67%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	publish()	0	4	1
A	__construct()	0	3	1
A	subscribe()	0	9	2

<?php

namespace BenTools\MercurePHP\Transport\PHP;

use BenTools\MercurePHP\Security\TopicMatcher;
use BenTools\MercurePHP\Model\Message;
use BenTools\MercurePHP\Transport\TransportInterface;
use Evenement\EventEmitter;
use Evenement\EventEmitterInterface;
use React\Promise\PromiseInterface;

use function React\Promise\resolve;

final class PHPTransport implements TransportInterface
{
    private EventEmitterInterface $emitter;

    public function __construct(?EventEmitterInterface $emitter = null)
    {
        $this->emitter = $emitter ?? new EventEmitter();
    }

    public function publish(string $topic, Message $message): PromiseInterface
    {
        $this->emitter->emit('message', [$topic, $message]);
        return resolve($message->getId());
    }

    public function subscribe(string $subscribedTopic, callable $callback): PromiseInterface
    {
        $this->emitter->on('message', function (string $topic, Message $message) use ($callback, $subscribedTopic) {
            if (!TopicMatcher::matchesTopicSelectors($topic, [$subscribedTopic])) {
                return;
            }
            return $callback($topic, $message);
        });
        return resolve($subscribedTopic);
    }
}