src/Aqarmap/Bundle/NotificationBundle/NotificationSubscriber.php line 55

  1. <?php
  3. namespace Aqarmap\Bundle\NotificationBundle;
  5. use Doctrine\ORM\EntityManagerInterface;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Contracts\Translation\TranslatorInterface;
  8. use Twig\Environment;
  10. class NotificationSubscriber implements EventSubscriberInterface
  11. {
  12. /**
  13. * [$action description].
  14. */
  15. public string $action;
  17. /**
  18. * Create a notification subscriber instance.
  19. */
  20. public function __construct(public NotificationManager $manager, private readonly Environment $templating, private readonly TranslatorInterface $translator, private readonly EntityManagerInterface $entityManager)
  21. {
  22. }
  24. /**
  25. * Register the listeners for the subscriber.
  26. */
  27. public static function getSubScribedEvents(): array
  28. {
  29. $path = __DIR__.'/Types';
  30. $events = [];
  31. $AllFileIterator = new \RecursiveIteratorIterator(new \RecursiveDirectoryIterator($path));
  32. $PhpFileIterator = new \RegexIterator($AllFileIterator, '/^.+\.php$/i', \RecursiveRegexIterator::GET_MATCH);
  34. foreach ($PhpFileIterator as $file => $object) {
  35. $file = pathinfo((string) $file);
  36. $event = strtolower((string) preg_replace('~(?<=\\w)([A-Z])~', '.$1', $file['filename']));
  37. $events[$event] = 'handle';
  38. }
  40. return $events;
  41. }
  43. /**
  44. * Handel notification.
  45. *
  46. * @throws \ReflectionException
  47. */
  48. public function handle(NotificationInterface $notification): void
  49. {
  50. $notification
  51. ->manager($this->manager)
  52. ->twig($this->templating)
  53. ->translator($this->translator);
  55. // force sending a particular channel
  56. if ($notification->isForce) {
  57. $notificationHandler = $this->manager->getHandler($notification);
  58. if (
  59. !($notification->forceSend ?? false)
  60. && $notificationHandler
  61. && method_exists($notification, $notificationHandler)
  62. ) {
  63. $notification->$notificationHandler();
  65. return;
  66. }
  67. $this->send($notification, $notification->channel);
  69. return;
  70. }
  71. if ($notification->getChannel()) {
  72. $this->hasChannel($notification, $notification->getChannel())
  73. ? $this->queue($notification, $notification->getChannel())
  74. : $this->send($notification, $notification->getChannel());
  76. return;
  77. }
  79. foreach ($this->manager->getChannel($notification) as $channel) {
  80. $this->hasChannel($notification, $channel)
  81. ? $this->queue($notification, $channel)
  82. : $this->send($notification, $channel);
  83. }
  84. }
  86. /**
  87. * Send notification.
  88. *
  89. * @param string $channel
  90. *
  91. * @throws Exceptions\DriverNotFoundException
  92. */
  93. public function send(NotificationInterface $notification, $channel): void
  94. {
  95. $notifiables = $notification->getNotifiables();
  97. if (!\count($notifiables)) {
  98. $notifiables = $notification->getUsers();
  99. }
  101. foreach ($notifiables as $user) {
  102. if (!$user->isEnabled()) {
  103. continue;
  104. }
  106. $user = $notification->to($user);
  107. $this->manager->send($user, $notification, $channel);
  108. }
  110. $this->entityManager->flush();
  111. }
  113. /**
  114. * Queue notification.
  115. *
  116. * @param string $channel
  117. *
  118. * @throws \ReflectionException
  119. */
  120. public function queue(NotificationInterface $notification, $channel): void
  121. {
  122. $message = [
  123. 'event' => strtolower(
  124. (string) preg_replace(
  125. '~(?<=\\w)([A-Z])~',
  126. '.$1',
  127. (new \ReflectionClass($notification))->getShortName()
  128. )
  129. ),
  130. 'class' => (new \ReflectionClass($notification))->getName(),
  131. 'entity' => (new \ReflectionClass($notification->getSubject()))->getName(),
  132. 'id' => $notification->getSubject()->getId(),
  133. 'channel' => $channel,
  134. 'sent_at' => date('d-m-Y \@ h:i A'),
  135. ];
  137. $this->manager->queue(json_encode($message), $notification->getHandoverDetails());
  138. }
  140. /**
  141. * Check that notification has channel.
  142. *
  143. * @throws \ReflectionException
  144. */
  145. public function hasChannel(NotificationInterface $notification, $channel): bool
  146. {
  147. return \in_array($channel, $this->manager->getQueue($notification));
  148. }
  149. }