src/App/Subscriber/MembershipTrackSubscriber.php line 63

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\Subscriber;
  5. use App\Entity\User;
  6. use App\Event\Recurring\MembershipAdd;
  7. use App\Event\Recurring\MembershipAttempt;
  8. use App\Event\Recurring\MembershipCancel;
  9. use App\Event\Recurring\MembershipRebill;
  10. use App\RabbitMq\Handler\MembershipStatsHandler;
  11. use App\RabbitMq\TasksPool;
  12. use RuntimeException;
  13. use Symfony\Component\Console\ConsoleEvents;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  16. use Symfony\Component\Validator\Exception\UnexpectedTypeException;
  18. class MembershipTrackSubscriber implements EventSubscriberInterface
  19. {
  21.     private TasksPool $tasksPool;
  23.     private bool $dirty = false;
  25.     public function __construct(TasksPool $tasksPool)
  26.     {
  27.         $this->tasksPool = $tasksPool;
  28.     }
  30.     public function onMembershipAttempt(MembershipAttempt $event): void
  31.     {
  32.         $user = $event->getUser();
  34.         if (!$user instanceof User) {
  35.             throw new UnexpectedTypeException($user, User::class);
  36.         }
  38.         $this->handle($user, MembershipStatsHandler::ATTEMPT);
  39.     }
  41.     public function onMembershipAdd(MembershipAdd $event): void
  42.     {
  43.         $user = $event->getUser();
  45.         if (!$user instanceof User) {
  46.             throw new UnexpectedTypeException($user, User::class);
  47.         }
  49.         $this->handle($user, MembershipStatsHandler::ADD);
  50.     }
  52.     public function onMembershipRebill(MembershipRebill $event): void
  53.     {
  54.         $user = $event->getUser();
  56.         if (!$user instanceof User) {
  57.             throw new UnexpectedTypeException($user, User::class);
  58.         }
  60.         $this->handle($user, MembershipStatsHandler::REBILL);
  61.     }
  63.     public function onMembershipCancel(MembershipCancel $event): void
  64.     {
  65.         $user = $event->getUser();
  67.         if (!$user instanceof User) {
  68.             throw new UnexpectedTypeException($user, User::class);
  69.         }
  71.         $this->handle($user, MembershipStatsHandler::CANCEL);
  72.     }
  74.     public function sendPool(): void
  75.     {
  76.         if (!$this->dirty) {
  77.             return;
  78.         }
  80.         $this->tasksPool->send();
  81.     }
  83.     private function handle(User $user, string $operation): void
  84.     {
  85.         if (!in_array($operation, [MembershipStatsHandler::ATTEMPT, MembershipStatsHandler::ADD, MembershipStatsHandler::REBILL, MembershipStatsHandler::CANCEL], true)) {
  86.             throw new RuntimeException('Unknown operation given. ' . $operation);
  87.         }
  89.         if (null === $user->getId()) {
  90.             throw new UnexpectedTypeException($user->getId(), 'int');
  91.         }
  93.         $this->dirty = true;
  94.         $this->tasksPool->addTask(
  95.             MembershipStatsHandler::class,
  96.             'handle',
  97.             User::class,
  98.             $user->getId(),
  99.             [$operation]
  100.         );
  101.     }
  103.     /**
  104.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  105.      */
  106.     public static function getSubscribedEvents(): array
  107.     {
  108.         $events = [
  109.             MembershipAttempt::class => 'onMembershipAttempt',
  110.             MembershipAdd::class => 'onMembershipAdd',
  111.             MembershipRebill::class => 'onMembershipRebill',
  112.             MembershipCancel::class => 'onMembershipCancel',
  113.         ];
  115.         if (class_exists(KernelEvents::class)) {
  116.             $events[KernelEvents::TERMINATE] = 'sendPool';
  117.         }
  119.         if (class_exists(ConsoleEvents::class)) {
  120.             $events[ConsoleEvents::TERMINATE] = 'sendPool';
  121.         }
  123.         return $events;
  124.     }
  126. }