FM / src

/opt/cpanel/ea-wappspector/vendor/guzzlehttp/guzzle/src/

/opt/cpanel/ea-wappspector/vendor/guzzlehttp/guzzle/src

Name	Size	Mode	Actions
Cookie/	-	0755	rm
Exception/	-	0755	rm
Handler/	-	0755	rm
BodySummarizer.php	608	0644	edit dl rm
BodySummarizerInterface.php	233	0644	edit dl rm
Client.php	55776	0644	edit dl rm
ClientInterface.php	2901	0644	edit dl rm
ClientTrait.php	9006	0644	edit dl rm
functions.php	10287	0644	edit dl rm
functions_include.php	160	0644	edit dl rm
HandlerStack.php	9091	0644	edit dl rm
MessageFormatter.php	7969	0644	edit dl rm
MessageFormatterInterface.php	561	0644	edit dl rm
Middleware.php	11159	0644	edit dl rm
Multiplexing.php	756	0644	edit dl rm
Pool.php	5114	0644	edit dl rm
PrepareBodyMiddleware.php	3136	0644	edit dl rm
RedirectMiddleware.php	8872	0644	edit dl rm
RequestOptions.php	20231	0644	edit dl rm
RetryMiddleware.php	3886	0644	edit dl rm
TransferStats.php	3180	0644	edit dl rm
TransportSharing.php	249	0644	edit dl rm
Utils.php	31209	0644	edit dl rm

Edit: /opt/cpanel/ea-wappspector/vendor/guzzlehttp/guzzle/src/RetryMiddleware.php (3886B)

<?php

namespace GuzzleHttp;

use GuzzleHttp\Promise as P;
use GuzzleHttp\Promise\PromiseInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * Middleware that retries requests based on the boolean result of
 * invoking the provided "decider" function.
 *
 * @final
 */
class RetryMiddleware
{
    /**
     * @var callable(RequestInterface, array): PromiseInterface
     */
    private $nextHandler;

/**
     * @var callable
     */
    private $decider;

/**
     * @var callable(int)
     */
    private $delay;

/**
     * @param callable                                            $decider     Function that accepts the number of retries,
     *                                                                         a request, [response], and [exception] and
     *                                                                         returns true if the request is to be
     *                                                                         retried.
     * @param callable(RequestInterface, array): PromiseInterface $nextHandler Next handler to invoke.
     * @param (callable(int): int)|null                           $delay       Function that accepts the number of retries
     *                                                                         and returns the number of
     *                                                                         milliseconds to delay.
     */
    public function __construct(callable $decider, callable $nextHandler, ?callable $delay = null)
    {
        $this->decider = $decider;
        $this->nextHandler = $nextHandler;
        $this->delay = $delay ?: static function (int $retries): int {
            return (int) 2 ** ($retries - 1) * 1000;
        };
    }

/**
     * Default exponential backoff delay function.
     *
     * @return int milliseconds.
     *
     * @deprecated since 7.11, will be removed in 8.0.
     */
    public static function exponentialDelay(int $retries): int
    {
        \trigger_deprecation('guzzlehttp/guzzle', '7.11', '%s::%s() is deprecated and will be removed in 8.0.', __CLASS__, __FUNCTION__);

return (int) 2 ** ($retries - 1) * 1000;
    }

public function __invoke(RequestInterface $request, array $options): PromiseInterface
    {
        if (!isset($options['retries'])) {
            $options['retries'] = 0;
        }

$fn = $this->nextHandler;

return $fn($request, $options)
            ->then(
                $this->onFulfilled($request, $options),
                $this->onRejected($request, $options)
            );
    }

/**
     * Execute fulfilled closure
     */
    private function onFulfilled(RequestInterface $request, array $options): callable
    {
        return function ($value) use ($request, $options) {
            if (!($this->decider)(
                $options['retries'],
                $request,
                $value,
                null
            )) {
                return $value;
            }

return $this->doRetry($request, $options, $value);
        };
    }

/**
     * Execute rejected closure
     */
    private function onRejected(RequestInterface $req, array $options): callable
    {
        return function ($reason) use ($req, $options) {
            if (!($this->decider)(
                $options['retries'],
                $req,
                null,
                $reason
            )) {
                return P\Create::rejectionFor($reason);
            }

return $this->doRetry($req, $options);
        };
    }

private function doRetry(RequestInterface $request, array $options, ?ResponseInterface $response = null): PromiseInterface
    {
        $options['delay'] = ($this->delay)(++$options['retries'], $response, $request);

return $this($request, $options);
    }
}

decider = $decider; $this->nextHandler = $nextHandler; $this->delay = $delay ?: static function (int $retries): int { return (int) 2 ** ($retries - 1) * 1000; }; } /** * Default exponential backoff delay function. * * @return int milliseconds. * * @deprecated since 7.11, will be removed in 8.0. */ public static function exponentialDelay(int $retries): int { \trigger_deprecation('guzzlehttp/guzzle', '7.11', '%s::%s() is deprecated and will be removed in 8.0.', __CLASS__, __FUNCTION__); return (int) 2 ** ($retries - 1) * 1000; } public function __invoke(RequestInterface $request, array $options): PromiseInterface { if (!isset($options['retries'])) { $options['retries'] = 0; } $fn = $this->nextHandler; return $fn($request, $options) ->then( $this->onFulfilled($request, $options), $this->onRejected($request, $options) ); } /** * Execute fulfilled closure */ private function onFulfilled(RequestInterface $request, array $options): callable { return function ($value) use ($request, $options) { if (!($this->decider)( $options['retries'], $request, $value, null )) { return $value; } return $this->doRetry($request, $options, $value); }; } /** * Execute rejected closure */ private function onRejected(RequestInterface $req, array $options): callable { return function ($reason) use ($req, $options) { if (!($this->decider)( $options['retries'], $req, null, $reason )) { return P\Create::rejectionFor($reason); } return $this->doRetry($req, $options); }; } private function doRetry(RequestInterface $request, array $options, ?ResponseInterface $response = null): PromiseInterface { $options['delay'] = ($this->delay)(++$options['retries'], $response, $request); return $this($request, $options); } }