Rawkode\Eidetic\EventStore\EventPublisherMixin

Complexity

Total Complexity

5

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	registerSubscriber()	0	4	1
A	publishAll()	0	6	2
A	publish()	0	7	2

<?php

namespace Rawkode\Eidetic\EventStore;

use Rawkode\Eidetic\EventSourcing\EventSourcedEntity;

trait EventPublisherMixin
{
    /**
     * @var array
     */
    protected $subscribers = [];

    /**
     * @param Subscriber $subscriber
     */
    public function registerSubscriber($subscriber)
    {
        array_push($this->subscribers, $subscriber);
    }

    /**
     * @param string             $eventHook
     * @param EventSourcedEntity $eventSourcedEntity
     */
    public function publishAll($eventHook, EventSourcedEntity $eventSourcedEntity)
    {
        foreach ($eventSourcedEntity->stagedEvents() as $event) {
            $this->publish($eventHook, $eventSourcedEntity, $event);
        }
    }

    /**
     * @param int                $eventHook
     * @param EventSourcedEntity $eventSourcedEntity
     * @param object             $event
     */
    public function publish($eventHook, EventSourcedEntity $eventSourcedEntity, $event)
    {
        /** @var Subscriber $subscriber */
        foreach ($this->subscribers as $subscriber) {
            $subscriber->handle($eventHook, $eventSourcedEntity, $event);
        }
    }
}