| Server IP : 78.140.185.180 / Your IP : 3.149.249.124 Web Server : LiteSpeed System : Linux cpanel13.v.fozzy.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : builderbox ( 1072) PHP Version : 7.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/builderbox/www/vendor/graham-campbell/guzzle-factory/src/ |
Upload File : |
<?php
declare(strict_types=1);
/*
* This file is part of Guzzle Factory.
*
* (c) Graham Campbell <graham@alt-three.com>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace GrahamCampbell\GuzzleFactory;
use GuzzleHttp\BodySummarizer;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\ConnectException;
use GuzzleHttp\Exception\TransferException;
use GuzzleHttp\HandlerStack;
use GuzzleHttp\Middleware;
use GuzzleHttp\Utils;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
/**
* This is the guzzle factory class.
*
* @author Graham Campbell <graham@alt-three.com>
*/
final class GuzzleFactory
{
/**
* The default connect timeout.
*
* @var int
*/
const CONNECT_TIMEOUT = 10;
/**
* The default transport timeout.
*
* @var int
*/
const TIMEOUT = 15;
/**
* The default backoff multiplier.
*
* @var int
*/
const BACKOFF = 1000;
/**
* The default 4xx retry codes.
*
* @var int[]
*/
const CODES = [429];
/**
* The default amount of retries.
*/
const RETRIES = 3;
/**
* Create a new guzzle client.
*
* @param array $options
* @param int|null $backoff
* @param int[]|null $codes
* @param int|null $retries
*
* @return \GuzzleHttp\Client
*/
public static function make(array $options = [], int $backoff = null, array $codes = null, int $retries = null)
{
$config = array_merge(['connect_timeout' => self::CONNECT_TIMEOUT, 'timeout' => self::TIMEOUT], $options);
$config['handler'] = self::handler($backoff, $codes, $retries, $options['handler'] ?? null);
return new Client($config);
}
/**
* Create a new retrying handler stack.
*
* @param int|null $backoff
* @param int[]|null $codes
* @param int|null $retries
* @param \GuzzleHttp\HandlerStack|null $stack
*
* @return \GuzzleHttp\HandlerStack
*/
public static function handler(int $backoff = null, array $codes = null, int $retries = null, HandlerStack $stack = null)
{
$stack = $stack ?? self::innerHandler();
if ($retries === 0) {
return $stack;
}
$stack->push(self::createRetryMiddleware($backoff ?? self::BACKOFF, $codes ?? self::CODES, $retries ?? self::RETRIES), 'retry');
return $stack;
}
/**
* Create a new handler stack.
*
* @param callable|null $handler
*
* @return \GuzzleHttp\HandlerStack
*/
public static function innerHandler(callable $handler = null): HandlerStack
{
$stack = new HandlerStack($handler ?? Utils::chooseHandler());
$stack->push(Middleware::httpErrors(new BodySummarizer(250)), 'http_errors');
$stack->push(Middleware::redirect(), 'allow_redirects');
$stack->push(Middleware::cookies(), 'cookies');
$stack->push(Middleware::prepareBody(), 'prepare_body');
return $stack;
}
/**
* Create a new retry middleware.
*
* @param int $backoff
* @param int[] $codes
* @param int $maxRetries
*
* @return callable
*/
private static function createRetryMiddleware(int $backoff, array $codes, int $maxRetries): callable
{
return Middleware::retry(function ($retries, RequestInterface $request, ResponseInterface $response = null, TransferException $exception = null) use ($codes, $maxRetries) {
return $retries < $maxRetries && ($exception instanceof ConnectException || ($response && ($response->getStatusCode() >= 500 || in_array($response->getStatusCode(), $codes, true))));
}, function ($retries) use ($backoff) {
return (int) pow(2, $retries) * $backoff;
});
}
}