src/TeclaConnector/EventSubscriber/SynchronizeCreatedUserSubscriber.php line 59

  1. <?php
  3. declare(strict_types=1);
  4. /**
  5.  * Copyright (c) 2020 TECLA Consulting Group oü.
  6.  * All rights reserved.
  7.  *
  8.  * This unpublished material is proprietary to TECLA Consulting Group oü.
  9.  * All rights reserved. The methods and
  10.  * techniques described herein are considered trade secrets
  11.  * and/or confidential. Reproduction or distribution, in whole
  12.  * or in part, is forbidden except by express written permission
  13.  * of TECLA Consulting Group oü.
  14.  *
  15.  * @author    Matúš Sýkorjak <matus@tecla.no>
  16.  * @copyright 2020 TECLA Consulting Group oü
  17.  */
  19. namespace App\TeclaConnector\EventSubscriber;
  21. use App\Core\Event\UserRegistrationConfirmedEvent;
  22. use App\Core\Event\UserRegistrationSuccessEvent;
  23. use App\Core\Model\UserInterface;
  24. use App\TeclaConnector\Exception\Synchronizer\LegacySynchronizerFailedExceptionInterface;
  25. use App\TeclaConnector\Service\FailedLegacySynchronizerServiceInterface;
  26. use App\TeclaConnector\Synchronizer\User\LegacyCreateSynchronizerInterface;
  27. use JetBrains\PhpStorm\ArrayShape;
  28. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  30. final class SynchronizeCreatedUserSubscriber implements EventSubscriberInterface
  31. {
  32.     private LegacyCreateSynchronizerInterface $synchronizer;
  34.     private FailedLegacySynchronizerServiceInterface $failedSynchronizerService;
  36.     public function __construct(LegacyCreateSynchronizerInterface $synchronizer, FailedLegacySynchronizerServiceInterface $failedSynchronizerService)
  37.     {
  38.         $this->synchronizer = $synchronizer;
  39.         $this->failedSynchronizerService = $failedSynchronizerService;
  40.     }
  42.     #[ArrayShape([
  43.         UserRegistrationSuccessEvent::class => 'string',
  44.         UserRegistrationConfirmedEvent::class => 'string',
  45.     ])]
  46.     public static function getSubscribedEvents(): array
  47.     {
  48.         return [
  49.             UserRegistrationSuccessEvent::class => 'onUserRegistrationSuccess',
  50.             UserRegistrationConfirmedEvent::class => 'onUserRegistrationConfirmedEvent',
  51.         ];
  52.     }
  54.     public function onUserRegistrationSuccess(UserRegistrationSuccessEvent $event): void
  55.     {
  56.         $this->synchronizeCreatedUser($event->getUser());
  57.     }
  59.     public function onUserRegistrationConfirmedEvent(UserRegistrationConfirmedEvent $event): void
  60.     {
  61.         $this->synchronizeCreatedUser($event->getUser());
  62.     }
  64.     private function synchronizeCreatedUser(UserInterface $user): void
  65.     {
  66.         try {
  67.             $this->synchronizer->synchronize($user);
  68.         } catch (LegacySynchronizerFailedExceptionInterface $e) {
  69.             $this->failedSynchronizerService->create($e->getSynchronizerRequest());
  70.         }
  71.     }
  72. }