vendor/abcpremium/asset-metadata-assigner/src/Event/Subscriber/DispatchMessageOnNewAsset.php line 37

Open in your IDE?
  1. <?php
  3. namespace Abcpremium\AssetMetadataAssignerBundle\Event\Subscriber;
  5. use Abcpremium\AssetMetadataAssignerBundle\Configuration\BundleConfiguration;
  6. use Abcpremium\AssetMetadataAssignerBundle\Event\Validator;
  7. use Abcpremium\AssetMetadataAssignerBundle\Messenger\AssetMetadataMessage;
  8. use Pimcore\Event\AssetEvents;
  9. use Pimcore\Event\Model\AssetEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\Messenger\MessageBusInterface;
  13. class DispatchMessageOnNewAsset implements EventSubscriberInterface
  14. {
  15.     private BundleConfiguration $bundleConfiguration;
  17.     private Validator $validator;
  18.     private MessageBusInterface $messageBus;
  20.     public function __construct(
  21.         BundleConfiguration $bundleConfiguration,
  22.         MessageBusInterface $messageBus,
  23.         Validator $validator
  24.     ) {
  25.         $this->bundleConfiguration = $bundleConfiguration;
  26.         $this->validator = $validator;
  27.         $this->messageBus = $messageBus;
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             AssetEvents::POST_ADD => 'dispatchMessageOnNewAsset',
  34.         ];
  35.     }
  37.     public function dispatchMessageOnNewAsset(AssetEvent $event): void
  38.     {
  39.         if (false === $this->validator->isValidAssetEvent($event)) {
  40.             return;
  41.         }
  43.         $assetModel = $event->getAsset();
  44.         $metaDataConfiguration = $this->bundleConfiguration->getAssetMetaDataConfiguration();
  45.         $message = new AssetMetadataMessage();
  46.         $message->setAssetId($assetModel->getId());
  47.         $message->setMetaDataConfiguration($metaDataConfiguration);
  49.         $this->messageBus->dispatch($message);
  50.     }
  51. }