ApiRequest.php

<?php
 
declare(strict_types=1);
namespace Commercetools\Client;
 
use Commercetools\Exception\InvalidArgumentException;
use GuzzleHttp\ClientInterface;
use GuzzleHttp\Exception\GuzzleException;
use GuzzleHttp\Promise\PromiseInterface;
use GuzzleHttp\Psr7\Query;
use GuzzleHttp\Psr7\Request;
use Psr\Http\Message\ResponseInterface;
use stdClass;
 
class ApiRequest extends Request implements ApiRequestInterface
{
    private $queryParts;
    private $query;
 
    private $client;
 
    public function __construct(?ClientInterface $client, string $method, string $uri, array $headers = [], $body = null, string $version = '1.1')
    {
        $this->client = $client;
        $headers = $this->ensureHeader($headers, 'Content-Type', 'application/json');
 
        parent::__construct($method, $uri, $headers, $body, $version);
    }
 
    protected function ensureHeader(array $headers, string $header, $defaultValue): array
    {
        $normalizedHeader = strtolower($header);
        foreach ($headers as $headerName => $value) {
            $normalized = strtolower($headerName);
            if ($normalized !== $normalizedHeader) {
                continue;
            }
            return $headers;
        }
        $headers[$header] = $defaultValue;
 
        return $headers;
    }
 
    public function withQueryParam(string $parameterName, $value): ApiRequestInterface
    {
        $query = $this->getUri()->getQuery();
        if ($this->query !== $query) {
            $this->queryParts = array_map(
                function ($value): array {
                    if (is_array($value)) {
                        return $value;
                    }
                    return [$value];
                },
                Query::parse($query)
            );
        }
        if (is_array($value)) {
            foreach ($value as $v) {
                $this->queryParts[$parameterName][] = $v;
            }
        } else {
            $this->queryParts[$parameterName][] = $value;
        }
        ksort($this->queryParts);
        $this->query = Query::build($this->queryParts);
 
        return $this->withUri($this->getUri()->withQuery($this->query));
    }
    
    public function send(array $options = []): ResponseInterface
    {
        if (is_null($this->client)) {
            throw new InvalidArgumentException('No http client set to send the request');
        }
        return $this->client->send($this, $options);
    }
 
    public function sendAsync(array $options = []): PromiseInterface
    {
        if (is_null($this->client)) {
            throw new InvalidArgumentException('No http client set to send the request');
        }
        return $this->client->sendAsync($this, $options);
    }
 
    public function getClient(): ?ClientInterface
    {
        return $this->client;
    }
 
    final protected function responseData(ResponseInterface $response)
    {
        $body = (string)$response->getBody();
        $data = json_decode($body);
        if (is_null($data)) {
            return new stdClass();
        }
        return $data;
    }
}