RayRutjes\GetEventStore\Client\Http\Feed\EventStreamViaPersistentSubscriptionFeed

Complexity

Total Complexity

18

Size/Duplication

Total Lines	141
Duplicated Lines	19.86 %

Coupling/Cohesion

Components	1
Dependencies	1

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	11	11	2
A	validateEvents()	8	8	3
A	validateLink()	9	9	3
A	hasPreviousLink()	0	4	1
A	getPreviousLink()	0	4	1
A	hasNextLink()	0	4	1
A	getNextLink()	0	4	1
A	hasLastLink()	0	4	1
A	getLastLink()	0	4	1
A	getAckAllLink()	0	4	1
A	getNackAllLink()	0	4	1
A	getEvents()	0	4	1
A	isHeadOfStream()	0	4	1

<?php

namespace RayRutjes\GetEventStore\Client\Http\Feed;

use RayRutjes\GetEventStore\EventRecord;

final class EventStreamViaPersistentSubscriptionFeed
{
    /**
     * @var array
     */
    private $events;

    /**
     * @var array
     */
    private $links = [];

    /**
     * @var bool
     */
    private $isHeadOfStream;

    /**
     * @param array $events
     * @param array $links
     * @param bool  $isHeadOfStream
     */
    public function __construct(array $events, array $links, bool $isHeadOfStream)

This method seems to be duplicated in your project.

    {
        $this->validateEvents($events);
        $this->events = $events;

        foreach ($links as $link) {
            $this->validateLink($link);
            $this->links[$link->getRelation()] = $link;
        }
        $this->isHeadOfStream = $isHeadOfStream;
    }

    /**
     * @param array $events
     *
     * @return mixed
     */
    private function validateEvents(array $events)

This method seems to be duplicated in your project.

    {
        foreach ($events as $event) {
            if (!$event instanceof EventRecord) {
                throw new \InvalidArgumentException(sprintf('Expected EventRecord, got %s', get_class($event)));
            }
        }
    }

    /**
     * @param $link
     */
    private function validateLink($link)

This method seems to be duplicated in your project.

    {
        if (!$link instanceof EventStreamViaPersistentSubscriptionFeedLink) {
            throw new \InvalidArgumentException('Invalid link type %s.', get_class($link));
        }
        if (isset($this->links[$link->getRelation()])) {
            throw new \InvalidArgumentException(sprintf('Link relation %s already there.', $link->getRelation()));
        }
    }

    /**
     * @return bool
     */
    public function hasPreviousLink(): bool
    {
        return isset($this->links[EventStreamViaPersistentSubscriptionFeedLink::LINK_PREVIOUS]);
    }

    /**
     * @return EventStreamViaPersistentSubscriptionFeedLink
     */
    public function getPreviousLink(): EventStreamViaPersistentSubscriptionFeedLink
    {
        return $this->links[EventStreamViaPersistentSubscriptionFeedLink::LINK_PREVIOUS];
    }

    /**
     * @return bool
     */
    public function hasNextLink(): bool
    {
        return isset($this->links[EventStreamViaPersistentSubscriptionFeedLink::LINK_NEXT]);
    }

    /**
     * @return EventStreamViaPersistentSubscriptionFeedLink
     */
    public function getNextLink(): EventStreamViaPersistentSubscriptionFeedLink
    {
        return $this->links[EventStreamViaPersistentSubscriptionFeedLink::LINK_NEXT];
    }

    /**
     * @return bool
     */
    public function hasLastLink(): bool
    {
        return isset($this->links[EventStreamViaPersistentSubscriptionFeedLink::LINK_LAST]);
    }

    /**
     * @return EventStreamViaPersistentSubscriptionFeedLink
     */
    public function getLastLink(): EventStreamViaPersistentSubscriptionFeedLink
    {
        return $this->links[EventStreamViaPersistentSubscriptionFeedLink::LINK_LAST];
    }

    /**
     * @return EventStreamViaPersistentSubscriptionFeedLink
     */
    public function getAckAllLink(): EventStreamViaPersistentSubscriptionFeedLink
    {
        return $this->links[EventStreamViaPersistentSubscriptionFeedLink::LINK_ACK_ALL];
    }

    /**
     * @return EventStreamViaPersistentSubscriptionFeedLink
     */
    public function getNackAllLink(): EventStreamViaPersistentSubscriptionFeedLink
    {
        return $this->links[EventStreamViaPersistentSubscriptionFeedLink::LINK_NACK_ALL];
    }

    /**
     * @return array
     */
    public function getEvents(): array
    {
        return $this->events;
    }

    /**
     * @return bool
     */
    public function isHeadOfStream(): bool
    {
        return $this->isHeadOfStream;
    }
}