julienj / twity

src/Messenger/MessageHandler/ProviderImportationHandler.php

<?php

namespace App\Messenger\MessageHandler;

use App\Composer\PackageImporter;
use App\Document\Provider;
use App\Mercure\ProviderPublisher;
use App\Messenger\Message\ProviderImportation;
use Doctrine\ODM\MongoDB\DocumentManager;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;

class ProviderImportationHandler implements MessageHandlerInterface
{
    private $packageImporter;
    private $dm;
    private $publisher;

    public function __construct(PackageImporter $packageImporter, DocumentManager $dm, ProviderPublisher $publisher)
    {
        $this->packageImporter = $packageImporter;
        $this->dm = $dm;
        $this->publisher = $publisher;
    }

    public function __invoke(ProviderImportation $message)
    {
        $this->dm->clear();

        /** @var Provider $provider */
        $provider = $this->dm->getRepository('App:Provider')->find($message->getName());

        if (!$provider) {

$provider is of type App\Document\Provider, thus it always evaluated to true.

            return;
        }

        try {
            $rs = $this->packageImporter->import($provider);
            $provider->setHasError(!$rs);
        } catch (\Exception $e) {
            $provider->setHasError(true);
            $provider->setLogs($e->getMessage());
        }

        $provider->setUpdateInProgress(false);
        $this->dm->flush();

        $this->packageImporter->updateReplaceProviderSignature($provider);
        $this->dm->flush();

        $this->publisher->publishProviderUpdate($provider);


    }
}