src/EventSubscriber/JobCompletedSubscriber.php line 38

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. use function in_array;
  18. final class JobCompletedSubscriber implements EventSubscriberInterface
  19. {
  20.     /** @var string The relative path inside templates/messages without any extensions */
  21.     private const TEMPLATE = 'job/completed';
  23.     public function __construct(
  24.         private readonly TokenStorageInterface $tokenStorage,
  25.         private readonly Message $messageService,
  26.     )
  27.     {
  28.     }
  30.     #[ArrayShape([KernelEvents::VIEW => "array"])]
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             KernelEvents::VIEW => ['sendMessage', EventPriorities::POST_WRITE],
  35.         ];
  36.     }
  38.     public function sendMessage(ViewEvent $event): void
  39.     {
  40.         $job = $event->getControllerResult();
  41.         $method = $event->getRequest()->getMethod();
  43.         # PUT and PATCH methods are used to update instances, and we are only interested in updated jobs
  44.         if (!$job instanceof Job || !in_array($method, [Request::METHOD_PUT, Request::METHOD_PATCH])) {
  45.             return;
  46.         }
  48.         $previousData = $event->getRequest()->get('previous_data');
  50.         # If the status hasn't changed, we're not interested
  51.         if ($previousData->getStatus() === $job->getStatus()) {
  52.             return;
  53.         }
  55.         # If the status hasn't changed to "unable to complete", we're not interested
  56.         if ($job->getStatus() !== Job::JOB_STATUS_COMPLETE) {
  57.             return;
  58.         }
  60.         $customer = $job->getPond()->getCustomer();
  62.         $message = $this->messageService
  63.             ->withRecipient($customer)
  64.             ->withSubject('We have completed your job')
  65.             ->withTemplate(self::TEMPLATE)
  66.             ->withTemplateData([
  67.                 'addressLine1' => $job->getPond()->getAddress1(),
  68.                 'firstName' => $customer->getFirstName() === 'ANNETTE' ? null : $customer->getFirstName(),
  69.                 'fullAddress' => $job->getPond()->getAddress(),
  70.                 'reviewUrl' => 'TBC', // @todo change this when we are provided with one
  71.             ]);
  73.         $currentUser = $this->tokenStorage->getToken()->getUser();
  74.         if ($currentUser instanceof User) {
  75.             $message = $message->withCurrentUser($currentUser);
  76.         }
  78.         $message->send();
  79.     }
  80. }