php-service-bus / http-client

src/Artax/functions.php

<?php

/**
 * Abstraction over Http client implementations.
 *
 * @author  Maksim Masiukevich <contacts@desperado.dev>
 * @license MIT
 * @license https://opensource.org/licenses/MIT
 */

declare(strict_types = 0);

namespace ServiceBus\HttpClient\Artax;

use Amp\CancelledException;
use Amp\Dns\DnsException;
use Amp\Dns\NoRecordException;
use Amp\Http\Client\ParseException;
use Amp\Http\Client\Request;
use Amp\Http\Client\SocketException;
use Amp\Http\Client\TimeoutException;
use Amp\Promise;
use GuzzleHttp\Psr7\Response;
use Psr\Log\LoggerInterface;
use ServiceBus\HttpClient\Exception as HttpClientExceptions;
use function ServiceBus\Common\throwableMessage;

The function ServiceBus\Common\throwableMessage was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * Download file.
 *
 * @api
 *
 * @return Promise<string>
 *
 * @throws \ServiceBus\HttpClient\Exception\HttpClientException
 * @throws \ServiceBus\HttpClient\Exception\ConnectionFailed
 * @throws \ServiceBus\HttpClient\Exception\DnsResolveFailed
 * @throws \ServiceBus\HttpClient\Exception\IncorrectParameters
 * @throws \ServiceBus\HttpClient\Exception\RequestTimeoutReached
 */
function downloadFile(string $url, string $toDirectory, string $withName): Promise
{
    return (new ArtaxHttpClient())->download($url, $toDirectory, $withName);
}

/**
 * @internal
 */
function logArtaxRequest(LoggerInterface $logger, Request $request, string $requestId): \Generator
{
    $logger->debug(
        'Request: [{requestMethod}] {requestUri} {requestHeaders}',
        [
            'requestMethod'  => $request->getMethod(),
            'requestUri'     => $request->getUri(),
            'requestContent' => yield $request->getBody()->createBodyStream()->read(),
            'requestHeaders' => $request->getHeaders(),
            'requestId'      => $requestId,
        ]
    );
}

/**
 * @internal
 *
 * @return void
 */
function logArtaxResponse(LoggerInterface $logger, Response $response, string $requestId, string $executionTime): void
{
    $logger->debug(
        'Response: {responseHttpCode} {responseContent} {responseHeaders}',
        [
            'responseHttpCode' => $response->getStatusCode(),
            'responseContent'  => (string) $response->getBody(),
            'responseHeaders'  => $response->getHeaders(),
            'requestId'        => $requestId,
            'executionTime'    => \sprintf('%.2f', $executionTime)
        ]
    );
}

/**
 * @internal
 *
 * @return void
 */
function logArtaxThrowable(LoggerInterface $logger, \Throwable $throwable, string $requestId, string $executionTime): void
{
    $logger->error(
        'During the execution of the request with identifier "{requestId}" an exception was caught: "{throwableMessage}"',
        [
            'requestId'        => $requestId,
            'throwableMessage' => throwableMessage($throwable),

The function throwableMessage was not found. Maybe you did not declare it correctly or list all dependencies?

            'throwablePoint'   => \sprintf('%s:%d', $throwable->getFile(), $throwable->getLine()),
            'executionTime'    => \sprintf('%.2f', $executionTime)
        ]
    );
}

/**
 * @internal
 *
 * @return \Throwable
 */
function adaptArtaxThrowable(\Throwable $throwable): \Throwable
{
    /** @psalm-var array<class-string<\Amp\Http\Client\HttpException>, class-string<\Exception>> $mapping */
    $mapping = [
        NoRecordException::class  => HttpClientExceptions\DnsResolveFailed::class,
        DnsException::class       => HttpClientExceptions\DnsResolveFailed::class,
        SocketException::class    => HttpClientExceptions\ConnectionFailed::class,
        ParseException::class     => HttpClientExceptions\IncorrectParameters::class,
        TimeoutException::class   => HttpClientExceptions\RequestTimeoutReached::class,
        CancelledException::class => HttpClientExceptions\RequestTimeoutReached::class,
    ];

    /** @psalm-var class-string<\Amp\Http\Client\HttpException> $exceptionClass */
    $exceptionClass = \get_class($throwable);

    if (isset($mapping[$exceptionClass]))
    {
        /** @var class-string<\Exception> $exceptionClass */
        $exceptionClass = $mapping[$exceptionClass];

        /** @psalm-suppress UnsafeInstantiation */
        return new $exceptionClass($throwable->getMessage(), (int) $throwable->getCode(), $throwable);
    }

    return new HttpClientExceptions\HttpClientException(
        $throwable->getMessage(),
        (int) $throwable->getCode(),
        $throwable
    );
}