Snapshot::getMaxCallsCntByAppAndLabel() - Code Metrics - Inspection of "added possibility to skip snapshots with too few c..." - badoo/liveprof-ui - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 40a2ec...a041ae )

by Shagiakhmetov

created 2019-05-02 10:55 UTC

Snapshot::getMaxCallsCntByAppAndLabel() A

↳ Parent: Project

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	2

Importance

Changes

Metric	Value
cc	2
nc	2
nop	2
dl	0
loc	16
ccs	8
cts	8
cp	1
crap	2
rs	9.7333
c	0
b	0
f	0

<?php declare(strict_types=1);

/**
 * @maintainer Timur Shagiakhmetov <[email protected]>
 */

namespace Badoo\LiveProfilerUI\DataProviders;

use Badoo\LiveProfilerUI\DataProviders\Interfaces\SnapshotInterface;

class Snapshot extends Base implements SnapshotInterface
{
    const TABLE_NAME = 'aggregator_snapshots';

    /**
     * @param string $app
     * @return \Badoo\LiveProfilerUI\Entity\Snapshot[]
     */
    public function getList(string $app = '') : array
    {
        $last_snapshots = $this->getLastSnapshots($app);
        if (empty($last_snapshots)) {
            return [];
        }

        $last_snapshots_data = [];
        foreach ($last_snapshots as $last_snapshot) {
            $snapshot_filter = [];
            unset($last_snapshot['id']);
            foreach ($last_snapshot as $key => $value) {
                $snapshot_filter[] = [$key, $value];
            }
            $last_snapshots_data[] = $snapshot_filter;
        }

        $filter = [
            ['union', $last_snapshots_data],
            ['label', '', '!='],
        ];
        if ($app) {
            $filter[] = ['app', $app];
        }

        $snapshots = $this->AggregatorStorage->getAll(
            self::TABLE_NAME,
            ['all'],
            [
                'filter' => $filter,
                'order' => [
                    'date' => 'desc',
                    'label' => 'asc',
                    'app' => 'asc'
                ]
            ]
        );

        $return = [];
        if (!empty($snapshots)) {
            foreach ($snapshots as $snapshot) {
                $return[] = new \Badoo\LiveProfilerUI\Entity\Snapshot(
                    $snapshot,
                    $this->FieldList->getAllFieldsWithVariations()
                );
            }
        }

        return $return;
    }

    public function getLastSnapshots(string $app = '', string $from_date = '') : array
    {
        $filter = [
            ['label', '', '!='],
        ];
        if ($app) {
            $filter[] = ['app', $app];
        }
        if ($from_date) {
            $filter[] = ['date', $from_date, '>='];
        }

        $last_snapshots = $this->AggregatorStorage->getAll(
            self::TABLE_NAME,
            [['field' => 'id', 'function' => 'max'], 'app', 'label', ['field' => 'date', 'function' => 'max']],
            [
                'filter' => $filter,
                'group' => [
                    'app',
                    'label'
                ]
            ]
        );

        return $last_snapshots;
    }

    public function getOneById(int $snapshot_id) : \Badoo\LiveProfilerUI\Entity\Snapshot
    {
        $snapshot = $this->AggregatorStorage->getOne(
            self::TABLE_NAME,
            ['all'],
            [
                'filter' => [['id', $snapshot_id]]
            ]
        );

        if (empty($snapshot)) {
            throw new \InvalidArgumentException('Can\'t get snapshot');
        }

        return new \Badoo\LiveProfilerUI\Entity\Snapshot(
            $snapshot,
            $this->FieldList->getAllFieldsWithVariations()
        );
    }

    public function getOneByAppAndLabel(string $app, string $label) : \Badoo\LiveProfilerUI\Entity\Snapshot
    {
        $snapshot = $this->AggregatorStorage->getOne(
            self::TABLE_NAME,
            ['all'],
            [
                'filter' => [
                    ['app', $app],
                    ['label', $label]
                ],
                'order' => ['date' => 'desc']
            ]
        );

        if (empty($snapshot)) {
            throw new \InvalidArgumentException('Can\'t get snapshot');
        }

        return new \Badoo\LiveProfilerUI\Entity\Snapshot(
            $snapshot,
            $this->FieldList->getAllFieldsWithVariations()
        );
    }

    public function getOneByAppAndLabelAndDate(
        string $app,
        string $label,
        string $date
    ) : \Badoo\LiveProfilerUI\Entity\Snapshot {
        $snapshot = $this->AggregatorStorage->getOne(
            self::TABLE_NAME,
            ['all'],
            [
                'filter' => [
                    ['app', $app],
                    ['label', $label],
                    ['date', $date]
                ],
                'order' => ['date' => 'desc']
            ]
        );

        if (empty($snapshot)) {
            throw new \InvalidArgumentException('Can\'t get snapshot');
        }

        return new \Badoo\LiveProfilerUI\Entity\Snapshot(
            $snapshot,
            $this->FieldList->getAllFieldsWithVariations()
        );
    }

    public function getSnapshotsByDates(array $dates, string $param = '') : array
    {
        if (empty($dates)) {
            return [];
        }

        $fields = ['id', 'app', 'label', 'date', 'type'];
        if ($param) {
            $fields[] = $param;
        }

        $snapshots = $this->AggregatorStorage->getAll(
            self::TABLE_NAME,
            $fields,
            [
                'filter' => [
                    ['date', $dates],
                ],
            ]
        );
        return $snapshots;
    }

    public function getSnapshotIdsByDates(array $dates, string $app, string $label) : array
    {
        if (empty($dates) || !$app || !$label) {
            return [];
        }

        $snapshots = $this->AggregatorStorage->getAll(
            self::TABLE_NAME,
            ['id', 'calls_count', 'date'],
            [
                'filter' => [
                    ['date', $dates],
                    ['app', $app],
                    ['label', $label],
                ],
            ]
        );

        $result = [];
        if (!empty($snapshots)) {
            foreach ($snapshots as $row) {
                $result[$row['date']] = [
                    'id' => (int)$row['id'],
                    'calls_count' => (int)$row['calls_count'],
                ];
            }
        }
        foreach ($dates as $date) {
            if (!isset($result[$date])) {
                $result[$date] = null;
            }
        }
        ksort($result);

        return $result;
    }

    public function getOldSnapshots(int $keep_days = 200, int $limit = 2000) : array
    {
        $snapshots = $this->AggregatorStorage->getAll(
            self::TABLE_NAME,
            ['id', 'app', 'label', 'date'],
            [
                'filter' => [
                    ['date', date('Y-m-d', strtotime("-$keep_days day")), '<'],
                ],
                'order' => ['id' => 'asc'],
                'limit' => $limit
            ]
        );

        return $snapshots;
    }

    public function getDatesByAppAndLabel(string $app, string $label) : array
    {
        $snapshots = $this->AggregatorStorage->getAll(
            self::TABLE_NAME,
            ['date'],
            [
                'filter' => [
                    ['date', date('Y-m-d', strtotime('-1 year')), '>'],
                    ['app', $app],
                    ['label', $label],
                ],
                'order' => ['date' => 'desc']
            ]
        );

        return $snapshots ? array_column($snapshots, 'date') : [];
    }

    public function getMaxCallsCntByAppAndLabel(string $app, string $label) : int
    {
        $result = $this->AggregatorStorage->getOne(
            self::TABLE_NAME,
            [['field' => 'calls_count', 'function' => 'max']],
            [
                'filter' => [
                    ['app', $app],
                    ['label', $label],
                ],
                'group' => ['app', 'label'],
            ]
        );

        return $result ? (int)current($result) : 0;
    }

    public function getAppList(string $label = '') : array
    {
        $filter = [];
        if ($label) {
            $filter[] = ['label', $label];
        }
        $apps = $this->AggregatorStorage->getAll(
            self::TABLE_NAME,
            ['app'],
            [
                'filter' => $filter,
                'group' => ['app'],
                'order' => ['app' => 'asc'],
            ]
        );

        return $apps ? array_column($apps, 'app') : [];
    }

    public function updateSnapshot(int $snapshot_id, array $snapshot_data) : bool
    {
        if (empty($snapshot_data)) {
            return false;
        }

        return $this->AggregatorStorage->update(
            self::TABLE_NAME,
            $snapshot_data,
            ['id' => $snapshot_id]
        );
    }

    public function createSnapshot(array $snapshot_data) : int
    {
        if (empty($snapshot_data)) {
            return 0;
        }

        return $this->AggregatorStorage->insert(self::TABLE_NAME, $snapshot_data);
    }

    /**
     * Delete snapshot by id,  aggregator_tree and aggregator_method_data will be deleted by cascade
     * @param int $snapshot_id
     * @return bool
     */
    public function deleteById(int $snapshot_id) : bool
    {
        if (!$snapshot_id) {
            return false;
        }

        return $this->AggregatorStorage->delete(
            self::TABLE_NAME,
            ['id' => $snapshot_id]
        );
    }
}


1		<?php declare(strict_types=1);
2
3		/**
4		* @maintainer Timur Shagiakhmetov <[email protected]>
5		*/
6
7		namespace Badoo\LiveProfilerUI\DataProviders;
8
9		use Badoo\LiveProfilerUI\DataProviders\Interfaces\SnapshotInterface;
10
11		class Snapshot extends Base implements SnapshotInterface
12		{
13		const TABLE_NAME = 'aggregator_snapshots';
14
15		/**
16		* @param string $app
17		* @return \Badoo\LiveProfilerUI\Entity\Snapshot[]
18		*/
19	3	public function getList(string $app = '') : array
20		{
21	3	$last_snapshots = $this->getLastSnapshots($app);
22	3	if (empty($last_snapshots)) {
23	1	return [];
24		}
25
26	2	$last_snapshots_data = [];
27	2	foreach ($last_snapshots as $last_snapshot) {
28	2	$snapshot_filter = [];
29	2	unset($last_snapshot['id']);
30	2	foreach ($last_snapshot as $key => $value) {
31	2	$snapshot_filter[] = [$key, $value];
32		}
33	2	$last_snapshots_data[] = $snapshot_filter;
34		}
35
36		$filter = [
37	2	['union', $last_snapshots_data],
38		['label', '', '!='],
39		];
40	2	if ($app) {
41	2	$filter[] = ['app', $app];
42		}
43
44	2	$snapshots = $this->AggregatorStorage->getAll(
45	2	self::TABLE_NAME,
46	2	['all'],
47		[
48	2	'filter' => $filter,
49		'order' => [
50		'date' => 'desc',
51		'label' => 'asc',
52		'app' => 'asc'
53		]
54		]
55		);
56
57	2	$return = [];
58	2	if (!empty($snapshots)) {
59	1	foreach ($snapshots as $snapshot) {
60	1	$return[] = new \Badoo\LiveProfilerUI\Entity\Snapshot(
61	1	$snapshot,
62	1	$this->FieldList->getAllFieldsWithVariations()
63		);
64		}
65		}
66
67	2	return $return;
68		}
69
70	1	public function getLastSnapshots(string $app = '', string $from_date = '') : array
71		{
72		$filter = [
73	1	['label', '', '!='],
74		];
75	1	if ($app) {
76	1	$filter[] = ['app', $app];
77		}
78	1	if ($from_date) {
79	1	$filter[] = ['date', $from_date, '>='];
80		}
81
82	1	$last_snapshots = $this->AggregatorStorage->getAll(
83	1	self::TABLE_NAME,
84	1	[['field' => 'id', 'function' => 'max'], 'app', 'label', ['field' => 'date', 'function' => 'max']],
85		[
86	1	'filter' => $filter,
87		'group' => [
88		'app',
89		'label'
90		]
91		]
92		);
93
94	1	return $last_snapshots;
95		}
96
97	5	public function getOneById(int $snapshot_id) : \Badoo\LiveProfilerUI\Entity\Snapshot
98		{
99	5	$snapshot = $this->AggregatorStorage->getOne(
100	5	self::TABLE_NAME,
101	5	['all'],
102		[
103	5	'filter' => [['id', $snapshot_id]]
104		]
105		);
106
107	5	if (empty($snapshot)) {
108	4	throw new \InvalidArgumentException('Can\'t get snapshot');
109		}
110
111	1	return new \Badoo\LiveProfilerUI\Entity\Snapshot(
112	1	$snapshot,
113	1	$this->FieldList->getAllFieldsWithVariations()
114		);
115		}
116
117	5	public function getOneByAppAndLabel(string $app, string $label) : \Badoo\LiveProfilerUI\Entity\Snapshot
118		{
119	5	$snapshot = $this->AggregatorStorage->getOne(
120	5	self::TABLE_NAME,
121	5	['all'],
122		[
123	5	'filter' => [
124	5	['app', $app],
125	5	['label', $label]
126		],
127		'order' => ['date' => 'desc']
128		]
129		);
130
131	5	if (empty($snapshot)) {
132	4	throw new \InvalidArgumentException('Can\'t get snapshot');
133		}
134
135	1	return new \Badoo\LiveProfilerUI\Entity\Snapshot(
136	1	$snapshot,
137	1	$this->FieldList->getAllFieldsWithVariations()
138		);
139		}
140
141	5	public function getOneByAppAndLabelAndDate(
142		string $app,
143		string $label,
144		string $date
145		) : \Badoo\LiveProfilerUI\Entity\Snapshot {
146	5	$snapshot = $this->AggregatorStorage->getOne(
147	5	self::TABLE_NAME,
148	5	['all'],
149		[
150	5	'filter' => [
151	5	['app', $app],
152	5	['label', $label],
153	5	['date', $date]
154		],
155		'order' => ['date' => 'desc']
156		]
157		);
158
159	5	if (empty($snapshot)) {
160	4	throw new \InvalidArgumentException('Can\'t get snapshot');
161		}
162
163	1	return new \Badoo\LiveProfilerUI\Entity\Snapshot(
164	1	$snapshot,
165	1	$this->FieldList->getAllFieldsWithVariations()
166		);
167		}
168
169	2	public function getSnapshotsByDates(array $dates, string $param = '') : array
170		{
171	2	if (empty($dates)) {
172	1	return [];
173		}
174
175	1	$fields = ['id', 'app', 'label', 'date', 'type'];
176	1	if ($param) {
177	1	$fields[] = $param;
178		}
179
180	1	$snapshots = $this->AggregatorStorage->getAll(
181	1	self::TABLE_NAME,
182	1	$fields,
183		[
184		'filter' => [
185	1	['date', $dates],
186		],
187		]
188		);
189	1	return $snapshots;
190		}
191
192	3	public function getSnapshotIdsByDates(array $dates, string $app, string $label) : array
193		{
194	3	if (empty($dates) \|\| !$app \|\| !$label) {
195	1	return [];
196		}
197
198	2	$snapshots = $this->AggregatorStorage->getAll(
199	2	self::TABLE_NAME,
200	2	['id', 'calls_count', 'date'],
201		[
202		'filter' => [
203	2	['date', $dates],
204	2	['app', $app],
205	2	['label', $label],
206		],
207		]
208		);
209
210	2	$result = [];
211	2	if (!empty($snapshots)) {
212	2	foreach ($snapshots as $row) {
213	2	$result[$row['date']] = [
214	2	'id' => (int)$row['id'],
215	2	'calls_count' => (int)$row['calls_count'],
216		];
217		}
218		}
219	2	foreach ($dates as $date) {
220	2	if (!isset($result[$date])) {
221	2	$result[$date] = null;
222		}
223		}
224	2	ksort($result);
225
226	2	return $result;
227		}
228
229	1	public function getOldSnapshots(int $keep_days = 200, int $limit = 2000) : array
230		{
231	1	$snapshots = $this->AggregatorStorage->getAll(
232	1	self::TABLE_NAME,
233	1	['id', 'app', 'label', 'date'],
234		[
235	1	'filter' => [
236	1	['date', date('Y-m-d', strtotime("-$keep_days day")), '<'],
237		],
238		'order' => ['id' => 'asc'],
239	1	'limit' => $limit
240		]
241		);
242
243	1	return $snapshots;
244		}
245
246	1	public function getDatesByAppAndLabel(string $app, string $label) : array
247		{
248	1	$snapshots = $this->AggregatorStorage->getAll(
249	1	self::TABLE_NAME,
250	1	['date'],
251		[
252	1	'filter' => [
253	1	['date', date('Y-m-d', strtotime('-1 year')), '>'],
254	1	['app', $app],
255	1	['label', $label],
256		],
257		'order' => ['date' => 'desc']
258		]
259		);
260
261	1	return $snapshots ? array_column($snapshots, 'date') : [];
262		}
263
264	1	public function getMaxCallsCntByAppAndLabel(string $app, string $label) : int
265		{
266	1	$result = $this->AggregatorStorage->getOne(
267	1	self::TABLE_NAME,
268	1	[['field' => 'calls_count', 'function' => 'max']],
269		[
270	1	'filter' => [
271	1	['app', $app],
272	1	['label', $label],
273		],
274		'group' => ['app', 'label'],
275		]
276		);
277
278	1	return $result ? (int)current($result) : 0;
279		}
280
281	2	public function getAppList(string $label = '') : array
282		{
283	2	$filter = [];
284	2	if ($label) {
285	1	$filter[] = ['label', $label];
286		}
287	2	$apps = $this->AggregatorStorage->getAll(
288	2	self::TABLE_NAME,
289	2	['app'],
290		[
291	2	'filter' => $filter,
292		'group' => ['app'],
293		'order' => ['app' => 'asc'],
294		]
295		);
296
297	2	return $apps ? array_column($apps, 'app') : [];
298		}
299
300	2	public function updateSnapshot(int $snapshot_id, array $snapshot_data) : bool
301		{
302	2	if (empty($snapshot_data)) {
303	1	return false;
304		}
305
306	1	return $this->AggregatorStorage->update(
307	1	self::TABLE_NAME,
308	1	$snapshot_data,
309	1	['id' => $snapshot_id]
310		);
311		}
312
313	2	public function createSnapshot(array $snapshot_data) : int
314		{
315	2	if (empty($snapshot_data)) {
316	1	return 0;
317		}
318
319	1	return $this->AggregatorStorage->insert(self::TABLE_NAME, $snapshot_data);
320		}
321
322		/**
323		* Delete snapshot by id, aggregator_tree and aggregator_method_data will be deleted by cascade
324		* @param int $snapshot_id
325		* @return bool
326		*/
327	2	public function deleteById(int $snapshot_id) : bool
328		{
329	2	if (!$snapshot_id) {
330	1	return false;
331		}
332
333	1	return $this->AggregatorStorage->delete(
334	1	self::TABLE_NAME,
335	1	['id' => $snapshot_id]
336		);
337		}
338		}
339

badoo / liveprof-ui

Push — master ( 40a2ec...a041ae )

Snapshot::getMaxCallsCntByAppAndLabel() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like