Init Partial Product Sync

Console/Command/NostoClearQueueCommand.php

@@ -27,6 +27,20 @@ class NostoClearQueueCommand extends Command
      */
     public const NOSTO_DELETE_MESSAGE_QUEUE = 'nosto_product_sync.delete';
 
+    /**
+     * Nosto Product Sync Partial Price label.
+     *
+     * @var string
+     */
+    public const NOSTO_PRODUCT_PARTIAL_PRICE_QUEUE = 'nosto_product_sync.partial_price_update';
+
+    /**
+     * Nosto Product Sync Partial Inventory label.
+     *
+     * @var string
+     */
+    public const NOSTO_PRODUCT_PARTIAL_INVENTORY_QUEUE = 'nosto_product_sync.partial_inventory_update';
+
     /**
      * @var ConsumerConfig
      */
@@ -40,6 +54,8 @@ class NostoClearQueueCommand extends Command
     private array $consumers = [
         self::NOSTO_DELETE_MESSAGE_QUEUE,
         self::NOSTO_UPDATE_SYNC_MESSAGE_QUEUE,
+        self::NOSTO_PRODUCT_PARTIAL_PRICE_QUEUE,
+        self::NOSTO_PRODUCT_PARTIAL_INVENTORY_QUEUE
     ];
 
     /**

Model/Indexer/Partial/ProductInventoryIndexer.php

@@ -0,0 +1,145 @@
+<?php
+/**
+ * Copyright (c) 2020, Nosto Solutions Ltd
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without modification,
+ * are permitted provided that the following conditions are met:
+ *
+ * 1. Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ *
+ * 2. Redistributions in binary form must reproduce the above copyright notice,
+ * this list of conditions and the following disclaimer in the documentation
+ * and/or other materials provided with the distribution.
+ *
+ * 3. Neither the name of the copyright holder nor the names of its contributors
+ * may be used to endorse or promote products derived from this software without
+ * specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR
+ * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
+ * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ *
+ * @author Nosto Solutions Ltd <[email protected]>
+ * @copyright 2020 Nosto Solutions Ltd
+ * @license http://opensource.org/licenses/BSD-3-Clause BSD 3-Clause
+ *
+ */
+
+namespace Nosto\Tagging\Model\Indexer;
+
+use Exception;
+use Magento\Indexer\Model\ProcessManager;
+use Magento\Store\Model\App\Emulation;
+use Magento\Store\Model\Store;
+use Nosto\NostoException;
+use Nosto\Tagging\Helper\Scope as NostoHelperScope;
+use Nosto\Tagging\Logger\Logger as NostoLogger;
+use Nosto\Tagging\Model\Indexer\Dimensions\Product\ModeSwitcher as ProductModeSwitcher;
+use Nosto\Tagging\Model\Indexer\Dimensions\ModeSwitcherInterface;
+use Nosto\Tagging\Model\Indexer\Dimensions\StoreDimensionProvider;
+use Nosto\Tagging\Model\ResourceModel\Magento\Product\Collection as ProductCollection;
+use Nosto\Tagging\Model\ResourceModel\Magento\Product\CollectionBuilder;
+use Nosto\Tagging\Model\Service\Indexer\IndexerStatusServiceInterface;
+use Symfony\Component\Console\Input\InputInterface;
+
+/**
+ * Class ProductInventoryIndexer
+ * Fetches product ID's from CL tables and create entries in the message queue
+ */
+class ProductInventoryIndexer extends AbstractIndexer
+{
+    public const INDEXER_ID = 'nosto_index_partial_product_inventory';
+
+    /** @var CollectionBuilder */
+    private CollectionBuilder $productCollectionBuilder;
+
+    /** @var ProductModeSwitcher */
+    private ProductModeSwitcher $modeSwitcher;
+
+    /**
+     * Invalidate constructor.
+     * @param NostoHelperScope $nostoHelperScope
+     * @param NostoLogger $logger
+     * @param CollectionBuilder $productCollectionBuilder
+     * @param ProductModeSwitcher $modeSwitcher
+     * @param StoreDimensionProvider $dimensionProvider
+     * @param Emulation $storeEmulation
+     * @param ProcessManager $processManager
+     * @param InputInterface $input
+     * @param IndexerStatusServiceInterface $indexerStatusService
+     */
+    public function __construct(
+        NostoHelperScope              $nostoHelperScope,
+        NostoLogger                   $logger,
+        CollectionBuilder             $productCollectionBuilder,
+        ProductModeSwitcher           $modeSwitcher,
+        StoreDimensionProvider        $dimensionProvider,
+        Emulation                     $storeEmulation,
+        ProcessManager                $processManager,
+        InputInterface                $input,
+        IndexerStatusServiceInterface $indexerStatusService
+    ) {
+        $this->productCollectionBuilder = $productCollectionBuilder;
+        $this->modeSwitcher = $modeSwitcher;
+        parent::__construct(
+            $nostoHelperScope,
+            $logger,
+            $dimensionProvider,
+            $storeEmulation,
+            $input,
+            $indexerStatusService,
+            $processManager
+        );
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function getModeSwitcher(): ModeSwitcherInterface
+    {
+        return $this->modeSwitcher;
+    }
+
+    /**
+     * @inheritDoc
+     * @throws NostoException
+     * @throws Exception
+     */
+    public function doIndex(Store $store, array $ids = [])
+    {
+        $collection = $this->getCollection($store, $ids);
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function getIndexerId(): string
+    {
+        return self::INDEXER_ID;
+    }
+
+    /**
+     * @param Store $store
+     * @param array $ids
+     * @return ProductCollection
+     */
+    public function getCollection(Store $store, array $ids = []): ProductCollection
+    {
+        $this->productCollectionBuilder->initDefault($store);
+        if (!empty($ids)) {
+            $this->productCollectionBuilder->withIds($ids);
+        } else {
+            $this->productCollectionBuilder->withDefaultVisibility($store);
+        }
+        return $this->productCollectionBuilder->build();
+    }
+}

Model/Indexer/Partial/ProductPriceIndexer.php

@@ -0,0 +1,145 @@
+<?php
+/**
+ * Copyright (c) 2020, Nosto Solutions Ltd
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without modification,
+ * are permitted provided that the following conditions are met:
+ *
+ * 1. Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ *
+ * 2. Redistributions in binary form must reproduce the above copyright notice,
+ * this list of conditions and the following disclaimer in the documentation
+ * and/or other materials provided with the distribution.
+ *
+ * 3. Neither the name of the copyright holder nor the names of its contributors
+ * may be used to endorse or promote products derived from this software without
+ * specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR
+ * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
+ * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ *
+ * @author Nosto Solutions Ltd <[email protected]>
+ * @copyright 2020 Nosto Solutions Ltd
+ * @license http://opensource.org/licenses/BSD-3-Clause BSD 3-Clause
+ *
+ */
+
+namespace Nosto\Tagging\Model\Indexer;
+
+use Exception;
+use Magento\Indexer\Model\ProcessManager;
+use Magento\Store\Model\App\Emulation;
+use Magento\Store\Model\Store;
+use Nosto\NostoException;
+use Nosto\Tagging\Helper\Scope as NostoHelperScope;
+use Nosto\Tagging\Logger\Logger as NostoLogger;
+use Nosto\Tagging\Model\Indexer\Dimensions\Product\ModeSwitcher as ProductModeSwitcher;
+use Nosto\Tagging\Model\Indexer\Dimensions\ModeSwitcherInterface;
+use Nosto\Tagging\Model\Indexer\Dimensions\StoreDimensionProvider;
+use Nosto\Tagging\Model\ResourceModel\Magento\Product\Collection as ProductCollection;
+use Nosto\Tagging\Model\ResourceModel\Magento\Product\CollectionBuilder;
+use Nosto\Tagging\Model\Service\Indexer\IndexerStatusServiceInterface;
+use Symfony\Component\Console\Input\InputInterface;
+
+/**
+ * Class ProductPriceIndexer
+ * Fetches product ID's from CL tables and create entries in the message queue
+ */
+class ProductPriceIndexer extends AbstractIndexer
+{
+    public const INDEXER_ID = 'nosto_index_partial_product_price';
+
+    /** @var CollectionBuilder */
+    private CollectionBuilder $productCollectionBuilder;
+
+    /** @var ProductModeSwitcher */
+    private ProductModeSwitcher $modeSwitcher;
+
+    /**
+     * Invalidate constructor.
+     * @param NostoHelperScope $nostoHelperScope
+     * @param NostoLogger $logger
+     * @param CollectionBuilder $productCollectionBuilder
+     * @param ProductModeSwitcher $modeSwitcher
+     * @param StoreDimensionProvider $dimensionProvider
+     * @param Emulation $storeEmulation
+     * @param ProcessManager $processManager
+     * @param InputInterface $input
+     * @param IndexerStatusServiceInterface $indexerStatusService
+     */
+    public function __construct(
+        NostoHelperScope              $nostoHelperScope,
+        NostoLogger                   $logger,
+        CollectionBuilder             $productCollectionBuilder,
+        ProductModeSwitcher           $modeSwitcher,
+        StoreDimensionProvider        $dimensionProvider,
+        Emulation                     $storeEmulation,
+        ProcessManager                $processManager,
+        InputInterface                $input,
+        IndexerStatusServiceInterface $indexerStatusService
+    ) {
+        $this->productCollectionBuilder = $productCollectionBuilder;
+        $this->modeSwitcher = $modeSwitcher;
+        parent::__construct(
+            $nostoHelperScope,
+            $logger,
+            $dimensionProvider,
+            $storeEmulation,
+            $input,
+            $indexerStatusService,
+            $processManager
+        );
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function getModeSwitcher(): ModeSwitcherInterface
+    {
+        return $this->modeSwitcher;
+    }
+
+    /**
+     * @inheritDoc
+     * @throws NostoException
+     * @throws Exception
+     */
+    public function doIndex(Store $store, array $ids = [])
+    {
+        $collection = $this->getCollection($store, $ids);
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function getIndexerId(): string
+    {
+        return self::INDEXER_ID;
+    }
+
+    /**
+     * @param Store $store
+     * @param array $ids
+     * @return ProductCollection
+     */
+    public function getCollection(Store $store, array $ids = []): ProductCollection
+    {
+        $this->productCollectionBuilder->initDefault($store);
+        if (!empty($ids)) {
+            $this->productCollectionBuilder->withIds($ids);
+        } else {
+            $this->productCollectionBuilder->withDefaultVisibility($store);
+        }
+        return $this->productCollectionBuilder->build();
+    }
+}

Model/Product/Builder.php

@@ -405,7 +405,7 @@ private function amendAttributeTags(Product $product, NostoProduct $nostoProduct
      * @param Store $store
      * @return string
      */
-    private function buildAvailability(Product $product, Store $store)
+    public function buildAvailability(Product $product, Store $store)
     {
         $availability = ProductInterface::OUT_OF_STOCK;
         $isInStock = $this->availabilityService->isInStock($product, $store);