Gica\Cqrs\Saga\SagasOnlyOnceEventDispatcher::dispatchEvent()

Complexity

Conditions	4
Paths	4

Size

Total Lines	18
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	10
CRAP Score	4

Importance

Changes

0

<?php
    public function dispatchEvent(EventWithMetaData $eventWithMetaData)
    {
        $listeners = $this->eventSubscriber->getListenersForEvent($eventWithMetaData->getEvent());

        foreach ($listeners as $listener) {
            $metaData = $eventWithMetaData->getMetaData();

            if (is_array($listener)) {
                $saga = $listener[0];

                if (!$this->sagaRepository->isEventAlreadyDispatched(get_class($saga), $metaData->getSequence(), $metaData->getIndex())) {
                    call_user_func($listener, $eventWithMetaData->getEvent(), $metaData);

                    $this->sagaRepository->persistLastProcessedEventBySaga(get_class($saga), $metaData->getSequence(), $metaData->getIndex());
                }
            }
        }
    }
}