<?php

declare(strict_types=1);

namespace Akeneo\Pim\Structure\Component\Remover;

use Akeneo\Pim\Enrichment\Component\Product\ProductAndProductModel\Query\CountEntityWithFamilyVariantInterface;
use Akeneo\Pim\Structure\Component\Model\FamilyVariantInterface;
use Akeneo\Tool\Component\StorageUtils\Event\RemoveEvent;
use Akeneo\Tool\Component\StorageUtils\Exception\InvalidObjectException;
use Akeneo\Tool\Component\StorageUtils\Remover\RemoverInterface;
use Akeneo\Tool\Component\StorageUtils\StorageEvents;
use Doctrine\Common\Util\ClassUtils;
use Doctrine\Persistence\ObjectManager;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

/**
 * Removes a family variant if there is no entity with family variants already associated with it.
 *
 * @author    Samir Boulil <samir.boulil@akeneo.com>
 * @copyright 2018 Akeneo SAS (http://www.akeneo.com)
 * @license   http://opensource.org/licenses/osl-3.0.php  Open Software License (OSL 3.0)
 */
class FamilyVariantRemover implements RemoverInterface
{
    /** @var ObjectManager */
    private $objectManager;

    /** @var EventDispatcherInterface */
    private $eventDispatcher;

    /** @var CountEntityWithFamilyVariantInterface */
    private $counter;

    /**
     * @param ObjectManager                         $objectManager
     * @param EventDispatcherInterface              $eventDispatcher
     * @param CountEntityWithFamilyVariantInterface $counter
     */
    public function __construct(
        ObjectManager $objectManager,
        EventDispatcherInterface $eventDispatcher,
        CountEntityWithFamilyVariantInterface $counter
    ) {
        $this->objectManager = $objectManager;
        $this->eventDispatcher = $eventDispatcher;
        $this->counter = $counter;
    }

    /**
     * {@inheritdoc}
     */
    public function remove($familyVariant, array $options = []): RemoverInterface
    {
        if (!$familyVariant instanceof FamilyVariantInterface) {
            throw InvalidObjectException::objectExpected(
                ClassUtils::getClass($familyVariant),
                FamilyVariantInterface::class
            );
        }

        if ($this->hasEntityWithFamilyVariant($familyVariant)) {
            throw new \LogicException(
                sprintf(
                    'Family variant "%s", could not be removed as it is used by some entities with family variants.',
                    $familyVariant->getCode()
                )
            );
        }

        $this->removeFamilyVariant($familyVariant, $options);

        return $this;
    }

    private function hasEntityWithFamilyVariant(FamilyVariantInterface $familyVariant): bool
    {
        return 0 !== $this->counter->belongingToFamilyVariant($familyVariant);
    }

    /**
     * @param FamilyVariantInterface $familyVariant
     * @param array                  $options
     */
    private function removeFamilyVariant(FamilyVariantInterface $familyVariant, array $options): void
    {
        $objectId = $familyVariant->getId();

        $options['unitary'] = true;

        $this->eventDispatcher->dispatch(
            new RemoveEvent($familyVariant, $objectId, $options),
            StorageEvents::PRE_REMOVE
        );

        $this->objectManager->remove($familyVariant);
        $this->objectManager->flush();

        $this->eventDispatcher->dispatch(
            new RemoveEvent($familyVariant, $objectId, $options),
            StorageEvents::POST_REMOVE
        );
    }
}