ReactInspector\HttpMiddleware\MiddlewareCollector

Complexity

Total Complexity

2

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	__invoke()	0	28	1

<?php

declare(strict_types=1);

namespace ReactInspector\HttpMiddleware;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use React\Promise\PromiseInterface;

The type React\Promise\PromiseInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use WyriHaximus\Metrics\Label;
use WyriHaximus\Metrics\Registry\Counters;
use WyriHaximus\Metrics\Registry\Gauges;
use WyriHaximus\Metrics\Registry\Summaries;

use function React\Promise\resolve;
use function Safe\hrtime;
use function strtoupper;

final class MiddlewareCollector
{
    public const LABELS_ATTRIBUTE = 'react-inspector-http-middleware-labels-iugioawfe';

    /** @var array<Label> */
    private array $defaultLabels;

    private Gauges $inflight;

    private Counters $requests;

    private Summaries $responseTime;

    public function __construct(Metrics $metrics)
    {
        $this->defaultLabels = $metrics->defaultLabels();
        $this->inflight      = $metrics->inflight();
        $this->requests      = $metrics->requests();
        $this->responseTime  = $metrics->responseTime();
    }

    /** @return PromiseInterface<ResponseInterface> */
    public function __invoke(ServerRequestInterface $request, callable $next): PromiseInterface
    {
        $method = strtoupper($request->getMethod());
        $gauge  = $this->inflight->gauge(new Label('method', $method), ...$this->defaultLabels);
        $gauge->incr();
        $labels  = new Labels();
        $request = $request->withAttribute(self::LABELS_ATTRIBUTE, $labels);
        $time    = hrtime(true);

        return resolve($next($request))->then(function (ResponseInterface $response) use ($method, $gauge, $time, $labels): ResponseInterface {
            /** @psalm-suppress PossiblyInvalidOperand */
            $this->responseTime->summary(
                new Label('method', $method),
                new Label('code', (string) $response->getStatusCode()),
                ...$this->defaultLabels,
                ...$labels->labels(),
            )->observe(
                (hrtime(true) - $time) / 1e+9, /** @phpstan-ignore-line */
            );
            $this->requests->counter(
                new Label('method', $method),
                new Label('code', (string) $response->getStatusCode()),
                ...$this->defaultLabels,
                ...$labels->labels(),
            )->incr();
            $gauge->dcr();

            return $response;
        });
    }
}