Spryker\Zed\MerchantProduct\Communication\Plugin\Publisher\MerchantProductPublisherPlugin

Complexity

Total Complexity

2

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscribedEvents()	0	5	1
A	handleBulk()	0	6	1

<?php

/**
 * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
 * Use of this software requires acceptance of the Spryker Marketplace License Agreement. See LICENSE file.
 */

namespace Spryker\Zed\MerchantProduct\Communication\Plugin\Publisher;

use Generated\Shared\Transfer\MerchantProductCriteriaTransfer;
use Spryker\Shared\MerchantProduct\MerchantProductConfig;
use Spryker\Zed\Kernel\Communication\AbstractPlugin;
use Spryker\Zed\PublisherExtension\Dependency\Plugin\PublisherPluginInterface;

/**
 * @method \Spryker\Zed\MerchantProduct\Business\MerchantProductFacadeInterface getFacade()
 * @method \Spryker\Zed\MerchantProduct\Communication\MerchantProductCommunicationFactory getFactory()
 * @method \Spryker\Zed\MerchantProduct\Business\MerchantProductBusinessFactory getBusinessFactory()
 * @method \Spryker\Zed\MerchantProduct\MerchantProductConfig getConfig()
 */
class MerchantProductPublisherPlugin extends AbstractPlugin implements PublisherPluginInterface
{
    /**
     * {@inheritDoc}
     *
     * - Extracts Merchant IDs from event entity transfers.
     * - Retrieves product abstract IDs related to these merchants.
     * - Triggers product abstract events to rebuild merchant product abstracts after merchant changes.
     *
     * @api
     *
     * @param array<\Generated\Shared\Transfer\EventEntityTransfer> $eventEntityTransfers
     * @param string $eventName
     *
     * @return void
     */
    public function handleBulk(array $eventEntityTransfers, $eventName): void
    {
        $this->getBusinessFactory()->createProductEventTrigger()->trigger(
            (new MerchantProductCriteriaTransfer())
                ->setMerchantIds(
                    $this->getFactory()->getEventBehaviorFacade()->getEventTransferIds($eventEntityTransfers),
                ),
        );
    }

    /**
     * {@inheritDoc}
     *
     * @api
     *
     * @return array<string>
     */
    public function getSubscribedEvents(): array
    {
        return [
            MerchantProductConfig::MERCHANT_PUBLISH,
            MerchantProductConfig::ENTITY_SPY_MERCHANT_UPDATE,
        ];
    }
}