<?php

/*
 * This file is part of the Sylius package.
 *
 * (c) Paweł Jędrzejewski
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Sylius\Component\Core\Updater;

use Psr\Log\LoggerInterface;
use SM\Factory\Factory;
use Sylius\Component\Core\Repository\OrderRepositoryInterface;
use Sylius\Component\Order\Model\OrderInterface;
use Sylius\Component\Order\OrderTransitions;

final class UnpaidOrdersStateUpdater implements UnpaidOrdersStateUpdaterInterface
{
    /** @var OrderRepositoryInterface */
    private $orderRepository;

    /** @var Factory */
    private $stateMachineFactory;

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

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

    /**
     * @param string $expirationPeriod
     */
    public function __construct(
        OrderRepositoryInterface $orderRepository,
        Factory $stateMachineFactory,
        $expirationPeriod,
        LoggerInterface $logger = null
    ) {
        $this->orderRepository = $orderRepository;
        $this->stateMachineFactory = $stateMachineFactory;
        $this->expirationPeriod = $expirationPeriod;
        if (null === $logger) {
            @trigger_error(
                'Not passing a logger is deprecated since 1.7',
                \E_USER_DEPRECATED
            );
        }

        $this->logger = $logger;
    }

    public function cancel(): void
    {
        $expiredUnpaidOrders = $this->orderRepository->findOrdersUnpaidSince(new \DateTime('-' . $this->expirationPeriod));
        foreach ($expiredUnpaidOrders as $expiredUnpaidOrder) {
            try {
                $this->cancelOrder($expiredUnpaidOrder);
            } catch (\Exception $e) {
                if (null !== $this->logger) {
                    $this->logger->error(
                        sprintf('An error occurred while cancelling unpaid order #%s', $expiredUnpaidOrder->getId()),
                        ['exception' => $e, 'message' => $e->getMessage()]
                    );
                }
            }
        }
    }

    private function cancelOrder(OrderInterface $expiredUnpaidOrder): void
    {
        $stateMachine = $this->stateMachineFactory->get($expiredUnpaidOrder, OrderTransitions::GRAPH);
        $stateMachine->apply(OrderTransitions::TRANSITION_CANCEL);
    }
}
