App\Messenger\MessageHandler\ProviderImportationHandler

Complexity

Total Complexity

4

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__invoke()	0	26	3

<?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);


    }
}