Ivory\HttpAdapter\HttpAdapterTrait

Complexity

Total Complexity

22

Size/Duplication

Total Lines	254
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	get()	0	4	1
A	head()	0	4	1
A	trace()	0	4	1
A	post()	0	4	1
A	put()	0	4	1
A	patch()	0	4	1
A	delete()	0	4	1
A	options()	0	4	1
A	send()	0	11	1
A	sendRequest()	0	20	2
C	sendRequests()	0	46	7
	sendInternalRequest()	0	1	?
A	sendInternalRequests()	0	14	4

<?php

/*
 * This file is part of the Ivory Http Adapter package.
 *
 * (c) Eric GELOEN <geloen.eric@gmail.com>
 *
 * For the full copyright and license information, please read the LICENSE
 * file that was distributed with this source code.
 */

namespace Ivory\HttpAdapter;

use Ivory\HttpAdapter\Message\InternalRequestInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * @author GeLo <geloen.eric@gmail.com>
 */
trait HttpAdapterTrait
{
    /**
     * @param string|object $uri
     * @param array         $headers
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function get($uri, array $headers = [])
    {
        return $this->send($uri, InternalRequestInterface::METHOD_GET, $headers);
    }

    /**
     * @param string|object $uri
     * @param array         $headers
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function head($uri, array $headers = [])
    {
        return $this->send($uri, InternalRequestInterface::METHOD_HEAD, $headers);
    }

    /**
     * @param string|object $uri
     * @param array         $headers
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function trace($uri, array $headers = [])
    {
        return $this->send($uri, InternalRequestInterface::METHOD_TRACE, $headers);
    }

    /**
     * @param string|object $uri
     * @param array         $headers
     * @param array|string  $datas
     * @param array         $files
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function post($uri, array $headers = [], $datas = [], array $files = [])
    {
        return $this->send($uri, InternalRequestInterface::METHOD_POST, $headers, $datas, $files);
    }

    /**
     * @param string|object $uri
     * @param array         $headers
     * @param array|string  $datas
     * @param array         $files
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function put($uri, array $headers = [], $datas = [], array $files = [])
    {
        return $this->send($uri, InternalRequestInterface::METHOD_PUT, $headers, $datas, $files);
    }

    /**
     * @param string|object $uri
     * @param array         $headers
     * @param array|string  $datas
     * @param array         $files
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function patch($uri, array $headers = [], $datas = [], array $files = [])
    {
        return $this->send($uri, InternalRequestInterface::METHOD_PATCH, $headers, $datas, $files);
    }

    /**
     * @param string|object $uri
     * @param array         $headers
     * @param array|string  $datas
     * @param array         $files
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function delete($uri, array $headers = [], $datas = [], array $files = [])
    {
        return $this->send($uri, InternalRequestInterface::METHOD_DELETE, $headers, $datas, $files);
    }

    /**
     * @param string|object $uri
     * @param array         $headers
     * @param array|string  $datas
     * @param array         $files
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function options($uri, array $headers = [], $datas = [], array $files = [])
    {
        return $this->send($uri, InternalRequestInterface::METHOD_OPTIONS, $headers, $datas, $files);
    }

    /**
     * @param string|object $uri
     * @param string        $method
     * @param array         $headers
     * @param array|string  $datas
     * @param array         $files
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function send($uri, $method, array $headers = [], $datas = [], array $files = [])
    {
        return $this->sendRequest($this->getConfiguration()->getMessageFactory()->createInternalRequest(

It seems like getConfiguration() must be provided by classes using this trait. How about adding it as abstract method to this trait?

            $uri,
            $method,
            $this->getConfiguration()->getProtocolVersion(),

It seems like getConfiguration() must be provided by classes using this trait. How about adding it as abstract method to this trait?

            $headers,
            $datas,
            $files
        ));
    }

    /**
     * @param RequestInterface $request
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    public function sendRequest(RequestInterface $request)
    {
        if ($request instanceof InternalRequestInterface) {
            return $this->sendInternalRequest($request);
        }

        $protocolVersion = $this->getConfiguration()->getProtocolVersion();

It seems like getConfiguration() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        $this->getConfiguration()->setProtocolVersion($request->getProtocolVersion());

It seems like getConfiguration() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        $response = $this->send(
            $request->getUri(),
            $request->getMethod(),
            $request->getHeaders(),
            $request->getBody()
        );

        $this->getConfiguration()->setProtocolVersion($protocolVersion);

It seems like getConfiguration() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        return $response;
    }

    /**
     * @param array $requests
     *
     * @throws MultiHttpAdapterException
     *
     * @return array
     */
    public function sendRequests(array $requests)
    {
        $responses = $exceptions = [];

        foreach ($requests as $index => &$request) {
            if (is_string($request)) {
                $request = [$request];
            }

            if (is_array($request)) {
                $request = call_user_func_array(
                    [$this->getConfiguration()->getMessageFactory(), 'createInternalRequest'],

It seems like getConfiguration() must be provided by classes using this trait. How about adding it as abstract method to this trait?

                    $request
                );
            }

            if (!$request instanceof RequestInterface) {
                $exceptions[] = HttpAdapterException::requestIsNotValid($request);
                unset($requests[$index]);
            } elseif (!$request instanceof InternalRequestInterface) {
                $request = $this->getConfiguration()->getMessageFactory()->createInternalRequest(

It seems like getConfiguration() must be provided by classes using this trait. How about adding it as abstract method to this trait?

                    $request->getUri(),
                    $request->getMethod(),
                    $request->getProtocolVersion(),
                    $request->getHeaders(),
                    $request->getBody()
                );
            }
        }

        $success = function (ResponseInterface $response) use (&$responses) {
            $responses[] = $response;
        };

        $error = function (HttpAdapterException $exception) use (&$exceptions) {
            $exceptions[] = $exception;
        };

        $this->sendInternalRequests($requests, $success, $error);

        if (!empty($exceptions)) {
            throw new MultiHttpAdapterException($exceptions, $responses);
        }

        return $responses;
    }

    /**
     * @param InternalRequestInterface $internalRequest
     *
     * @throws HttpAdapterException
     *
     * @return ResponseInterface
     */
    abstract protected function sendInternalRequest(InternalRequestInterface $internalRequest);

    /**
     * @param array    $internalRequests
     * @param callable $success
     * @param callable $error
     *
     * @throws MultiHttpAdapterException
     *
     * @return array
     */
    protected function sendInternalRequests(array $internalRequests, $success, $error)
    {
        foreach ($internalRequests as $internalRequest) {
            try {
                $response = $this->sendInternalRequest($internalRequest);
                $response = $response->withParameter('request', $internalRequest);
                call_user_func($success, $response);
            } catch (HttpAdapterException $e) {
                $e->setRequest($internalRequest);
                $e->setResponse(isset($response) ? $response : null);
                call_user_func($error, $e);
            }
        }
    }
}