src/EventSubscriber/Payment/StripePaymentSubscriber.php line 37

  1. <?php
  3. /*
  4.  * This file is part of the Pellipop project.
  5.  *
  6.  * (c) Mobizel
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. declare(strict_types=1);
  14. namespace App\EventSubscriber\Payment;
  16. use App\Entity\Payment\Payment;
  17. use App\PaymentStates;
  18. use App\Repository\Payment\PaymentRepository;
  19. use FluxSE\PayumStripe\Action\NotifyAction;
  20. use Payum\Core\Bridge\Symfony\Event\ExecuteEvent;
  21. use Payum\Core\Bridge\Symfony\PayumEvents;
  22. use Payum\Core\Request\GetHumanStatus;
  23. use Payum\Core\Request\Notify;
  24. use Psr\Log\LoggerInterface;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  26. use Symfony\Component\Workflow\WorkflowInterface;
  28. class StripePaymentSubscriber implements EventSubscriberInterface
  29. {
  30.     public function __construct(
  31.         private LoggerInterface $logger,
  32.         private PaymentRepository $paymentRepository,
  33.         private WorkflowInterface $paymentStateMachine,
  34.     ) {
  35.     }
  37.     public function onPostExecute(ExecuteEvent $event)
  38.     {
  39.         $context = $event->getContext();
  40.         $action = $context->getAction();
  41.         $request = $context->getRequest();
  43.         if ($action instanceof NotifyAction && $request instanceof Notify) {
  44.             $payment = $request->getFirstModel();
  46.             if (!$payment instanceof Payment) {
  47.                 return;
  48.             }
  50.             $context->getGateway()->execute($status = new GetHumanStatus($payment));
  52.             $this->logger->debug(sprintf("Stripe payment status is '%s'.", $status->getValue()));
  54.             /** @var Payment $payment */
  55.             $payment = $status->getFirstModel();
  57.             if ($status->isCaptured() && $this->paymentStateMachine->can($payment, PaymentStates::TRANSITION_COMPLETE)) {
  58.                 $this->paymentStateMachine->apply($payment, PaymentStates::TRANSITION_COMPLETE);
  59.                 $this->paymentRepository->add($payment);
  60.             } elseif ($status->isCanceled() && $this->paymentStateMachine->can($payment, PaymentStates::TRANSITION_CANCEL)) {
  61.                 $this->paymentStateMachine->apply($payment, PaymentStates::TRANSITION_CANCEL);
  62.                 $this->paymentRepository->add($payment);
  63.             }
  64.         }
  65.     }
  67.     public static function getSubscribedEvents()
  68.     {
  69.         return [
  70.             PayumEvents::GATEWAY_POST_EXECUTE => 'onPostExecute',
  71.         ];
  72.     }
  73. }