PhpJsonRpc\Common\Interceptor\Interceptor

Complexity

Total Complexity

9

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	createBase()	0	4	1
A	createWith()	0	7	1
A	add()	0	10	2
A	handle()	0	21	4

<?php

namespace PhpJsonRpc\Common\Interceptor;

/**
 * Based on "Chain of Responsibility" pattern
 */
class Interceptor
{
    /**
     * @var Interceptor
     */
    private $next;

    /**
     * @var callable
     */
    private $callback;

    /**
     * Chain constructor.
     */
    private function __construct()
    {
        $this->next     = null;
        $this->callback = null;
    }

    /**
     * @return Interceptor
     */
    public static function createBase(): Interceptor
    {
        return new Interceptor();
    }

    /**
     * @param callable $callback
     *
     * @return Interceptor
     */
    public static function createWith(callable $callback): Interceptor
    {
        $element = new Interceptor();
        $element->callback = $callback;

        return $element;
    }

    /**
     * @param Interceptor $element
     *
     * @return $this
     */
    public function add(Interceptor $element)
    {
        if ($this->next) {
            $this->next->add($element);
        } else {
            $this->next = $element;
        }

        return $this;
    }

    /**
     * @param AbstractContainer $container
     *
     * @return mixed
     */
    public function handle(AbstractContainer $container): AbstractContainer
    {
        // Execute callback and pass result next chain
        if (is_callable($this->callback)) {
            $result = call_user_func($this->callback, $container);

            if (!$this->next) {
                return $result;
            }

            return $this->next->handle($result);
        }

        // End of chain
        if (!$this->next) {
            return $container;
        }

        // Execute next chain
        return $this->next->handle($container);
    }
}