ElasticsearchProfiler::getQueries() - Code Metrics - Inspection of "Merge branch '1.0'" - ongr-io/ElasticsearchBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.1 ( 58a883 )

by Simonas

created 2016-05-25 21:37 UTC

ElasticsearchProfiler::getQueries() A

↳ Parent: ElasticsearchProfiler

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	4
c	0
b	0
f	0
rs	10
cc	1
eloc	2
nc	1
nop	0

<?php

/*
 * This file is part of the ONGR package.
 *
 * (c) NFQ Technologies UAB <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace ONGR\ElasticsearchBundle\Profiler;

use Monolog\Logger;
use ONGR\ElasticsearchBundle\Profiler\Handler\CollectionHandler;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpKernel\DataCollector\DataCollectorInterface;

/**
 * Data collector for profiling elasticsearch bundle.
 */
class ElasticsearchProfiler implements DataCollectorInterface
{
    const UNDEFINED_ROUTE = 'undefined_route';

    /**
     * @var Logger[] Watched loggers.
     */
    private $loggers = [];

    /**
     * @var array Queries array.
     */
    private $queries = [];

    /**
     * @var int Query count.
     */
    private $count = 0;

    /**
     * @var float Time all queries took.
     */
    private $time = .0;

    /**
     * @var array Registered managers.
     */
    private $managers = [];

    /**
     * Adds logger to look for collector handler.
     *
     * @param Logger $logger
     */
    public function addLogger(Logger $logger)
    {
        $this->loggers[] = $logger;
    }

    /**
     * {@inheritdoc}
     */
    public function collect(Request $request, Response $response, \Exception $exception = null)
    {
        /** @var Logger $logger */
        foreach ($this->loggers as $logger) {
            foreach ($logger->getHandlers() as $handler) {
                if ($handler instanceof CollectionHandler) {
                    $this->handleRecords($this->getRoute($request), $handler->getRecords());
                    $handler->clearRecords();
                }
            }
        }
    }

    /**
     * Returns total time queries took.
     *
     * @return string
     */
    public function getTime()
    {
        return round($this->time * 1000, 2);
    }

    /**
     * Returns number of queries executed.
     *
     * @return int
     */
    public function getQueryCount()
    {
        return $this->count;
    }

    /**
     * Returns information about executed queries.
     *
     * Eg. keys:
     *      'body'    - Request body.
     *      'method'  - HTTP method.
     *      'uri'     - Uri request was sent.
     *      'time'    - Time client took to respond.
     *
     * @return array
     */
    public function getQueries()
    {
        return $this->queries;
    }

    /**
     * @return array
     */
    public function getManagers()
    {
        if (is_array(reset($this->managers))) {
            foreach ($this->managers as $name => &$manager) {
                $manager = $name === 'default' ? 'es.manager' : sprintf('es.manager.%s', $name);
            }
        }

        return $this->managers;
    }

    /**
     * @param array $managers
     */
    public function setManagers($managers)
    {
        $this->managers = $managers;
    }

    /**
     * {@inheritdoc}
     */
    public function getName()
    {
        return 'ongr.profiler';
    }

    /**
     * Handles passed records.
     *
     * @param string $route
     * @param array  $records
     */
    private function handleRecords($route, $records)
    {
        $this->count += count($records) / 2;
        $queryBody = '';
        foreach ($records as $record) {
            // First record will never have context.
            if (!empty($record['context'])) {
                $this->time += $record['context']['duration'];
                $this->addQuery($route, $record, $queryBody);
            } else {
                $position = strpos($record['message'], ' -d');
                $queryBody = $position !== false ? substr($record['message'], $position + 3) : '';
            }
        }
    }

    /**
     * Adds query to collected data array.
     *
     * @param string $route
     * @param array  $record
     * @param string $queryBody
     */
    private function addQuery($route, $record, $queryBody)
    {
        parse_str(parse_url($record['context']['uri'], PHP_URL_QUERY), $httpParameters);
        $body = json_decode(trim($queryBody, " '\r\t\n"), true);
        $this->queries[$route][] = array_merge(
            [
                'body' => $body !== null ? json_encode($body, JSON_PRETTY_PRINT) : '',
                'method' => $record['context']['method'],
                'httpParameters' => $httpParameters,
                'time' => $record['context']['duration'] * 100,
            ],
            array_diff_key(parse_url($record['context']['uri']), array_flip(['query']))
        );
    }

    /**
     * Returns route name from request.
     *
     * @param Request $request
     *
     * @return string
     */
    private function getRoute(Request $request)
    {
        $route = $request->attributes->get('_route');

        return empty($route) ? self::UNDEFINED_ROUTE : $route;
    }
}


1			<?php
2
3			/*
4			* This file is part of the ONGR package.
5			*
6			* (c) NFQ Technologies UAB <[email protected]>
7			*
8			* For the full copyright and license information, please view the LICENSE
9			* file that was distributed with this source code.
10			*/
11
12			namespace ONGR\ElasticsearchBundle\Profiler;
13
14			use Monolog\Logger;
15			use ONGR\ElasticsearchBundle\Profiler\Handler\CollectionHandler;
16			use Symfony\Component\HttpFoundation\Request;
17			use Symfony\Component\HttpFoundation\Response;
18			use Symfony\Component\HttpKernel\DataCollector\DataCollectorInterface;
19
20			/**
21			* Data collector for profiling elasticsearch bundle.
22			*/
23			class ElasticsearchProfiler implements DataCollectorInterface
24			{
25			const UNDEFINED_ROUTE = 'undefined_route';
26
27			/**
28			* @var Logger[] Watched loggers.
29			*/
30			private $loggers = [];
31
32			/**
33			* @var array Queries array.
34			*/
35			private $queries = [];
36
37			/**
38			* @var int Query count.
39			*/
40			private $count = 0;
41
42			/**
43			* @var float Time all queries took.
44			*/
45			private $time = .0;
46
47			/**
48			* @var array Registered managers.
49			*/
50			private $managers = [];
51
52			/**
53			* Adds logger to look for collector handler.
54			*
55			* @param Logger $logger
56			*/
57			public function addLogger(Logger $logger)
58			{
59			$this->loggers[] = $logger;
60			}
61
62			/**
63			* {@inheritdoc}
64			*/
65			public function collect(Request $request, Response $response, \Exception $exception = null)
66			{
67			/** @var Logger $logger */
68			foreach ($this->loggers as $logger) {
69			foreach ($logger->getHandlers() as $handler) {
70			if ($handler instanceof CollectionHandler) {
71			$this->handleRecords($this->getRoute($request), $handler->getRecords());
72			$handler->clearRecords();
73			}
74			}
75			}
76			}
77
78			/**
79			* Returns total time queries took.
80			*
81			* @return string
82			*/
83			public function getTime()
84			{
85			return round($this->time * 1000, 2);
86			}
87
88			/**
89			* Returns number of queries executed.
90			*
91			* @return int
92			*/
93			public function getQueryCount()
94			{
95			return $this->count;
96			}
97
98			/**
99			* Returns information about executed queries.
100			*
101			* Eg. keys:
102			* 'body' - Request body.
103			* 'method' - HTTP method.
104			* 'uri' - Uri request was sent.
105			* 'time' - Time client took to respond.
106			*
107			* @return array
108			*/
109			public function getQueries()
110			{
111			return $this->queries;
112			}
113
114			/**
115			* @return array
116			*/
117			public function getManagers()
118			{
119			if (is_array(reset($this->managers))) {
120			foreach ($this->managers as $name => &$manager) {
121			$manager = $name === 'default' ? 'es.manager' : sprintf('es.manager.%s', $name);
122			}
123			}
124
125			return $this->managers;
126			}
127
128			/**
129			* @param array $managers
130			*/
131			public function setManagers($managers)
132			{
133			$this->managers = $managers;
134			}
135
136			/**
137			* {@inheritdoc}
138			*/
139			public function getName()
140			{
141			return 'ongr.profiler';
142			}
143
144			/**
145			* Handles passed records.
146			*
147			* @param string $route
148			* @param array $records
149			*/
150			private function handleRecords($route, $records)
151			{
152			$this->count += count($records) / 2;
153			$queryBody = '';
154			foreach ($records as $record) {
155			// First record will never have context.
156			if (!empty($record['context'])) {
157			$this->time += $record['context']['duration'];
158			$this->addQuery($route, $record, $queryBody);
159			} else {
160			$position = strpos($record['message'], ' -d');
161			$queryBody = $position !== false ? substr($record['message'], $position + 3) : '';
162			}
163			}
164			}
165
166			/**
167			* Adds query to collected data array.
168			*
169			* @param string $route
170			* @param array $record
171			* @param string $queryBody
172			*/
173			private function addQuery($route, $record, $queryBody)
174			{
175			parse_str(parse_url($record['context']['uri'], PHP_URL_QUERY), $httpParameters);
176			$body = json_decode(trim($queryBody, " '\r\t\n"), true);
177			$this->queries[$route][] = array_merge(
178			[
179			'body' => $body !== null ? json_encode($body, JSON_PRETTY_PRINT) : '',
180			'method' => $record['context']['method'],
181			'httpParameters' => $httpParameters,
182			'time' => $record['context']['duration'] * 100,
183			],
184			array_diff_key(parse_url($record['context']['uri']), array_flip(['query']))
185			);
186			}
187
188			/**
189			* Returns route name from request.
190			*
191			* @param Request $request
192			*
193			* @return string
194			*/
195			private function getRoute(Request $request)
196			{
197			$route = $request->attributes->get('_route');
198
199			return empty($route) ? self::UNDEFINED_ROUTE : $route;
200			}
201			}
202

ongr-io / ElasticsearchBundle

Push — 1.1 ( 58a883 )

ElasticsearchProfiler::getQueries() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like