Socialblue\LaravelQueryAdviser\DataListener\QueryListener

Complexity

Total Complexity

14

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
B	listen()	0	35	7
A	getPossibleTraces()	0	12	3
A	formatPossibleTraces()	0	16	3
A	formatData()	0	17	1

<?php

namespace Socialblue\LaravelQueryAdviser\DataListener;

use Illuminate\Database\Events\QueryExecuted;
use Illuminate\Support\Facades\Cache;
use Socialblue\LaravelQueryAdviser\Helper\QueryBuilderHelper;

class QueryListener {

    public static function listen(QueryExecuted $query) {
        if (config('laravel-query-adviser.enable_query_logging') === false) {
            return;
        }

        $url = url()->current();
        if (strpos($url, '/query-adviser') !== false) {
            return;
        }
        $time = time();
        $referer = request()->headers->get('referer');

        if (empty($url)) {
            $url = '';
        }

        $data = Cache::get(config('laravel-query-adviser.cache.key'), []);
        if (!is_array($data)) {
            $data = [];
        }

        if (!isset($data[$time])) {
            $data[$time] = [];
        }

        $possibleTraces = self::formatPossibleTraces(self::getPossibleTraces());

        $data = self::formatData($query, $data, $time, $possibleTraces, $url, $referer);

        if (count($data) > config('laravel-query-adviser.cache.max_entries')) {
            array_shift($data);
        }

        Cache::put(config('laravel-query-adviser.cache.key'), $data, config('laravel-query-adviser.cache.ttl'));
    }

    /**
     * @return array
     */
    protected static function getPossibleTraces(): array
    {
        $possibleTraces = array_filter(debug_backtrace(\DEBUG_BACKTRACE_PROVIDE_OBJECT, 25),
            static function ($trace) {
                return isset($trace['file']) &&
                    strpos($trace['file'], '/var/www/app/') !== false &&
                    isset($trace['object']);

            }
        );
        return $possibleTraces;
    }

    /**
     * @param possibleTraces
     * @return mixed
     */
    protected static function formatPossibleTraces($possibleTraces)
    {
        array_walk($possibleTraces, static function (&$trace) {
            if (method_exists($trace['object'], 'getModel')) {
                $a = $trace['object']->getModel();
                if (is_string($a)) {
                    $trace['model'] = $a;
                } else {
                    $trace['model'] = get_class($a);
                }
            }
            unset($trace['object']);
            unset($trace['args']);
        });
        return $possibleTraces;
    }

    /**
     * @param QueryExecuted $query
     * @param array $data
     * @param int $time
     * @param $possibleTraces
     * @param string $url
     * @param string|null $referer
     * @return array
     */
    protected static function formatData(QueryExecuted $query, array $data, int $time, $possibleTraces, string $url, ?string $referer): array
    {
        $key = count($data[$time]);

        $data[$time][$key] = [
            'time'      => $time,
            'timeKey'   => $key,
            'backtrace' => $possibleTraces,
            'sql'       => QueryBuilderHelper::combineQueryAndBindings($query->sql, $query->bindings),
            'rawSql'    => $query->sql,
            'bindings'  => $query->bindings,
            'queryTime' => $query->time,
            'url'       => $url,
            'referer'   => $referer,
        ];
        return $data;
    }
}