App\Messenger\MessageHandler\ProviderImportationHandler::__invoke()

Complexity

Conditions	3
Paths	4

Size

Total Lines	26
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

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