vendor/ibexa/payment/src/bundle/EventSubscriber/PaymentCancellingSubscriber.php line 46

Open in your IDE?
  1. <?php
  3. /**
  4. * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5. * @license For full copyright and license information view LICENSE file distributed with this source code.
  6. */
  7. declare(strict_types=1);
  9. namespace Ibexa\Bundle\Payment\EventSubscriber;
  11. use Ibexa\Contracts\OrderManagement\Event\BeforeCancelOrderEvent;
  12. use Ibexa\Contracts\OrderManagement\Value\Order\OrderInterface;
  13. use Ibexa\Contracts\Payment\Payment\PaymentInterface;
  14. use Ibexa\Contracts\Payment\Payment\PaymentQuery;
  15. use Ibexa\Contracts\Payment\Payment\PaymentUpdateStruct;
  16. use Ibexa\Contracts\Payment\Payment\Query\Criterion\Order as PaymentOrderCriterion;
  17. use Ibexa\Contracts\Payment\PaymentServiceInterface;
  18. use Ibexa\Payment\Workflow\WorkflowResolver;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. final class PaymentCancellingSubscriber implements EventSubscriberInterface
  22. {
  23. private PaymentServiceInterface $paymentService;
  25. private WorkflowResolver $workflowResolver;
  27. public function __construct(
  28. PaymentServiceInterface $paymentService,
  29. WorkflowResolver $workflowResolver
  30. ) {
  31. $this->paymentService = $paymentService;
  32. $this->workflowResolver = $workflowResolver;
  33. }
  35. public static function getSubscribedEvents(): array
  36. {
  37. return [
  38. BeforeCancelOrderEvent::class => 'cancelPayment',
  39. ];
  40. }
  42. /**
  43. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\UnauthorizedException
  44. * @throws \Ibexa\Contracts\Core\Repository\Exceptions\BadStateException
  45. */
  46. public function cancelPayment(BeforeCancelOrderEvent $event): void
  47. {
  48. $payment = $this->getOrderPayment($event->getOrder());
  49. if ($payment === null) {
  50. return;
  51. }
  53. $workflow = $this->workflowResolver->resolveWorkflow($payment);
  55. if ($workflow->can($payment, 'cancel')) {
  56. $this->paymentService->updatePayment($payment, new PaymentUpdateStruct('cancel'));
  57. }
  58. }
  60. private function getOrderPayment(OrderInterface $order): ?PaymentInterface
  61. {
  62. $payments = $this->paymentService->findPayments(
  63. new PaymentQuery(new PaymentOrderCriterion($order))
  64. )->getPayments();
  66. return $payments[0] ?? null;
  67. }
  68. }