RequestBuilder::build() - Code Metrics - Inspection of "Merge pull request #72 from tebru/v3" - tebru/retrofit-php - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Branch — master (203e41)

by Nate

created 2017-09-12 22:59 UTC

RequestBuilder::build() C

↳ Parent: RequestBuilder

Complexity

Conditions	7
Paths	21

Size

Total Lines	28
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	16
CRAP Score	7

Importance

Changes

Metric	Value
dl	0
loc	28
ccs	16
cts	16
cp	1
rs	6.7272
c	0
b	0
f	0
cc	7
eloc	16
nc	21
nop	0
crap	7

<?php
/*
 * Copyright (c) Nate Brunette.
 * Distributed under the MIT License (http://opensource.org/licenses/MIT)
 */

declare(strict_types=1);

namespace Tebru\Retrofit\Internal;

use GuzzleHttp\Psr7;
use GuzzleHttp\Psr7\MultipartStream;
use GuzzleHttp\Psr7\Request;
use GuzzleHttp\Psr7\Uri;
use LogicException;
use Psr\Http\Message\StreamInterface;

/**
 * Class RequestBuilder
 *
 * @author Nate Brunette <[email protected]>
 */
final class RequestBuilder
{
    /**
     * The request method
     *
     * @var string
     */
    private $method;

    /**
     * The request [@see Uri] object
     *
     * @var Uri
     */
    private $uri;

    /**
     * An array of query strings that can be appended together
     *
     * @var array
     */
    private $queries = [];

    /**
     * An array of headers in PSR-7 format
     *
     * @var array
     */
    private $headers;

    /**
     * The request body
     *
     * @var StreamInterface
     */
    private $body;

    /**
     * An array of request body fields that can be appended together
     *
     * @var array
     */
    private $fields = [];

    /**
     * An array of arrays of multipart parts, each with name, content, headers, and filename
     *
     * @var array[]
     */
    private $parts = [];

    /**
     * Constructor
     *
     * @param string $method
     * @param string $baseUrl
     * @param string $uri
     * @param array $headers
     */
    public function __construct(string $method, string $baseUrl, string $uri, array $headers)
    {
        $this->method = $method;
        $this->uri = new Uri($baseUrl.$uri);
        $this->headers = $headers;
    }

    /**
     * Set the uri base url
     *
     * @param string $value
     */
    public function setBaseUrl(string $value): void
    {
        $uri = new Uri($value);
        $this->uri = $this->uri
            ->withScheme($uri->getScheme())
            ->withHost($uri->getHost())
            ->withPort($uri->getPort());
    }

    /**
     * Replace a url path placeholder with a value
     *
     * @param string $name
     * @param string $value
     */
    public function replacePath(string $name, string $value): void
    {
        $path = rawurldecode($this->uri->getPath());
        $path = str_replace(sprintf('{%s}', $name), $value, $path);
        $this->uri = $this->uri->withPath($path);
    }

    /**
     * Add a query string; if encoded, decodes to be encoded later
     *
     * @param string $name
     * @param string $value
     * @param bool $encoded
     */
    public function addQuery(string $name, string $value, bool $encoded): void
    {
        if ($encoded === true) {
            $name = rawurldecode($name);
            $value = rawurldecode($value);
        }

        $this->queries[] = $name.'='.$value;
    }

    /**
     * Adds a query string without value; if encoded, decodes to be encoded later
     *
     * @param string $value
     * @param bool $encoded
     */
    public function addQueryName(string $value, bool $encoded): void
    {
        if ($encoded === true) {
            $value = rawurldecode($value);
        }

        $this->queries[] = $value;
    }

    /**
     * Add a header in PSR-7 format
     *
     * @param string $name
     * @param string $value
     */
    public function addHeader(string $name, string $value): void
    {
        $name = strtolower($name);
        $this->headers[$name][] = $value;
    }

    /**
     * Set the request body
     *
     * @param StreamInterface $body
     */
    public function setBody(StreamInterface $body): void
    {
        $this->body = $body;
    }

    /**
     * Add a field; if not encoded, encodes first
     *
     * @param string $name
     * @param string $value
     * @param bool $encoded
     */
    public function addField(string $name, string $value, bool $encoded): void
    {
        if ($encoded === false) {
            $name = rawurlencode($name);
            $value = rawurlencode($value);
        }

        $this->fields[] = $name.'='.$value;
    }

    /**
     * Add a multipart part
     *
     * @param string $name
     * @param StreamInterface $contents
     * @param array $headers
     * @param null|string $filename
     */
    public function addPart(string $name, StreamInterface $contents, array $headers = [], ?string $filename = null): void
    {
        $this->parts[] = [
            'name' => $name,
            'contents' => $contents,
            'headers' => $headers,
            'filename' => $filename,
        ];
    }

    /**
     * Create a PSR-7 request
     *
     * @return Request
     * @throws \LogicException
     */
    public function build(): Request
    {
        $uri = $this->uri;
        if ($this->queries !== []) {
            $query = implode('&', $this->queries);
            $uri = $this->uri->getQuery() === ''
                ? $this->uri->withQuery($query)
                : $this->uri->withQuery($query.'&'.$this->uri->getQuery());
        }

        if ($this->fields !== []) {
            if ($this->body !== null) {
                throw new LogicException('Retrofit: Cannot mix @Field and @Body annotations.');
            }

            $this->body = Psr7\stream_for(implode('&', $this->fields));
        }

        if ($this->parts !== []) {
            if ($this->body !== null) {
                throw new LogicException('Retrofit: Cannot mix @Part and @Body annotations.');
            }

            $this->body = new MultipartStream($this->parts);
        }

        return new Request($this->method, $uri, $this->headers, $this->body);
    }
}


1		<?php
2		/*
3		* Copyright (c) Nate Brunette.
4		* Distributed under the MIT License (http://opensource.org/licenses/MIT)
5		*/
6
7		declare(strict_types=1);
8
9		namespace Tebru\Retrofit\Internal;
10
11		use GuzzleHttp\Psr7;
12		use GuzzleHttp\Psr7\MultipartStream;
13		use GuzzleHttp\Psr7\Request;
14		use GuzzleHttp\Psr7\Uri;
15		use LogicException;
16		use Psr\Http\Message\StreamInterface;
17
18		/**
19		* Class RequestBuilder
20		*
21		* @author Nate Brunette <[email protected]>
22		*/
23		final class RequestBuilder
24		{
25		/**
26		* The request method
27		*
28		* @var string
29		*/
30		private $method;
31
32		/**
33		* The request [@see Uri] object
34		*
35		* @var Uri
36		*/
37		private $uri;
38
39		/**
40		* An array of query strings that can be appended together
41		*
42		* @var array
43		*/
44		private $queries = [];
45
46		/**
47		* An array of headers in PSR-7 format
48		*
49		* @var array
50		*/
51		private $headers;
52
53		/**
54		* The request body
55		*
56		* @var StreamInterface
57		*/
58		private $body;
59
60		/**
61		* An array of request body fields that can be appended together
62		*
63		* @var array
64		*/
65		private $fields = [];
66
67		/**
68		* An array of arrays of multipart parts, each with name, content, headers, and filename
69		*
70		* @var array[]
71		*/
72		private $parts = [];
73
74		/**
75		* Constructor
76		*
77		* @param string $method
78		* @param string $baseUrl
79		* @param string $uri
80		* @param array $headers
81		*/
82	56	public function __construct(string $method, string $baseUrl, string $uri, array $headers)
83		{
84	56	$this->method = $method;
85	56	$this->uri = new Uri($baseUrl.$uri);
86	56	$this->headers = $headers;
87	56	}
88
89		/**
90		* Set the uri base url
91		*
92		* @param string $value
93		*/
94	4	public function setBaseUrl(string $value): void
95		{
96	4	$uri = new Uri($value);
97	4	$this->uri = $this->uri
98	4	->withScheme($uri->getScheme())
99	4	->withHost($uri->getHost())
100	4	->withPort($uri->getPort());
101	4	}
102
103		/**
104		* Replace a url path placeholder with a value
105		*
106		* @param string $name
107		* @param string $value
108		*/
109	4	public function replacePath(string $name, string $value): void
110		{
111	4	$path = rawurldecode($this->uri->getPath());
112	4	$path = str_replace(sprintf('{%s}', $name), $value, $path);
113	4	$this->uri = $this->uri->withPath($path);
114	4	}
115
116		/**
117		* Add a query string; if encoded, decodes to be encoded later
118		*
119		* @param string $name
120		* @param string $value
121		* @param bool $encoded
122		*/
123	7	public function addQuery(string $name, string $value, bool $encoded): void
124		{
125	7	if ($encoded === true) {
126	1	$name = rawurldecode($name);
127	1	$value = rawurldecode($value);
128		}
129
130	7	$this->queries[] = $name.'='.$value;
131	7	}
132
133		/**
134		* Adds a query string without value; if encoded, decodes to be encoded later
135		*
136		* @param string $value
137		* @param bool $encoded
138		*/
139	5	public function addQueryName(string $value, bool $encoded): void
140		{
141	5	if ($encoded === true) {
142	1	$value = rawurldecode($value);
143		}
144
145	5	$this->queries[] = $value;
146	5	}
147
148		/**
149		* Add a header in PSR-7 format
150		*
151		* @param string $name
152		* @param string $value
153		*/
154	6	public function addHeader(string $name, string $value): void
155		{
156	6	$name = strtolower($name);
157	6	$this->headers[$name][] = $value;
158	6	}
159
160		/**
161		* Set the request body
162		*
163		* @param StreamInterface $body
164		*/
165	6	public function setBody(StreamInterface $body): void
166		{
167	6	$this->body = $body;
168	6	}
169
170		/**
171		* Add a field; if not encoded, encodes first
172		*
173		* @param string $name
174		* @param string $value
175		* @param bool $encoded
176		*/
177	8	public function addField(string $name, string $value, bool $encoded): void
178		{
179	8	if ($encoded === false) {
180	7	$name = rawurlencode($name);
181	7	$value = rawurlencode($value);
182		}
183
184	8	$this->fields[] = $name.'='.$value;
185	8	}
186
187		/**
188		* Add a multipart part
189		*
190		* @param string $name
191		* @param StreamInterface $contents
192		* @param array $headers
193		* @param null\|string $filename
194		*/
195	9	public function addPart(string $name, StreamInterface $contents, array $headers = [], ?string $filename = null): void
196		{
197	9	$this->parts[] = [
198	9	'name' => $name,
199	9	'contents' => $contents,
200	9	'headers' => $headers,
201	9	'filename' => $filename,
202		];
203	9	}
204
205		/**
206		* Create a PSR-7 request
207		*
208		* @return Request
209		* @throws \LogicException
210		*/
211	22	public function build(): Request
212		{
213	22	$uri = $this->uri;
214	22	if ($this->queries !== []) {
215	3	$query = implode('&', $this->queries);
216	3	$uri = $this->uri->getQuery() === ''
217	1	? $this->uri->withQuery($query)
218	3	: $this->uri->withQuery($query.'&'.$this->uri->getQuery());
219		}
220
221	22	if ($this->fields !== []) {
222	4	if ($this->body !== null) {
223	1	throw new LogicException('Retrofit: Cannot mix @Field and @Body annotations.');
224		}
225
226	3	$this->body = Psr7\stream_for(implode('&', $this->fields));
227		}
228
229	21	if ($this->parts !== []) {
230	4	if ($this->body !== null) {
231	1	throw new LogicException('Retrofit: Cannot mix @Part and @Body annotations.');
232		}
233
234	3	$this->body = new MultipartStream($this->parts);
235		}
236
237	20	return new Request($this->method, $uri, $this->headers, $this->body);
238		}
239		}
240

tebru / retrofit-php

Branch — master (203e41)

RequestBuilder::build() C

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like