Implement indexer, support update by schedule mode

Model/Indexer/Product.php

@@ -0,0 +1,69 @@
+<?php
+
+namespace Clerk\Clerk\Model\Indexer;
+
+class Product implements \Magento\Framework\Indexer\ActionInterface, \Magento\Framework\Mview\ActionInterface
+{
+    /**
+     * @var Product\Action\Rows
+     */
+    protected $productIndexerRows;
+
+    /**
+     * @param Product\Action\Rows $productIndexerRows
+     */
+    public function __construct(
+        Product\Action\Rows $productIndexerRows
+    ) {
+        $this->productIndexerRows = $productIndexerRows;
+    }
+
+    /**
+     * Execute materialization on ids entities
+     *
+     * @param int[] $ids
+     * @throws \Magento\Framework\Exception\LocalizedException
+     *
+     * @return void
+     */
+    public function execute($ids)
+    {
+        $this->productIndexerRows->execute($ids);
+    }
+
+    /**
+     * Execute full indexation
+     *
+     * @return void
+     */
+    public function executeFull()
+    {
+        // not implemented
+    }
+
+    /**
+     * Execute partial indexation by ID list
+     *
+     * @param int[] $ids
+     * @throws \Magento\Framework\Exception\LocalizedException
+     *
+     * @return void
+     */
+    public function executeList(array $ids)
+    {
+        $this->productIndexerRows->execute($ids);
+    }
+
+    /**
+     * Execute partial indexation by ID
+     *
+     * @param int $id
+     * @throws \Magento\Framework\Exception\LocalizedException
+     *
+     * @return void
+     */
+    public function executeRow($id)
+    {
+        $this->productIndexerRows->execute([$id]);
+    }
+}

Model/Indexer/Product/Action/Rows.php

@@ -0,0 +1,206 @@
+<?php
+
+namespace Clerk\Clerk\Model\Indexer\Product\Action;
+
+use Clerk\Clerk\Model\Api;
+use Clerk\Clerk\Model\Config;
+use Magento\Catalog\Model\Product\Type;
+use Magento\Catalog\Model\Product\Type\AbstractType;
+use Magento\Catalog\Model\ProductRepository;
+use Magento\Framework\App\Config\ScopeConfigInterface;
+use Magento\Framework\Event\ManagerInterface;
+use Magento\Framework\Exception\NoSuchEntityException;
+use Magento\Framework\ObjectManagerInterface;
+
+class Rows
+{
+    /**
+     * @var ObjectManagerInterface
+     */
+    protected $objectManager;
+
+    /**
+     * @var ScopeConfigInterface
+     */
+    protected $scopeConfig;
+
+    /**
+     * @var ManagerInterface
+     */
+    protected $eventManager;
+
+    /**
+     * @var ProductRepository
+     */
+    protected $productRepository;
+
+    /**
+     * @var Type
+     */
+    protected $productType;
+
+    /**
+     * @var Api
+     */
+    protected $api;
+
+    /**
+     * @var AbstractType[]
+     */
+    protected $compositeTypes;
+
+    /**
+     * @param ObjectManagerInterface $objectManager
+     * @param ScopeConfigInterface $scopeConfig
+     * @param ManagerInterface $eventManager
+     * @param ProductRepository $productRepository
+     * @param Api $api
+     */
+    public function __construct(
+        ObjectManagerInterface $objectManager,
+        ScopeConfigInterface $scopeConfig,
+        ManagerInterface $eventManager,
+        ProductRepository $productRepository,
+        Type $productType,
+        Api $api
+    ) {
+        $this->objectManager = $objectManager;
+        $this->scopeConfig = $scopeConfig;
+        $this->eventManager = $eventManager;
+        $this->productRepository = $productRepository;
+        $this->productType = $productType;
+        $this->api = $api;
+    }
+
+    /**
+     * Execute action for given ids
+     *
+     * @param array|int $ids
+     * @throws \Magento\Framework\Exception\LocalizedException
+     * @return void
+     */
+    public function execute($ids = null)
+    {
+        if (!$this->scopeConfig->getValue(Config::XML_PATH_PRODUCT_SYNCHRONIZATION_REAL_TIME_ENABLED)) {
+            return;
+        }
+
+        if (!isset($ids) || empty($ids)) {
+            throw new \Magento\Framework\Exception\LocalizedException(
+                __('We can\'t rebuild the index for an undefined product.')
+            );
+        }
+
+        if (!is_array($ids)) {
+            $ids = [$ids];
+        }
+
+        foreach ($ids as $id) {
+            $this->reindexRow($id);
+            $this->updateParentProducts($id);
+        }
+    }
+
+    /**
+     * Refresh entity index
+     *
+     * @param int $productId
+     * @return void
+     */
+    protected function reindexRow($productId)
+    {
+        try {
+            $product = $this->productRepository->getById($productId);
+        } catch (NoSuchEntityException $e) {
+            $this->api->removeProduct($productId);
+            return;
+        }
+
+        //Cancel if product visibility is not as defined
+        if ($product->getVisibility() != $this->scopeConfig->getValue(Config::XML_PATH_PRODUCT_SYNCHRONIZATION_VISIBILITY)) {
+            return;
+        }
+
+        //Cancel if product is not saleable
+        if ($this->scopeConfig->getValue(Config::XML_PATH_PRODUCT_SYNCHRONIZATION_SALABLE_ONLY)) {
+            if (!$product->isSalable()) {
+                return;
+            }
+        }
+
+        $store = $this->objectManager->get('Magento\Store\Model\StoreManagerInterface')->getStore();
+        $imageUrl = $store->getBaseUrl(\Magento\Framework\UrlInterface::URL_TYPE_MEDIA) . 'catalog/product' . $product->getImage();
+
+        $productItem = [
+            'id' => $product->getId(),
+            'name' => $product->getName(),
+            'description' => $product->getDescription(),
+            'price' => $product->getFinalPrice(),
+            'list_price' => $product->getPrice(),
+            'image' => $imageUrl,
+            'url' => $product->getUrlModel()->getUrl($product),
+            'categories' => $product->getCategoryIds(),
+            'sku' => $product->getSku(),
+            'on_sale' => ($product->getFinalPrice() < $product->getPrice()),
+        ];
+
+        /**
+         * @todo Refactor to use fieldhandlers or similar
+         */
+        $configFields = $this->scopeConfig->getValue(
+            Config::XML_PATH_PRODUCT_SYNCHRONIZATION_ADDITIONAL_FIELDS
+        );
+
+        $fields = explode(',', $configFields);
+
+        foreach ($fields as $field) {
+            if (! isset($productItem[$field])) {
+                $productItem[$field] = $product->getData($field);
+            }
+        }
+
+        $productObject = new \Magento\Framework\DataObject();
+        $productObject->setData($productItem);
+
+        $this->eventManager->dispatch('clerk_product_sync_before', ['product' => $productObject]);
+
+        $this->api->addProduct($productObject->toArray());
+    }
+
+    /**
+     * Reindex parent configurable/bundle/grouped products
+     *
+     * @param int $productId
+     * @return void
+     * @see \Magento\Catalog\Model\Indexer\Product\Flat\AbstractAction::_getProductTypeInstances
+     */
+    public function updateParentProducts($productId)
+    {
+        $parentIds = [];
+
+        foreach ($this->getCompositeTypes() as $typeInstance) {
+            $parentIds = array_merge($parentIds, $typeInstance->getParentIdsByChild($productId));
+        }
+
+        foreach ($parentIds as $parentId) {
+            $this->reindexRow($parentId);
+        }
+    }
+
+    /**
+     * @return AbstractType[]
+     * @throws \Magento\Framework\Exception\LocalizedException
+     */
+    protected function getCompositeTypes()
+    {
+        if (null === $this->compositeTypes) {
+            $productEmulator = new \Magento\Framework\DataObject();
+            foreach ($this->productType->getCompositeTypes() as $typeId) {
+                $productEmulator->setTypeId($typeId);
+                $this->compositeTypes[$typeId] = $this->productType->factory($productEmulator);
+            }
+        }
+
+        return $this->compositeTypes;
+    }
+}