src/Domain/EventSubscriber/LogEntryCreatedEventSubscriber.php line 35

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Domain\EventSubscriber;
  7. use Domain\Event\LogEntryCreated;
  8. use Domain\Repository\UserRepositoryInterface;
  9. use Infrastructure\Persistence\Doctrine\Entity\LogEntry;
  10. use Symfony\Bridge\Twig\Mime\TemplatedEmail;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Mailer\MailerInterface;
  13. use Symfony\Component\Mime\Address;
  15. final class LogEntryCreatedEventSubscriber implements EventSubscriberInterface
  16. {
  17.     private UserRepositoryInterface $userRepository;
  18.     private MailerInterface $mailer;
  20.     public function __construct(
  21.         UserRepositoryInterface $userRepository,
  22.         MailerInterface $mailer
  23.     ) {
  24.         $this->userRepository = $userRepository;
  25.         $this->mailer = $mailer;
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             LogEntryCreated::class => 'handle',
  32.         ];
  33.     }
  35.     public function handle(LogEntryCreated $event): void
  36.     {
  37.         $logEntry = $event->logEntry();
  38.         $recipients = [];
  40.         $logEntryCreator = $logEntry->getUser();
  42.         if ($logEntryCreator->isManager() || $logEntryCreator->isCleaner()) {
  43.             return;
  44.         }
  46.         if ($logEntryCreator->isClient()) {
  47.             $recipientRole = 'ROLE_CFC_MANAGER';
  48.             $recipients = $this->getAddresses($recipientRole);
  49.         }
  51.         $this->communicateToRecipients($recipients, $logEntry);
  52.     }
  54.     private function communicateToRecipients(array $recipients, LogEntry $logEntry): void
  55.     {
  56.         if (empty($recipients)) {
  57.             return;
  58.         }
  59.         // dd($recipients);
  60.         $this->mailer->send((new TemplatedEmail())
  61.             ->from(new Address('platform@cfc-platform.com', 'CFC Platform'))
  62.             ->to(...$recipients)
  63.             ->subject('Er is een nieuwe logboek item op CFC Platform')
  64.             ->htmlTemplate('logbook/new_logEntry_email.html.twig')
  65.             ->context([
  66.                 'createdByClient' => $logEntry->getUser()->isClient(),
  67.                 'companyName' => $logEntry->getCompany()->getName(),
  68.                 'companyId' => $logEntry->getCompany()->getId(),
  69.                 'logEntryId' => $logEntry->getId(),
  70.             ]));
  71.     }
  73.     /**
  74.      * @return Address[]
  75.      */
  76.     private function getAddresses(string $recipientRole, ?int $companyId = null): array
  77.     {
  78.         return array_map(static function (array $recipient): Address {
  79.             return new Address($recipient['email'], $recipient['fullName']);
  80.         }, $this->userRepository->byRole($recipientRole, $companyId)->toArray());
  81.     }
  82. }