TomCizek\ResponseRecorder\Application\ResponseRecorder\MutationResponse\DomainEventCollection

Complexity

Total Complexity

9

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getAll()	0	4	1
A	getDomainEventOfType()	0	15	3
A	getDomainEventsOfType()	0	11	3
A	count()	0	4	1

<?php declare(strict_types = 1);

namespace TomCizek\ResponseRecorder\Application\ResponseRecorder\MutationResponse;

use Countable;
use Prooph\Common\Messaging\DomainEvent;
use TomCizek\ResponseRecorder\Application\ResponseRecorder\MutationResponse\DomainEventCollection\MoreThanOneEventOfRequestedTypeExists;

class DomainEventCollection implements Countable
{
	/** @var DomainEvent[] */
	protected $domainEvents = [];

	/**
	 * @param DomainEvent[] $domainEvents
	 */
	public function __construct(array $domainEvents)
	{
		$this->domainEvents = $domainEvents;
	}

	/**
	 * @return DomainEvent[]
	 */
	public function getAll(): array
	{
		return $this->domainEvents;
	}

	public function getDomainEventOfType(string $type): ?DomainEvent
	{
		$ofType = $this->getDomainEventsOfType($type);

		if (count($ofType) > 1) {
			throw new MoreThanOneEventOfRequestedTypeExists(
				sprintf('More than one event of requested type %s exists.', $type)
			);
		}
		if (isset($ofType[0])) {
			return $ofType[0];
		}

		return null;
	}

	/**
	 * @param string $type
	 *
	 * @return DomainEvent[]
	 */
	public function getDomainEventsOfType(string $type): array
	{
		$ofType = [];
		foreach ($this->domainEvents as $event) {
			if (is_a($event, $type)) {
				$ofType[] = $event;
			}
		}

		return $ofType;
	}

	public function count(): int
	{
		return count($this->domainEvents);
	}
}