WPEmerge\Routing\PipelineHandler

Complexity

Total Complexity

8

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	12	2
A	__construct()	0	2	1
A	get()	0	2	1
A	getResponse()	0	14	4

<?php
/**
 * @package   WPEmerge
 * @author    Atanas Angelov <atanas.angelov.dev@gmail.com>
 * @copyright 2018 Atanas Angelov
 * @license   https://www.gnu.org/licenses/gpl-2.0.html GPL-2.0
 * @link      https://wpemerge.com/
 */

namespace WPEmerge\Routing;

use Psr\Http\Message\ResponseInterface;
use WPEmerge\Exceptions\Exception;
use WPEmerge\Facades\Response;
use WPEmerge\Helpers\Handler;
use WPEmerge\Responses\ResponsableInterface;

/**
 * Represent a Closure or a controller method to be executed in response to a request
 */
class PipelineHandler {
	/**
	 * Actual handler
	 *
	 * @var Handler
	 */
	protected $handler = null;

	/**
	 * Constructor
	 *
	 * @param string|\Closure $handler
	 * @throws Exception
	 */
	public function __construct( $handler ) {
		$this->handler = new Handler( $handler, '', '\\App\\Controllers\\' );
	}

	/**
	 * Get the handler
	 *
	 * @return Handler
	 */
	public function get() {
		return $this->handler;
	}

	/**
	 * Convert a user returned response to a ResponseInterface instance if possible.
	 * Return the original value if unsupported.
	 *
	 * @param  mixed $response
	 * @return mixed
	 */
	protected function getResponse( $response ) {
		if ( is_string( $response ) ) {
			return Response::output( $response );
		}

		if ( is_array( $response ) ) {
			return Response::json( $response );
		}

		if ( $response instanceof ResponsableInterface ) {
			return $response->toResponse();
		}

		return $response;
	}

	/**
	 * Execute the handler
	 *
	 * @throws Exception
	 * @param  mixed             ...$arguments
	 * @return ResponseInterface
	 */
	public function execute() {
		$response = call_user_func_array( [$this->handler, 'execute'], func_get_args() );
		$response = $this->getResponse( $response );

		if ( ! $response instanceof ResponseInterface ) {
			throw new Exception(
				'Response returned by controller is not valid ' .
				'(expected ' . ResponseInterface::class . '; received ' . gettype( $response ) . ').'
			);
		}

		return $response;
	}
}