custom/plugins/RpayPayments/src/Components/RatepayApi/Subscriber/PaymentRequestSubscriber.php line 45

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * Copyright (c) Ratepay GmbH
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Ratepay\RpayPayments\Components\RatepayApi\Subscriber;
  14. use RatePAY\Model\Response\PaymentRequest;
  15. use Ratepay\RpayPayments\Components\Checkout\Service\ExtensionService;
  16. use Ratepay\RpayPayments\Components\RatepayApi\Dto\OrderOperationData;
  17. use Ratepay\RpayPayments\Components\RatepayApi\Dto\PaymentRequestData;
  18. use Ratepay\RpayPayments\Components\RatepayApi\Event\ResponseEvent;
  19. use Ratepay\RpayPayments\Components\RatepayApi\Service\Request\PaymentRequestService;
  20. use Ratepay\RpayPayments\Components\RatepayApi\Service\TransactionIdService;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. class PaymentRequestSubscriber implements EventSubscriberInterface
  24. {
  25.     private ExtensionService $extensionService;
  27.     private TransactionIdService $transactionIdService;
  29.     public function __construct(
  30.         TransactionIdService $transactionIdService,
  31.         ExtensionService $extensionService
  32.     ) {
  33.         $this->transactionIdService = $transactionIdService;
  34.         $this->extensionService = $extensionService;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             PaymentRequestService::EVENT_SUCCESSFUL => 'onSuccess',
  41.             PaymentRequestService::EVENT_FAILED => 'onFailure',
  42.         ];
  43.     }
  45.     public function onFailure(ResponseEvent $requestEvent): void
  46.     {
  47.         /** @var PaymentRequestData $requestData */
  48.         $requestData = $requestEvent->getRequestData();
  50.         $this->transactionIdService->deleteTransactionId($requestData->getRatepayTransactionId(), $requestData->getContext());
  52.         /** @var PaymentRequest $responseModel */
  53.         $responseModel = $requestEvent->getRequestBuilder()->getResponse();
  55.         $this->extensionService->createOrderExtensionEntity(
  56.             $requestData,
  57.             $responseModel->getTransactionId(),
  58.             $responseModel->getDescriptor(),
  59.             false
  60.         );
  61.     }
  63.     public function onSuccess(ResponseEvent $requestEvent): void
  64.     {
  65.         /** @var PaymentRequestData $requestData */
  66.         $requestData = $requestEvent->getRequestData();
  68.         $this->transactionIdService->deleteTransactionId($requestData->getRatepayTransactionId(), $requestData->getContext());
  70.         /** @var PaymentRequest $responseModel */
  71.         $responseModel = $requestEvent->getRequestBuilder()->getResponse();
  73.         $orderItems = $requestData->getOrder()->getLineItems();
  75.         $lineItems = [];
  76.         foreach (array_keys($requestData->getItems()) as $id) {
  77.             if ($id !== OrderOperationData::ITEM_ID_SHIPPING) {
  78.                 // shipping will written into the order-extension
  79.                 $lineItems[] = $orderItems->get($id);
  80.             }
  81.         }
  83.         $this->extensionService->createLineItemExtensionEntities($lineItems, $requestData->getContext());
  85.         $this->extensionService->createOrderExtensionEntity(
  86.             $requestData,
  87.             $responseModel->getTransactionId(),
  88.             $responseModel->getDescriptor(),
  89.             true
  90.         );
  91.     }
  92. }