src/EventSubscriber/RotationServiceSubscriber.php line 45

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Event\Profile\ConfirmationRequest\ProfileModerationRejected;
  6. use App\Event\Profile\ConfirmationRequest\ProfileModerationPassed;
  7. use App\Event\Profile\ProfileDataChanged;
  8. use App\Event\Profile\ProfileEvent;
  9. use App\Event\Profile\ProfileWasDeleted;
  10. use App\Event\Profile\ProfileWasHidden;
  11. use App\Event\Profile\ProfileWasPlacedOnAdBoard;
  12. use App\Event\Profile\ProfileWasRemovedFromAdBoard;
  13. use App\Message\UpdateRotationMessage;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\Messenger\MessageBusInterface;
  17. readonly class RotationServiceSubscriber implements EventSubscriberInterface
  18. {
  19.     public function __construct(private MessageBusInterface $bus)
  20.     {
  21.     }
  23.     // Вызывать при любом изменении анкеты, изменении тарифа размещения или добавлении в листинг
  24.     public function onChange(ProfileEvent $event): void
  25.     {
  26.         $caused = get_class($event);
  27.         $profile = $event->getProfile();
  28.         $eligible = $profile->isEligibleToShowByModeration()
  29.             && $profile->isActive()
  30.             && !$profile->isHidden()
  31.             && !$profile->isDeleted();
  32.         $message = $eligible
  33.             ? UpdateRotationMessage::place($caused, $profile->getId())
  34.             : UpdateRotationMessage::delete($caused, $profile->getId());
  36.         $this->bus->dispatch($message);
  37.     }
  39.     public function onModerationPassed(ProfileModerationPassed $event): void
  40.     {
  41.         $this->onChange($event);
  42.     }
  44.     // Вызывать при удалении анкеты из листинга
  45.     public function onDelete(ProfileEvent $event): void
  46.     {
  47.         $caused = get_class($event);
  48.         $this->bus->dispatch(UpdateRotationMessage::delete($caused, $event->getProfile()->getId()));
  49.     }
  51.     public static function getSubscribedEvents(): iterable
  52.     {
  53.         return [
  54.             ProfileWasRemovedFromAdBoard::NAME => ['onDelete', -110],
  55.             ProfileWasHidden::NAME => ['onDelete', -110],
  56.             ProfileWasDeleted::NAME => ['onDelete', -110],
  57.             ProfileModerationRejected::NAME => ['onDelete', -110],
  58.             ProfileModerationPassed::NAME => ['onModerationPassed', -110],
  60.             ProfileDataChanged::NAME => ['onChange', -100],
  61.             ProfileWasPlacedOnAdBoard::NAME => ['onChange', -100],
  62.         ];
  63.     }
  64. }