src/EventSubscriber/LivingCostStatisticsReadSubscriber.php line 65

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\GeneralMetrics\GeneralMetricsOperations;
  6. use App\CityMetrics\CityMetricsOperations;
  7. use App\Entity\LivingCostStatistics;
  8. use App\Repository\CityMetricsRepository;
  9. use App\Repository\GeneralMetricsRepository;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpKernel\KernelEvents;
  12. use Symfony\Component\HttpKernel\Event\ViewEvent;
  13. use ApiPlatform\Symfony\EventListener\EventPriorities;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. /**
  17.  * Subscribes to reading of a LivingCostStatistics entity.
  18.  * Happens in GET operations in this system's case.
  19.  */
  20. final class LivingCostStatisticsReadSubscriber implements EventSubscriberInterface
  21. {
  23.     /**
  24.      * Constructor.
  25.      *
  26.      * @param GeneralMetricsRepository $generalMetricsRepository
  27.      * @param CityMetricsRepository    $cityMetricsRepository
  28.      * @param GeneralMetricsOperations $generalMetricsOperations
  29.      * @param CityMetricsOperations    $cityMetricsOperations
  30.      */
  31.     public function __construct(
  32.         private GeneralMetricsRepository $generalMetricsRepository,
  33.         private CityMetricsRepository $cityMetricsRepository,
  34.         private GeneralMetricsOperations $generalMetricsOperations,
  35.         private CityMetricsOperations $cityMetricsOperations
  36.     ) {
  37.     }
  39.     /**
  40.      * Returns which events are subscribed to.
  41.      *
  42.      * @return void
  43.      */
  44.     public static function getSubscribedEvents()
  45.     {
  46.         return [
  47.             KernelEvents::VIEW => [
  48.                 ['onRead', EventPriorities::PRE_SERIALIZE],
  49.             ],
  50.         ];
  51.     }
  53.     /**
  54.      * Increments metrics data when an entity is read.
  55.      *   - CityMetrics if a LivingCostStatistics entity is read for a specific City
  56.      *   - GeneralMetrics if any LivingCostStatistics entity is read
  57.      *
  58.      * @param ViewEvent $event
  59.      *
  60.      * @return void
  61.      */
  62.     public function onRead(ViewEvent $event): void
  63.     {
  64.         $request = $event->getRequest();
  65.         $apiMetricsPath = $request->attributes->get('_route_params')['_api_operation_name'];
  66.         $method = $request->getMethod();
  68.         if (LivingCostStatistics::GET_RESOURCE_PATH != $apiMetricsPath
  69.             && LivingCostStatistics::GET_COLLECTION_PATH != $apiMetricsPath
  70.             || !in_array($method, [Request::METHOD_GET])
  71.         ) {
  72.             return;
  73.         }
  75.         if (LivingCostStatistics::GET_RESOURCE_PATH == $apiMetricsPath) {
  76.             $resources[] = $event->getControllerResult();
  77.         } else {
  78.             $resources = $event->getControllerResult();
  79.         }
  81.         foreach ($resources as $resource) {
  82.             $cityMetrics = $this->cityMetricsOperations->incrementForLivingCostStatistics($resource);
  83.             $this->cityMetricsRepository->save($cityMetrics, true);
  85.             $generalMetrics = $this->generalMetricsOperations->increment();
  86.             $this->generalMetricsRepository->save($generalMetrics, true);
  87.         }
  88.     }
  89. }