src/EventSubscriber/JobStatusChangeSubscriber.php line 35

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventSubscriber;
  7. use ApiPlatform\Symfony\EventListener\EventPriorities;
  8. use App\Entity\Job;
  9. use App\Entity\JobStatusLog;
  10. use App\Entity\Schedule;
  11. use App\Entity\User;
  12. use Doctrine\Persistence\ManagerRegistry;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpKernel\Event\ViewEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  16. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  18. final class JobStatusChangeSubscriber implements EventSubscriberInterface
  19. {
  20.     public function __construct(
  21.         private readonly ManagerRegistry $managerRegistry,
  22.         private readonly TokenStorageInterface $tokenStorage,
  23.     )
  24.     {
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             KernelEvents::VIEW => ['addStatusLog', EventPriorities::POST_WRITE],
  32.         ];
  33.     }
  35.     public function addStatusLog(ViewEvent $event): void
  36.     {
  37.         if ($event->getRequest()->getMethod() !== 'PUT') {
  38.             return;
  39.         }
  41.         $job = $event->getControllerResult();
  44.         if ($job instanceof Schedule) {
  45.             $job = $job->getJob();
  46.         }
  48.         if (!$job instanceof Job) {
  49.             return;
  50.         }
  52.         $log = new JobStatusLog();
  53.         $log->setJob($job);
  54.         $log->setStatus($job->getStatus());
  56.         $currentUser = $this->tokenStorage->getToken()?->getUser();
  57.         if ($currentUser instanceof User) {
  58.             $log->setUser($currentUser);
  59.         }
  61.         $em = $this->managerRegistry->getManager();
  62.         $em->persist($log);
  63.         $em->flush();
  64.     }
  65. }