Damax\Common\Domain\EventPublisher\SimpleBusEventPublisher

Complexity

Total Complexity

5

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	discard()	0	3	1
A	publish()	0	12	3

<?php

declare(strict_types=1);

namespace Damax\Common\Domain\EventPublisher;

use SimpleBus\Message\Bus\MessageBus;
use SimpleBus\Message\Recorder\ContainsRecordedMessages;

final class SimpleBusEventPublisher implements EventPublisher
{
    private $recorder;
    private $eventBus;

    public function __construct(ContainsRecordedMessages $recorder, MessageBus $eventBus)
    {
        $this->recorder = $recorder;
        $this->eventBus = $eventBus;
    }

    public function publish(): void
    {
        $eventStream = $this->recorder->recordedMessages();

        if (!count($eventStream)) {
            return;
        }

        $this->recorder->eraseMessages();

        foreach ($eventStream as $event) {
            $this->eventBus->handle($event);
        }
    }

    public function discard(): void
    {
        $this->recorder->eraseMessages();
    }
}