src/Subscriber/Search/MemberSearchSubscriber.php line 49

Open in your IDE?
  1. <?php
  2. /*
  3.  * Author: Dominik Piekarski <code@dompie.de>
  4.  * Created at: 2020/10/01 16:23
  5.  */
  6. declare(strict_types=1);
  8. namespace App\Subscriber\Search;
  10. use App\Event\User\AccountStatusChangeEvent;
  11. use App\Event\User\AmateurUpdateEvent;
  12. use App\Event\User\AmateurUpgradeCompleteEvent;
  13. use App\Event\User\LoginCreatedEvent;
  14. use App\Event\User\LogoutEvent;
  15. use App\Service\Search\MemberSearchService;
  16. use Elasticsearch\Common\Exceptions\Missing404Exception;
  17. use Psr\Log\LoggerInterface;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class MemberSearchSubscriber implements EventSubscriberInterface
  21. {
  22.     protected MemberSearchService $amateurSearch;
  23.     protected bool $enabled = false;
  24.     protected LoggerInterface $logger;
  26.     public function __construct(MemberSearchService $amateurSearch, LoggerInterface $appLogger)
  27.     {
  28.         $this->amateurSearch = $amateurSearch;
  29.         $this->enabled = (bool) (getenv($_ENV['REALTIME_MEMBER_SEARCH']) ?? false);
  30.         $this->logger = $appLogger;
  31.     }
  33.     public function enable(): void
  34.     {
  35.         $this->enabled = true;
  36.     }
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             AmateurUpdateEvent::class => [['onAmateurUpdateIndex', 0]],
  42.             AmateurUpgradeCompleteEvent::class => [['onNewAmateurUpdateIndex', 0]],
  43.             AccountStatusChangeEvent::class => [['onAccountStatusChangeUpdateIndex', 0]],
  44.             LoginCreatedEvent::class => [['onLoginUpdateIndex', 0]],
  45.             LogoutEvent::class => [['onLogoutUpdateIndex', 0]],
  46.         ];
  47.     }
  49.     public function onAmateurUpdateIndex(AmateurUpdateEvent $event)
  50.     {
  51.         if (false === $event->getEntity()->getIsAmateur()) {
  52.             return;
  53.         }
  54.         $this->amateurSearch->updateOrInsert($event->getEntity());
  55.     }
  57.     public function onLoginUpdateIndex(LoginCreatedEvent $event): void
  58.     {
  59.         if (!$this->enabled) {
  60.             return;
  61.         }
  62.         $account = $event->getLogin()->getAccount();
  63.         if (null === $account || null === $account->getMember()) {
  64.             return;
  65.         }
  66.         $this->amateurSearch->updateOrInsert($account->getMember());
  67.     }
  69.     public function onLogoutUpdateIndex(LogoutEvent $event): void
  70.     {
  71.         if (!$this->enabled) {
  72.             return;
  73.         }
  74.         $member = $event->getAccount()->getMember();
  75.         if (null === $member) {
  76.             return;
  77.         }
  78.         $this->amateurSearch->updateOrInsert($member);
  79.     }
  81.     public function onNewAmateurUpdateIndex(AmateurUpgradeCompleteEvent $event): void
  82.     {
  83.         if (!$this->enabled) {
  84.             return;
  85.         }
  86.         if (null === $event->getAmateurUpgrade()->getAccount() || !$event->getAmateurUpgrade()->getAccount()->hasMember()) {
  87.             return;
  88.         }
  89.         $this->amateurSearch->updateOrInsert($event->getAmateurUpgrade()->getAccount()->getMember(), true);
  90.     }
  92.     public function onAccountStatusChangeUpdateIndex(AccountStatusChangeEvent $event): void
  93.     {
  94.         if (!$this->enabled) {
  95.             return;
  96.         }
  97.         $member = $event->getAccount()->getMember();
  98.         if (!$member) {
  99.             return;
  100.         }
  101.         try {
  102.             if ($event->gotBlocked()) {
  103.                 $this->amateurSearch->removeById($member->getId(), true);
  104.             }
  105.             if ($event->gotReenabled()) {
  106.                 $this->amateurSearch->updateOrInsert($member);
  107.             }
  108.         } catch (Missing404Exception $e) {
  109.             $this->logger->error($e->getMessage().PHP_EOL.$e->getTraceAsString());
  110.         }
  111.     }
  112. }