IBM\Watson\Common\RequestBuilder

Complexity

Total Complexity

7

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	3
A	create()	0	10	2
A	createMultipartStreamRequest()	0	17	2

<?php

namespace IBM\Watson\Common;

use Http\Discovery\MessageFactoryDiscovery;
use Http\Message\MultipartStream\MultipartStreamBuilder;
use Http\Message\RequestFactory;
use Psr\Http\Message\StreamInterface;
use Psr\Http\Message\UriInterface;

final class RequestBuilder
{
    /**
     * @var \Http\Message\MessageFactory
     */
    private $requestFactory;

    private $multipartStreamBuilder;

    /**
     * RequestBuilder constructor.
     *
     * @param \Http\Message\MultipartStream\MultipartStreamBuilder|null $multipartStreamBuilder
     * @param \Http\Message\RequestFactory|\Http\Message\MessageFactory|null $requestFactory
     *
     * @throws \Http\Discovery\Exception\NotFoundException
     */
    public function __construct(
        RequestFactory $requestFactory = null,
        MultipartStreamBuilder $multipartStreamBuilder = null
    ) {
        $this->requestFactory = $requestFactory ?: MessageFactoryDiscovery::find();

It seems like $requestFactory ?: \Http\Discovery\MessageFactoryDiscovery::find() can also be of type object<Http\Message\RequestFactory>. However, the property $requestFactory is declared as type object<Http\Message\MessageFactory>. Maybe add an additional type check?

        $this->multipartStreamBuilder = $multipartStreamBuilder ?: new MultipartStreamBuilder;
    }

    /**
     * Create a new PSR-7 request
     *
     * @param string                                     $method
     * @param string|UriInterface                        $uri
     * @param array|null                                 $headers
     * @param array|resource|string|StreamInterface|null $body
     *
     * @return \Psr\Http\Message\RequestInterface
     */
    public function create($method, $uri, array $headers = [], $body = null)
    {
        if (!is_array($body)) {
            $request = $this->requestFactory->createRequest($method, $uri, $headers, $body);
        } else {
            $request = $this->createMultipartStreamRequest($method, $uri, $headers, $body);
        }

        return $request;
    }

    protected function createMultipartStreamRequest($method, $uri, array $headers = [], array $body = [])
    {
        foreach ($body as $item) {
            $name = $item['name'];
            $content = $item['content'];
            unset($item['name'], $item['content']);

            $this->multipartStreamBuilder->addResource($name, $content, $item);
        }

        $multipartStream = $this->multipartStreamBuilder->build();
        $boundary = $this->multipartStreamBuilder->getBoundary();

        $headers['Content-Type'] = 'multipart/form-data; boundary='.$boundary;

        return $this->requestFactory->createRequest($method, $uri, $headers, $multipartStream);
    }
}