src/Modules/Notification/Event/Subscriber/SendChangesRequestCreatedNotification.php line 73

Open in your IDE?
  1. <?php
  3. namespace App\Modules\Notification\Event\Subscriber;
  6. use App\Modules\ChangesRequest\Event\ChangesRequestCreated;
  7. use App\Modules\ChangesRequest\Factory\CommandFactory;
  8. use App\Modules\Notification\Entity\NotificationEntity;
  9. use App\Modules\Notification\Message\System\ChangesRequest\PartnerWantsAddNewAddressNotification;
  10. use App\Modules\Notification\Message\System\ChangesRequest\PartnerWantsAddServiceNotification;
  11. use App\Modules\Notification\Message\System\ChangesRequest\PartnerWantsChangeAddressNotification;
  12. use App\Modules\Notification\Message\System\ChangesRequest\UserWantsChangePasswordNotification;
  13. use App\Modules\Notification\Service\NotificationService;
  14. use App\Modules\User\Entity\User;
  15. use App\Modules\User\Repository\UserRepositoryInterface;
  16. use App\Modules\User\Service\PartnerService;
  17. use App\Service\WebRoutes;
  18. use Psr\Log\LoggerInterface;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class SendChangesRequestCreatedNotification implements EventSubscriberInterface
  22. {
  23.     private $notificationService;
  24.     private $logger;
  26.     /**
  27.      * @var UserRepositoryInterface
  28.      */
  29.     private $userRepository;
  30.     /**
  31.      * @var PartnerService
  32.      */
  33.     private $partnerService;
  35.     public function __construct(
  36.         NotificationService $notificationService,
  37.         UserRepositoryInterface $userRepository,
  38.         PartnerService $partnerService,
  39.         LoggerInterface $logger
  40.     )
  41.     {
  42.         $this->notificationService = $notificationService;
  43.         $this->logger = $logger;
  44.         $this->userRepository = $userRepository;
  45.         $this->partnerService = $partnerService;
  46.     }
  48.     /**
  49.      * Returns an array of event names this subscriber wants to listen to.
  50.      *
  51.      * The array keys are event names and the value can be:
  52.      *
  53.      *  * The method name to call (priority defaults to 0)
  54.      *  * An array composed of the method name to call and the priority
  55.      *  * An array of arrays composed of the method names to call and respective
  56.      *    priorities, or 0 if unset
  57.      *
  58.      * For instance:
  59.      *
  60.      *  * ['eventName' => 'methodName']
  61.      *  * ['eventName' => ['methodName', $priority]]
  62.      *  * ['eventName' => [['methodName1', $priority], ['methodName2']]]
  63.      *
  64.      * @return array The event names to listen to
  65.      */
  66.     public static function getSubscribedEvents()
  67.     {
  68.         return [
  69.             ChangesRequestCreated::class => ['sendNotification']
  70.         ];
  71.     }
  73.     public function sendNotification(ChangesRequestCreated $event)
  74.     {
  75.         try {
  76.             $changesRequest = $event->getChangesRequest();
  78.             $initiator = $changesRequest->getInitiator();
  80.             $link = [
  81.                 'id' => $changesRequest->getInitiator()->getId(),
  82.                 'entity' => NotificationEntity::CHANGE_REQUEST
  83.             ];
  84.             $recipients = $this->userRepository->findByRoles([User::ROLE_ADMIN]);
  86.             $notification = $this->createNotification($changesRequest->getOperation(), $initiator, $link, $recipients);
  87.             $this->notificationService->sendSystem($notification);
  88.         } catch (\Exception $e) {
  89.             $this->logger->error($e->getMessage());
  90.         }
  91.     }
  93.     private function createNotification(string $operation, User $initiator, array $link, $receivers)
  94.     {
  96.         switch ($operation) {
  97.             case CommandFactory::ADD_PARTNER_ADDRESS:
  98.                 return $this->partnerWantsAddAddressNotification($initiator, $link, $receivers);
  99.             case CommandFactory::EDIT_PARTNER_ADDRESS:
  100.                 return $this->partnerWantsChangeAddressNotification($initiator, $link, $receivers);
  101.             case CommandFactory::ADD_PARTNER_SERVICE:
  102.                 return $this->partnerWantsAddServiceNotification($initiator, $link, $receivers);
  103.             case CommandFactory::CHANGE_PASSWORD:
  104.                 return $this->userWantsChangePassword($initiator, $link, $receivers);
  105.             default:
  106.                 throw new \Exception('Unknown operation '. $operation);
  107.         }
  108.     }
  110.     private function partnerWantsAddAddressNotification(User $initiator, array $link, $receivers)
  111.     {
  112.         $partner = $initiator->getPartner();
  113.         $partnerTitle = $partner->getCompanyName();
  115.         return new PartnerWantsAddNewAddressNotification($partnerTitle, $link, $initiator, $receivers);
  116.     }
  118.     private function partnerWantsChangeAddressNotification(User $initiator, array $link, $receivers)
  119.     {
  120.         $partner = $initiator->getPartner();
  121.         $partnerTitle = $partner->getCompanyName();
  123.         return new PartnerWantsChangeAddressNotification($partnerTitle, $link, $initiator, $receivers);
  124.     }
  126.     private function partnerWantsAddServiceNotification(User $initiator, array $link, $receivers)
  127.     {
  128.         $partner = $initiator->getPartner();
  129.         $partnerTitle = $partner->getCompanyName();
  131.         return new PartnerWantsAddServiceNotification($partnerTitle, $link, $initiator, $receivers);
  132.     }
  134.     private function userWantsChangePassword(User $initiator, array $link, $receivers)
  135.     {
  136.         return new UserWantsChangePasswordNotification($link, $initiator, $receivers);
  137.     }
  138. }