<?php
/**
 * Copyright © Magento, Inc. All rights reserved.
 * See COPYING.txt for license details.
 */
declare(strict_types=1);

namespace Magento\MediaContent\Plugin;

use Magento\Framework\App\ResourceConnection;
use Magento\Framework\DB\Adapter\AdapterInterface;
use Magento\Framework\Exception\CouldNotDeleteException;
use Magento\MediaContentApi\Api\DeleteContentAssetLinksByAssetIdsInterface;
use Magento\MediaGalleryApi\Api\DeleteDirectoriesByPathsInterface;
use Psr\Log\LoggerInterface;

/**
 * Remove media content record after media gallery asset removal.
 */
class MediaGalleryAssetDeleteByDirectoryPath
{
    private const TABLE_MEDIA_GALLERY_ASSET = 'media_gallery_asset';

    /**
     * @var ResourceConnection
     */
    private $resourceConnection;

    /**
     * @var LoggerInterface
     */
    private $logger;

    /**
     * @var DeleteContentAssetLinksByAssetIdsInterface
     */
    private $deleteContentAssetLinksByAssetIds;

    /**
     * @param DeleteContentAssetLinksByAssetIdsInterface $deleteContentAssetLinksByAssetIds
     * @param ResourceConnection $resourceConnection
     * @param LoggerInterface $logger
     */
    public function __construct(
        DeleteContentAssetLinksByAssetIdsInterface $deleteContentAssetLinksByAssetIds,
        ResourceConnection $resourceConnection,
        LoggerInterface $logger
    ) {
        $this->deleteContentAssetLinksByAssetIds = $deleteContentAssetLinksByAssetIds;
        $this->resourceConnection = $resourceConnection;
        $this->logger = $logger;
    }

    /**
     * Around plugin on execute method
     *
     * @param DeleteDirectoriesByPathsInterface $subject
     * @param \Closure $proceed
     * @param array $paths
     * @throws CouldNotDeleteException
     * @return void
     *
     * @SuppressWarnings(PHPMD.UnusedFormalParameter)
     */
    public function aroundExecute(
        DeleteDirectoriesByPathsInterface $subject,
        \Closure $proceed,
        array $paths
    ) : void {
        $assetIdsArrays =[];
        foreach ($paths as $path) {
            $assetIdsArrays[] = $this->getAssetIdsByDirectoryPath($path);
        }

        $assetIds = array_unique(array_merge([], ...$assetIdsArrays));

        $proceed($paths);

        $this->deleteContentAssetLinksByAssetIds->execute($assetIds);
    }

    /**
     * Get ids of media assets by directory path
     *
     * @param string $path
     * @return int[]
     */
    private function getAssetIdsByDirectoryPath(string $path): array
    {
        /** @var AdapterInterface $connection */
        $connection = $this->resourceConnection->getConnection();
        $galleryAssetTableName = $this->resourceConnection->getTableName(self::TABLE_MEDIA_GALLERY_ASSET);

        $select = $connection->select();
        $select->from($galleryAssetTableName, ['id']);
        $select->where('path LIKE ?', $path . '%');
        return $connection->fetchCol($select);
    }
}