UMA\JsonRpc\Internal\Pipeliner

Complexity

Total Complexity

3

Size/Duplication

Total Lines	24
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	build()	0	9	2
A	chain()	0	4	1

<?php

declare(strict_types=1);

namespace UMA\JsonRpc\Internal;

use Psr\Container\ContainerInterface;
use UMA\JsonRpc;

/**
 * Helper class to compose the pipeline of middlewares + procedure
 */
class Pipeliner
{
    /**
     * @param ContainerInterface $container
     * @param JsonRpc\Procedure  $procedure
     * @param string[]           $services
     *
     * @return callable
     */
    public static function build(ContainerInterface $container, JsonRpc\Procedure $procedure, array $services): callable
    {
        $pipe = $procedure;

        foreach ($services as $service => $_) {
            $pipe = self::chain($container->get($service), $pipe);
        }

        return $pipe;
    }

    private static function chain(JsonRpc\Middleware $outer, callable $inner): callable
    {
        return function (JsonRpc\Request $request) use ($outer, $inner): JsonRpc\Response {
            return $outer($request, $inner);
        };
    }
}