ClientFactory.php

<?php
 
declare(strict_types=1);
namespace Commercetools\Client;
 
use Commercetools\Exception\InvalidArgumentException;
use GuzzleHttp\Client as HttpClient;
use GuzzleHttp\ClientInterface;
use GuzzleHttp\HandlerStack;
use Psr\Log\LoggerInterface;
 
class ClientFactory
{
    public function createGuzzleClient(Config $config, ?AuthConfig $authConfig = null, ?LoggerInterface $logger = null, array $middlewares = []): ClientInterface
    {
        $handler = null;
        if (!is_null($authConfig)) {
            $handler = OAuthHandlerFactory::ofAuthConfig($authConfig);
        }
 
        return $this->createGuzzleClientForHandler($config, $handler, $logger, $middlewares);
    }
 
    public function createGuzzleClientForHandler(Config $config, ?OAuth2Handler $handler = null, ?LoggerInterface $logger = null, array $middlewares = []): ClientInterface
    {
        $middlewares = array_merge(
            MiddlewareFactory::createDefaultMiddlewares($handler, $logger, (int) ($config->getOptions()['maxRetries'] ?? 0)),
            $middlewares
        );
        return $this->createGuzzleClientWithOptions($config->getOptions(), $middlewares);
    }
 
    public function createGuzzleClientForMiddlewares(
        Config $config,
        array $middlewares = []
    ): ClientInterface {
        return $this->createGuzzleClientWithOptions($config->getOptions(), $middlewares);
    }
 
    private function createGuzzleClientWithOptions(array $options, array $middlewares = []): ClientInterface
    {
        if (isset($options['handler']) && $options['handler'] instanceof HandlerStack) {
            $stack = $options['handler'];
        } else {
            $stack = HandlerStack::create();
            $options['handler'] = $stack;
        }
 
        $options = array_replace(
            [
                'allow_redirects' => false,
                'verify' => true,
                'timeout' => 60,
                'connect_timeout' => 10,
                'pool_size' => 25,
                'headers' => []
            ],
            $options
        );
        if (!isset($options['headers']['accept-encoding']) && $this->acceptCompressedResponse()) {
            $options['headers']['accept-encoding'] = 'gzip';
        }
        if (!isset($options['headers']['user-agent'])) {
            $options['headers']['user-agent'] = (new UserAgentProvider())->getUserAgent();
        }
        foreach ($middlewares as $key => $middleware) {
            if (!is_callable($middleware)) {
                throw new InvalidArgumentException('Middleware isn\'t callable');
            }
            $name = is_numeric($key) ? '' : $key;
            $stack->push($middleware, $name);
        }
 
        $client = new HttpClient($options);
 
        return $client;
    }
    
    private function acceptCompressedResponse(): bool
    {
        if (function_exists('gzdecode')) {
            return true;
        }
        
        return false;
    }
 
    public static function of(): ClientFactory
    {
        return new self();
    }
}