vendor/abcpremium/data-object-quality-bundle/src/Event/Subscriber/HandleObjectSave.php line 45

Open in your IDE?
  1. <?php
  3. namespace Abcpremium\DataObjectQualityBundle\Event\Subscriber;
  5. use Abcpremium\DataObjectQualityBundle\Cache\BundleCache;
  6. use Abcpremium\DataObjectQualityBundle\Configuration\BundleConfiguration;
  7. use Abcpremium\DataObjectQualityBundle\Messenger\Message\UpdateDataQualityAsyncMessage;
  8. use Abcpremium\DataObjectQualityBundle\Messenger\Message\UpdateDataQualityMessage;
  9. use Abcpremium\DataObjectQualityBundle\Model\DataQuality\DataQualityService;
  10. use Pimcore\Event\DataObjectEvents;
  11. use Pimcore\Event\Model\DataObjectEvent;
  12. use Pimcore\Model\DataObject\Concrete;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\Messenger\MessageBusInterface;
  16. class HandleObjectSave implements EventSubscriberInterface
  17. {
  19.     private BundleConfiguration $bundleConfiguration;
  21.     private MessageBusInterface $messageBus;
  23.     private BundleCache $cache;
  25.     public function __construct(
  26.         BundleCache $cache,
  27.         BundleConfiguration $bundleConfiguration,
  28.         MessageBusInterface $messageBus
  29.     ) {
  30.         $this->bundleConfiguration = $bundleConfiguration;
  31.         $this->messageBus = $messageBus;
  32.         $this->cache = $cache;
  33.     }
  35.     /**
  36.      * {@inheritDoc}
  37.      */
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             DataObjectEvents::POST_UPDATE => 'setDataQualityOfObject',
  42.         ];
  43.     }
  45.     public function setDataQualityOfObject(DataObjectEvent $dataObjectEvent): void
  46.     {
  47.         if (true === $this->isAutoSave($dataObjectEvent->getArguments())) {
  48.             return;
  49.         }
  51.         $element = $dataObjectEvent->getElement();
  53.         if (!$element instanceof Concrete) {
  54.             return;
  55.         }
  57.         $this->cache->deleteResultFromCache($element);
  59.         $dataQualityPropertyName = $this->bundleConfiguration->getPropertyNameForDataQuality($element->getClassId());
  61.         if (null === $dataQualityPropertyName) {
  62.             return;
  63.         }
  65.         $this->dispatchUpdateMessage($element, $dataQualityPropertyName);
  66.     }
  68.     private function isAutoSave(array $eventArguments): bool
  69.     {
  70.         if (isset($eventArguments['isAutoSave']) && true === $eventArguments['isAutoSave']) {
  71.             return true;
  72.         }
  74.         return false;
  75.     }
  77.     private function dispatchUpdateMessage(Concrete $element, string $dataQualityPropertyName): void
  78.     {
  79.         if (true === $this->bundleConfiguration->isCalculationOnSaveDoneAsync()) {
  80.             $updateMessage = new UpdateDataQualityAsyncMessage($element->getId(), $dataQualityPropertyName);
  81.         } else {
  82.             $updateMessage = new UpdateDataQualityMessage($element->getId(), $dataQualityPropertyName);
  83.         }
  85.         $this->messageBus->dispatch($updateMessage);
  86.     }
  87. }