ReindexAfterSourceItemsDeletePlugin.php

Go to the documentation of this file.

<?php
declare(strict_types=1);

namespace Magento\InventoryIndexer\Plugin\InventoryApi;

use Magento\InventoryApi\Api\Data\SourceItemInterface;
use Magento\InventoryApi\Api\SourceItemsDeleteInterface;
use Magento\InventoryIndexer\Indexer\Source\SourceIndexer;

class ReindexAfterSourceItemsDeletePlugin
{
    private $sourceIndexer;

    public function __construct(SourceIndexer $sourceIndexer)
    {
        $this->sourceIndexer = $sourceIndexer;
    }

    public function aroundExecute(
        SourceItemsDeleteInterface $subject,
        callable $proceed,
        array $sourceItems
    ) {
        $sourceCodes = [];
        foreach ($sourceItems as $sourceItem) {
            $sourceCodes[] = $sourceItem->getSourceCode();
        }

        $proceed($sourceItems);

        if (count($sourceCodes)) {
            $this->sourceIndexer->executeList($sourceCodes);
        }
    }
}