BulkService::chunkIterator() - Code Metrics - bavix/laravel-entry - Measure and Improve Code Quality continuously with Scrutinizer

BulkService::chunkIterator() A
last analyzed 2020-09-24 07:48 UTC

↳ Parent: BulkService

Complexity

Conditions	4
Paths	4

Size

Total Lines	15
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

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

<?php

namespace Bavix\Entry\Services;

use Bavix\Entry\Models\Entry;
use Illuminate\Support\Facades\Redis;

class BulkService
{

    /**
     * @param int $batchSize
     * @param string $key
     * @return \Generator
     */
    public function chunkIterator(int $batchSize, string $key): \Generator
    {
        $start = \strpos($key, $this->prefixKey());
        if ($start !== false) {
            $key = \substr($key, $start);
        }

        do {
            $bulk = Redis::lrange($key, 0, \max($batchSize - 1, 0));
            $count = \count($bulk);
            if ($count) {
                yield $bulk;
                Redis::ltrim($key, $count, -1);
            }
        } while ($count >= $batchSize);
    }

    /**
     * @return array
     */
    public function keys(): array
    {
        return Redis::keys($this->prefixKey() . '*');
    }

    /**
     * @param Entry $entry
     * @return int
     */
    public function insert(Entry $entry): int
    {
        return Redis::rpush($this->writeKey($entry), \json_encode($entry->toArray()));
    }

    /**
     * @param Entry $entry
     * @return string
     */
    public function writeKey(Entry $entry): string
    {
        return $this->prefixKey() . \get_class($entry);
    }

    /**
     * @return string
     */
    protected function prefixKey(): string
    {
        return 'bavixBulkWrite:';
    }

}


1			<?php
2
3			namespace Bavix\Entry\Services;
4
5			use Bavix\Entry\Models\Entry;
6			use Illuminate\Support\Facades\Redis;
7
8			class BulkService
9			{
10
11			/**
12			* @param int $batchSize
13			* @param string $key
14			* @return \Generator
15			*/
16			public function chunkIterator(int $batchSize, string $key): \Generator
17			{
18			$start = \strpos($key, $this->prefixKey());
19			if ($start !== false) {
20			$key = \substr($key, $start);
21			}
22
23			do {
24			$bulk = Redis::lrange($key, 0, \max($batchSize - 1, 0));
25			$count = \count($bulk);
26			if ($count) {
27			yield $bulk;
28			Redis::ltrim($key, $count, -1);
29			}
30			} while ($count >= $batchSize);
31			}
32
33			/**
34			* @return array
35			*/
36			public function keys(): array
37			{
38			return Redis::keys($this->prefixKey() . '*');
39			}
40
41			/**
42			* @param Entry $entry
43			* @return int
44			*/
45			public function insert(Entry $entry): int
46			{
47			return Redis::rpush($this->writeKey($entry), \json_encode($entry->toArray()));
48			}
49
50			/**
51			* @param Entry $entry
52			* @return string
53			*/
54			public function writeKey(Entry $entry): string
55			{
56			return $this->prefixKey() . \get_class($entry);
57			}
58
59			/**
60			* @return string
61			*/
62			protected function prefixKey(): string
63			{
64			return 'bavixBulkWrite:';
65			}
66
67			}
68

bavix / laravel-entry

BulkService::chunkIterator() A last analyzed 2020-09-24 07:48 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

BulkService::chunkIterator() A
last analyzed 2020-09-24 07:48 UTC