for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?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
App\Document\Provider
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->publisher->publishProviderUpdate($provider);
julienj /
twity
Loading history...