src/EventSubscriber/JobScheduledSubscriber.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Symfony\EventListener\EventPriorities;
  6. use App\Entity\Schedule;
  7. use App\Entity\User;
  8. use App\Service\Message;
  9. use JetBrains\PhpStorm\ArrayShape;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpKernel\Event\ViewEvent;
  13. use Symfony\Component\HttpKernel\KernelEvents;
  14. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  16. final class JobScheduledSubscriber implements EventSubscriberInterface
  17. {
  18.     /** @var string The relative path inside templates/messages without any extensions */
  19.     private const TEMPLATE = 'job/scheduled';
  21.     public function __construct(
  22.         private readonly TokenStorageInterface $tokenStorage,
  23.         private readonly Message $messageService,
  24.     )
  25.     {
  26.     }
  28.     #[ArrayShape([KernelEvents::VIEW => "array"])]
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             KernelEvents::VIEW => ['sendMessage', EventPriorities::POST_WRITE],
  33.         ];
  34.     }
  36.     public function sendMessage(ViewEvent $event): void
  37.     {
  38.         $schedule = $event->getControllerResult();
  39.         $method = $event->getRequest()->getMethod();
  41.         # POST methods are used to create instances, and we are only interested in new schedules
  42.         if (!$schedule instanceof Schedule || $method !== Request::METHOD_POST) {
  43.             return;
  44.         }
  46.         $pond = $schedule->getJob()->getPond();
  47.         $customer = $pond->getCustomer();
  49.         $message = $this->messageService
  50.             ->withRecipient($customer)
  51.             ->withSubject('Your job has been scheduled')
  52.             ->withTemplate(self::TEMPLATE)
  53.             ->withTemplateData([
  54.                 'addressLine1' => $pond->getAddress1(),
  55.                 'employee' => $schedule->getEmployee()->getUser()->getFirstName(),
  56.                 'firstName' => $customer->getFirstName() === 'ANNETTE' ? null : $customer->getFirstName(),
  57.                 'fullAddress' => $pond->getAddress(),
  58.                 'timeWindow' => $schedule->getTimeWindow(),
  59.             ]);
  61.         $currentUser = $this->tokenStorage->getToken()->getUser();
  62.         if ($currentUser instanceof User) {
  63.             $message = $message->withCurrentUser($currentUser);
  64.         }
  66.         $message->send();
  67.     }
  68. }