src/EventListener/VoucherUploadSubscriber.php line 68

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Atd\Supplier\Atd\Voucher\Service\VoucherService;
  6. use App\Atd\Utilities\HttpClientResponse;
  7. use App\enum\Events;
  8. use App\Event\VoucherUploadEvent;
  9. use App\Event\VoucherUploadFailEvent;
  10. use App\Event\VoucherUploadSuccessEvent;
  11. use Psr\EventDispatcher\EventDispatcherInterface;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class VoucherUploadSubscriber implements EventSubscriberInterface
  16. {
  17.     public function __construct(
  18.         private readonly VoucherService $voucherService,
  19.         private readonly LoggerInterface $logger,
  20.         private readonly EventDispatcherInterface $eventDispatcher
  21.     ) {
  22.     }
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             Events::VOUCHER_UPLOAD_TRIGGER => 'onVoucherUploadTriggered',
  28.             Events::VOUCHER_UPLOAD_SUCCESS => 'onUploadSucceeded',
  29.             Events::VOUCHER_UPLOAD_FAIL => 'onUploadFailed',
  30.         ];
  31.     }
  33.     /**
  34.      * @throws \Throwable
  35.      */
  36.     public function onVoucherUploadTriggered(VoucherUploadEvent $event): void
  37.     {
  38.         $voucherDto = $event->getVoucherDto();
  39.         $voucherFileId = $voucherDto->getMeta()['voucher_id'];
  41.         $this->logger->info(sprintf('Uploading Voucher File ID [%s]', $voucherFileId));
  43.         try {
  44.             /** @var HttpClientResponse $response */
  45.             $response = $this->voucherService->upload($voucherDto);
  46.             if ('success' == $response->getStatus()) {
  47.                 $this->eventDispatcher->dispatch(new VoucherUploadSuccessEvent($voucherDto, $response), Events::VOUCHER_UPLOAD_SUCCESS);
  48.             } else {
  49.                 $this->eventDispatcher->dispatch(new VoucherUploadFailEvent($voucherDto, $response), Events::VOUCHER_UPLOAD_FAIL);
  50.             }
  51.         } catch (\Throwable $e) {
  52.             $this->logger->error($e->getMessage());
  53.             // maybe dispatch general error here
  54.             throw $e;
  55.         }
  56.     }
  58.     public function onUploadSucceeded(VoucherUploadSuccessEvent $event): void
  59.     {
  60.         $this->logger->info(
  61.             sprintf('Voucher Upload (voucher_file_id)[%s] Success [%s]',
  62.                 $event->getVoucherDto()->getMeta()['voucher_id'],
  63.                 $event->getClientResponse()->getPhrase()
  64.             )
  65.         );
  66.     }
  68.     public function onUploadFailed(VoucherUploadFailEvent $event): void
  69.     {
  70.         $this->logger->error(
  71.             sprintf('Voucher Upload (voucher_file_id)[%s] FAILED [%s]',
  72.                 $event->getVoucherDto()->getMeta()['voucher_id'],
  73.                 $event->getClientResponse()->getPhrase()
  74.             )
  75.         );
  76.     }
  77. }