<?php

namespace Lackoxygen\TiktokShop\Transmit;

use Lackoxygen\TiktokShop\Exception\ClientException;
use Lackoxygen\TiktokShop\Exception\RetryException;

class Retry
{
    protected \Closure $execute;

    protected \Closure $when;

    /**
     * @param  \Closure  $execute
     * @param  \Closure  $when
     */
    public function __construct(\Closure $execute, \Closure $when)
    {
        $this->execute = $execute;

        $this->when = $when;
    }

    /**
     * @param  int  $retries
     * @param  int  $waitMilliseconds
     *
     * @return mixed|void
     * @throws ClientException
     * @throws RetryException
     */
    public function __invoke(int $retries = 3, int $waitMilliseconds = 500)
    {
        $callback = $this->execute;
        $when     = $this->when;
        $attempts = 0;
        do {
            try {
                return $callback($retries);
            } catch (\Throwable $e) {
                if (!$when($e)) {
                    throw new ClientException($e);
                }
                $waitMilliseconds && usleep($waitMilliseconds * 1000);
            }
            finally {
                ++$attempts;
            }
        } while ($attempts < $retries);

        throw new RetryException(sprintf('maximum number of attempts(%d) reached', $attempts));
    }
}