src/EventSubscriber/LivingCostSubmissionWriteSubscriber.php line 63

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\LivingCostStatistics;
  6. use App\Entity\LivingCostSubmission;
  7. use Symfony\Component\HttpFoundation\Request;
  8. use Symfony\Component\HttpKernel\KernelEvents;
  9. use Symfony\Component\HttpKernel\Event\ViewEvent;
  10. use App\Repository\LivingCostStatisticsRepository;
  11. use App\LivingCosts\LivingCostStatisticsCalculator;
  12. use App\LivingCosts\LivingCostStatisticsOperations;
  13. use ApiPlatform\Symfony\EventListener\EventPriorities;
  14. use App\LivingCosts\LivingCostStatisticsOverallOperations;
  15. use App\Repository\LivingCostStatisticsOverallRepository;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. /**
  19.  * Subscribes to write operations.
  20.  * Used when a LivingCostSubmission is created, modified or deleted.
  21.  */
  22. final class LivingCostSubmissionWriteSubscriber implements EventSubscriberInterface
  23. {
  25.     /**
  26.      * Constructor.
  27.      *
  28.      * @param LivingCostStatisticsRepository $livingCostStatisticsRepository
  29.      * @param LivingCostStatisticsCalculator $livingCostStatisticsCalculator
  30.      * @param LivingCostStatisticsOperations $livingCostStatisticsOperations
  31.      */
  32.     public function __construct(
  33.         private LivingCostStatisticsRepository $livingCostStatisticsRepository,
  34.         private LivingCostStatisticsCalculator $livingCostStatisticsCalculator,
  35.         private LivingCostStatisticsOperations $livingCostStatisticsOperations,
  36.         private LivingCostStatisticsOverallOperations $livingCostStatisticsOverallOperations,
  37.         private LivingCostStatisticsOverallRepository $livingCostStatisticsOverallRepository,)
  38.     {
  39.     }
  41.     /**
  42.      * Returns which events are subscribed to.
  43.      *
  44.      * @return void
  45.      */
  46.     public static function getSubscribedEvents()
  47.     {
  48.         return [
  49.             KernelEvents::VIEW => [
  50.                 ['onLivingCostSubmissionDeleted', EventPriorities::PRE_WRITE],
  51.                 ['onLivingCostSubmissionCreatedOrUpdated', EventPriorities::PRE_WRITE],
  52.             ],
  53.         ];
  54.     }
  56.     /**
  57.      * Updates LivingCostStatistics with new / modified LivingCostSubmission data.
  58.      *
  59.      * @param ViewEvent $event
  60.      *
  61.      * @return void
  62.      */
  63.     public function onLivingCostSubmissionCreatedOrUpdated(ViewEvent $event): void
  64.     {
  65.         $livingCostSubmission = $event->getControllerResult();
  66.         $method = $event->getRequest()->getMethod();
  68.         if (!$livingCostSubmission instanceof LivingCostSubmission
  69.             || !in_array(
  70.                 $method,
  71.                 [
  72.                     Request::METHOD_POST,
  73.                     Request::METHOD_PATCH,
  74.                     Request::METHOD_PUT,
  75.                 ]
  76.             )
  77.         ) {
  78.             return;
  79.         }
  81.         $livingCostStatistics = $this->livingCostStatisticsOperations->handleNewSubmission($livingCostSubmission);
  82.         $this->livingCostStatisticsRepository->save($livingCostStatistics, true);
  84.         $livingCostStatisticsOverall = $this->livingCostStatisticsOverallOperations->handleNewSubmission();
  85.         $this->livingCostStatisticsOverallRepository->save($livingCostStatisticsOverall);
  86.     }
  88.     /**
  89.      * Handles if a LivingCostSubmission is deleted.
  90.      *
  91.      * @param ViewEvent $event
  92.      *
  93.      * @return void
  94.      */
  95.     public function onLivingCostSubmissionDeleted(ViewEvent $event): void
  96.     {
  97.         $livingCostSubmission = $event->getControllerResult();
  98.         $method = $event->getRequest()->getMethod();
  100.         if (!$livingCostSubmission instanceof LivingCostSubmission
  101.             || Request::METHOD_DELETE !== $method
  102.         ) {
  103.             return;
  104.         }
  106.         $this->livingCostStatisticsOperations->handleDeleteSubmission($livingCostSubmission);
  108.         $livingCostStatisticsOverall = $this->livingCostStatisticsOverallOperations->handleDeleteSubmission();
  109.         $this->livingCostStatisticsOverallRepository->save($livingCostStatisticsOverall, true);
  110.     }
  111. }