MultipartStream::addElement() - Code Metrics - Inspection of ":sparkles: +MultipartStream" - chillerlan/php-httpinterface - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 71b082...d4eb58 )

by smiley

created 2018-12-23 14:42 UTC

MultipartStream::addElement() F

↳ Parent: MultipartStream

Complexity

Conditions	15
Paths	650

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	15
nc	650
nop	1
dl	0
loc	61
rs	2.2361
c	0
b	0
f	0

How to fix Long Method Complexity

<?php
/**
 * Class MultipartStream
 *
 * @link https://github.com/guzzle/psr7/blob/master/src/MultipartStream.php
 *
 * @filesource   MultipartStream.php
 * @created      20.12.2018
 * @package      chillerlan\HTTP\Psr7
 * @author       smiley <[email protected]>
 * @copyright    2018 smiley
 * @license      MIT
 */

namespace chillerlan\HTTP\Psr7;

use chillerlan\HTTP\Psr17;
use InvalidArgumentException, RuntimeException;

/**
 * @property \chillerlan\HTTP\Psr7\AppendStream $stream
 */
final class MultipartStream extends StreamAbstract{

	/**
	 * @var string
	 */
	protected $boundary;

	/**
	 * @var \Psr\Http\Message\StreamFactoryInterface
	 */
	protected $streamFactory;

	/**
	 * @var bool
	 */
	protected $built = false;

	/**
	 * MultipartStream constructor.
	 *
	 * @param array        $elements [

	 *                                   name => string,
	 *                                   contents => StreamInterface/resource/string,
	 *                                   headers => array,
	 *                                   filename => string
	 *                               ]
	 * @param string|null  $boundary
	 */
	public function __construct(array $elements = null, string $boundary = null){
		$this->boundary = $boundary ?? sha1(random_bytes(1024));
		$this->stream   = Psr17\create_stream();

		foreach($elements ?? [] as $element){
			$this->addElement($element);
		}

	}

	/**
	 * @return string
	 */
	public function getBoundary():string{
		return $this->boundary;
	}

	/**
	 * @return \chillerlan\HTTP\Psr7\MultipartStream
	 */
	public function build():MultipartStream{

		if(!$this->built){
			$this->stream->write("--{$this->getBoundary()}--\r\n");
		}

		$this->stream->rewind();

		$this->built = true;

		return $this;
	}

	/**
	 * @param array $e
	 *
	 * @return \chillerlan\HTTP\Psr7\MultipartStream
	 */
	public function addElement(array $e):MultipartStream{

		if($this->built){
			throw new RuntimeException('Stream already built');
		}

		$e = array_merge(['filename' => null, 'headers' => []], $e);

		foreach(['contents', 'name'] as $key){
			if(!isset($e[$key])){
				throw new InvalidArgumentException('A "'.$key.'" element is required');
			}
		}

		$e['contents'] = Psr17\create_stream_from_input($e['contents']);

		if(empty($e['filename'])){
			$uri = $e['contents']->getMetadata('uri');

			if(substr($uri, 0, 6) !== 'php://'){
				$e['filename'] = $uri;
			}
		}

		$hasFilename = $e['filename'] === '0' || $e['filename'];

		// Set a default content-disposition header if none was provided
		if(!$this->hasHeader($e['headers'], 'content-disposition')){
			$e['headers']['Content-Disposition'] = 'form-data; name="'.$e['name'].'"'.($hasFilename ? '; filename="'.basename($e['filename']).'"' : '');
		}

		// Set a default content-length header if none was provided
		if(!$this->hasHeader($e['headers'], 'content-length')){
			$length = $e['contents']->getSize();

			if($length){
				$e['headers']['Content-Length'] = $length;
			}
		}

		// Set a default Content-Type if none was supplied
		if(!$this->hasHeader($e['headers'], 'content-type') && $hasFilename){
			$type = MIMETYPES[pathinfo($e['filename'], PATHINFO_EXTENSION)] ?? null;

			if($type){
				$e['headers']['Content-Type'] = $type;
			}
		}


		$this->stream->write('--'.$this->boundary."\r\n");

		foreach($e['headers'] as $key => $value){
			$this->stream->write($key.': '.$value."\r\n");
		}

		$this->stream->write("\r\n".$e['contents']->getContents()."\r\n");


		return $this;
	}


	private function hasHeader(array $headers, $key){
		$lowercaseHeader = strtolower($key);
		foreach ($headers as $k => $v) {
			if (strtolower($k) === $lowercaseHeader) {
				return true;
			}
		}

		return false;
	}

	/**
	 * @inheritdoc
	 */
	public function __toString(){
		return $this->getContents();
	}

	/**
	 * @inheritdoc
	 */
	public function getSize():?int{
		return $this->stream->getSize() + strlen($this->boundary) + 6;
	}

	/**
	 * @inheritdoc
	 */
	public function isWritable():bool{
		return false;
	}

	/**
	 * @inheritdoc
	 */
	public function write($string):int{
		throw new RuntimeException('Cannot write to a MultipartStream, use the "addElement" method instead.');
	}

	/**
	 * @inheritdoc
	 */
	public function isReadable():bool{
		return true;
	}

	/**
	 * @inheritdoc
	 */
	public function getContents():string{
		return $this->build()->stream->getContents();
	}

}


1			<?php
2			/**
3			* Class MultipartStream
4			*
5			* @link https://github.com/guzzle/psr7/blob/master/src/MultipartStream.php
6			*
7			* @filesource MultipartStream.php
8			* @created 20.12.2018
9			* @package chillerlan\HTTP\Psr7
10			* @author smiley <[email protected]>
11			* @copyright 2018 smiley
12			* @license MIT
13			*/
14
15			namespace chillerlan\HTTP\Psr7;
16
17			use chillerlan\HTTP\Psr17;
18			use InvalidArgumentException, RuntimeException;
19
20			/**
21			* @property \chillerlan\HTTP\Psr7\AppendStream $stream
22			*/
23			final class MultipartStream extends StreamAbstract{
24
25			/**
26			* @var string
27			*/
28			protected $boundary;
29
30			/**
31			* @var \Psr\Http\Message\StreamFactoryInterface
32			*/
33			protected $streamFactory;
34
35			/**
36			* @var bool
37			*/
38			protected $built = false;
39
40			/**
41			* MultipartStream constructor.
42			*
43			* @param array $elements [
			0 ignored issues – show Documentation introduced 2018-12-23 14:44 UTC by Report Bug Copy Issue Report Should the type for parameter `$elements` not be `null\|array`? Also, consider making the array more specific, something like `array<String>`, or `String[]`. This check looks for `@param` annotations where the type inferred by our type inference engine differs from the declared type. It makes a suggestion as to what type it considers more descriptive. In addition it looks for parameters that have the generic type `array` and suggests a stricter type like `array<String>`. Most often this is a case of a parameter that can be null in addition to its declared types. Loading history...
44			* name => string,
45			* contents => StreamInterface/resource/string,
46			* headers => array,
47			* filename => string
48			* ]
49			* @param string\|null $boundary
50			*/
51			public function __construct(array $elements = null, string $boundary = null){
52			$this->boundary = $boundary ?? sha1(random_bytes(1024));
53			$this->stream = Psr17\create_stream();
54
55			foreach($elements ?? [] as $element){
56			$this->addElement($element);
57			}
58
59			}
60
61			/**
62			* @return string
63			*/
64			public function getBoundary():string{
65			return $this->boundary;
66			}
67
68			/**
69			* @return \chillerlan\HTTP\Psr7\MultipartStream
70			*/
71			public function build():MultipartStream{
72
73			if(!$this->built){
74			$this->stream->write("--{$this->getBoundary()}--\r\n");
75			}
76
77			$this->stream->rewind();
78
79			$this->built = true;
80
81			return $this;
82			}
83
84			/**
85			* @param array $e
86			*
87			* @return \chillerlan\HTTP\Psr7\MultipartStream
88			*/
89			public function addElement(array $e):MultipartStream{
90
91			if($this->built){
92			throw new RuntimeException('Stream already built');
93			}
94
95			$e = array_merge(['filename' => null, 'headers' => []], $e);
96
97			foreach(['contents', 'name'] as $key){
98			if(!isset($e[$key])){
99			throw new InvalidArgumentException('A "'.$key.'" element is required');
100			}
101			}
102
103			$e['contents'] = Psr17\create_stream_from_input($e['contents']);
104
105			if(empty($e['filename'])){
106			$uri = $e['contents']->getMetadata('uri');
107
108			if(substr($uri, 0, 6) !== 'php://'){
109			$e['filename'] = $uri;
110			}
111			}
112
113			$hasFilename = $e['filename'] === '0' \|\| $e['filename'];
114
115			// Set a default content-disposition header if none was provided
116			if(!$this->hasHeader($e['headers'], 'content-disposition')){
117			$e['headers']['Content-Disposition'] = 'form-data; name="'.$e['name'].'"'.($hasFilename ? '; filename="'.basename($e['filename']).'"' : '');
118			}
119
120			// Set a default content-length header if none was provided
121			if(!$this->hasHeader($e['headers'], 'content-length')){
122			$length = $e['contents']->getSize();
123
124			if($length){
125			$e['headers']['Content-Length'] = $length;
126			}
127			}
128
129			// Set a default Content-Type if none was supplied
130			if(!$this->hasHeader($e['headers'], 'content-type') && $hasFilename){
131			$type = MIMETYPES[pathinfo($e['filename'], PATHINFO_EXTENSION)] ?? null;
132
133			if($type){
134			$e['headers']['Content-Type'] = $type;
135			}
136			}
137
138
139			$this->stream->write('--'.$this->boundary."\r\n");
140
141			foreach($e['headers'] as $key => $value){
142			$this->stream->write($key.': '.$value."\r\n");
143			}
144
145			$this->stream->write("\r\n".$e['contents']->getContents()."\r\n");
146
147
148			return $this;
149			}
150
151
152			private function hasHeader(array $headers, $key){
153			$lowercaseHeader = strtolower($key);
154			foreach ($headers as $k => $v) {
155			if (strtolower($k) === $lowercaseHeader) {
156			return true;
157			}
158			}
159
160			return false;
161			}
162
163			/**
164			* @inheritdoc
165			*/
166			public function __toString(){
167			return $this->getContents();
168			}
169
170			/**
171			* @inheritdoc
172			*/
173			public function getSize():?int{
174			return $this->stream->getSize() + strlen($this->boundary) + 6;
175			}
176
177			/**
178			* @inheritdoc
179			*/
180			public function isWritable():bool{
181			return false;
182			}
183
184			/**
185			* @inheritdoc
186			*/
187			public function write($string):int{
188			throw new RuntimeException('Cannot write to a MultipartStream, use the "addElement" method instead.');
189			}
190
191			/**
192			* @inheritdoc
193			*/
194			public function isReadable():bool{
195			return true;
196			}
197
198			/**
199			* @inheritdoc
200			*/
201			public function getContents():string{
202			return $this->build()->stream->getContents();
203			}
204
205			}
206

chillerlan / php-httpinterface

Push — master ( 71b082...d4eb58 )

MultipartStream::addElement() F

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like