Shippinno\Notification\Infrastructure\Domain\Model\InMemoryNotificationRepository

Complexity

Total Complexity

11

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

96.43%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	add()	0	9	3
A	persist()	0	4	1
A	notificationOfId()	0	8	2
A	hasNotificationOfDeduplicationKey()	0	10	3
A	query()	0	20	1
A	nextIdentity()	0	4	1

<?php
declare(strict_types=1);

namespace Shippinno\Notification\Infrastructure\Domain\Model;

use Shippinno\Notification\Domain\Model\DeduplicationKey;
use Shippinno\Notification\Domain\Model\Notification;
use Shippinno\Notification\Domain\Model\NotificationDeduplicationKeySpecification;
use Shippinno\Notification\Domain\Model\NotificationId;
use Shippinno\Notification\Domain\Model\NotificationRepository;
use Tanigami\Specification\Specification;

class InMemoryNotificationRepository implements NotificationRepository
{
    /**
     * @var Notification[]
     */
    private $notifications = [];

    /**
     * @var int
     */
    private $nextIdentity = 1;

    /**
     * {@inheritdoc}
     */
    public function add(Notification $notification): void
    {
        $deduplicationKey = $notification->deduplicationKey();
        if (!is_null($deduplicationKey) && $this->hasNotificationOfDeduplicationKey($deduplicationKey)) {
            return;
        }
        $notification->setNotificationId($this->nextIdentity());
        $this->persist($notification);
    }

    /**
     * {@inheritdoc}
     */
    public function persist(Notification $notification): void
    {
        $this->notifications[$notification->notificationId()->id()] = $notification;
    }

    /**
     * {@inheritdoc}
     */
    public function notificationOfId(NotificationId $notificationId): ?Notification
    {
        if (!isset($this->notifications[$notificationId->id()])) {
            return null;
        }

        return clone $this->notifications[$notificationId->id()];
    }

    /**
     * {@inheritdoc}
     */
    public function hasNotificationOfDeduplicationKey(DeduplicationKey $deduplicationKey): bool
    {
        foreach ($this->notifications as $notification) {
            if ((new NotificationDeduplicationKeySpecification($deduplicationKey))->isSatisfiedBy($notification)) {
                return true;
            }
        }

        return false;
    }

    /**
     * {@inheritdoc}
     */
    public function query(
        Specification $specification,
        array $orderings = null,
        int $maxResults = null,
        int $firstResult = null
    ): array {
        $notifications =
            array_values(
                array_filter(
                    $this->notifications,
                    function (Notification $notification) use ($specification) {
                        return $specification->isSatisfiedBy($notification);
                    }
                )
            );

        // No max results or first result implementation

        return $notifications;
    }

    /**
     * @return NotificationId
     */
    private function nextIdentity(): NotificationId
    {
        return new NotificationId($this->nextIdentity++);
    }
}