Merge pull request #817 from Nosto/release/7.2.0

Release/7.2.0
Nosto · Jan 9, 2023 · e0d316c · e0d316c
2 parents 5eff14c + 35b544d
commit e0d316c
Show file tree

Hide file tree

Showing 13 changed files with 11 additions and 400 deletions.
diff --git a/Model/Indexer/ProductIndexer.php b/Model/Indexer/ProductIndexer.php
@@ -50,7 +50,6 @@
 use Nosto\Tagging\Model\ResourceModel\Magento\Product\CollectionBuilder;
 use Nosto\Tagging\Model\Service\Indexer\IndexerStatusServiceInterface;
 use Nosto\Tagging\Model\Service\Update\ProductUpdateService;
-use Nosto\Tagging\Util\PagingIterator;
 use Symfony\Component\Console\Input\InputInterface;
 
 /**
@@ -129,38 +128,6 @@ public function doIndex(Store $store, array $ids = [])
             $collection,
             $store
         );
-        $this->handleDeletedProducts($collection, $store, $ids);
-    }
-
-    /**
-     * @param ProductCollection $existingCollection
-     * @param Store $store
-     * @param array $givenIds
-     * @throws NostoException
-     */
-    private function handleDeletedProducts(ProductCollection $existingCollection, Store $store, array $givenIds)
-    {
-        if (!empty($givenIds)) {
-            $existingCollection->setPageSize(1000);
-            $iterator = new PagingIterator($existingCollection);
-            $present = [];
-            foreach ($iterator as $page) {
-                foreach ($page->getItems() as $item) {
-                    /** @noinspection PhpPossiblePolymorphicInvocationInspection */
-                    $id = $item->getId();
-                    $present[$id] = $id;
-                }
-            }
-            $removed = [];
-            foreach ($givenIds as $productId) {
-                if (!isset($present[$productId])) {
-                    $removed[] = $productId;
-                }
-            }
-            if (count($removed) > 0) {
-                $this->productUpdateService->addIdsToDeleteMessageQueue($removed, $store);
-            }
-        }
     }
 
     /**

diff --git a/Model/Service/Sync/Delete/AsyncBulkConsumer.php b/Model/Service/Sync/Delete/AsyncBulkConsumer.php
diff --git a/Model/Service/Sync/Delete/AsyncBulkPublisher.php b/Model/Service/Sync/Delete/AsyncBulkPublisher.php
diff --git a/Model/Service/Sync/Delete/DeleteService.php b/Model/Service/Sync/Delete/DeleteService.php