Hhxsv5\LaravelS\Components\Prometheus\Collectors\HttpRequestCollector

Complexity

Total Complexity

29

Size/Duplication

Total Lines	122
Duplicated Lines	0 %

Importance

Changes	7
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
B	findRouteUri()	0	26	9
B	collect()	0	50	8
C	__construct()	0	32	12

<?php

Missing file doc comment

namespace Hhxsv5\LaravelS\Components\Prometheus\Collectors;

use Closure;
use Hhxsv5\LaravelS\Components\MetricCollector;
use Illuminate\Http\Request;

The type Illuminate\Http\Request was not found. Maybe you did not declare it correctly or list all dependencies?

class HttpRequestCollector extends MetricCollector

Missing doc comment for class HttpRequestCollector

{
    const MAX_ROUND = 10;
    protected $routes          = [];
    protected $routesByUses    = [];
    protected $routesByClosure = [];

    public function __construct(array $config)

Missing doc comment for function __construct()

    {
        parent::__construct($config);
        
        if (!isset($this->config['max_duration_time_window'])) {
            $this->config['max_duration_time_window'] = 60;
        }

        $routes = method_exists(app(), 'getRoutes') ? app()->getRoutes() : app('router')->getRoutes();

The function app was not found. Maybe you did not declare it correctly or list all dependencies?

        if ($routes instanceof \Illuminate\Routing\RouteCollection) { // Laravel

The type Illuminate\Routing\RouteCollection was not found. Maybe you did not declare it correctly or list all dependencies?

            foreach ($routes->getRoutes() as $route) {
                $method = $route->methods()[0];
                $uri = '/' . ltrim($route->uri(), '/');
                $this->routes[$method . $uri] = $uri;

                $action = $route->getAction();
                if (is_string($action['uses'])) { // Uses
                    $this->routesByUses[$method . $action['uses']] = $uri;
                } elseif ($action['uses'] instanceof Closure) {  // Closure
                    $objectId = spl_object_hash($action['uses']);
                    $this->routesByClosure[$method . $objectId] = $uri;
                }
            }
        } elseif (is_array($routes)) { // Lumen
            $this->routes = $routes;
            foreach ($routes as $route) {
                if (isset($route['action']['uses'])) { // Uses
                    $this->routesByUses[$route['method'] . $route['action']['uses']] = $route['uri'];
                }
                if (isset($route['action'][0]) && $route['action'][0] instanceof Closure) { // Closure
                    $objectId = spl_object_hash($route['action'][0]);
                    $this->routesByClosure[$route['method'] . $objectId] = $route['uri'];
                }
            }
        }
    }

    public function collect(array $params = [])

Missing doc comment for function collect()

    {
        if (!$this->config['enable']) {
            return;
        }

        /**@var \Illuminate\Http\Request $request */

The open comment tag must be the only content on the line

Missing short description in doc comment

The close comment tag must be the only content on the line

        /**@var \Illuminate\Http\Response $response */

The open comment tag must be the only content on the line

Missing short description in doc comment

The close comment tag must be the only content on the line

        list($request, $response) = $params;

        $status = $response->getStatusCode();
        if (isset($this->config['ignored_http_codes'][$status])) {
            // Ignore the requests.
            return;
        }

        $uri = $this->findRouteUri($request);
        $cost = (int)round((microtime(true) - $request->server('REQUEST_TIME_FLOAT')) * 1000000); // Time unit: μs

        // Http Request Stats
        $requestLabels = http_build_query([

The opening parenthesis of a multi-line function call should be the last content on the line.

            'method' => $request->getMethod(),
            'uri'    => $uri,
            'status' => $status,
        ]);

For multi-line function calls, the closing parenthesis should be on a new line.

        // Key Format: prefix+metric_name+metric_type+metric_labels
        $countKey = implode($this->config['apcu_key_separator'], [$this->config['apcu_key_prefix'], 'http_server_requests_seconds_count', 'summary', $requestLabels]);
        $sumKey = implode($this->config['apcu_key_separator'], [$this->config['apcu_key_prefix'], 'http_server_requests_seconds_sum', 'summary', $requestLabels]);
        $maxKey = implode($this->config['apcu_key_separator'], [$this->config['apcu_key_prefix'], 'http_server_requests_seconds_max', 'gauge', $requestLabels]);
        apcu_inc($countKey, 1, $success, $this->config['apcu_key_max_age']);
        apcu_inc($sumKey, $cost, $success, $this->config['apcu_key_max_age']);

        $round = 0;
        do {
            $round++;
            $lastCost = apcu_fetch($maxKey);
            if ($lastCost === false) {
                if (!apcu_add($maxKey, $cost, $this->config['max_duration_time_window'])) {
                    continue;
                }
                break;
            }
            if ($cost <= $lastCost) {
                break;
            }
            if (apcu_cas($maxKey, $lastCost, $cost)) {
                break;
            }
        } while ($round <= self::MAX_ROUND);
    }

    protected function findRouteUri(Request $request)

Missing doc comment for function findRouteUri()

    {
        $method = $request->getMethod();
        $uri = $request->getPathInfo();
        $key = $method . $uri;
        if (isset($this->routes[$key])) {
            return $uri;
        }

        $route = $request->route();
        if ($route instanceof \Illuminate\Routing\Route) { // Laravel

The type Illuminate\Routing\Route was not found. Maybe you did not declare it correctly or list all dependencies?

            $uri = $route->uri();
        } elseif (is_array($route)) { // Lumen
            if (isset($route[1]['uses'])) {
                $key = $method . $route[1]['uses'];
                if (isset($this->routesByUses[$key])) {
                    $uri = $this->routesByUses[$key];
                }
            } elseif (isset($route[1][0]) && $route[1][0] instanceof Closure) {
                $key = $method . spl_object_hash($route[1][0]);
                if (isset($this->routesByClosure[$key])) {
                    $uri = $this->routesByClosure[$key];
                }
            }
        }
        return $uri;
    }
}