<?php

declare(strict_types=1);

namespace Akeneo\Connectivity\Connection\Infrastructure\Webhook\Service;

use Akeneo\Connectivity\Connection\Domain\Webhook\Persistence\Query\SelectEventsApiRequestCountWithinLastHourQueryInterface;

/**
 * @author Pierre Jolly <pierre.jolly@akeneo.com>
 * @copyright 2021 Akeneo SAS (http://www.akeneo.com)
 * @license http://opensource.org/licenses/osl-3.0.php  Open Software License (OSL 3.0)
 */
class GetDelayUntilNextRequest
{
    private SelectEventsApiRequestCountWithinLastHourQueryInterface $selectEventsApiRequestCountWithinLastHourQuery;

    public function __construct(
        SelectEventsApiRequestCountWithinLastHourQueryInterface $selectEventsApiRequestCountWithinLastHourQuery
    ) {
        $this->selectEventsApiRequestCountWithinLastHourQuery = $selectEventsApiRequestCountWithinLastHourQuery;
    }

    /**
     * We are fetching the count of events api request for each minutes ordered from youngest to oldest, then we are
     * adding the count together until the limit is reached to finally calculate the number of seconds between the
     * current time and the time where the limit was reached and adding the remaining time in seconds to "complete"
     * the 1 hour quota
     */
    public function execute(\DateTimeImmutable $dateTime, int $limit): int
    {
        $eventsApiRequestCountWithinLastHour = $this->selectEventsApiRequestCountWithinLastHourQuery->execute($dateTime);

        $count = 0;
        foreach ($eventsApiRequestCountWithinLastHour as $currentEventsApiRequestCount) {
            $count += $currentEventsApiRequestCount['event_count'];

            if ($count >= $limit) {
                $lastDateTime = \DateTimeImmutable::createFromFormat('Y-m-d H:i:s', $currentEventsApiRequestCount['updated']);

                return 3600 - ($dateTime->getTimestamp() - $lastDateTime->getTimestamp());
            }
        }

        return 0;
    }
}