src/EventSubscriber/CommonCategorySubscriber.php line 26

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\JobQueue;
  6. use App\Service\EsJobQueue;
  7. use App\Event\CommonCategoryPreRemoveEvent;
  8. use App\Event\CommonCategoryPostUpdateEvent;
  9. use App\Service\JobQueueAction\ElasticDependentUpdateAction;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class CommonCategorySubscriber implements EventSubscriberInterface
  13. {
  14.     public function __construct(
  15.         private EsJobQueue $esJobQueue
  16.     ) {}
  18.     public static function getSubscribedEvents(): array
  19.     {
  20.         return [
  21.             CommonCategoryPostUpdateEvent::NAME => 'onPostUpdate',
  22.             CommonCategoryPreRemoveEvent::NAME => 'onPreRemove'
  23.         ];
  24.     }
  26.     public function onPostUpdate(CommonCategoryPostUpdateEvent $event)
  27.     {
  28.         $object = $event->getObject();
  30.         $payload = [...$object->getQueueInfo(), 'operation' => 'UPDATE'];
  31.         $this->esJobQueue->create(
  32.             ElasticDependentUpdateAction::NAME,
  33.             json_encode($payload),
  34.             JobQueue::PRIORITY_LOW,
  35.             null,
  36.             1,
  37.             null,
  38.             false,
  39.             false
  40.         );
  41.     }
  43.     public function onPreRemove(CommonCategoryPreRemoveEvent $event)
  44.     {
  45.         $object = $event->getObject();
  46.         $payload = [...$object->getQueueInfo(), 'operation' => 'DELETE'];
  47.         $this->esJobQueue->create(
  48.             ElasticDependentUpdateAction::NAME,
  49.             json_encode($payload),
  50.             JobQueue::PRIORITY_LOW
  51.         );
  52.     }
  53. }