src/EventListener/RedisUploadSubscriber.php line 44

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Atd\Domain\Datastore\Redis\DataScoreUpdateDto;
  6. use App\Atd\Domain\Datastore\Redis\DataScoreUpdateDtoFactory;
  7. use App\Atd\Utilities\CalendarToDataScoreDtoAdapter;
  8. use App\enum\Events;
  9. use App\Event\CacheDataEvent;
  11. use App\Atd\Domain\Datastore\Redis\Service\RedisDatastoreService;
  12. use App\Service\ProviderFactoryService;
  13. use App\Atd\Domain\Datastore\Redis\DataScoreDto;
  14. use Psr\EventDispatcher\EventDispatcherInterface;
  15. use Psr\Log\LoggerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Throwable;
  19. class RedisUploadSubscriber implements EventSubscriberInterface
  20. {
  21.     use CalendarToDataScoreDtoAdapter;
  23.     public function __construct(
  24.         private ProviderFactoryService $providerFactory,
  25.         private RedisDatastoreService $redisDatastoreService,
  26.         private LoggerInterface $logger
  27.     ){}
  29.     /**
  30.      * @return string[]
  31.      */
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             Events::CACHE_DATA_TRIGGER => 'onCacheUpdateTriggered'
  36.         ];
  37.     }
  39.     /**
  40.      * @param CacheDataEvent $event
  41.      * @return void
  42.      * @throws Throwable
  43.      */
  44.     public function onCacheUpdateTriggered(CacheDataEvent $event): void
  45.     {
  46.         try {
  47.             $storageKey = $event->getStorageKey();
  48.             $maxScore = $event->getMaxScore();
  49.             $minScore = $event->getMinScore();
  50.             $dataScoreDto = $this->getDataScoreDto(
  51.                 $event->getData()
  52.             );
  54.             $dataScoreUpdateDto = new DataScoreUpdateDto([
  55.                 'storageKey'          => $storageKey->getKey(),
  56.                 'maxScore'            => $maxScore,
  57.                 'minScore'            => $minScore,
  58.                 'dataScoreCollection' => $dataScoreDto
  59.             ]);
  61.             $this->redisDatastoreService->eventUpdate(
  62.                 $dataScoreUpdateDto
  63.             );
  65.         } catch (Throwable $e) {
  66.             $this->logger->error($e->getMessage());
  67.             throw $e;
  68.         }
  69.     }
  71.     /**
  72.      * @param array $setData
  73.      * @return array
  74.      */
  75.     private function getDataScoreDto(array $setData): array
  76.     {
  77.         return $this->adaptCalendarToDataScoreDto($setData);
  78.     }
  79. }