src/Atd/Supplier/Bokun/Domain/EventListeners/PickupPlacesRequestListener.php line 53

  1. <?php
  3. namespace App\Atd\Supplier\Bokun\Domain\EventListeners;
  5. use App\Atd\Domain\Config\ConfigDto;
  6. use App\Atd\Domain\RequestDto;
  7. use App\Atd\Supplier\Bokun\Auth\Domain\AuthCommand;
  8. use App\Atd\Supplier\Bokun\Domain\CommandRunnerContext;
  9. use App\Atd\Supplier\Bokun\Domain\Events\EventTypes;
  10. use App\Atd\Supplier\Bokun\Domain\Events\PickupPlacesRequestEvent;
  11. use App\Atd\Supplier\Bokun\Domain\Location;
  12. use App\Atd\Supplier\Bokun\KeyGenerator\Service\KeyGeneratorService;
  13. use App\Atd\Supplier\Bokun\PickupPlaces\Domain\PickupPlacesCommand;
  14. use App\EventListener\SupplierEventSubscriber;
  15. use App\Service\AuxDataStorageService;
  16. use App\Service\ConfigDtoService;
  17. use App\Service\Connections\RedisConnection;
  18. use Psr\EventDispatcher\EventDispatcherInterface;
  19. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  21. class PickupPlacesRequestListener extends SupplierEventSubscriber
  22. {
  23. /** Odd that even though this is domain logic we still need to identify the domain */
  24. public const PROVIDER_CODE = 'bkn';
  26. public function __construct(
  27. private readonly CommandRunnerContext $context,
  28. private readonly AuthCommand $authCommand,
  29. private readonly PickupPlacesCommand $pickupPlacesCommand,
  30. private readonly ConfigDtoService $configDtoService,
  31. private readonly AuxDataStorageService $auxDataStorageService,
  32. private readonly ParameterBagInterface $parameterBag,
  33. private readonly KeyGeneratorService $keyGeneratorService,
  34. protected EventDispatcherInterface $dispatcher,
  35. ) {
  36. parent::__construct($dispatcher);
  37. }
  39. /**
  40. * @return string[]
  41. */
  42. public static function getSubscribedEvents(): array
  43. {
  44. return [
  45. EventTypes::PICKUP_PLACES_REQUEST => 'handleEvent',
  46. ];
  47. }
  49. /**
  50. * @throws \Exception
  51. */
  52. public function handleEvent(PickupPlacesRequestEvent $event): void
  53. {
  54. try {
  55. $payload = [
  56. 'activityId' => $event->getActivityId(),
  57. ];
  59. $this->setEndpointRequestDto($payload);
  60. $this->authCommand->execute($this->context, PickupPlacesCommand::CMD_NAME, $payload);
  62. $this->pickupPlacesCommand->execute($this->context);
  63. $placesResponse = $this->context->getPickupPlacesResponseDao();
  65. $this->cacheLocations($event->getActivityId(), $placesResponse->getLocations());
  67. $this->sendInterruptResponse($placesResponse->toArray());
  68. } catch (\Throwable $exception) {
  69. throw new \Exception($exception->getMessage());
  70. }
  71. }
  73. private function getConfigDto(): ConfigDto
  74. {
  75. return $this->configDtoService->configDtoFactory(self::PROVIDER_CODE);
  76. }
  78. /**
  79. * @throws \Exception
  80. */
  81. private function setEndpointRequestDto(array $requestData = []): void
  82. {
  83. $this->context->setRequestDto(
  84. RequestDto::factory([
  85. 'method' => 'PUT',
  86. 'query' => null,
  87. 'data' => $requestData,
  88. 'provider' => self::PROVIDER_CODE,
  89. 'nocache' => true,
  90. 'configDto' => $this->getConfigDto(),
  91. 'updateDatastore' => false,
  92. ])
  93. );
  94. }
  96. private function getConnectedAuxCacheStoreService(): AuxDataStorageService
  97. {
  98. $conn = new RedisConnection(
  99. $this->parameterBag->get('app.aux.redis.ip'),
  100. $this->parameterBag->get('app.aux.redis.port')
  101. );
  103. return $this->auxDataStorageService->connect($conn);
  104. }
  106. /**
  107. * @param array|Location[] $locations
  108. *
  109. * @throws \Exception
  110. */
  111. private function cacheLocations(string $activityId, array $locations): void
  112. {
  113. $key = $this->keyGeneratorService->generatePickupLocationsKey(
  114. self::PROVIDER_CODE,
  115. $activityId
  116. );
  117. $this->getConnectedAuxCacheStoreService()
  118. ->store(
  119. $key,
  120. $locations
  121. );
  122. }
  123. }