src/V4/EventSubscriber/Task/TaskPostPersistEventSubscriber.php line 79

Open in your IDE?
  1. <?php
  3. namespace App\V4\EventSubscriber\Task;
  5. use ApiPlatform\Core\DataProvider\CollectionDataProviderInterface;
  6. use ApiPlatform\Core\Exception\ResourceClassNotSupportedException;
  7. use App\V4\DataPersister\AbstractWithoutRequestDataPersister;
  8. use App\V4\Event\PostPersistEvent;
  9. use App\V4\EventSubscriber\AbstractSubscriber;
  10. use App\V4\Handler\Task\CrudTaskHandler;
  11. use App\V4\Logger\SentryLogger;
  12. use App\V4\Model\Quote\Quote;
  13. use App\V4\Model\QuoteState\QuoteState;
  14. use App\V4\Model\QuoteTaskExternalRef\QuoteTaskExternalRef;
  15. use App\V4\Model\Task\Task;
  16. use Psr\Log\LogLevel;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\Serializer\Exception\ExceptionInterface;
  20. class TaskPostPersistEventSubscriber extends AbstractSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @var CollectionDataProviderInterface
  24.      */
  25.     private $collectionDataProvider;
  27.     /**
  28.      * @var CrudTaskHandler
  29.      */
  30.     private $crudTaskHandler;
  32.     /**
  33.      * @var SentryLogger
  34.      */
  35.     private $sentryLogger;
  37.     /**
  38.      * @param CollectionDataProviderInterface $collectionDataProvider
  39.      * @param CrudTaskHandler                 $crudTaskHandler
  40.      * @param SentryLogger                    $sentryLogger
  41.      */
  42.     public function __construct(
  43.         CollectionDataProviderInterface $collectionDataProvider,
  44.         CrudTaskHandler $crudTaskHandler,
  45.         SentryLogger $sentryLogger
  46.     ) {
  47.         $this->collectionDataProvider = $collectionDataProvider;
  48.         $this->crudTaskHandler = $crudTaskHandler;
  49.         $this->sentryLogger = $sentryLogger;
  50.     }
  52.     /**
  53.      * @param $entity
  54.      *
  55.      * @return bool
  56.      */
  57.     public function supports($entity): bool
  58.     {
  59.         return $entity instanceof Task && !$entity->getQuotes()->isEmpty();
  60.     }
  62.     /**
  63.      * @return string[]
  64.      */
  65.     public static function getSubscribedEvents(): array
  66.     {
  67.         return [
  68.             PostPersistEvent::NAME => 'onPostPersist',
  69.         ];
  70.     }
  72.     /**
  73.      * @param PostPersistEvent $event
  74.      *
  75.      * @throws ResourceClassNotSupportedException
  76.      * @throws ExceptionInterface
  77.      * @throws \Exception
  78.      */
  79.     public function onPostPersist(PostPersistEvent $event): void
  80.     {
  81.         /** @var Task $objPersisted */
  82.         $objPersisted = $event->getAfter();
  83.         if (!$this->supports($objPersisted) || $this->isIdAlreadyManaged($objPersisted->getId(), get_class($this))) {
  84.             return;
  85.         }
  87.         $quoteIds = [];
  88.         foreach ($objPersisted->getQuotes() as $quoteRef) {
  89.             $quoteIds[] = $quoteRef->getExternalValue();
  90.         }
  92.         if (empty($quoteIds)) {
  93.             // You can never be too careful, apparently.
  94.             $this->sentryLogger->captureMessage(
  95.                 SentryLogger::CHANNEL_SUBSCRIBER,
  96.                 'TaskPostPersistEventSubscriber::onPostPersist() called with empty quoteIds. (bypassed checks)',
  97.                 [
  98.                     'catchOnClass' => self::class,
  99.                 ],
  100.                 LogLevel::CRITICAL
  101.             );
  103.             return;
  104.         }
  106.         $quotes = $this->collectionDataProvider->getCollection(Quote::class, null, [
  107.             'filters' => [
  108.                 'id' => $quoteIds,
  109.             ],
  110.         ]);
  112.         /** @var Quote $quote */
  113.         foreach ($quotes as $quote) {
  114.             if ($quote->hasTask($objPersisted->getId())) {
  115.                 continue;
  116.             }
  117.             if ($quote->getStatus() instanceof QuoteState) {
  118.                 $quote->getStatus()->setNormalizeAsIRI(true);
  119.             }
  120.             foreach ($quote->getQuoteLines() as $quoteLine) {
  121.                 $quoteLine->setNormalizeAsIRI(true);
  122.             }
  123.             foreach ($quote->getTasks() as $task) {
  124.                 $task->setNormalizeAsIRI(true);
  125.             }
  126.             $quote->addTask((new QuoteTaskExternalRef())->setExternalValue($objPersisted->getId()));
  128.             $this->crudTaskHandler->submitQuoteForm(
  129.                 $quote,
  130.                 [AbstractWithoutRequestDataPersister::CONTEXT_NOT_POST_PERSIST_EVENT => true]
  131.             );
  132.         }
  133.     }
  134. }