src/Subscriber/User/AccountStatusSubscriber.php line 41

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\User;
  5. use App\Dictionary\ContentStatus;
  6. use App\Entity\Content;
  7. use App\Event\Mail\DirectLinkRequestEvent;
  8. use App\Event\User\AccountStatusChangeEvent;
  9. use App\Security\UserChecker;
  10. use App\Service\Content\ContentService;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class AccountStatusSubscriber implements EventSubscriberInterface
  14. {
  15.     protected ContentService $contentService;
  17.     protected UserChecker $userChecker;
  19.     public function __construct(ContentService $contentService, UserChecker $userChecker)
  20.     {
  21.         $this->contentService = $contentService;
  22.         $this->userChecker = $userChecker;
  23.     }
  25.     public static function getSubscribedEvents(): array
  26.     {
  27.         return [
  28.             AccountStatusChangeEvent::class => [
  29.                 ['onAccountStatusChange', 0],
  30.             ],
  31.             DirectLinkRequestEvent::class => [
  32.                 ['onRequestDirectLinkUpdateAccountStatus', 1],
  33.             ],
  34.         ];
  35.     }
  37.     /**
  38.      * @throws \Doctrine\ORM\ORMException
  39.      * @throws \Doctrine\ORM\OptimisticLockException
  40.      */
  41.     public function onRequestDirectLinkUpdateAccountStatus(DirectLinkRequestEvent $event): bool
  42.     {
  43.         $account = $event->getAccount();
  44.         if ($this->userChecker->isReactivationPossible($account)) {
  45.             return $this->userChecker->reactivateDeletedAccount($account);
  46.         }
  48.         return false;
  49.     }
  51.     /**
  52.      * @throws \Doctrine\ORM\ORMException
  53.      * @throws \Doctrine\ORM\OptimisticLockException
  54.      */
  55.     public function onAccountStatusChange(AccountStatusChangeEvent $event)
  56.     {
  57.         if ($event->gotBlocked()) {
  58.             $this->onAccountBlocked($event);
  59.         }
  60.         if ($event->gotReenabled()) {
  61.             $this->onAccountReenabled($event);
  62.         }
  63.     }
  65.     /**
  66.      * account geblockt oder gelöscht:
  67.      * - aktiven content (6) auf inactive (7) setzen
  68.      * - nicht auf 9 (blocked) setzen, da dann bei reaktivierung nicht mehr
  69.      * zwischen "ursprünglich aktivem" content und gewollt blockiertem
  70.      * content unterschieden werden kann
  71.      *
  72.      * @throws \Doctrine\ORM\ORMException
  73.      * @throws \Doctrine\ORM\OptimisticLockException
  74.      */
  75.     public function onAccountBlocked(AccountStatusChangeEvent $event)
  76.     {
  77.         $member = $event->getAccount()->getMember();
  78.         $contentService = $this->getContentService();
  80.         // search for active content
  81.         $contents = $contentService->getContentsByMember($member, [
  82.             ContentStatus::ACTIVE,
  83.         ]);
  85.         foreach ($contents as $content) {
  86.             $contentService->changeContentStatus($content, ContentStatus::INACTIVE, false);
  87.         }
  88.         if (count($contents)) {
  89.             $contentService->delayedFlush();
  90.         }
  91.     }
  93.     /**
  94.      * Account von "gelöscht" oder "geblockt" wieder auf "aktiv" gesetzt =
  95.      * inaktiven content (7) wieder auf active (6) setzen.
  96.      *
  97.      * @throws \Doctrine\ORM\ORMException
  98.      * @throws \Doctrine\ORM\OptimisticLockException
  99.      */
  100.     public function onAccountReenabled(AccountStatusChangeEvent $event)
  101.     {
  102.         $member = $event->getAccount()->getMember();
  103.         $contentService = $this->getContentService();
  105.         // search for inactive content
  106.         $contents = $contentService->getContentsByMember($member, [
  107.             ContentStatus::INACTIVE,
  108.         ]);
  110.         foreach ($contents as $content) {
  111.             $contentService->changeContentStatus($content, ContentStatus::ACTIVE, false);
  112.         }
  113.         if (count($contents)) {
  114.             $contentService->delayedFlush();
  115.         }
  116.     }
  118.     protected function getContentService(): ContentService
  119.     {
  120.         return $this->contentService;
  121.     }
  122. }