VSVverkeerskunde/gvq-api

<?php declare(strict_types=1);

namespace VSV\GVQ_API\Registration\Repositories;

use Ramsey\Uuid\UuidInterface;
use VSV\GVQ_API\Common\Repositories\AbstractDoctrineRepository;
use VSV\GVQ_API\Registration\Models\Registration;
use VSV\GVQ_API\Registration\Repositories\Entities\RegistrationEntity;
use VSV\GVQ_API\Registration\ValueObjects\UrlSuffix;

class RegistrationDoctrineRepository extends AbstractDoctrineRepository implements RegistrationRepository
{
    /**
     * @inheritdoc
     */
    protected function getRepositoryName(): string
    {
        return RegistrationEntity::class;
    }

    /**
     * @inheritdoc
     */
    public function save(Registration $registration): void
    {
        $registrationEntity = RegistrationEntity::fromRegistration($registration);

        // The user object inside registration is not managed,
        // therefore we need to use merge instead of persist.
        // When user wouldn't exist yet, the user is not created.
        $this->entityManager->merge($registrationEntity);
        $this->entityManager->flush();
    }

    /**
     * @inheritdoc
     */
    public function delete(UuidInterface $id): void
    {
        $registrationEntity = $this->getEntityById($id);

        if ($registrationEntity !== null) {
            $this->entityManager->merge($registrationEntity);
            $this->entityManager->remove($registrationEntity);
            $this->entityManager->flush();
        }
    }

    /**
     * @inheritdoc
     */
    public function getById(UuidInterface $id): ?Registration
    {
        $registrationEntity = $this->getEntityById($id);

        return $registrationEntity ? $registrationEntity->toRegistration() : null;
    }

    /**
     * @inheritdoc
     */
    public function getByUrlSuffix(UrlSuffix $urlSuffix): ?Registration
    {
        /** @var RegistrationEntity|null $registrationEntity */
        $registrationEntity = $this->objectRepository->findOneBy(
            [
                'urlSuffix' => $urlSuffix->toNative(),
            ]
        );

        return $registrationEntity ? $registrationEntity->toRegistration() : null;
    }

    /**
     * @inheritdoc
     */
    public function getByUserId(UuidInterface $userId): ?Registration
    {
        /** @var RegistrationEntity|null $registrationEntity */
        $registrationEntity = $this->objectRepository->findOneBy(
            [
                'userEntity' => $userId->toString(),
            ]
        );

        return $registrationEntity ? $registrationEntity->toRegistration() : null;
    }

    /**
     * @param UuidInterface $id
     * @return RegistrationEntity
     */
    private function getEntityById(UuidInterface $id): ?RegistrationEntity
    {
        /** @var RegistrationEntity|null $registrationEntity */
        $registrationEntity = $this->objectRepository->findOneBy(
            [
                'id' => $id,
            ]
        );

        return $registrationEntity;
    }

    /**
     * @inheritdoc
     */
    public function getUsedRegistrationsCreatedBefore(\DateTimeImmutable $kickOffDate): array
    {
        $registrations = $this->objectRepository->findBy(
            [
                'passwordReset' => false,
                'used' => true,
            ]
        );

        $registrations = array_map(
            function (RegistrationEntity $registration) {
                return $registration->toRegistration();
            },
            $registrations
        );

        $registrations = array_filter(
            $registrations,
            function (Registration $registration) use ($kickOffDate) {
                return $registration->getCreatedOn() < $kickOffDate;
            }
        );

        return $registrations;
    }
}