feat: add error resolution ui

src/Controller/HistoryController.php

@@ -12,6 +12,7 @@
 use Shopware\Core\Framework\Routing\RoutingException;
 use SwagMigrationAssistant\Exception\MigrationException;
 use SwagMigrationAssistant\Migration\History\HistoryServiceInterface;
+use SwagMigrationAssistant\Migration\History\LogGroupingServiceInterface;
 use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
 use Symfony\Component\HttpFoundation\HeaderUtils;
 use Symfony\Component\HttpFoundation\JsonResponse;
@@ -25,11 +26,13 @@
 #[Package('fundamentals@after-sales')]
 class HistoryController extends AbstractController
 {
-    public function __construct(private readonly HistoryServiceInterface $historyService)
-    {
+    public function __construct(
+        private readonly HistoryServiceInterface $historyService,
+        private readonly LogGroupingServiceInterface $logGroupingService,
+    ) {
     }
 
-    #[Route(path: '/api/migration/get-grouped-logs-of-run', name: 'api.admin.migration.get-grouped-logs-of-run', methods: ['GET'], defaults: ['_acl' => ['swag_migration.viewer']])]
+    #[Route(path: '/api/_action/migration/get-grouped-logs-of-run', name: 'api.admin.migration.get-grouped-logs-of-run', methods: ['GET'], defaults: ['_acl' => ['swag_migration.viewer']])]
     public function getGroupedLogsOfRun(Request $request, Context $context): JsonResponse
     {
         $runUuid = $request->query->getAlnum('runUuid');
@@ -105,4 +108,102 @@ public function isMediaProcessing(): JsonResponse
 
         return new JsonResponse($result);
     }
+
+    #[Route(
+        path: '/api/_action/migration/get-log-groups',
+        name: 'api.admin.migration.get-log-groups',
+        methods: ['GET'],
+        defaults: ['_acl' => ['swag_migration.viewer']]
+    )]
+    public function getLogGroups(Request $request, Context $context): JsonResponse
+    {
+        $runId = $request->query->getAlnum('runId');
+
+        if (empty($runId)) {
+            throw RoutingException::missingRequestParameter('runId');
+        }
+
+        $level = $request->query->getAlpha('level');
+
+        if (empty($level)) {
+            throw RoutingException::missingRequestParameter('level');
+        }
+
+        $page = $request->query->getInt('page', 1);
+        $limit = $request->query->getInt('limit', 25);
+
+        $sortBy = $request->query->getAlpha('sortBy') ?: 'count';
+        $sortDirection = $request->query->getAlpha('sortDirection') ?: 'DESC';
+
+        if (!\in_array(\strtoupper($sortDirection), ['ASC', 'DESC'], true)) {
+            $sortDirection = 'DESC';
+        }
+
+        $filterCode = $request->query->get('filterCode');
+        $filterStatus = $request->query->get('filterStatus');
+        $filterEntity = $request->query->get('filterEntity');
+        $filterField = $request->query->get('filterField');
+
+        $result = $this->logGroupingService->getGroupedLogsByCodeAndEntity(
+            $runId,
+            $level,
+            $page,
+            $limit,
+            $sortBy,
+            \strtoupper($sortDirection),
+            \is_string($filterCode) && !empty($filterCode) ? $filterCode : null,
+            \is_string($filterStatus) && !empty($filterStatus) ? $filterStatus : null,
+            \is_string($filterEntity) && !empty($filterEntity) ? $filterEntity : null,
+            \is_string($filterField) && !empty($filterField) ? $filterField : null,
+        );
+
+        return new JsonResponse($result);
+    }
+
+    #[Route(
+        path: '/api/_action/migration/get-all-log-ids',
+        name: 'api.admin.migration.get-all-log-ids',
+        methods: ['POST'],
+        defaults: ['_acl' => ['swag_migration.viewer']]
+    )]
+    public function getAllLogIds(Request $request): JsonResponse
+    {
+        $runId = $request->request->getAlnum('runId');
+
+        if (empty($runId)) {
+            throw RoutingException::missingRequestParameter('runId');
+        }
+
+        $code = $request->request->get('code');
+
+        if (!\is_string($code) || empty($code)) {
+            throw RoutingException::missingRequestParameter('code');
+        }
+
+        $entityName = $request->request->get('entityName');
+
+        if (!\is_string($entityName) || empty($entityName)) {
+            throw RoutingException::missingRequestParameter('entityName');
+        }
+
+        $fieldName = $request->request->get('fieldName');
+
+        if (!\is_string($fieldName) || empty($fieldName)) {
+            throw RoutingException::missingRequestParameter('fieldName');
+        }
+
+        $connectionId = $request->request->getAlnum('connectionId');
+
+        $logIds = $this->logGroupingService->getAllLogIdsByCodeAndEntity(
+            $runId,
+            $code,
+            $entityName,
+            $fieldName,
+            !empty($connectionId) ? $connectionId : null
+        );
+
+        return new JsonResponse([
+            'ids' => $logIds,
+        ]);
+    }
 }

src/Controller/StatusController.php

@@ -14,8 +14,10 @@
 use Shopware\Core\Framework\Routing\RoutingException;
 use SwagMigrationAssistant\Exception\MigrationException;
 use SwagMigrationAssistant\Migration\Connection\SwagMigrationConnectionCollection;
+use SwagMigrationAssistant\Migration\Connection\SwagMigrationConnectionEntity;
 use SwagMigrationAssistant\Migration\DataSelection\DataSelectionRegistryInterface;
 use SwagMigrationAssistant\Migration\Gateway\GatewayRegistryInterface;
+use SwagMigrationAssistant\Migration\MigrationContext;
 use SwagMigrationAssistant\Migration\MigrationContextFactoryInterface;
 use SwagMigrationAssistant\Migration\Profile\ProfileRegistryInterface;
 use SwagMigrationAssistant\Migration\Run\RunServiceInterface;
@@ -88,7 +90,10 @@ public function getProfileInformation(Request $request): Response
         }
 
         $profile = $this->profileRegistry->getProfile($profileName);
-        $gateways = $this->gatewayRegistry->getGateways($profile);
+        $context = new MigrationContext(new SwagMigrationConnectionEntity());
+        $context->setProfile($profile);
+
+        $gateways = $this->gatewayRegistry->getGateways($context);
 
         $currentGateway = null;
         foreach ($gateways as $gateway) {
@@ -152,7 +157,10 @@ public function getGateways(Request $request): JsonResponse
         }
 
         $profile = $this->profileRegistry->getProfile($profileName);
-        $gateways = $this->gatewayRegistry->getGateways($profile);
+        $context = new MigrationContext(new SwagMigrationConnectionEntity());
+        $context->setProfile($profile);
+
+        $gateways = $this->gatewayRegistry->getGateways($context);
 
         $gatewayNames = [];
         foreach ($gateways as $gateway) {
@@ -318,11 +326,7 @@ public function approveFinishedMigration(Context $context): Response
     )]
     public function abortMigration(Context $context): Response
     {
-        try {
-            $this->runService->abortMigration($context);
-        } catch (\Exception $e) {
-            return new Response($e->getMessage(), Response::HTTP_BAD_REQUEST);
-        }
+        $this->runService->abortMigration($context);
 
         return new Response(null, Response::HTTP_NO_CONTENT);
     }
@@ -360,7 +364,7 @@ public function cleanupMigrationData(Context $context): Response
     }
 
     #[Route(
-        path: '/api/_action/migration/get-reset-status',
+        path: '/api/_action/migration/is-truncating-migration-data',
         name: 'api.admin.migration.get-reset-status',
         defaults: ['_acl' => ['swag_migration.viewer']],
         methods: [Request::METHOD_GET]

src/DependencyInjection/migration.xml

@@ -198,6 +198,10 @@
             <argument type="service" id="Doctrine\DBAL\Connection"/>
         </service>
 
+        <service id="SwagMigrationAssistant\Migration\History\LogGroupingService">
+            <argument type="service" id="Doctrine\DBAL\Connection"/>
+        </service>
+
         <service id="SwagMigrationAssistant\Migration\History\HistoryService">
             <argument type="service" id="swag_migration_logging.repository"/>
             <argument type="service" id="swag_migration_run.repository"/>
@@ -279,6 +283,7 @@
 
         <service id="SwagMigrationAssistant\Controller\HistoryController" public="true">
             <argument type="service" id="SwagMigrationAssistant\Migration\History\HistoryService"/>
+            <argument type="service" id="SwagMigrationAssistant\Migration\History\LogGroupingService"/>
 
             <call method="setContainer">
                 <argument type="service" id="service_container"/>

src/Migration/Gateway/GatewayRegistry.php

@@ -10,7 +10,6 @@
 use Shopware\Core\Framework\Log\Package;
 use SwagMigrationAssistant\Exception\MigrationException;
 use SwagMigrationAssistant\Migration\MigrationContextInterface;
-use SwagMigrationAssistant\Migration\Profile\ProfileInterface;
 
 #[Package('fundamentals@after-sales')]
 class GatewayRegistry implements GatewayRegistryInterface
@@ -25,8 +24,10 @@ public function __construct(private readonly iterable $gateways)
     /**
      * @return GatewayInterface[]
      */
-    public function getGateways(ProfileInterface $profile): array
+    public function getGateways(MigrationContextInterface $migrationContext): array
     {
+        $profile = $migrationContext->getProfile();
+
         $gateways = [];
         foreach ($this->gateways as $gateway) {
             if ($gateway->supports($profile)) {

src/Migration/Gateway/GatewayRegistryInterface.php

@@ -9,15 +9,14 @@
 
 use Shopware\Core\Framework\Log\Package;
 use SwagMigrationAssistant\Migration\MigrationContextInterface;
-use SwagMigrationAssistant\Migration\Profile\ProfileInterface;
 
 #[Package('fundamentals@after-sales')]
 interface GatewayRegistryInterface
 {
     /**
      * @return GatewayInterface[]
      */
-    public function getGateways(ProfileInterface $profile): array;
+    public function getGateways(MigrationContextInterface $migrationContext): array;
 
     /**
      * Selects the correct gateway by the given migration context