MDEE-1023: Add ability to collect entities payload for saas:resync --dry-run command (#480)

Author: le0n4ik

DataExporter/Model/Indexer/Config.php

@@ -155,4 +155,15 @@ public function isDryRun(): bool
         $configOptions = $this->configOptionsHandler->getConfigOptionsPool();
         return $configOptions->getFeedOption(self::EXPORTER_DRY_RUN) ?? false;
     }
+
+    /**
+     * Check if submitted items should be included in dry run mode
+     *
+     * @return bool
+     */
+    public function includeSubmittedInDryRun(): bool
+    {
+        $configOptions = $this->configOptionsHandler->getConfigOptionsPool();
+        return $this->isDryRun() && $configOptions->getFeedOption(self::EXPORTER_CLEAN_UP_FEED) ?? false;
+    }
 }

DataExporter/Model/Indexer/FeedIndexProcessorCreateUpdate.php

@@ -18,6 +18,7 @@
 
 use Magento\DataExporter\Model\Batch\BatchGeneratorInterface;
 use Magento\DataExporter\Model\Batch\FeedSource\Generator as FeedSourceBatchGenerator;
+use Magento\DataExporter\Model\Indexer\Config as IndexerConfig;
 use Magento\DataExporter\Model\Logging\CommerceDataExportLoggerInterface;
 use Magento\DataExporter\Status\ExportStatusCodeProvider as ExportStatusCode;
 use Magento\Framework\App\ObjectManager;
@@ -47,6 +48,8 @@ class FeedIndexProcessorCreateUpdate implements FeedIndexProcessorInterface
     private BatchGeneratorInterface $batchGenerator;
     private IndexStateProviderFactory $indexStateProviderFactory;
 
+    private Config $indexerConfig;
+
     /**
      * @param ResourceConnection $resourceConnection
      * @param ExportProcessor $exportProcessor
@@ -59,6 +62,7 @@ class FeedIndexProcessorCreateUpdate implements FeedIndexProcessorInterface
      * @param ProcessManagerFactory|null $processManagerFactory
      * @param BatchGeneratorInterface|null $batchGenerator
      * @param ?IndexStateProviderFactory $indexStateProviderFactory
+     * @param ?Config $indexerConfig
      *
      * @SuppressWarnings(PHPMD.ExcessiveParameterList)
      */
@@ -73,7 +77,8 @@ public function __construct(
         ?DeletedEntitiesProviderInterface $deletedEntitiesProvider = null,
         ?ProcessManagerFactory $processManagerFactory = null,
         ?BatchGeneratorInterface $batchGenerator = null,
-        ?IndexStateProviderFactory $indexStateProviderFactory = null
+        ?IndexStateProviderFactory $indexStateProviderFactory = null,
+        ?IndexerConfig $indexerConfig = null
     ) {
         $this->resourceConnection = $resourceConnection;
         $this->exportProcessor = $exportProcessor;
@@ -90,6 +95,8 @@ public function __construct(
             ObjectManager::getInstance()->get(FeedSourceBatchGenerator::class);
         $this->indexStateProviderFactory = $indexStateProviderFactory ??
             ObjectManager::getInstance()->get(IndexStateProviderFactory::class);
+        $this->indexerConfig = $indexerConfig
+            ?? ObjectManager::getInstance()->get(IndexerConfig::class);
     }
 
     /**
@@ -355,7 +362,8 @@ private function isSendNeeded(string $oldFeedHash, string $newFeedHash, int $fee
                 true
             )
             && $feedStatus !== ExportStatusCode::FAILED_ITEM_ERROR
-        );
+        )
+        || $this->indexerConfig->includeSubmittedInDryRun();
     }
 
     /**