Stu\Module\Tick\User\UserTick

Complexity

Total Complexity

6

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getUser()	0	11	2
A	getEntitiesToLock()	0	3	1
A	processEvent()	0	4	2
A	__construct()	0	5	1

<?php

declare(strict_types=1);

namespace Stu\Module\Tick\User;

use Doctrine\Common\Collections\ArrayCollection;
use Doctrine\Common\Collections\Collection;
use JsonMapper\JsonMapperInterface;
use RuntimeException;
use Stu\Component\Event\Payload\PayloadWithIdAndTurn;
use Stu\Component\Event\Strategy\EventStrategyInterface;
use Stu\Orm\Entity\EventInterface;
use Stu\Orm\Entity\UserInterface;
use Stu\Orm\Repository\UserRepositoryInterface;

class UserTick implements EventStrategyInterface
{
    /** @param array<int, UserTickComponentInterface> $components */
    public function __construct(
        private UserRepositoryInterface $userRepository,
        private array $components,
        private JsonMapperInterface $jsonMapper
    ) {
    }

    public function getEntitiesToLock(EventInterface $event): Collection
    {
        return new ArrayCollection([$this->getUser($event)]);
    }

    public function processEvent(EventInterface $event): void
    {
        foreach ($this->components as $component) {
            $component->processUser($this->getUser($event));
        }
    }

    private function getUser(EventInterface $event): UserInterface
    {
        /** @var PayloadWithIdAndTurn */
        $payload = $event->getPayloadAsObject($this->jsonMapper);

        $user = $this->userRepository->find($payload->id);
        if ($user === null) {
            throw new RuntimeException(sprintf('userId %d does not exist', $payload->id));
        }

        return $user;
    }
}