Shippinno\YahooShoppingJp\Client

Complexity

Total Complexity

18

Size/Duplication

Total Lines	180
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	12

Importance

Changes

0

<?php

class Client
{
//    /**
//     * @var string
//     */
//    const BASE_URL = 'https://circus.shopping.yahooapis.jp/ShoppingWebService/V1/';

    /**
     * @var string
     */
    const BASE_URL = 'https://test.circus.shopping.yahooapis.jp/ShoppingWebService/V1/';

    /**
     * @var HttpClient
     */
    private $httpClient;

    /**
     * @var AbstractApi
     */
    private $api;

    /**
     * @var string
     */
    private $accessToken;

    /**
     * @var string
     */
    private $cert;

    /**
     * @var
     */
    private $sslKey;

    /**
     * @param string $accessToken
     * @param string $cert
     * @param string $sslKey
     * @param HttpClient|null $httpClient
     */
    public function __construct(
        string $accessToken,
        string $cert = null,
        string $sslKey = null,
        HttpClient $httpClient = null
    ) {
        if (null === $httpClient) {
            $httpClient = new HttpClient([
                'base_uri' => self::BASE_URL,
            ]);
        }

        $this->accessToken = $accessToken;
        $this->cert = $cert;
        $this->sslKey = $sslKey;
        $this->httpClient = $httpClient;
    }

    /**
     * @param AbstractRequest $request
     * @return array|mixed
     * @throws ClientException
     * @throws ConnectException
     * @throws ExpiredAccessTokenException
     * @throws ServerException
     */
    public function execute(AbstractRequest $request): array
    {
        $this->setApi($request->api());

        $options = $this->setAuthorizationHeader($this->setRequestParams($request));

        $options = $this->setCertAndSslKey($options);
        
        try {
            $rawResponse = $this->request($options);
        } catch (GuzzleClientException $e) {
            $wwwAuthenticateHeaders = $e->getResponse()->getHeader('WWW-Authenticate');

            if ([] !== $wwwAuthenticateHeaders) {
                if (false !== strpos($wwwAuthenticateHeaders[0], 'error_description="expired token"')) {
                    throw new ExpiredAccessTokenException;
                }
            }

            throw new ClientException($e->getMessage(), $e->getCode(), $e);
        } catch (GuzzleServerException $e) {
            throw new ServerException($e->getMessage(), $e->getCode(), $e);
        } catch (GuzzleConnectException $e) {
            throw new ConnectException($e->getMessage(), $e->getCode(), $e);
        }

        return $this->api->distillResponse($this->decodeResponse($rawResponse));
//        $response = $request->response()->setData($distilledResponse);

63% of this comment could be valid code. Did you maybe forget this after debugging?

    }

    /**
     * @param AbstractApi $api
     */
    private function setApi(AbstractApi $api)
    {
        $this->api = $api;
    }

    /**
     * @param array $options
     * @return array
     */
    private function setCertAndSslKey(array $options): array
    {
        if (null !== $this->cert && null !== $this->sslKey) {
            $options[RequestOptions::CERT] = $this->cert,

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected ','

            $options[RequestOptions::SSL_KEY] = $this->sslKey;
        }

        return $options;
    }

    /**
     * @param array $options
     * @return array
     */
    private function setAuthorizationHeader(array $options): array
    {
        $options['headers'] = [
            'Authorization' => 'Bearer ' . $this->accessToken,
        ];

        return $options;
    }

    /**
     * @param AbstractRequest $request
     * @return array
     */
    private function setRequestParams(AbstractRequest $request): array
    {
        $options = [];
        if ($this->api->httpMethod()->equals(HttpMethod::GET())) {
            $options = $this->setRequestParamsForGetRequest($options, $request);
        } else {
            if ($this->api->httpMethod()->equals(HttpMethod::POST())) {
                $options = $this->setRequestParamsForPostRequest($options, $request);
            }
        }

        return $options;
    }

    /**
     * @param array $options
     * @param AbstractRequest $request
     * @return array
     */
    private function setRequestParamsForGetRequest(array $options, AbstractRequest $request): array
    {
        $options['query'] = $request->getParams();

        return $options;
    }

    /**
     * @param array $options
     * @param AbstractRequest $request
     * @return array
     */
    private function setRequestParamsForPostRequest(array $options, AbstractRequest $request): array
    {
        if ($this->api->expectsFormFields()) {
            $options['form_params'] = $request->getParams();
        } else {
            $options['body'] = $request->getParams();
        }

        return $options;
    }