Shippinno\Notification\Infrastructure\Domain\Model\InMemoryNotificationRepository

Complexity

Total Complexity

13

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

77.78%

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	8	3
A	freshNotifications()	0	11	3
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\NotificationId;
use Shippinno\Notification\Domain\Model\NotificationRepository;

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 ($notification->deduplicationKey()->equals($deduplicationKey)) {
                return true;
            }
        }
    }

    /**
     * {@inheritdoc}
     */
    public function freshNotifications(): array
    {
        $unsent = [];
        foreach ($this->notifications as $notification) {
            if ($notification->isFresh()) {
                $unsent[] = clone $notification;
            }
        }

        return $unsent;
    }

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