HttpRequestCollector::__construct() - Code Metrics - Inspection of "default max_duration_time_window 60s" - hhxsv5/laravel-s - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — feature/request-max-time-metri... ( 1c2c01...0aba3b )

by Biao

created 2024-12-13 04:47 UTC

HttpRequestCollector::__construct() C

↳ Parent: HttpRequestCollector

Complexity

Conditions	12
Paths	40

Size

Total Lines	32
Code Lines	23

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
cc	12
eloc	23
c	2
b	0
f	0
nc	40
nop	1
dl	0
loc	32
rs	6.9666

How to fix Complexity

<?php


namespace Hhxsv5\LaravelS\Components\Prometheus\Collectors;

use Closure;
use Hhxsv5\LaravelS\Components\MetricCollector;
use Illuminate\Http\Request;
filter:
    dependency_paths: ["lib/*"]

class HttpRequestCollector extends MetricCollector

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

    public function __construct(array $config)

    {
        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();
        $routes = method_exists(/** @scrutinizer ignore-call */ app(), 'getRoutes') ? app()->getRoutes() : app('router')->getRoutes();
        if ($routes instanceof \Illuminate\Routing\RouteCollection) { // Laravel
filter:
    dependency_paths: ["lib/*"]
            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 = [])

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

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

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

        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([

            'method' => $request->getMethod(),
            'uri'    => $uri,
            'status' => $status,
        ]);
someFunctionCall(
    $firstArgument,
    $secondArgument,
    $thirdArgument
); // Closing parenthesis 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)

    {
        $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
filter:
    dependency_paths: ["lib/*"]
            $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;
    }
}

hhxsv5 / laravel-s

Push — feature/request-max-time-metri... ( 1c2c01...0aba3b )

HttpRequestCollector::__construct() C

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like