Category indexer

Exception/ParentCategoryDisabledException.php

@@ -41,7 +41,7 @@
 
 class ParentCategoryDisabledException extends NostoException
 {
-    public function __construct(int $categoryId, $code = 0, Throwable $previous = null)
+    public function __construct($categoryId, $code = 0, Throwable $previous = null)
     {
         $message = "Parent category is disabled for category with id: " . $categoryId;
         parent::__construct($message, $code, $previous);

Model/Indexer/CategoryIndexer.php

@@ -125,6 +125,7 @@ public function getModeSwitcher(): ModeSwitcherInterface
     public function doIndex(Store $store, array $ids = [])
     {
         $collection = $this->getCollection($store, $ids);
+
         $this->categoryUpdateService->addCollectionToUpdateMessageQueue(
             $collection,
             $store
@@ -144,7 +145,7 @@ public function getIndexerId(): string
      * @param array $ids
      * @return CategoryCollection
      */
-    public function getCollection(Store $store, array $ids = []) //: CategoryCollection
+    public function getCollection(Store $store, array $ids = []) : CategoryCollection
     {
         $this->categoryCollectionBuilder->initDefault($store);
 
@@ -154,8 +155,6 @@ public function getCollection(Store $store, array $ids = []) //: CategoryCollect
             $this->categoryCollectionBuilder->withStore($store);
         }
 
-        return null;
-        // @TODO: Implement logic
-        // return $this->categoryCollectionBuilder->build();
+        return $this->categoryCollectionBuilder->build();
     }
 }

Model/ResourceModel/Magento/Category/Collection.php

@@ -36,7 +36,7 @@
 
 namespace Nosto\Tagging\Model\ResourceModel\Magento\Category;
 
-use Magento\Catalog\Model\Category\Attribute\Source\Status;
+//use Magento\Catalog\Model\Category\Attribute\Source\Status;
 use Magento\Catalog\Model\ResourceModel\Category\Collection as MagentoCategoryCollection;
 
 class Collection extends MagentoCategoryCollection
@@ -46,8 +46,11 @@ class Collection extends MagentoCategoryCollection
      */
     public function addActiveFilter()
     {
+        echo '<pre>';
+        print_r(44);
+        die;
         // @TODO: Here should be included in the menu
-        return $this->addAttributeToFilter('status', ['eq' => Status::STATUS_ENABLED]);
+        return $this->addAttributeToFilter('status', ['eq' => 1]);
     }
 
     /**
@@ -56,6 +59,9 @@ public function addActiveFilter()
      */
     public function addIdsToFilter(array $ids)
     {
+        echo '<pre>';
+        print_r(222);
+        die;
         return $this->addAttributeToFilter($this->getIdFieldName(), ['in' => $ids]);
     }
 }

Model/ResourceModel/Magento/Category/CollectionBuilder.php

@@ -39,24 +39,24 @@
 use Magento\Framework\Exception\LocalizedException;
 use Magento\Sales\Api\Data\EntityInterface;
 use Magento\Store\Model\Store;
-use Magento\Catalog\Model\ResourceModel\Category\Collection as CategoryCollection;
+//use Magento\Catalog\Model\ResourceModel\Category\Collection as CategoryCollection;
+use Nosto\Tagging\Model\ResourceModel\Magento\Category\Collection  as CategoryCollection;
 use Magento\Framework\DB\Select;
 
 /**
  * A builder class for building product collection with the most common filters
  */
 class CollectionBuilder
 {
+
     /** @var CategoryCollection */
     private CategoryCollection $categoryCollection;
 
     /**
-     * Collection constructor.
-     * @param CategoryCollection $categoryCollection,
+     * @param CategoryCollection $categoryCollection
      */
-    public function __construct(
-        CategoryCollection $categoryCollection
-    ) {
+    public function __construct(CategoryCollection $categoryCollection)
+    {
         $this->categoryCollection = $categoryCollection;
     }
 

Model/Service/Sync/Upsert/Category/BulkConsumer.php → Model/Service/Sync/Upsert/Category/AsyncBulkConsumer.php

@@ -34,7 +34,7 @@
  *
  */
 
-namespace Nosto\Tagging\Model\Service\Sync\Upsert;
+namespace Nosto\Tagging\Model\Service\Sync\Upsert\Category;
 
 use Magento\Framework\EntityManager\EntityManager;
 use Magento\Framework\Json\Helper\Data as JsonHelper;
@@ -45,13 +45,14 @@
 use Nosto\Tagging\Logger\Logger;
 use Nosto\Tagging\Model\ResourceModel\Magento\Product\CollectionFactory;
 use Nosto\Tagging\Model\Service\Sync\AbstractBulkConsumer;
+use Nosto\Tagging\Model\Service\Sync\Upsert\SyncService;
 
 /**
  * Asynchronous Bulk Consumer
  *
  * Class AsyncBulkConsumer
  */
-class BulkConsumer extends AbstractBulkConsumer
+class AsyncBulkConsumer extends AbstractBulkConsumer
 {
     /** @var SyncService */
     private SyncService $syncService;
@@ -99,6 +100,9 @@ public function __construct(
      */
     public function doOperation(array $categoryIds, string $storeId)
     {
+        echo '<pre>';
+        print_r(122);
+        die;
         $store = $this->nostoScopeHelper->getStore($storeId);
         $categoryCollection = $this->collectionFactory->create()
             ->addIdsToFilter($categoryIds)

Model/Service/Sync/Upsert/Category/BulkPublisher.php

@@ -49,6 +49,9 @@ class BulkPublisher extends AbstractBulkPublisher
      */
     public function getTopicName(): string
     {
+        echo '<pre>';
+        print_r(122);
+        die;
         return self::NOSTO_SYNC_MESSAGE_QUEUE;
     }
 

etc/communication.xml

@@ -41,4 +41,7 @@
     <topic name="nosto_product_sync.delete" request="Magento\AsynchronousOperations\Api\Data\OperationInterface">
         <handler name="nosto_product_sync.delete" type="Nosto\Tagging\Model\Service\Sync\Delete\AsyncBulkConsumer" method="processOperation"/>
     </topic>
+    <topic name="nosto_category_sync.update" request="Magento\AsynchronousOperations\Api\Data\OperationInterface">
+        <handler name="nosto_category_sync.update" type="Nosto\Tagging\Model\Service\Sync\Upsert\Category\AsyncBulkConsumer" method="processOperation"/>
+    </topic>
 </config>

etc/di.xml

@@ -224,6 +224,13 @@
             </argument>
         </arguments>
     </type>
+    <type name="Nosto\Tagging\Model\Service\Sync\Upsert\Category\BulkPublisher">
+        <arguments>
+            <argument name="AsyncBulkConsumer" xsi:type="object" shared="false">
+                Nosto\Tagging\Model\Service\Sync\Upsert\Category\AsyncBulkConsumer
+            </argument>
+        </arguments>
+    </type>
     <type name="Nosto\Tagging\Model\Service\Sync\Upsert\SyncService">
         <arguments>
             <argument name="productService" xsi:type="object" shared="false">
@@ -251,8 +258,8 @@
     </type>
     <type name="Nosto\Tagging\Model\Service\Update\CategoryUpdateService">
         <arguments>
-            <argument name="upsertBulkPublisher" xsi:type="object" shared="false">
-                Nosto\Tagging\Model\Service\Sync\Upsert\AsyncBulkPublisher
+            <argument name="upsertCategoryBulkPublisher" xsi:type="object" shared="false">
+                Nosto\Tagging\Model\Service\Sync\Upsert\Category\BulkPublisher
             </argument>
             <argument name="deleteBulkPublisher" xsi:type="object" shared="false">
                 Nosto\Tagging\Model\Service\Sync\Delete\AsyncBulkPublisher

etc/queue.xml

@@ -47,4 +47,10 @@
                consumerInstance="Magento\Framework\MessageQueue\Consumer"
                handler="Nosto\Tagging\Model\Service\Sync\Delete\AsyncBulkConsumer::process"/>
     </broker>
+    <broker topic="nosto_category_sync.update" exchange="magento-amqp" type="amqp">
+        <queue name="nosto_category_sync.update"
+               consumer="nosto_category_sync.update"
+               consumerInstance="Magento\Framework\MessageQueue\Consumer"
+               handler="Nosto\Tagging\Model\Service\Sync\Upsert\Category\AsyncBulkConsumer::process"/>
+    </broker>
 </config>

etc/queue_consumer.xml

@@ -47,4 +47,10 @@
               maxMessages="100"
               consumerInstance="Magento\Framework\MessageQueue\Consumer"
               handler="Nosto\Tagging\Model\Service\Sync\Delete\AsyncBulkConsumer::processOperation"/>
+    <consumer name="nosto_category_sync.update"
+              queue="nosto_category_sync.update"
+              connection="amqp"
+              maxMessages="200"
+              consumerInstance="Magento\Framework\MessageQueue\Consumer"
+              handler="Nosto\Tagging\Model\Service\Sync\Upsert\Category\AsyncBulkConsumer::processOperation"/>
 </config>

etc/queue_publisher.xml

@@ -41,4 +41,7 @@
     <publisher topic="nosto_product_sync.delete">
         <connection name="amqp" exchange="magento-amqp"/>
     </publisher>
+    <publisher topic="nosto_category_sync.update">
+        <connection name="amqp" exchange="magento-amqp"/>
+    </publisher>
 </config>