chill-bundles/src/Bundle/ChillDocGeneratorBundle/Service/Messenger/RequestGenerationHandler.php

<?php

namespace Chill\DocGeneratorBundle\Service\Messenger;

use Chill\DocGeneratorBundle\Repository\DocGeneratorTemplateRepository;
use Chill\DocGeneratorBundle\Service\Generator\Generator;
use Chill\DocStoreBundle\Entity\StoredObject;
use Chill\DocStoreBundle\Repository\StoredObjectRepository;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Messenger\Exception\UnrecoverableMessageHandlingException;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;

/**
 * Handle the request of document generation
 */
class RequestGenerationHandler implements MessageHandlerInterface
{
    private StoredObjectRepository $storedObjectRepository;

    private DocGeneratorTemplateRepository $docGeneratorTemplateRepository;

    private EntityManagerInterface $entityManager;

    private Generator $generator;

    public const AUTHORIZED_TRIALS = 5;

    public function __construct(
        DocGeneratorTemplateRepository $docGeneratorTemplateRepository,
        EntityManagerInterface $entityManager,
        Generator $generator,
        StoredObjectRepository $storedObjectRepository
    ) {
        $this->docGeneratorTemplateRepository = $docGeneratorTemplateRepository;
        $this->entityManager = $entityManager;
        $this->generator = $generator;
        $this->storedObjectRepository = $storedObjectRepository;
    }

    public function __invoke(RequestGenerationMessage $message)
    {
        if (null === $template = $this->docGeneratorTemplateRepository->find($message->getTemplateId())) {
            throw new \RuntimeException('template not found: ' . $message->getTemplateId());
        }

        if (null === $destinationStoredObject = $this->storedObjectRepository->find($message->getDestinationStoredObjectId())) {
            throw new \RuntimeException('destination stored object not found : ' . $message->getDestinationStoredObjectId());
        }

        if ($destinationStoredObject->getGenerationTrialsCounter() >= self::AUTHORIZED_TRIALS) {
            throw new UnrecoverableMessageHandlingException('maximum number of retry reached');
        }

        $destinationStoredObject->addGenerationTrial();
        $this->entityManager->createQuery('UPDATE '.StoredObject::class.' s SET s.generationTrialsCounter = s.generationTrialsCounter + 1 WHERE s.id = :id')
            ->setParameter('id', $destinationStoredObject->getId())
            ->execute();

        $this->generator->generateDocFromTemplate(
            $template,
            $message->getEntityId(),
            $message->getContextGenerationData(),
            $destinationStoredObject
        );
    }
}