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

namespace Magento\CatalogRule\Test\Unit\Model\Indexer;

use Magento\Catalog\Model\ResourceModel\Indexer\ActiveTableSwitcher;
use Magento\CatalogRule\Model\Indexer\IndexerTableSwapperInterface;
use Magento\CatalogRule\Model\Indexer\ReindexRuleProduct;
use Magento\CatalogRule\Model\Rule;
use Magento\Framework\App\ResourceConnection;
use Magento\Framework\DB\Adapter\AdapterInterface;
use Magento\Framework\Stdlib\DateTime\TimezoneInterface;
use Magento\Store\Model\ScopeInterface;
use PHPUnit\Framework\MockObject\MockObject;
use PHPUnit\Framework\TestCase;

class ReindexRuleProductTest extends TestCase
{
    private const ADMIN_WEBSITE_ID = 0;

    /**
     * @var ReindexRuleProduct
     */
    private $model;

    /**
     * @var ResourceConnection|MockObject
     */
    private $resourceMock;

    /**
     * @var IndexerTableSwapperInterface|MockObject
     */
    private $tableSwapperMock;

    /**
     * @var TimezoneInterface|MockObject
     */
    private $localeDateMock;

    /**
     * @var AdapterInterface|MockObject
     */
    private $connectionMock;

    /**
     * @var Rule|MockObject
     */
    private $ruleMock;

    /**
     * @var string
     */
    private $adminTimeZone;

    /**
     * @var string
     */
    private $websiteTz;

    /**
     * @inheritDoc
     */
    protected function setUp(): void
    {
        $this->resourceMock = $this->createMock(ResourceConnection::class);
        $activeTableSwitcherMock = $this->createMock(ActiveTableSwitcher::class);
        $this->tableSwapperMock = $this->getMockForAbstractClass(IndexerTableSwapperInterface::class);
        $this->localeDateMock = $this->getMockForAbstractClass(TimezoneInterface::class);
        $this->connectionMock = $this->getMockForAbstractClass(AdapterInterface::class);
        $this->ruleMock = $this->createMock(Rule::class);

        $this->model = new ReindexRuleProduct(
            $this->resourceMock,
            $activeTableSwitcherMock,
            $this->tableSwapperMock,
            $this->localeDateMock,
            true
        );

        $this->adminTimeZone = 'America/Chicago';
        $this->websiteTz = 'America/Los_Angeles';
    }

    /**
     * @return void
     */
    public function testExecuteIfRuleInactive(): void
    {
        $ruleMock = $this->createMock(Rule::class);
        $ruleMock->expects(self::once())
            ->method('getIsActive')
            ->willReturn(false);
        self::assertFalse($this->model->execute($ruleMock, 100, true));
    }

    /**
     * @return void
     */
    public function testExecuteIfRuleWithoutWebsiteIds(): void
    {
        $ruleMock = $this->createMock(Rule::class);
        $ruleMock->expects(self::once())
            ->method('getIsActive')
            ->willReturn(true);
        $ruleMock->expects(self::once())
            ->method('getWebsiteIds')
            ->willReturn(null);
        self::assertFalse($this->model->execute($ruleMock, 100, true));
    }

    /**
     * @return void
     */
    public function testExecute(): void
    {
        $websiteId = 3;
        $productIds = [
            4 => [$websiteId => 1],
            5 => [$websiteId => 1],
            6 => [$websiteId => 1]
        ];

        $this->prepareResourceMock();
        $this->prepareRuleMock([3], $productIds, [10]);

        $this->localeDateMock->method('getConfigTimezone')
            ->willReturnMap([
                [ScopeInterface::SCOPE_WEBSITE, self::ADMIN_WEBSITE_ID, $this->adminTimeZone],
                [ScopeInterface::SCOPE_WEBSITE, $websiteId, $this->websiteTz]
            ]);

        $batchRows = [
            [
                'rule_id' => 100,
                'from_time' => 1498028400,
                'to_time' => 1498892399,
                'website_id' => $websiteId,
                'customer_group_id' => 10,
                'product_id' => 4,
                'action_operator' => 'simple_action',
                'action_amount' => 43,
                'action_stop' => true,
                'sort_order' => 1
            ],
            [
                'rule_id' => 100,
                'from_time' => 1498028400,
                'to_time' => 1498892399,
                'website_id' => $websiteId,
                'customer_group_id' => 10,
                'product_id' => 5,
                'action_operator' => 'simple_action',
                'action_amount' => 43,
                'action_stop' => true,
                'sort_order' => 1
            ]
        ];

        $rowsNotInBatch = [
            [
                'rule_id' => 100,
                'from_time' => 1498028400,
                'to_time' => 1498892399,
                'website_id' => $websiteId,
                'customer_group_id' => 10,
                'product_id' => 6,
                'action_operator' => 'simple_action',
                'action_amount' => 43,
                'action_stop' => true,
                'sort_order' => 1
            ]
        ];

        $this->connectionMock
            ->method('insertMultiple')
            ->willReturnCallback(
                function ($table, $rows) use ($batchRows, $rowsNotInBatch) {
                    if ($table == 'catalogrule_product_replica' && $rows == $batchRows) {
                        return 2;
                    } elseif ($table == 'catalogrule_product_replica' && $rows == $rowsNotInBatch) {
                        return 1;
                    }
                }
            );
        
        self::assertTrue($this->model->execute($this->ruleMock, 2, true));
    }

    public function testExecuteWithCustomBatchSize()
    {
        $websiteId = 3;
        $productIds = [
            4 => [$websiteId => 1],
            5 => [$websiteId => 1],
            6 => [$websiteId => 1]
        ];

        $this->prepareResourceMock();
        $this->prepareRuleMock([3], $productIds, [10]);

        $this->localeDateMock->method('getConfigTimezone')
            ->willReturnMap([
                [ScopeInterface::SCOPE_WEBSITE, self::ADMIN_WEBSITE_ID, $this->adminTimeZone],
                [ScopeInterface::SCOPE_WEBSITE, $websiteId, $this->websiteTz]
            ]);

        $this->connectionMock->expects($this->exactly(2))->method('insertMultiple');
        self::assertTrue($this->model->execute($this->ruleMock, '2', true));
    }

    /**
     * @param array $websitesIds
     * @param array $productIds
     * @param array $batchRows
     * @return void
     * @dataProvider executeDataProvider
     */
    public function testExecuteWithExcludedWebsites(array $websitesIds, array $productIds, array $batchRows): void
    {
        $this->prepareResourceMock();
        $this->prepareRuleMock($websitesIds, $productIds, [10, 20]);

        $extensionAttributes = $this->getMockBuilder(\Magento\Framework\Api\ExtensionAttributesInterface::class)
            ->addMethods(['getExtensionAttributes', 'getExcludeWebsiteIds'])
            ->disableOriginalConstructor()
            ->getMockForAbstractClass();
        $this->ruleMock->expects(self::once())->method('getExtensionAttributes')
            ->willReturn($extensionAttributes);
        $extensionAttributes->expects(self::exactly(2))->method('getExcludeWebsiteIds')
            ->willReturn([10 => [1, 2]]);

        $this->localeDateMock->method('getConfigTimezone')
            ->willReturnMap([
                [ScopeInterface::SCOPE_WEBSITE, self::ADMIN_WEBSITE_ID, $this->adminTimeZone],
                [ScopeInterface::SCOPE_WEBSITE, 1, $this->websiteTz],
                [ScopeInterface::SCOPE_WEBSITE, 2, $this->websiteTz],
                [ScopeInterface::SCOPE_WEBSITE, 3, $this->websiteTz]
            ]);

        $this->connectionMock
            ->method('insertMultiple')
            ->with('catalogrule_product_replica', $batchRows);

        self::assertTrue($this->model->execute($this->ruleMock, 100, true));
    }

    /**
     * @return array
     * @SuppressWarnings(PHPMD.ExcessiveMethodLength)
     */
    public static function executeDataProvider(): array
    {
        return [
            [
                [1, 2, 3],
                [
                    1 => [1 => 1],
                    2 => [2 => 1],
                    3 => [3 => 1]
                ],
                [
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 1,
                        'customer_group_id' => 20,
                        'product_id' => 1,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ],
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 2,
                        'customer_group_id' => 20,
                        'product_id' => 2,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ],
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 3,
                        'customer_group_id' => 10,
                        'product_id' => 3,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ],
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 3,
                        'customer_group_id' => 20,
                        'product_id' => 3,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ]
                ]
            ],
            [
                [1, 2, 3],
                [
                    1 => [1 => true],
                    2 => [2 => 'true'],
                    3 => [3 => 0]
                ],
                [
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 1,
                        'customer_group_id' => 20,
                        'product_id' => 1,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ],
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 2,
                        'customer_group_id' => 20,
                        'product_id' => 2,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ]
                ]
            ],
            [
                [1, 2, 3],
                [
                    1 => [1 => true],
                    2 => [2 => true],
                    3 => [3 => null]
                ],
                [
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 1,
                        'customer_group_id' => 20,
                        'product_id' => 1,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ],
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 2,
                        'customer_group_id' => 20,
                        'product_id' => 2,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ]
                ]
            ],
            [
                [1, 2, 3],
                [
                    1 => [1 => true],
                    2 => [2 => true],
                    3 => []
                ],
                [
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 1,
                        'customer_group_id' => 20,
                        'product_id' => 1,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ],
                    [
                        'rule_id' => 100,
                        'from_time' => 1498028400,
                        'to_time' => 1498892399,
                        'website_id' => 2,
                        'customer_group_id' => 20,
                        'product_id' => 2,
                        'action_operator' => 'simple_action',
                        'action_amount' => 43,
                        'action_stop' => true,
                        'sort_order' => 1
                    ]
                ]
                ],
                [
                    [1, 2, 3],
                    [
                        1 => [1 => true],
                        2 => [2 => true],
                        3 => [3 => false]
                    ],
                    [
                        [
                            'rule_id' => 100,
                            'from_time' => 1498028400,
                            'to_time' => 1498892399,
                            'website_id' => 1,
                            'customer_group_id' => 20,
                            'product_id' => 1,
                            'action_operator' => 'simple_action',
                            'action_amount' => 43,
                            'action_stop' => true,
                            'sort_order' => 1
                        ],
                        [
                            'rule_id' => 100,
                            'from_time' => 1498028400,
                            'to_time' => 1498892399,
                            'website_id' => 2,
                            'customer_group_id' => 20,
                            'product_id' => 2,
                            'action_operator' => 'simple_action',
                            'action_amount' => 43,
                            'action_stop' => true,
                            'sort_order' => 1
                        ]
                    ]
                ]
        ];
    }

    /**
     * @return void
     */
    private function prepareResourceMock(): void
    {
        $this->tableSwapperMock->expects(self::once())
            ->method('getWorkingTableName')
            ->with('catalogrule_product')
            ->willReturn('catalogrule_product_replica');
        $this->resourceMock
            ->method('getConnection')
            ->willReturn($this->connectionMock);
        $this->resourceMock
            ->method('getTableName')
            ->willReturnCallback(fn($param) => match ([$param]) {
                ['catalogrule_product'] => 'catalogrule_product',
                ['catalogrule_product_replica'] => 'catalogrule_product_replica'
            });
    }

    /**
     * @param array $websiteId
     * @param array $productIds
     * @param array $customerGroupIds
     *
     * @return void
     */
    private function prepareRuleMock(array $websiteId, array $productIds, array $customerGroupIds): void
    {
        $this->ruleMock->expects(self::once())->method('getIsActive')->willReturn(true);
        $this->ruleMock->expects(self::exactly(2))->method('getWebsiteIds')->willReturn($websiteId);
        $this->ruleMock->expects(self::once())->method('getMatchingProductIds')->willReturn($productIds);
        $this->ruleMock->expects(self::once())->method('getId')->willReturn(100);
        $this->ruleMock->expects(self::once())->method('getCustomerGroupIds')->willReturn($customerGroupIds);
        $this->ruleMock->expects(self::atLeastOnce())->method('getFromDate')->willReturn('2017-06-21');
        $this->ruleMock->expects(self::atLeastOnce())->method('getToDate')->willReturn('2017-06-30');
        $this->ruleMock->expects(self::once())->method('getSortOrder')->willReturn(1);
        $this->ruleMock->expects(self::once())->method('getSimpleAction')->willReturn('simple_action');
        $this->ruleMock->expects(self::once())->method('getDiscountAmount')->willReturn(43);
        $this->ruleMock->expects(self::once())->method('getStopRulesProcessing')->willReturn(true);
    }
}