PAYOSWXP-156: set transaction-state to „authorized“ on „appointed“

src/DependencyInjection/controllers.xml

@@ -61,19 +61,6 @@
             </call>
         </service>
 
-        <service id="PayonePayment\Storefront\Controller\Account\AccountOrderControllerDecorator"
-                 decorates="Shopware\Storefront\Controller\AccountOrderController">
-            <argument type="service" id="PayonePayment\Storefront\Controller\Account\AccountOrderControllerDecorator.inner" />
-            <argument type="service" id="order.repository" />
-
-            <call method="setContainer">
-                <argument type="service" id="service_container"/>
-            </call>
-            <call method="setTwig">
-                <argument type="service" id="twig"/>
-            </call>
-        </service>
-
         <service id="PayonePayment\Storefront\Controller\Debit\ManageMandateController">
             <argument type="service" id="PayonePayment\Payone\RequestParameter\RequestParameterFactory" />
             <argument type="service" id="PayonePayment\Payone\Client\PayoneClient" />

src/DependencyInjection/webhooks.xml

@@ -10,29 +10,36 @@
             <argument key="$logger" type="service" id="monolog.logger.payone" />
         </service>
 
-        <service id="PayonePayment\Payone\Webhook\Handler\TransactionStatusWebhookHandler">
-            <argument type="service" id="PayonePayment\Components\TransactionStatus\TransactionStatusService"/>
+        <service id="PayonePayment\Payone\Webhook\Handler\WebhookLogHandler">
             <argument type="service" id="PayonePayment\Components\DataHandler\Transaction\TransactionDataHandlerInterface" />
+            <argument type="service" id="PayonePayment\Components\DataHandler\WebhookLog\WebhookLogDataHandlerInterface" />
             <argument type="service" id="monolog.logger.payone" />
-            <argument type="service" id="PayonePayment\Components\AutomaticCaptureService\AutomaticCaptureServiceInterface" />
 
-            <tag name="payone.webhook.handler" />
+            <tag name="payone.webhook.handler" priority="1000" />
         </service>
 
-        <service id="PayonePayment\Payone\Webhook\Handler\WebhookLogHandler">
+        <service id="PayonePayment\Payone\Webhook\Handler\TransactionStatusWebhookHandler">
+            <argument type="service" id="PayonePayment\Components\TransactionStatus\TransactionStatusService"/>
             <argument type="service" id="PayonePayment\Components\DataHandler\Transaction\TransactionDataHandlerInterface" />
-            <argument type="service" id="PayonePayment\Components\DataHandler\WebhookLog\WebhookLogDataHandlerInterface" />
             <argument type="service" id="monolog.logger.payone" />
 
-            <tag name="payone.webhook.handler" />
+            <tag name="payone.webhook.handler" priority="300" />
+        </service>
+
+        <service id="PayonePayment\Payone\Webhook\Handler\PaymentStatusHandler" autowire="true">
+            <tag name="payone.webhook.handler" priority="200" />
+        </service>
+
+        <service id="PayonePayment\Payone\Webhook\Handler\AutoCaptureHandler" autowire="true">
+            <tag name="payone.webhook.handler" priority="100" />
         </service>
 
         <service id="PayonePayment\Payone\Webhook\Handler\NotificationForwardHandler">
             <argument type="service" id="payone_payment_notification_target.repository"/>
             <argument type="service" id="PayonePayment\Components\DataHandler\Transaction\TransactionDataHandlerInterface" />
             <argument type="service" id="messenger.bus.shopware"/>
 
-            <tag name="payone.webhook.handler" />
+            <tag name="payone.webhook.handler" priority="0" />
         </service>
 
         <service id="PayonePayment\Payone\Webhook\MessageBus\MessageHandler\NotificationForwardHandler" autowire="true">

src/Payone/Webhook/Handler/AutoCaptureHandler.php

@@ -0,0 +1,40 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PayonePayment\Payone\Webhook\Handler;
+
+use PayonePayment\Components\AutomaticCaptureService\AutomaticCaptureServiceInterface;
+use PayonePayment\Components\DataHandler\Transaction\TransactionDataHandlerInterface;
+use PayonePayment\Components\TransactionStatus\TransactionStatusService;
+use PayonePayment\Struct\PaymentTransaction;
+use Shopware\Core\System\SalesChannel\SalesChannelContext;
+use Symfony\Component\HttpFoundation\Request;
+
+class AutoCaptureHandler implements WebhookHandlerInterface
+{
+    public function __construct(
+        private readonly TransactionDataHandlerInterface $transactionDataHandler,
+        private readonly AutomaticCaptureServiceInterface $automaticCaptureService
+    ) {
+    }
+
+    public function process(SalesChannelContext $salesChannelContext, Request $request): void
+    {
+        $paymentTransaction = $this->transactionDataHandler->getPaymentTransactionByPayoneTransactionId(
+            $salesChannelContext->getContext(),
+            $request->request->getInt('txid')
+        );
+
+        if (!$paymentTransaction instanceof PaymentTransaction) {
+            return;
+        }
+
+        $this->automaticCaptureService->captureIfPossible($paymentTransaction, $salesChannelContext);
+    }
+
+    public function supports(SalesChannelContext $salesChannelContext, array $data): bool
+    {
+        return isset($data['txid']) && ($data['txaction'] ?? null) === TransactionStatusService::ACTION_APPOINTED;
+    }
+}

src/Payone/Webhook/Handler/PaymentStatusHandler.php

@@ -0,0 +1,51 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PayonePayment\Payone\Webhook\Handler;
+
+use PayonePayment\Components\DataHandler\Transaction\TransactionDataHandlerInterface;
+use PayonePayment\Components\TransactionStatus\TransactionStatusService;
+use PayonePayment\Struct\PaymentTransaction;
+use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionDefinition;
+use Shopware\Core\System\SalesChannel\SalesChannelContext;
+use Shopware\Core\System\StateMachine\Aggregation\StateMachineTransition\StateMachineTransitionActions;
+use Shopware\Core\System\StateMachine\StateMachineRegistry;
+use Shopware\Core\System\StateMachine\Transition;
+use Symfony\Component\HttpFoundation\Request;
+
+class PaymentStatusHandler implements WebhookHandlerInterface
+{
+    public function __construct(
+        private readonly TransactionDataHandlerInterface $transactionDataHandler,
+        private readonly StateMachineRegistry $stateMachineRegistry
+    ) {
+    }
+
+    public function process(SalesChannelContext $salesChannelContext, Request $request): void
+    {
+        $paymentTransaction = $this->transactionDataHandler->getPaymentTransactionByPayoneTransactionId(
+            $salesChannelContext->getContext(),
+            $request->request->getInt('txid')
+        );
+
+        if (!$paymentTransaction instanceof PaymentTransaction) {
+            return;
+        }
+
+        $this->stateMachineRegistry->transition(
+            new Transition(
+                OrderTransactionDefinition::ENTITY_NAME,
+                $paymentTransaction->getOrderTransaction()->getId(),
+                StateMachineTransitionActions::ACTION_AUTHORIZE,
+                'stateId'
+            ),
+            $salesChannelContext->getContext()
+        );
+    }
+
+    public function supports(SalesChannelContext $salesChannelContext, array $data): bool
+    {
+        return isset($data['txid']) && ($data['txaction'] ?? null) === TransactionStatusService::ACTION_APPOINTED;
+    }
+}

src/Payone/Webhook/Handler/TransactionStatusWebhookHandler.php

@@ -4,7 +4,6 @@
 
 namespace PayonePayment\Payone\Webhook\Handler;
 
-use PayonePayment\Components\AutomaticCaptureService\AutomaticCaptureServiceInterface;
 use PayonePayment\Components\DataHandler\Transaction\TransactionDataHandlerInterface;
 use PayonePayment\Components\TransactionStatus\TransactionStatusServiceInterface;
 use PayonePayment\Struct\PaymentTransaction;
@@ -17,8 +16,7 @@ class TransactionStatusWebhookHandler implements WebhookHandlerInterface
     public function __construct(
         private readonly TransactionStatusServiceInterface $transactionStatusService,
         private readonly TransactionDataHandlerInterface $transactionDataHandler,
-        private readonly LoggerInterface $logger,
-        private readonly AutomaticCaptureServiceInterface $automaticCaptureService
+        private readonly LoggerInterface $logger
     ) {
     }
 
@@ -54,17 +52,6 @@ public function process(SalesChannelContext $salesChannelContext, Request $reque
 
         $this->transactionDataHandler->saveTransactionData($paymentTransaction, $salesChannelContext->getContext(), $payoneTransactionData);
         $this->transactionStatusService->transitionByConfigMapping($salesChannelContext, $paymentTransaction, $data);
-
-        // Reload the paymentTransaction for automatic capture
-        /** @var PaymentTransaction|null $paymentTransaction */
-        $paymentTransaction = $this->transactionDataHandler->getPaymentTransactionByPayoneTransactionId(
-            $salesChannelContext->getContext(),
-            (int) $data['txid']
-        );
-
-        if ($paymentTransaction) {
-            $this->automaticCaptureService->captureIfPossible($paymentTransaction, $salesChannelContext);
-        }
     }
 
     private function utf8EncodeRecursive(array $transactionData): array

tests/Payone/Webhook/Handler/AutoCaptureHandlerTest.php

@@ -0,0 +1,68 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PayonePayment\Payone\Webhook\Handler;
+
+use PayonePayment\Components\AutomaticCaptureService\AutomaticCaptureServiceInterface;
+use PayonePayment\Components\DataHandler\Transaction\TransactionDataHandlerInterface;
+use PayonePayment\Components\TransactionStatus\TransactionStatusService;
+use PayonePayment\Struct\PaymentTransaction;
+use PHPUnit\Framework\TestCase;
+use Shopware\Core\System\SalesChannel\SalesChannelContext;
+use Symfony\Component\HttpFoundation\Request;
+
+/**
+ * @covers \PayonePayment\Payone\Webhook\Handler\AutoCaptureHandler
+ */
+class AutoCaptureHandlerTest extends TestCase
+{
+    public function testSupports(): void
+    {
+        $handler = new AutoCaptureHandler(
+            $this->createMock(TransactionDataHandlerInterface::class),
+            $this->createMock(AutomaticCaptureServiceInterface::class),
+        );
+
+        $salesChannelMock = $this->createMock(SalesChannelContext::class);
+
+        static::assertTrue($handler->supports($salesChannelMock, ['txid' => 1, 'txaction' => 'appointed']), 'supports should return true, cause of valid txid nd correct status');
+
+        static::assertFalse($handler->supports($salesChannelMock, ['txaction' => 'appointed']), 'supports should return false, cause of missing txid');
+        static::assertFalse($handler->supports($salesChannelMock, ['txid' => 1]), 'supports should return false, cause of missing status');
+        static::assertFalse($handler->supports($salesChannelMock, []), 'supports should return false, cause of missing data');
+        static::assertFalse($handler->supports($salesChannelMock, []), 'supports should return false, cause of missing data');
+
+        static::assertFalse($handler->supports($salesChannelMock, ['txid' => 1, 'txaction' => TransactionStatusService::ACTION_CAPTURE]), 'supports should return false, cause of wrong status');
+        static::assertFalse($handler->supports($salesChannelMock, ['txid' => 1, 'txaction' => TransactionStatusService::ACTION_COMPLETED]), 'supports should return false, cause of wrong status');
+        static::assertFalse($handler->supports($salesChannelMock, ['txid' => 1, 'txaction' => TransactionStatusService::ACTION_FAILED]), 'supports should return false, cause of wrong status');
+    }
+
+    public function testIsCaptureGotExecuted(): void
+    {
+        $dataHandler = $this->createMock(TransactionDataHandlerInterface::class);
+        $dataHandler->method('getPaymentTransactionByPayoneTransactionId')->willReturn($this->createMock(PaymentTransaction::class));
+        $captureService = $this->createMock(AutomaticCaptureServiceInterface::class);
+        $captureService->expects(static::once())->method('captureIfPossible');
+
+        $request = new Request();
+        $request->request->set('txid', 123);
+
+        (new AutoCaptureHandler($dataHandler, $captureService))
+            ->process($this->createMock(SalesChannelContext::class), $request);
+    }
+
+    public function testIsCaptureGotNotExecutedIfTransactionIsNotFound(): void
+    {
+        $dataHandler = $this->createMock(TransactionDataHandlerInterface::class);
+        $dataHandler->method('getPaymentTransactionByPayoneTransactionId')->willReturn(null);
+        $captureService = $this->createMock(AutomaticCaptureServiceInterface::class);
+        $captureService->expects(static::never())->method('captureIfPossible');
+
+        $request = new Request();
+        $request->request->set('txid', 123);
+
+        (new AutoCaptureHandler($dataHandler, $captureService))
+            ->process($this->createMock(SalesChannelContext::class), $request);
+    }
+}