src/FMT/Domain/EventSubscriber/BookstoreApiNotificationSubscriber.php line 72

Open in your IDE?
  1. <?php
  3. namespace FMT\Domain\EventSubscriber;
  5. use Exception;
  6. use FMT\Data\Entity\User;
  7. use FMT\Data\Entity\UserNotifications;
  8. use FMT\Domain\Event\BookstoreApiNotificationEvent;
  9. use FMT\Domain\Repository\UserNotificationsRepositoryInterface;
  10. use FMT\Infrastructure\Helper\NotificationHelper;
  11. use Psr\Log\LoggerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Contracts\Translation\TranslatorInterface;
  14. use Twig\Environment;
  16. class BookstoreApiNotificationSubscriber implements EventSubscriberInterface
  17. {
  18.     private const BOOKSTORE_FAILS_TITLE = 'fmt.notifications.api_fails';
  19.     private UserNotificationsRepositoryInterface $userNotificationsRepository;
  20.     private TranslatorInterface $translator;
  21.     private LoggerInterface $logger;
  22.     private Environment $parser;
  24.     public function __construct(
  25.         UserNotificationsRepositoryInterface $userNotificationsRepository,
  26.         TranslatorInterface $translator,
  27.         LoggerInterface $logger,
  28.         Environment $parser
  29.     ) {
  30.         $this->userNotificationsRepository = $userNotificationsRepository;
  31.         $this->translator = $translator;
  32.         $this->logger = $logger;
  33.         $this->parser = $parser;
  34.     }
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [
  39.             BookstoreApiNotificationEvent::USERS_NOTIFICATION => 'onBookstoreApiFailed',
  40.             BookstoreApiNotificationEvent::ADMIN_NOTIFICATION => 'notifyAdmin'
  41.         ];
  42.     }
  44.     public function onBookstoreApiFailed(BookstoreApiNotificationEvent $event)
  45.     {
  46.         $users = $event->getUsers();
  47.         $message = $this->translator->trans(
  48.             'fmt.notifications.api_fails',
  49.             ['%school_name%' => $event->getBookstore()],
  50.         );
  52.         $existingNotifications = $this
  53.             ->userNotificationsRepository
  54.             ->findExistingNotificationsForUserByTitle($users, $message);
  56.         foreach ($users as $user) {
  57.             if ($this->hasSameNotification($user, $message, $existingNotifications)) {
  58.                 continue;
  59.             }
  61.             $notification = new UserNotifications();
  62.             $notification->setUser($user);
  63.             $notification->setTitle(BookstoreApiNotificationEvent::NOTIFICATION_TITLE);
  65.             $notification->setMessage($message);
  66.             $this->userNotificationsRepository->add($notification);
  67.         }
  69.         $this->userNotificationsRepository->save();
  70.     }
  72.     public function notifyAdmin(BookstoreApiNotificationEvent $event)
  73.     {
  74.         try {
  75.             $users = $event->getUsers();
  77.             foreach ($users as $user) {
  78.                 $message = $this->parser->render('@Public/emails/bookstore_blocked.email.html.twig', [
  79.                     'schoolName' => $event->getBookstore(),
  80.                     'user' => $user,
  81.                 ]);
  83.                 NotificationHelper::submitFromTemplate($message, $user->getProfile()->getEmail());
  84.             }
  85.         } catch (Exception $exception) {
  86.             $this->logger->error($exception->getMessage());
  87.         }
  88.     }
  90.     /**
  91.      * @param User $user
  92.      * @param string $message
  93.      * @param array $notifications
  94.      * @return bool
  95.      */
  96.     private function hasSameNotification(User $user, string $message, array $notifications): bool
  97.     {
  98.         foreach ($notifications as $notification) {
  99.             if ($notification->getUser() === $user
  100.                 && $notification->isSent() === false
  101.                 && $notification->getTitle() === $message) {
  103.                 return true;
  104.             }
  105.         }
  107.         return false;
  108.     }
  109. }