Stu\Component\Event\Strategy\AnomalyProcessingEventStrategy

Complexity

Total Complexity

6

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

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

<?php

namespace Stu\Component\Event\Strategy;

use Doctrine\Common\Collections\ArrayCollection;
use Doctrine\Common\Collections\Collection;
use JsonMapper\JsonMapperInterface;
use RuntimeException;
use Stu\Component\Anomaly\AnomalyHandlingInterface;
use Stu\Component\Event\Payload\PayloadWithIdAndTurn;
use Stu\Orm\Entity\AnomalyInterface;
use Stu\Orm\Entity\EventInterface;
use Stu\Orm\Entity\ShipInterface;
use Stu\Orm\Entity\UserInterface;
use Stu\Orm\Repository\AnomalyRepositoryInterface;

class AnomalyProcessingEventStrategy implements EventStrategyInterface
{
    public function __construct(
        private AnomalyRepositoryInterface $anomalyRepository,
        private AnomalyHandlingInterface $anomalyHandling,
        private JsonMapperInterface $jsonMapper
    ) {
    }

    public function getEntitiesToLock(EventInterface $event): Collection
    {
        $users = $this->getAnomaly($event)
            ->getLocation()
            ->getShips()
            ->map(fn (ShipInterface $ship) => $ship->getUser())
            ->filter(fn (UserInterface $user) => !$user->isVacationRequestOldEnough());

        $result = [];

        foreach ($users as $user) {

            $result[$user->getId()] = $user;
        }

        return new ArrayCollection($result);
    }

    public function processEvent(EventInterface $event): void
    {
        $this->anomalyHandling->processExistingAnomaly($this->getAnomaly($event));
    }

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

        $anomaly = $this->anomalyRepository->find($payload->id);
        if ($anomaly === null) {
            throw new RuntimeException('no existing anomaly found for id %d', $payload->id);
        }

        return $anomaly;
    }
}