httpquery.php

<?php
 
namespace Bitrix\Calendar\Sync\Google;
 
use Bitrix\Calendar\Sync\Util\RequestLogger;
use Bitrix\Main\DB\Exception;
use Bitrix\Main\Web\HttpClient;
 
class HttpQuery
{
    private const SERVICE_NAME = 'google';
    private HttpClient $client;
    private ?RequestLogger $logger = null;
 
    public function __construct(HttpClient $client, int $userId, string $serviceName = 'google')
    {
        $this->client = $client;
        if (RequestLogger::isEnabled())
        {
            $this->logger = new RequestLogger($userId, self::SERVICE_NAME);
        }
    }
 
    public function getClient(): HttpClient
    {
        return $this->client;
    }
 
    public function query(string $method, string $url, $body = null): void
    {
        $this->client->query($method, $url, $body);
 
        if ($this->logger)
        {
            $this->logger->write([
                'requestParams' => $body,
                'url' => $url,
                'method' => $method,
                'statusCode' => $this->client->getStatus(),
                'response' => $this->prepareResponseForDebug($this->client->getResult()),
                'error' => $this->prepareErrorForDebug($this->client->getResult()),
            ]);
        }
    }
 
    public function getStatus(): int
    {
        return $this->client->getStatus();
    }
 
    public function getResult(): string
    {
        return $this->client->getResult();
    }
 
    public function post(string $url, $body = null): void
    {
        $this->query(HttpClient::HTTP_POST, $url, $body);
    }
 
    public function get(string $url, $body = null): void
    {
        $this->query(HttpClient::HTTP_GET, $url, $body);
    }
 
    public function delete(string $url, $body = null): void
    {
        $this->query(HttpClient::HTTP_DELETE, $url, $body);
    }
 
    public function put(string $url, $body = null): void
    {
        $this->query(HttpClient::HTTP_PUT, $url, $body);
    }
 
    private function prepareResponseForDebug($response): string
    {
        if ($this->client->getStatus() >= 300)
        {
            return '';
        }
 
        try
        {
            $response = \Bitrix\Main\Web\Json::decode($response);
        }
        catch (\Exception $e){}
 
        if (!$response || !is_array($response))
        {
            return '';
        }
 
        $result = '';
 
        foreach ($response as $key => $value)
        {
            if (is_string($value))
            {
                $result .= "{$key}:{$value}; ";
            }
            elseif (is_array($value))
            {
                $result .= "{$key}:";
                foreach ($value as $valueKey => $valueValue)
                {
                    $result .= "{$valueKey}:{$valueValue}, ";
                }
                $result .= "; ";
            }
        }
 
        return $result;
    }
 
    private function prepareErrorForDebug($response): string
    {
        try
        {
            $response = \Bitrix\Main\Web\Json::decode($response);
        }
        catch (\Exception $e){}
 
        if (
            (!$response || !is_array($response))
            || ($this->client->getStatus() < 400)
        )
        {
            return '';
        }
 
        return $response['error']['code'] . " " . $response['error']['message'] . "; ";
    }
}