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

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\QuoteReason\QuoteReason;
  14. use App\V4\Model\QuoteState\QuoteState;
  15. use App\V4\Model\QuoteTaskExternalRef\QuoteTaskExternalRef;
  16. use App\V4\Model\Task\Task;
  17. use Psr\Log\LogLevel;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\Serializer\Exception\ExceptionInterface;
  21. class TaskPostPersistEventSubscriber extends AbstractSubscriber implements EventSubscriberInterface
  22. {
  23.     /**
  24.      * @var CollectionDataProviderInterface
  25.      */
  26.     private $collectionDataProvider;
  28.     /**
  29.      * @var CrudTaskHandler
  30.      */
  31.     private $crudTaskHandler;
  33.     /**
  34.      * @var SentryLogger
  35.      */
  36.     private $sentryLogger;
  38.     /**
  39.      * @param CollectionDataProviderInterface $collectionDataProvider
  40.      * @param CrudTaskHandler                 $crudTaskHandler
  41.      * @param SentryLogger                    $sentryLogger
  42.      */
  43.     public function __construct(
  44.         CollectionDataProviderInterface $collectionDataProvider,
  45.         CrudTaskHandler $crudTaskHandler,
  46.         SentryLogger $sentryLogger
  47.     ) {
  48.         $this->collectionDataProvider = $collectionDataProvider;
  49.         $this->crudTaskHandler = $crudTaskHandler;
  50.         $this->sentryLogger = $sentryLogger;
  51.     }
  53.     /**
  54.      * @param $entity
  55.      *
  56.      * @return bool
  57.      */
  58.     public function supports($entity): bool
  59.     {
  60.         return $entity instanceof Task && !$entity->getQuotes()->isEmpty();
  61.     }
  63.     /**
  64.      * @return string[]
  65.      */
  66.     public static function getSubscribedEvents(): array
  67.     {
  68.         return [
  69.             PostPersistEvent::NAME => 'onPostPersist',
  70.         ];
  71.     }
  73.     /**
  74.      * @param PostPersistEvent $event
  75.      *
  76.      * @throws ResourceClassNotSupportedException
  77.      * @throws ExceptionInterface
  78.      * @throws \Exception
  79.      */
  80.     public function onPostPersist(PostPersistEvent $event): void
  81.     {
  82.         /** @var Task $objPersisted */
  83.         $objPersisted = $event->getAfter();
  84.         if (!$this->supports($objPersisted) || $this->isIdAlreadyManaged($objPersisted->getId(), get_class($this))) {
  85.             return;
  86.         }
  88.         $quoteIds = [];
  89.         foreach ($objPersisted->getQuotes() as $quoteRef) {
  90.             $quoteIds[] = $quoteRef->getExternalValue();
  91.         }
  93.         if (empty($quoteIds)) {
  94.             // You can never be too careful, apparently.
  95.             $this->sentryLogger->captureMessage(
  96.                 SentryLogger::CHANNEL_SUBSCRIBER,
  97.                 'TaskPostPersistEventSubscriber::onPostPersist() called with empty quoteIds. (bypassed checks)',
  98.                 [
  99.                     'catchOnClass' => self::class,
  100.                 ],
  101.                 LogLevel::CRITICAL
  102.             );
  104.             return;
  105.         }
  107.         $quotes = $this->collectionDataProvider->getCollection(Quote::class, null, [
  108.             'filters' => [
  109.                 'id' => $quoteIds,
  110.             ],
  111.         ]);
  113.         /** @var Quote $quote */
  114.         foreach ($quotes as $quote) {
  115.             if ($quote->hasTask($objPersisted->getId())) {
  116.                 continue;
  117.             }
  118.             if ($quote->getStatus() instanceof QuoteState) {
  119.                 $quote->getStatus()->setNormalizeAsIRI(true);
  120.             }
  121.             foreach ($quote->getQuoteLines() as $quoteLine) {
  122.                 $quoteLine->setNormalizeAsIRI(true);
  123.             }
  124.             foreach ($quote->getTasks() as $task) {
  125.                 $task->setNormalizeAsIRI(true);
  126.             }
  128.             if ($quote->getReason() instanceof QuoteReason) {
  129.                 $quote->getReason()->setNormalizeAsIRI(true);
  130.             }
  131.             $quote->addTask((new QuoteTaskExternalRef())->setExternalValue($objPersisted->getId()));
  133.             $this->crudTaskHandler->submitQuoteForm(
  134.                 $quote,
  135.                 [AbstractWithoutRequestDataPersister::CONTEXT_NOT_POST_PERSIST_EVENT => true]
  136.             );
  137.         }
  138.     }
  139. }