byp4a55 professor6T9

Linux ns1.eurodns.top 4.18.0-553.22.1.lve.1.el7h.x86_64 #1 SMP Tue Oct 8 14:36:03 UTC 2024 x86_64
LiteSpeed
135.181.9.38

File Name : RetryableHttpClient.php

<?php

/*
 * This file is part of the Symfony package.
 *
 * (c) Fabien Potencier <fabien@symfony.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Symfony\Component\HttpClient;

use Psr\Log\LoggerInterface;
use Symfony\Component\HttpClient\Response\AsyncContext;
use Symfony\Component\HttpClient\Response\AsyncResponse;
use Symfony\Component\HttpClient\Retry\GenericRetryStrategy;
use Symfony\Component\HttpClient\Retry\RetryStrategyInterface;
use Symfony\Contracts\HttpClient\ChunkInterface;
use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
use Symfony\Contracts\HttpClient\HttpClientInterface;
use Symfony\Contracts\HttpClient\ResponseInterface;
use Symfony\Contracts\Service\ResetInterface;

/**
 * Automatically retries failing HTTP requests.
 *
 * @author Jérémy Derussé <jeremy@derusse.com>
 */
class RetryableHttpClient implements HttpClientInterface, ResetInterface
{
    use AsyncDecoratorTrait;

private RetryStrategyInterface $strategy;
    private int $maxRetries;
    private ?LoggerInterface $logger;
    private array $baseUris = [];

/**
     * @param int $maxRetries The maximum number of times to retry
     */
    public function __construct(HttpClientInterface $client, ?RetryStrategyInterface $strategy = null, int $maxRetries = 3, ?LoggerInterface $logger = null)
    {
        $this->client = $client;
        $this->strategy = $strategy ?? new GenericRetryStrategy();
        $this->maxRetries = $maxRetries;
        $this->logger = $logger;
    }

public function withOptions(array $options): static
    {
        if (\array_key_exists('base_uri', $options)) {
            if (\is_array($options['base_uri'])) {
                $this->baseUris = $options['base_uri'];
                unset($options['base_uri']);
            } else {
                $this->baseUris = [];
            }
        }

$clone = clone $this;
        $clone->maxRetries = (int) ($options['max_retries'] ?? $this->maxRetries);
        unset($options['max_retries']);

$clone->client = $this->client->withOptions($options);

return $clone;
    }

public function request(string $method, string $url, array $options = []): ResponseInterface
    {
        $baseUris = \array_key_exists('base_uri', $options) ? $options['base_uri'] : $this->baseUris;
        $baseUris = \is_array($baseUris) ? $baseUris : [];
        $options = self::shiftBaseUri($options, $baseUris);

$maxRetries = (int) ($options['max_retries'] ?? $this->maxRetries);
        unset($options['max_retries']);

if ($maxRetries <= 0) {
            return new AsyncResponse($this->client, $method, $url, $options);
        }

return new AsyncResponse($this->client, $method, $url, $options, function (ChunkInterface $chunk, AsyncContext $context) use ($method, $url, $options, $maxRetries, &$baseUris) {
            static $retryCount = 0;
            static $content = '';
            static $firstChunk;

$exception = null;
            try {
                if ($context->getInfo('canceled') || $chunk->isTimeout() || null !== $chunk->getInformationalStatus()) {
                    yield $chunk;

return;
                }
            } catch (TransportExceptionInterface $exception) {
                // catch TransportExceptionInterface to send it to the strategy
            }
            if (null !== $exception) {
                // always retry request that fail to resolve DNS
                if ('' !== $context->getInfo('primary_ip')) {
                    $shouldRetry = $this->strategy->shouldRetry($context, null, $exception);
                    if (null === $shouldRetry) {
                        throw new \LogicException(sprintf('The "%s::shouldRetry()" method must not return null when called with an exception.', $this->strategy::class));
                    }

if (false === $shouldRetry) {
                        yield from $this->passthru($context, $firstChunk, $content, $chunk);

return;
                    }
                }
            } elseif ($chunk->isFirst()) {
                if (false === $shouldRetry = $this->strategy->shouldRetry($context, null, null)) {
                    yield from $this->passthru($context, $firstChunk, $content, $chunk);

return;
                }

// Body is needed to decide
                if (null === $shouldRetry) {
                    $firstChunk = $chunk;
                    $content = '';

return;
                }
            } else {
                if (!$chunk->isLast()) {
                    $content .= $chunk->getContent();

return;
                }

if (null === $shouldRetry = $this->strategy->shouldRetry($context, $content, null)) {
                    throw new \LogicException(sprintf('The "%s::shouldRetry()" method must not return null when called with a body.', $this->strategy::class));
                }

if (false === $shouldRetry) {
                    yield from $this->passthru($context, $firstChunk, $content, $chunk);

return;
                }
            }

$context->getResponse()->cancel();

$delay = $this->getDelayFromHeader($context->getHeaders()) ?? $this->strategy->getDelay($context, !$exception && $chunk->isLast() ? $content : null, $exception);
            ++$retryCount;
            $content = '';
            $firstChunk = null;

$this->logger?->info('Try #{count} after {delay}ms'.($exception ? ': '.$exception->getMessage() : ', status code: '.$context->getStatusCode()), [
                'count' => $retryCount,
                'delay' => $delay,
            ]);

$context->setInfo('retry_count', $retryCount);
            $context->replaceRequest($method, $url, self::shiftBaseUri($options, $baseUris));
            $context->pause($delay / 1000);

if ($retryCount >= $maxRetries) {
                $context->passthru();
            }
        });
    }

private function getDelayFromHeader(array $headers): ?int
    {
        if (null !== $after = $headers['retry-after'][0] ?? null) {
            if (is_numeric($after)) {
                return (int) ($after * 1000);
            }

if (false !== $time = strtotime($after)) {
                return max(0, $time - time()) * 1000;
            }
        }

return null;
    }

private function passthru(AsyncContext $context, ?ChunkInterface $firstChunk, string &$content, ChunkInterface $lastChunk): \Generator
    {
        $context->passthru();

if (null !== $firstChunk) {
            yield $firstChunk;
        }

if ('' !== $content) {
            $chunk = $context->createChunk($content);
            $content = '';

yield $chunk;
        }

yield $lastChunk;
    }

private static function shiftBaseUri(array $options, array &$baseUris): array
    {
        if ($baseUris) {
            $baseUri = 1 < \count($baseUris) ? array_shift($baseUris) : current($baseUris);
            $options['base_uri'] = \is_array($baseUri) ? $baseUri[array_rand($baseUri)] : $baseUri;
        }

return $options;
    }
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	equipati/equipati	0755	2025-12-01 07:54:25
..	dir	-	equipati/equipati	0755	2025-07-07 07:04:08
Chunk	dir	-	equipati/equipati	0755	2025-12-03 04:32:55
DataCollector	dir	-	equipati/equipati	0755	2025-12-06 06:08:19
DependencyInjection	dir	-	equipati/equipati	0755	2025-12-07 05:00:51
Exception	dir	-	equipati/equipati	0755	2025-12-01 11:07:02
Internal	dir	-	equipati/equipati	0755	2025-12-01 11:22:39
Messenger	dir	-	equipati/equipati	0755	2025-07-07 07:04:08
Response	dir	-	equipati/equipati	0755	2025-12-01 10:59:24
Retry	dir	-	equipati/equipati	0755	2025-12-04 07:53:07
Test	dir	-	equipati/equipati	0755	2025-07-07 07:04:08
AmpHttpClient.php	text/x-php	7.13 KB	equipati/equipati	0644	2024-08-25 09:30:20
AsyncDecoratorTrait.php	text/x-php	1.12 KB	equipati/equipati	0644	2024-08-25 09:30:20
CHANGELOG.md	text/plain	3.6 KB	equipati/equipati	0644	2024-08-25 09:30:20
CachingHttpClient.php	text/x-php	5.31 KB	equipati/equipati	0644	2024-08-25 09:30:20
CurlHttpClient.php	text/x-php	23.55 KB	equipati/equipati	0644	2024-08-25 09:30:20
DecoratorTrait.php	text/x-php	1.47 KB	equipati/equipati	0644	2024-08-25 09:30:20
EventSourceHttpClient.php	text/x-php	5.92 KB	equipati/equipati	0644	2024-08-25 09:30:20
HttpClient.php	text/x-php	3.36 KB	equipati/equipati	0644	2024-08-25 09:30:20
HttpClientTrait.php	text/x-php	33.16 KB	equipati/equipati	0644	2024-08-25 09:30:20
HttpOptions.php	text/x-php	6.01 KB	equipati/equipati	0644	2024-08-25 09:30:20
HttplugClient.php	text/x-php	11.03 KB	equipati/equipati	0644	2024-08-25 09:30:20
LICENSE	text/plain	1.04 KB	equipati/equipati	0644	2024-08-25 09:30:20
MockHttpClient.php	text/x-php	4.17 KB	equipati/equipati	0644	2024-08-25 09:30:20
NativeHttpClient.php	text/x-php	19.56 KB	equipati/equipati	0644	2024-08-25 09:30:20
NoPrivateNetworkHttpClient.php	text/x-php	3.5 KB	equipati/equipati	0644	2024-08-25 09:30:20
Psr18Client.php	text/x-php	7.41 KB	equipati/equipati	0644	2024-08-25 09:30:20
README.md	text/plain	1.05 KB	equipati/equipati	0644	2024-08-25 09:30:20
RetryableHttpClient.php	text/x-php	7.2 KB	equipati/equipati	0644	2024-08-25 09:30:20
ScopingHttpClient.php	text/x-php	3.99 KB	equipati/equipati	0644	2024-08-25 09:30:20
TraceableHttpClient.php	text/x-php	3.17 KB	equipati/equipati	0644	2024-08-25 09:30:20
UriTemplateHttpClient.php	text/x-php	2.68 KB	equipati/equipati	0644	2024-08-25 09:30:20
composer.json	application/json	1.76 KB	equipati/equipati	0644	2024-08-25 09:30:20
error_log	text/plain	25.21 KB	equipati/equipati	0644	2026-01-14 11:34:40

Team Anon Force

https://t.me/Professor6T9x