oliverde8 / phpEtlBundle

MessageHandler/EtlExecutionHandler.php

<?php

namespace Oliverde8\PhpEtlBundle\MessageHandler;

use Oliverde8\PhpEtlBundle\Message\EtlExecutionMessage;
use Oliverde8\PhpEtlBundle\Repository\EtlExecutionRepository;
use Oliverde8\PhpEtlBundle\Services\ChainProcessorsManager;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;

class EtlExecutionHandler implements MessageHandlerInterface
{
    /** @var ChainProcessorsManager */
    protected $chainProcessorManager;

    /** @var EtlExecutionRepository */
    protected $etlExecutionRepository;

    /**
     * EtlExecutionHandler constructor.
     * @param ChainProcessorsManager $chainProcessorManager
     * @param EtlExecutionRepository $etlExecutionRepository
     */
    public function __construct(ChainProcessorsManager $chainProcessorManager, EtlExecutionRepository $etlExecutionRepository)
    {
        $this->chainProcessorManager = $chainProcessorManager;
        $this->etlExecutionRepository = $etlExecutionRepository;
    }

    public function __invoke(EtlExecutionMessage $message)
    {
        $execution = $this->etlExecutionRepository->find($message->getId());
        $this->chainProcessorManager->executeFromEtlEntity($execution);

It seems like $execution can also be of type null; however, parameter $execution of Oliverde8\PhpEtlBundle\Services\ChainProcessorsManager::executeFromEtlEntity() does only seem to accept Oliverde8\PhpEtlBundle\Entity\EtlExecution, maybe add an additional type check?

    }
}