src/EventListener/VoucherUploadSubscriber.php line 36

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