custom/plugins/CrswCleverReachOfficial/src/Components/StateTransition/QueueItemFinishedListener.php line 30

Open in your IDE?
  1. <?php
  4. namespace Crsw\CleverReachOfficial\Components\StateTransition;
  6. use Crsw\CleverReachOfficial\Components\Entities\StateTransitionRecord;
  7. use Crsw\CleverReachOfficial\Core\BusinessLogic\InitialSynchronization\Tasks\Composite\InitialSyncTask;
  8. use Crsw\CleverReachOfficial\Core\BusinessLogic\TaskExecution\Events\QueueItemFinishedEvent;
  9. use Crsw\CleverReachOfficial\Core\Infrastructure\ORM\Exceptions\QueryFilterInvalidParamException;
  10. use Crsw\CleverReachOfficial\Core\Infrastructure\TaskExecution\Exceptions\QueueItemDeserializationException;
  11. use Crsw\CleverReachOfficial\Core\Infrastructure\TaskExecution\QueueItem;
  12. use JsonException;
  14. /**
  15.  * Class QueueItemFinishedListener
  16.  *
  17.  * @package Crsw\CleverReachOfficial\Components\StateTransition
  18.  */
  19. class QueueItemFinishedListener extends QueueItemListener
  20. {
  21.     /**
  22.      * Handles queue item finished event.
  23.      *
  24.      * @param QueueItemFinishedEvent $event
  25.      *
  26.      * @throws QueryFilterInvalidParamException
  27.      * @throws QueueItemDeserializationException
  28.      * @throws JsonException
  29.      */
  30.     public static function handle(QueueItemFinishedEvent $event): void
  31.     {
  32.         $queueItem = $event->getQueueItem();
  33.         $taskType = $queueItem->getTaskType();
  35.         if ($taskType === InitialSyncTask::getClassName()) {
  36.             $entity = new StateTransitionRecord();
  37.             $entity->setStatus(QueueItem::COMPLETED);
  38.             $entity->setTaskType($taskType);
  39.             $entity->setResolved(false);
  40.             $entity->setQueueItem($queueItem);
  42.             $existingRecord = self::getExistingRecord($taskType);
  44.             self::updateOrCreateStateTransitionRecord($entity, $existingRecord);
  45.         }
  46.     }
  47. }