Application\Api\Field\Mutation\ConfirmRegistration

Complexity

Total Complexity

7

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Test Coverage

Coverage

94.87%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	build()	0	71	7

<?php

declare(strict_types=1);

namespace Application\Api\Field\Mutation;

use Application\Api\Helper;
use Application\DBAL\Types\BookingStatusType;
use Application\DBAL\Types\BookingTypeType;
use Application\Model\Account;
use Application\Model\Bookable;
use Application\Model\Booking;
use Application\Model\User;
use Application\Repository\AccountRepository;
use Application\Repository\BookableRepository;
use Application\Repository\UserRepository;
use Cake\Chronos\Chronos;
use Ecodev\Felix\Api\Exception;
use Ecodev\Felix\Api\ExceptionWithoutMailLogging;
use Ecodev\Felix\Api\Field\FieldInterface;
use GraphQL\Type\Definition\Type;
use Mezzio\Session\SessionInterface;

abstract class ConfirmRegistration implements FieldInterface
{
    public static function build(): iterable
    {
        yield 'confirmRegistration' => fn () => [
            'type' => Type::nonNull(Type::boolean()),
            'description' => 'Second step to register as a new user.',
            'args' => [
                'token' => Type::nonNull(_types()->get('Token')),
                'input' => Type::nonNull(_types()->get('ConfirmRegistrationInput')),
            ],
            'resolve' => function ($root, array $args, SessionInterface $session): bool {
                /** @var UserRepository $repository */
                $repository = _em()->getRepository(User::class);

                /** @var null|User $user */
                $user = $repository->getAclFilter()->runWithoutAcl(fn () => $repository->findOneByToken($args['token']));

                if (!$user) {
                    throw new ExceptionWithoutMailLogging('La session a expiré ou le lien n\'est pas valable. Effectue une nouvelle demande.');
                }

                if (!$user->isTokenValid()) {
                    throw new ExceptionWithoutMailLogging('Le lien que tu as suivi est périmé. Effectue une nouvelle demande.');
                }

                $input = $args['input'];

                $repository->getAclFilter()->runWithoutAcl(function () use ($repository, $input): void {
                    if ($repository->findOneByLogin($input['login'])) {
                        throw new Exception('Ce nom d\'utilisateur est déjà attribué et ne peut être utilisé');
                    }
                });

                // Do it
                Helper::hydrate($user, $input);

                // Active the member
                $user->initialize();

                // Login
                Login::doLogin($session, $user);

                // Create account so the user can top-up money and start purchasing services
                // but only if it's head of the family
                if ($user->isFamilyOwner()) {
                    /** @var AccountRepository $accountRepository */
                    $accountRepository = _em()->getRepository(Account::class);
                    $accountRepository->getOrCreate($user);
                }

                // Create mandatory booking for him
                /** @var BookableRepository $bookableRepository */
                $bookableRepository = _em()->getRepository(Bookable::class);
                $mandatoryBookables = $bookableRepository->findByBookingType(BookingTypeType::MANDATORY);
                foreach ($mandatoryBookables as $bookable) {
                    $booking = new Booking();
                    _em()->persist($booking);

                    $booking->setOwner($user);
                    $booking->setStatus(BookingStatusType::BOOKED);
                    $booking->setStartDate(new Chronos());
                    $booking->setBookable($bookable);

                    // Non-periodic bookable must be terminated immediately
                    if ($bookable->getPeriodicPrice()->isZero()) {
                        $booking->terminate('Terminé automatiquement parce que paiement ponctuel uniquement');
                    }
                }

                _em()->flush();

                return true;
            },
        ];
    }
}