src/EventListener/Stock/StockSubscriber.php line 43

  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. }