ApaiIO\Request\Rest\Request

Complexity

Total Complexity

9

Size/Duplication

Total Lines	127
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes	14
Bugs	5	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	setConfiguration()	0	4	1
A	perform()	0	14	1
B	prepareRequestParams()	0	24	3
A	buildQueryString()	0	11	2
A	buildSignature()	0	13	1

<?php
/*
 * Copyright 2016 Jan Eichhorn <exeu65@googlemail.com>
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

namespace ApaiIO\Request\Rest;

use ApaiIO\ApaiIO;
use ApaiIO\Configuration\ConfigurationInterface;
use ApaiIO\Operations\OperationInterface;
use ApaiIO\Request\RequestInterface;
use ApaiIO\Request\Util;
use GuzzleHttp\ClientInterface;

/**
 * Basic implementation of the rest request
 *
 * @see    http://docs.aws.amazon.com/AWSECommerceService/2011-08-01/DG/AnatomyOfaRESTRequest.html
 * @author Jan Eichhorn <exeu65@googlemail.com>
 */
class Request implements RequestInterface
{
    /**
     * The requestscheme
     *
     * @var string
     */
    private $requestScheme = "http://webservices.amazon.%s/onca/xml?%s";

    /**
     * @var ConfigurationInterface
     */
    private $configuration;

    /**
     * @var ClientInterface
     */
    private $client;

    /**
     * Initialize instance
     *
     * @param ClientInterface $client
     */
    public function __construct(ClientInterface $client)
    {
        $this->client = $client;
    }

    /**
     * {@inheritdoc}
     */
    public function setConfiguration(ConfigurationInterface $configuration)
    {
        $this->configuration = $configuration;
    }

    /**
     * {@inheritdoc}
     */
    public function perform(OperationInterface $operation)
    {
        $preparedRequestParams = $this->prepareRequestParams($operation);
        $queryString = $this->buildQueryString($preparedRequestParams);

        $uri = sprintf($this->requestScheme, $this->configuration->getCountry(), $queryString);
        $request = new \GuzzleHttp\Psr7\Request('GET', $uri, [
            'User-Agent' => 'ApaiIO [' . ApaiIO::VERSION . ']'
        ]);

        $result = $this->client->send($request);

        return $result->getBody()->getContents();
    }

    /**
     * Prepares the parameters for the request
     *
     * @param OperationInterface $operation
     *
     * @return array
     */
    protected function prepareRequestParams(OperationInterface $operation)
    {
        $baseRequestParams = [
            'Service' => 'AWSECommerceService',
            'AWSAccessKeyId' => $this->configuration->getAccessKey(),
            'AssociateTag' => $this->configuration->getAssociateTag(),
            'Operation' => $operation->getName(),
            'Version' => '2011-08-01',
            'Timestamp' => Util::getTimeStamp()
        ];

        $operationParams = $operation->getOperationParameter();

        foreach ($operationParams as $key => $value) {
            if (true === is_array($value)) {
                $operationParams[$key] = implode(',', $value);
            }
        }

        $fullParameterList = array_merge($baseRequestParams, $operationParams);
        ksort($fullParameterList);

        return $fullParameterList;
    }

    /**
     * Builds the final querystring including the signature
     *
     * @param array $params
     *
     * @return string
     */
    protected function buildQueryString(array $params)
    {
        $parameterList = [];
        foreach ($params as $key => $value) {
            $parameterList[] = sprintf('%s=%s', $key, rawurlencode($value));
        }

        $parameterList[] = 'Signature=' . rawurlencode($this->buildSignature($parameterList));

        return implode("&", $parameterList);
    }

    /**
     * Calculates the signature for the request
     *
     * @param array $params
     *
     * @return string
     */
    protected function buildSignature(array $params)
    {
        $template = "GET\nwebservices.amazon.%s\n/onca/xml\n%s";

        return Util::buildSignature(
            sprintf(
                $template,
                $this->configuration->getCountry(),
                implode('&', $params)
            ),
            $this->configuration->getSecretKey()
        );
    }
}