feat: delay step transition until all media is processed

src/DependencyInjection/migration.xml

@@ -234,13 +234,6 @@
             <argument type="service" id="swag_migration_mapping.repository"/>
         </service>
 
-        <service id="SwagMigrationAssistant\Migration\Service\MediaFileProcessorService" public="true">
-            <argument type="service" id="messenger.default_bus"/>
-            <argument type="service" id="SwagMigrationAssistant\Migration\DataSelection\DataSet\DataSetRegistry"/>
-            <argument type="service" id="SwagMigrationAssistant\Migration\Logging\LoggingService"/>
-            <argument type="service" id="Doctrine\DBAL\Connection"/>
-        </service>
-
         <service id="SwagMigrationAssistant\Migration\Media\MediaFileProcessorRegistry">
             <argument type="tagged_iterator" tag="shopware.migration.media_file_processor"/>
         </service>
@@ -318,14 +311,6 @@
             <argument type="service" id="swag_migration_connection.repository"/>
         </service>
 
-        <service id="SwagMigrationAssistant\Migration\MessageQueue\Handler\ProcessMediaHandler">
-            <argument type="service" id="swag_migration_run.repository"/>
-            <argument type="service" id="SwagMigrationAssistant\Migration\Media\MediaFileProcessorRegistry"/>
-            <argument type="service" id="SwagMigrationAssistant\Migration\Logging\LoggingService"/>
-            <argument type="service" id="SwagMigrationAssistant\Migration\MigrationContextFactory"/>
-            <tag name="messenger.message_handler"/>
-        </service>
-
         <service id="SwagMigrationAssistant\Migration\MessageQueue\Handler\CleanupMigrationHandler">
             <argument type="service" id="Doctrine\DBAL\Connection"/>
             <argument type="service" id="messenger.default_bus"/>
@@ -407,8 +392,11 @@
 
         <service id="SwagMigrationAssistant\Migration\MessageQueue\Handler\Processor\MediaProcessingProcessor"
                  parent="SwagMigrationAssistant\Migration\MessageQueue\Handler\Processor\AbstractProcessor">
-            <argument type="service" id="SwagMigrationAssistant\Migration\Service\MediaFileProcessorService"/>
             <argument type="service" id="messenger.default_bus"/>
+            <argument type="service" id="SwagMigrationAssistant\Migration\Logging\LoggingService"/>
+            <argument type="service" id="Doctrine\DBAL\Connection"/>
+            <argument type="service" id="SwagMigrationAssistant\Migration\Media\MediaFileProcessorRegistry"/>
+            <argument type="service" id="SwagMigrationAssistant\Migration\DataSelection\DataSet\DataSetRegistry"/>
 
             <tag name="shopware.migration.processor"/>
         </service>

src/Migration/Logging/Log/CannotGetFileRunLog.php

@@ -7,7 +7,6 @@
 
 namespace SwagMigrationAssistant\Migration\Logging\Log;
 
-use GuzzleHttp\Exception\RequestException;
 use Shopware\Core\Framework\Log\Package;
 
 #[Package('fundamentals@after-sales')]
@@ -18,7 +17,7 @@ public function __construct(
         string $entity,
         string $sourceId,
         private readonly string $uri,
-        private readonly ?RequestException $requestException = null,
+        private readonly ?\Throwable $error = null,
     ) {
         parent::__construct($runId, $entity, $sourceId);
     }
@@ -71,10 +70,10 @@ public function getDescription(): string
             $args['sourceId']
         );
 
-        if ($this->requestException !== null) {
+        if ($this->error !== null) {
             $description .= \sprintf(
-                ' The following request error occurred: %s',
-                $this->requestException->getMessage()
+                ' The following error occurred: %s',
+                $this->error->getMessage()
             );
         }
 

src/Migration/Media/Processor/HttpDownloadServiceBase.php

@@ -9,7 +9,6 @@
 
 use Doctrine\DBAL\Connection;
 use GuzzleHttp\Exception\RequestException;
-use GuzzleHttp\Promise;
 use GuzzleHttp\Promise\PromiseInterface;
 use GuzzleHttp\Promise\Utils;
 use Psr\Http\Message\ResponseInterface;
@@ -30,7 +29,7 @@
 use SwagMigrationAssistant\Migration\Media\MediaFileProcessorInterface;
 use SwagMigrationAssistant\Migration\Media\MediaProcessWorkloadStruct;
 use SwagMigrationAssistant\Migration\Media\SwagMigrationMediaFileCollection;
-use SwagMigrationAssistant\Migration\MessageQueue\Handler\ProcessMediaHandler;
+use SwagMigrationAssistant\Migration\MessageQueue\Handler\Processor\MediaProcessingProcessor;
 use SwagMigrationAssistant\Migration\MigrationContextInterface;
 
 /**
@@ -114,7 +113,7 @@ function (MediaProcessWorkloadStruct $work) use ($uuid) {
                 $work->setAdditionalData($additionalData);
                 $work->setErrorCount($work->getErrorCount() + 1);
 
-                if ($work->getErrorCount() > ProcessMediaHandler::MEDIA_ERROR_THRESHOLD) {
+                if ($work->getErrorCount() > MediaProcessingProcessor::MEDIA_ERROR_THRESHOLD) {
                     $failureUuids[] = $uuid;
                     $work->setState(MediaProcessWorkloadStruct::ERROR_STATE);
                     $this->loggingService->addLogEntry(new CannotGetFileRunLog(