> 1, $delay) / 1000; return max($delay, self::parseRetryAfter($response)); } private static function parseRetryAfter(?ResponseInterface $response): int { if (!$response || !$retryAfter = $response->getHeaderLine('Retry-After')) { return 0; } $retryAfter = trim($retryAfter, " \t"); if ($retryAfter === (string) (int) $retryAfter) { return (int) $retryAfter; } if (($time = strtotime($retryAfter)) !== false) { return $time - time(); } return 0; } /** * @param list $encodings * @param array|null $appliedEncodings * @psalm-suppress PossiblyInvalidArrayOffset */ public static function encode(string $value, array $encodings, ?array &$appliedEncodings = null): string { for ($i = 0, $n = count($encodings); $i < $n; $i++) { if (!$encoder = self::encoder($encodings[$i])) { unset($encodings[$i]); continue; } try { $value = $encoder($value); } catch (Throwable) { unset($encodings[$i]); } } $appliedEncodings = $encodings; return $value; } /** * @param list $encodings * @psalm-suppress InvalidArrayOffset */ public static function decode(string $value, array $encodings): string { if ($value === '') { return $value; } for ($i = count($encodings); --$i >= 0;) { if (strcasecmp($encodings[$i], 'identity') === 0) { continue; } if (!$decoder = self::decoder($encodings[$i])) { throw new UnexpectedValueException(sprintf('Not supported decompression encoding "%s"', $encodings[$i])); } $value = $decoder($value); } return $value; } /** * Resolve an array or CSV of compression types to a list */ public static function compression($compression): array { if (is_array($compression)) { return $compression; } if (!$compression) { return []; } if (!str_contains((string) $compression, ',')) { return [$compression]; } return array_map('trim', explode(',', (string) $compression)); } private static function encoder(string $encoding): ?callable { static $encoders; /** @noinspection SpellCheckingInspection */ $encoders ??= array_map(fn (callable $callable): callable => self::throwOnErrorOrFalse($callable), array_filter([ TransportFactoryInterface::COMPRESSION_GZIP => 'gzencode', TransportFactoryInterface::COMPRESSION_DEFLATE => 'gzcompress', TransportFactoryInterface::COMPRESSION_BROTLI => 'brotli_compress', ], 'function_exists')); return $encoders[$encoding] ?? null; } private static function decoder(string $encoding): ?callable { static $decoders; /** @noinspection SpellCheckingInspection */ $decoders ??= array_map(fn (callable $callable): callable => self::throwOnErrorOrFalse($callable), array_filter([ TransportFactoryInterface::COMPRESSION_GZIP => 'gzdecode', TransportFactoryInterface::COMPRESSION_DEFLATE => 'gzuncompress', TransportFactoryInterface::COMPRESSION_BROTLI => 'brotli_uncompress', ], 'function_exists')); return $decoders[$encoding] ?? null; } private static function throwOnErrorOrFalse(callable $callable): callable { return static function (...$args) use ($callable) { set_error_handler(static function (int $errno, string $errstr, string $errfile, int $errline): bool { throw new ErrorException($errstr, 0, $errno, $errfile, $errline); }); try { $result = $callable(...$args); } finally { restore_error_handler(); } /** @phan-suppress-next-line PhanPossiblyUndeclaredVariable */ if ($result === false) { throw new LogicException(); } /** @phan-suppress-next-line PhanPossiblyUndeclaredVariable */ return $result; }; } }