FM / src

/var/www/vhosts/ihelp.ro/httpdocs/vendor/guzzlehttp/guzzle/src/

/var/www/vhosts/ihelp.ro/httpdocs/vendor/guzzlehttp/guzzle/src

Name	Size	Mode	Actions
Cookie/	-	0755	rm
Exception/	-	0755	rm
Handler/	-	0755	rm
BodySummarizer.php	631	0644	edit dl rm
BodySummarizerInterface.php	233	0644	edit dl rm
Client.php	18447	0644	edit dl rm
ClientInterface.php	2900	0644	edit dl rm
ClientTrait.php	9006	0644	edit dl rm
functions.php	5688	0644	edit dl rm
functions_include.php	160	0644	edit dl rm
HandlerStack.php	8709	0644	edit dl rm
MessageFormatter.php	7795	0644	edit dl rm
MessageFormatterInterface.php	559	0644	edit dl rm
Middleware.php	11158	0644	edit dl rm
Pool.php	4716	0644	edit dl rm
PrepareBodyMiddleware.php	3149	0644	edit dl rm
RedirectMiddleware.php	8112	0644	edit dl rm
RequestOptions.php	11045	0644	edit dl rm
RetryMiddleware.php	3613	0644	edit dl rm
TransferStats.php	3178	0644	edit dl rm
Utils.php	13077	0644	edit dl rm

Edit: /var/www/vhosts/ihelp.ro/httpdocs/vendor/guzzlehttp/guzzle/src/RetryMiddleware.php (3613B)

<?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 ?: __CLASS__.'::exponentialDelay';
    }

/**
     * Default exponential backoff delay function.
     *
     * @return int milliseconds.
     */
    public static function exponentialDelay(int $retries): int
    {
        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 ?: __CLASS__.'::exponentialDelay'; } /** * Default exponential backoff delay function. * * @return int milliseconds. */ public static function exponentialDelay(int $retries): int { 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); } }