Ackintosh\Ganesha\GuzzleMiddleware

Complexity

Total Complexity

4

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	23	2
A	__construct()	0	6	2

<?php
namespace Ackintosh\Ganesha;

use Ackintosh\Ganesha;
use Ackintosh\Ganesha\Exception\RejectedException;
use Ackintosh\Ganesha\GuzzleMiddleware\ServiceNameExtractor;
use Ackintosh\Ganesha\GuzzleMiddleware\ServiceNameExtractorInterface;
use Psr\Http\Message\RequestInterface;

class GuzzleMiddleware
{
    /**
     * @var \Ackintosh\Ganesha
     */
    private $ganesha;

    /*
     * @var ResourceNameExtractorInterface

The type Ackintosh\Ganesha\ResourceNameExtractorInterface was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    private $serviceNameExtractor;

    public function __construct(
        Ganesha $ganesha,
        ServiceNameExtractorInterface $serviceNameExtractor = null
    ) {
        $this->ganesha = $ganesha;
        $this->serviceNameExtractor = $serviceNameExtractor ?: new ServiceNameExtractor();

It seems like $serviceNameExtractor ?: new Ackintosh\Ganesha\GuzzleMiddleware\ServiceNameExtractor() of type Ackintosh\Ganesha\GuzzleMiddleware\ServiceNameExtractor or Ackintosh\Ganesha\GuzzleMiddleware\ServiceNameExtractorInterface is incompatible with the declared type Ackintosh\Ganesha\ResourceNameExtractorInterface of property $serviceNameExtractor.

    }

    /**
     * @param callable $handler
     * @return \Closure
     */
    public function __invoke(callable $handler): \Closure
    {
        return function (RequestInterface $request, array $options) use ($handler) {
            $serviceName = $this->serviceNameExtractor->extract($request, $options);

            if (!$this->ganesha->isAvailable($serviceName)) {
                return \GuzzleHttp\Promise\rejection_for(
                    new RejectedException(
                        sprintf('"%s" is not available', $serviceName)
                    )
                );
            }

            $promise = $handler($request, $options);

            return $promise->then(
                function ($value) use ($serviceName) {
                    $this->ganesha->success($serviceName);
                    return \GuzzleHttp\Promise\promise_for($value);
                },
                function ($reason) use ($serviceName) {
                    $this->ganesha->failure($serviceName);
                    return \GuzzleHttp\Promise\rejection_for($reason);
                }
            );
        };
    }
}