Cerbero\Workflow\Workflow

Complexity

Total Complexity

7

Size/Duplication

Total Lines	119
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	5
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	__call()	0	8	1
A	failIfNotExists()	0	9	2
A	dispatchWorkflow()	0	12	1
A	resolveRequest()	0	9	2

<?php namespace Cerbero\Workflow;

use Cerbero\Workflow\Repositories\PipelineRepositoryInterface;
use Cerbero\Workflow\Inflectors\InflectorInterface;
use Cerbero\Workflow\Wrappers\DispatcherInterface;
use Illuminate\Contracts\Container\Container;

/**
 * Hub of the pipelines.
 *
 * @author	Andrea Marco Sartori
 */
class Workflow {

	/**
	 * @author	Andrea Marco Sartori
	 * @var		Cerbero\Workflow\Repositories\PipelineRepositoryInterface	$pipelines	Pipelines repository.
	 */
	protected $pipelines;

	/**
	 * @author	Andrea Marco Sartori
	 * @var		Cerbero\Workflow\Inflectors\InflectorInterface	$inflector	Inflector.
	 */
	protected $inflector;

	/**
	 * @author	Andrea Marco Sartori
	 * @var		Illuminate\Contracts\Container\Container	$container	Service container.
	 */
	protected $container;

	/**
	 * @author	Andrea Marco Sartori
	 * @var		Cerbero\Workflow\Wrappers\DispatcherInterface	$dispatcher	Bus dispatcher.
	 */
	protected $dispatcher;
	
	/**
	 * Set the dependencies.
	 *
	 * @author	Andrea Marco Sartori
	 * @param	Cerbero\Workflow\Repositories\PipelineRepositoryInterface	$pipelines
	 * @param	Cerbero\Workflow\Wrappers\DispatcherInterface	$dispatcher
	 * @param	Cerbero\Workflow\Inflectors\InflectorInterface	$inflector
	 * @param	Illuminate\Contracts\Container\Container	$container
	 * @return	void

Adding a @return annotation to constructors is generally not recommended as a constructor does not have a meaningful return value.

	 */
	public function __construct(
		PipelineRepositoryInterface $pipelines,
		InflectorInterface $inflector,
		Container $container,
		DispatcherInterface $dispatcher
	) {
		$this->pipelines  = $pipelines;

It seems like $pipelines of type object<Cerbero\Workflow\Repositories\PipelineRepositoryInterface> is incompatible with the declared type object<Cerbero\Workflow\Cerbero\Workflow\Repositories\PipelineRepositoryInterface> of property $pipelines.

		$this->inflector  = $inflector;

It seems like $inflector of type object<Cerbero\Workflow\Inflectors\InflectorInterface> is incompatible with the declared type object<Cerbero\Workflow\Cerbero\Workflow\Inflectors\InflectorInterface> of property $inflector.

		$this->container  = $container;

It seems like $container of type object<Illuminate\Contracts\Container\Container> is incompatible with the declared type object<Cerbero\Workflow\Illuminate\Contracts\Container\Container> of property $container.

		$this->dispatcher = $dispatcher;

It seems like $dispatcher of type object<Cerbero\Workflow\Wrappers\DispatcherInterface> is incompatible with the declared type object<Cerbero\Workflow\Cerbero\Workflow\Wrappers\DispatcherInterface> of property $dispatcher.

	}

	/**
	 * Dynamically call pipelines.
	 *
	 * @author	Andrea Marco Sartori
	 * @param	string	$name
	 * @param	array	$arguments
	 * @return	mixed
	 */
	public function __call($name, $arguments)
	{
		$this->failIfNotExists($name);

		$this->inflector->of($name);

		return $this->dispatchWorkflow($name);
	}

	/**
	 * Throw an exception if the given workflow does not exist.
	 *
	 * @author	Andrea Marco Sartori
	 * @param	string	$workflow
	 * @return	void
	 */
	protected function failIfNotExists($workflow)
	{
		if( ! $this->pipelines->exists($workflow))
		{
			$error = "The workflow [$workflow] does not exist.";

			throw new \BadFunctionCallException($error);
		}
	}

	/**
	 * Dispatch the given workflow.
	 *
	 * @author	Andrea Marco Sartori
	 * @param	string	$workflow
	 * @return	mixed
	 */
	protected function dispatchWorkflow($workflow)
	{
		$job = $this->inflector->getJob();

		$request = $this->resolveRequest();

		$pipes = $this->pipelines->getPipesByPipeline($workflow);

		$parameters = $this->container->make('router')->current()->parameters();

		return $this->dispatcher->pipeThrough($pipes)->dispatchFrom($job, $request, $parameters);
	}

	/**
	 * Resolve the apter request.
	 *
	 * @author	Andrea Marco Sartori
	 * @return	Illuminate\Http\Request
	 */
	protected function resolveRequest()
	{
		if(class_exists($request = $this->inflector->getRequest()))
		{
			return $this->container->make($request);
		}

		return $this->container->make('Illuminate\Http\Request');
	}

}