src/EventSubscriber/JobOnWaySubscriber.php line 44

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\Schedule;
  8. use App\Entity\User;
  9. use App\Service\Message;
  10. use Doctrine\Persistence\ManagerRegistry;
  11. use JetBrains\PhpStorm\ArrayShape;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpKernel\Event\ViewEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  16. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  18. use function array_multisort;
  19. use function current;
  20. use function floor;
  21. use function in_array;
  23. final class JobOnWaySubscriber implements EventSubscriberInterface
  24. {
  25.     /** @var string The relative path inside templates/messages without any extensions */
  26.     private const TEMPLATE = 'job/on-way';
  28.     public function __construct(
  29.         private readonly TokenStorageInterface $tokenStorage,
  30.         private readonly ManagerRegistry $managerRegistry,
  31.         private readonly Message $messageService,
  32.     )
  33.     {
  34.     }
  36.     #[ArrayShape([KernelEvents::VIEW => "array"])]
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             KernelEvents::VIEW => ['sendMessage', EventPriorities::POST_WRITE],
  41.         ];
  42.     }
  44.     public function sendMessage(ViewEvent $event): void
  45.     {
  46.         $job = $event->getControllerResult();
  47.         $method = $event->getRequest()->getMethod();
  49.         # PUT and PATCH methods are used to update instances, and we are only interested in updated jobs
  50.         if (!$job instanceof Job || !in_array($method, [Request::METHOD_PUT, Request::METHOD_PATCH])) {
  51.             return;
  52.         }
  54.         $previousData = $event->getRequest()->get('previous_data');
  56.         # If the status hasn't changed, we're not interested
  57.         if ($previousData->getStatus() === $job->getStatus()) {
  58.             return;
  59.         }
  61.         # If the status hasn't changed to "on way", we're not interested
  62.         if ($job->getStatus() !== Job::JOB_STATUS_ON_WAY) {
  63.             return;
  64.         }
  66.         $customer = $job->getPond()->getCustomer();
  68.         $schedule = $this->getLatestSchedule($job);
  70.         $message = $this->messageService
  71.             ->withRecipient($customer)
  72.             ->withSubject('We are on our way')
  73.             ->withTemplate(self::TEMPLATE)
  74.             ->withTemplateData([
  75.                 'addressLine1' => $job->getPond()->getAddress1(),
  76.                 'firstName' => $customer->getFirstName() === 'ANNETTE' ? null : $customer->getFirstName(),
  77.                 'fullAddress' => $job->getPond()->getAddress(),
  78.                 'travelTime' => $this->formatTime($schedule->getEstimatedTravelTime()),
  79.             ]);
  81.         $currentUser = $this->tokenStorage->getToken()->getUser();
  82.         if ($currentUser instanceof User) {
  83.             $message = $message->withCurrentUser($currentUser);
  84.         }
  86.         $message->send();
  87.     }
  89.     private function getLatestSchedule(Job $job): Schedule
  90.     {
  91.         /** @var iterable<int, Schedule> $schedules */
  92.         $schedules = $this->managerRegistry->getRepository(Schedule::class)
  93.             ->findBy(['job' => $job]);
  95.         $sort = [];
  96.         foreach ($schedules as $schedule) {
  97.             $sort[] = $schedule->getDate()->getTimestamp();
  98.         }
  100.         array_multisort($schedules, SORT_DESC, $sort);
  102.         return current($schedules);
  103.     }
  105.     private function formatTime(int $time): string
  106.     {
  107.         $parts = [];
  109.         $days = floor($time / (60 * 60 * 24));
  110.         if ($days > 0) {
  111.             $parts[] = sprintf('%d day%s', $days, $days > 1 ? 's' : '');
  112.             $time -= $days * (60 * 60 * 24);
  113.         }
  115.         $hours = floor($time / (60 * 60));
  116.         if ($hours > 0) {
  117.             $parts[] = sprintf('%d hour%s', $hours, $hours > 1 ? 's' : '');
  118.             $time -= $hours * (60 * 60);
  119.         }
  121.         $minutes = floor($time / 60);
  122.         if ($minutes > 0) {
  123.             $parts[] = sprintf('%d minute%s', $minutes, $minutes > 1 ? 's' : '');
  124.         }
  126.         if (count($parts) === 0) {
  127.             return '1 minute';
  128.         }
  130.         return implode(', ', $parts);
  131.     }
  132. }