src/EventSubscriber/JobAcceptedSubscriber.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Symfony\EventListener\EventPriorities;
  6. use App\Entity\Job;
  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 JobAcceptedSubscriber implements EventSubscriberInterface
  17. {
  18.     /** @var string The relative path inside templates/messages without any extensions */
  19.     private const TEMPLATE = 'job/accepted';
  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.         $job = $event->getControllerResult();
  39.         $method = $event->getRequest()->getMethod();
  41.         # POST methods are used to create instances, and we are only interested in new jobs
  42.         if (!$job instanceof Job || $method !== Request::METHOD_POST) {
  43.             return;
  44.         }
  46.         $customer = $job->getPond()->getCustomer();
  48.         $message = $this->messageService
  49.             ->withRecipient($customer)
  50.             ->withSubject('Your job has been accepted')
  51.             ->withTemplate(self::TEMPLATE)
  52.             ->withTemplateData([
  53.                 'addressLine1' => $job->getPond()->getAddress1(),
  54.                 'firstName' => $customer->getFirstName() === 'ANNETTE' ? null : $customer->getFirstName(),
  55.                 'fullAddress' => $job->getPond()->getAddress(),
  56.             ]);
  58.         $currentUser = $this->tokenStorage->getToken()->getUser();
  59.         if ($currentUser instanceof User) {
  60.             $message = $message->withCurrentUser($currentUser);
  61.         }
  63.         $message->send();
  64.     }
  65. }