src/EventListener/Stock/StockSubscriber.php line 43

Open in your IDE?
  1. <?php
  3. namespace App\EventListener\Stock;
  5. use App\Atd\Domain\Response\BookingSummary\BookingSummary;
  6. use App\Atd\Domain\Response\ResponseWrapper;
  7. use App\Atd\Supplier\Atd\OrderLog\Event\OrderLogEvent;
  8. use App\Atd\Supplier\Atd\OrderLog\Service\OrderLogService;
  9. use App\Atd\Supplier\Atd\Stock\Service\StockService;
  10. use App\Event\Stock\StockTriggerEvent;
  11. use App\Service\ProviderFactoryService;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class StockSubscriber implements EventSubscriberInterface
  16. {
  17.     public const STOCK_SERVICE_TYPE = 'stock';
  18.     public const ORDER_SERVICE_TYPE = 'order';
  20.     private StockService $stockService;
  22.     /**
  23.      * @throws \Exception
  24.      */
  25.     public function __construct(
  26.         private readonly LoggerInterface $logger,
  27.         private readonly OrderLogService $orderLogService,
  28.         private readonly ProviderFactoryService $providerFactory,
  29.     ) {
  30.         $this->stockService = $this->providerFactory->factory('atd', self::STOCK_SERVICE_TYPE);
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             StockTriggerEvent::class => 'handleTrigger',
  37.         ];
  38.     }
  40.     /**
  41.      * @throws \Throwable
  42.      */
  43.     public function handleTrigger(StockTriggerEvent $event): void
  44.     {
  45.         $this->doStock($event->getResponseWrapper(), $event->getOrderId());
  46.     }
  48.     /**
  49.      * @throws \Exception
  50.      */
  51.     private function doStock(ResponseWrapper $bookingResponse, string $orderId): void
  52.     {
  53.         $orderService = $this->providerFactory->factory('atd', self::ORDER_SERVICE_TYPE);
  54.         $order = $orderService->getOrder($orderId);
  56.         try {
  57.             $stockResponse = $this->stockService->doRequest([
  58.                 'order' => $order,
  59.                 'bookingResponse' => $bookingResponse,
  60.             ], null);
  61.         } catch (\Exception $e) {
  62.             $this->logBookingSummary($orderId, $bookingResponse);
  63.             // Don't re-throw as we don't want the booking response to be blocked
  64.         }
  66.         if (!empty($stockResponse['errors'])) {
  67.             foreach ($stockResponse['errors'] as $error) {
  68.                 $this->logger->error($error);
  69.             }
  70.         } else {
  71.             $this->logger->info('Stock Updated!');
  72.         }
  73.     }
  75.     /**
  76.      * @todo - refactor to an Dispatch / Event
  77.      */
  78.     private function logBookingSummary(string $orderId, ResponseWrapper $bookingResponse): void
  79.     {
  80.         try {
  81.             $bookingSummary = BookingSummary::create($orderId, $bookingResponse);
  82.             $orderLogEvent = new OrderLogEvent($orderId, $bookingSummary->toString());
  83.             $this->orderLogService->write($orderLogEvent);
  84.         } catch (\Exception $e) {
  85.             $this->logger->error('When attempting to write a BookingSummary to the Order Log: '.$e->getMessage());
  86.         }
  87.     }
  88. }