Cerbero\Workflow\Workflow

Complexity

Total Complexity

7

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes	6
Bugs	1	Features	1

5 Methods

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

<?php

namespace Cerbero\Workflow;

use Cerbero\Workflow\Inflectors\InflectorInterface;
use Cerbero\Workflow\Repositories\PipelineRepositoryInterface;
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');
    }
}