Fitbug\Guzzle\SwaggerValidation\SwaggerSchemaValidationHandler

Complexity

Total Complexity

7

Size/Duplication

Total Lines	104
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	6

Test Coverage

Coverage

30.76%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	17	3
A	setSkip()	0	4	1
B	__invoke()	0	34	3

<?php

namespace Fitbug\Guzzle\SwaggerValidation;

use FR3D\SwaggerAssertions\PhpUnit\Psr7AssertsTrait;
use FR3D\SwaggerAssertions\SchemaManager;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * Middleware that wraps around the PSR7 Assertion handler to make it work for guzzle.
 */
class SwaggerSchemaValidationHandler
{
    use Psr7AssertsTrait;

    /**
     * @var SchemaManager
     */
    private $schemaManager;

    /**
     * @var bool
     */
    private $skip;
    /**
     * @var Psr7RequestPrinterInterface
     */
    private $psr7RequestPrinter;
    /**
     * @var Psr7ResponsePrinterInterface
     */
    private $psr7ResponsePrinter;

    /**
     * @var string
     */
    private $uri;

    /**
     * SwaggerSchemaValidationHandler constructor.
     *
     * @param string                            $uri
     * @param Psr7RequestPrinterInterface|null  $psr7RequestPrinter
     * @param Psr7ResponsePrinterInterface|null $psr7ResponsePrinter
     */
    public function __construct(
        $uri,
        Psr7RequestPrinterInterface $psr7RequestPrinter = null,
        Psr7ResponsePrinterInterface $psr7ResponsePrinter = null
    ) {
        $this->uri = $uri;

        if (!$psr7RequestPrinter) {
            $psr7RequestPrinter = new Psr7RequestPrinter();
        }
        $this->psr7RequestPrinter = $psr7RequestPrinter;

        if (!$psr7ResponsePrinter) {
            $psr7ResponsePrinter = new Psr7ResponsePrinter();
        }
        $this->psr7ResponsePrinter = $psr7ResponsePrinter;
    }

    /**
     * Disable (or enable) the middleware's testing temporarily.
     *
     * @param bool $skip
     */
    public function setSkip($skip)
    {
        $this->skip = $skip;
    }

    /**
     * Guzzle Middleware.
     *
     * @param callable $handler
     *
     * @return \Closure
     */
    public function __invoke(callable $handler)
    {
        return function (
            RequestInterface $request,
            array $options
        ) use ($handler) {
            $promise = $handler($request, $options);

            return $promise->then(
                function (ResponseInterface $response) use ($request) {
                    if (!$this->skip) {
                        // This needs to be done every time as it modifies itself during the validation
                        // meaning the second request will fail.
                        $schemaManager = $this->schemaManager = SchemaManager::fromUri($this->uri);

                        try {
                            $this->assertResponseAndRequestMatch($response, $request, $schemaManager);
                        } catch (\Exception $e) {
                            $requestString = $this->psr7RequestPrinter->toString($request);
                            $responseString = $this->psr7ResponsePrinter->toString($response);

                            throw new \Exception(
                                "{$e->getMessage()}\n\n$requestString\n\n\n$responseString\n",
                                $e->getCode(),
                                $e
                            );
                        }
                    }

                    return $response;
                }
            );
        };
    }
}