Merge pull request #448 from adobe-commerce-tier-4/T4-02-16-2024

T4-02-16-2024 PR Delivery

Author: okolesnyk

InventoryCache/Model/FlushCacheOnProductSalabilityChange.php

@@ -0,0 +1,54 @@
+<?php
+/************************************************************************
+ *
+ * Copyright 2024 Adobe
+ * All Rights Reserved.
+ *
+ * NOTICE: All information contained herein is, and remains
+ * the property of Adobe and its suppliers, if any. The intellectual
+ * and technical concepts contained herein are proprietary to Adobe
+ * and its suppliers and are protected by all applicable intellectual
+ * property laws, including trade secret and copyright laws.
+ * Dissemination of this information or reproduction of this material
+ * is strictly forbidden unless prior written permission is obtained
+ * from Adobe.
+ * ************************************************************************
+ */
+declare(strict_types=1);
+
+namespace Magento\InventoryCache\Model;
+
+use Magento\InventoryCatalogApi\Model\GetProductIdsBySkusInterface;
+use Magento\InventoryIndexer\Model\ProductSalabilityChangeProcessorInterface;
+use Magento\InventoryIndexer\Model\ResourceModel\GetCategoryIdsByProductIds;
+
+class FlushCacheOnProductSalabilityChange implements ProductSalabilityChangeProcessorInterface
+{
+    /**
+     * @param GetProductIdsBySkusInterface $getProductIdsBySkus
+     * @param FlushCacheByProductIds $flushCacheByIds
+     * @param GetCategoryIdsByProductIds $getCategoryIdsByProductIds
+     * @param FlushCacheByCategoryIds $flushCategoryByCategoryIds
+     */
+    public function __construct(
+        private readonly GetProductIdsBySkusInterface $getProductIdsBySkus,
+        private readonly FlushCacheByProductIds $flushCacheByIds,
+        private readonly GetCategoryIdsByProductIds $getCategoryIdsByProductIds,
+        private readonly FlushCacheByCategoryIds $flushCategoryByCategoryIds
+    ) {
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function execute(array $skus): void
+    {
+        $ids = array_values($this->getProductIdsBySkus->execute($skus));
+        if (empty($ids)) {
+            return;
+        }
+        $categoryIds = $this->getCategoryIdsByProductIds->execute($ids);
+        $this->flushCacheByIds->execute($ids);
+        $this->flushCategoryByCategoryIds->execute($categoryIds);
+    }
+}

InventoryCache/etc/di.xml

@@ -34,4 +34,11 @@
             </argument>
         </arguments>
     </type>
+    <type name="Magento\InventoryIndexer\Model\CompositeProductSalabilityChangeProcessor">
+        <arguments>
+            <argument name="processors" xsi:type="array">
+                <item name="flush_cache" sortOrder="30" xsi:type="object">Magento\InventoryCache\Model\FlushCacheOnProductSalabilityChange</item>
+            </argument>
+        </arguments>
+    </type>
 </config>

InventoryCatalog/Model/Cache/ProductIdsBySkusStorage.php

@@ -49,6 +49,16 @@ public function set(string $sku, int $id): void
         $this->storage[$this->normalizeSku($sku)] = $id;
     }
 
+    /**
+     * Invalidate cache for provided sku
+     *
+     * @param string $sku
+     */
+    public function delete(string $sku): void
+    {
+        unset($this->storage[$this->normalizeSku($sku)]);
+    }
+
     /**
      * Clean storage
      *

InventoryCatalog/Model/Cache/ProductSkusByIdsStorage.php

@@ -49,6 +49,16 @@ public function set(int $id, string $sku): void
         $this->storage[$id] = $sku;
     }
 
+    /**
+     * Invalidate cache for provided id
+     *
+     * @param int $id
+     */
+    public function delete(int $id): void
+    {
+        unset($this->storage[$id]);
+    }
+
     /**
      * Clean storage
      *

InventoryCatalog/Model/Cache/ProductTypesBySkusStorage.php

@@ -49,6 +49,16 @@ public function set(string $sku, string $type): void
         $this->storage[$this->normalizeSku($sku)] = $type;
     }
 
+    /**
+     * Invalidate cache for provided sku
+     *
+     * @param string $sku
+     */
+    public function delete(string $sku): void
+    {
+        unset($this->storage[$this->normalizeSku($sku)]);
+    }
+
     /**
      * Clean storage
      *