chillerlan\HTTP\Psr7\MultipartStream

Complexity

Total Complexity

31

Size/Duplication

Total Lines	198
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

<?php
final class MultipartStream extends StreamAbstract{

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

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected T_STRING, expecting T_FUNCTION or T_CONST

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

	/**
	 * MultipartStream constructor.
	 *
	 * @param array|null   $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   = 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->built = true;
		}

		$this->stream->rewind();

		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');
			}
		}

		// at this point we assume the string is already the file content and don't guess anymore
		$e['contents'] = is_string($e['contents'])
			? create_stream($e['contents'])
			: create_stream_from_input($e['contents']);

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

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

		$e = $this->setElementHeaders($e);

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

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

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

		return $this;
	}

	/**
	 * @param array $e
	 *
	 * @return array
	 */
	protected function setElementHeaders(array $e):array{
		$hasFilename = $e['filename'] === '0' || $e['filename'];

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

			$e['headers']['Content-Disposition'] = 'form-data; name="'.$e['name'].'"'.$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;
			}
		}

		return $e;
	}

	/**
	 * @param array  $headers
	 * @param string $key
	 *
	 * @return bool
	 */
	protected function hasHeader(array $headers, string $key):bool{
		$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 MultipartStream::addElement() instead.');
	}

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

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

}