IndexCommand::handle() - Code Metrics - Inspection of "Count and display error details" - digiaonline/lumen-elasticsearch - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — develop (#115)

unknown

created 2018-10-18 16:17 UTC

IndexCommand::handle() B

↳ Parent: IndexCommand

Complexity

Conditions	7
Paths	20

Size

Total Lines	58
Code Lines	34

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	34
dl	0
loc	58
rs	8.4426
c	0
b	0
f	0
cc	7
nc	20
nop	0

How to fix Long Method

<?php namespace Nord\Lumen\Elasticsearch\Console;

use Nord\Lumen\Elasticsearch\Documents\Bulk\BulkAction;
use Nord\Lumen\Elasticsearch\Documents\Bulk\BulkQuery;
use Nord\Lumen\Elasticsearch\Documents\Bulk\BulkResponseAggregator;

abstract class IndexCommand extends AbstractCommand
{

    /**
     * The number of items to process before updating the progress bar
     */
    const PROGRESS_BAR_REDRAW_FREQUENCY = 50;

    /**
     * @return array
     */
    abstract public function getData();

    /**
     * @return string
     */
    abstract public function getIndex();

    /**
     * @return string
     */
    abstract public function getType();

    /**
     * @param mixed $item
     *
     * @return array
     */
    abstract public function getItemBody($item);

    /**
     * @param mixed $item
     *
     * @return string
     */
    abstract public function getItemId($item);

    /**
     * @param mixed $item
     *
     * @return string
     */
    abstract public function getItemParent($item);

    /**
     * @inheritdoc
     */
    public function handle()
    {
        $this->info(sprintf('Indexing data of type "%s" into "%s"', $this->getType(), $this->getIndex()));

        $data = $this->getData();

        $bar = $this->output->createProgressBar($this->getCount());
        $bar->setRedrawFrequency($this->getProgressBarRedrawFrequency());

        $bulkQuery = new BulkQuery($this->getBulkSize());
        $bulkResponseAggregator = new BulkResponseAggregator();

        foreach ($data as $item) {
            $action = new BulkAction();

            $meta = [
                '_index' => $this->getIndex(),
                '_type'  => $this->getType(),
                '_id'    => $this->getItemId($item),
            ];

            if (($parent = $this->getItemParent($item)) !== null) {
                $meta['_parent'] = $parent;
            }

            $action->setAction(BulkAction::ACTION_INDEX, $meta)
                   ->setBody($this->getItemBody($item));

            $bulkQuery->addAction($action);

            if ($bulkQuery->isReady()) {
                $response = $this->elasticsearchService->bulk($bulkQuery->toArray());
                $bulkQuery->reset();
                $bulkResponseAggregator->addResponse($response);
            }

            $bar->advance();
        }

        if ($bulkQuery->hasItems()) {
            $response = $this->elasticsearchService->bulk($bulkQuery->toArray());
            $bulkResponseAggregator->addResponse($response);
        }

        $bar->finish();

        $hasErrors = $bulkResponseAggregator->hasErrors();
        if ($hasErrors) {
            $this->info("\n");
            $errors = $bulkResponseAggregator->getErrors();
            foreach ($errors as $error) {
                $this->error($error);
            }
        }

        $this->info("\nDone!");

        return 0;
    }

    /**
     * @return int the bulk size (for bulk indexing)
     */
    protected function getBulkSize()
    {
        return BulkQuery::BULK_SIZE_DEFAULT;
    }

    /**
     * @return int the progress bar redraw frequency
     */
    protected function getProgressBarRedrawFrequency()
    {
        return self::PROGRESS_BAR_REDRAW_FREQUENCY;
    }

    /**
     * Get the total count.
     *
     * @return int
     */
    protected function getCount()
    {
        return count($this->getData());
    }
}


1			<?php namespace Nord\Lumen\Elasticsearch\Console;
2
3			use Nord\Lumen\Elasticsearch\Documents\Bulk\BulkAction;
4			use Nord\Lumen\Elasticsearch\Documents\Bulk\BulkQuery;
5			use Nord\Lumen\Elasticsearch\Documents\Bulk\BulkResponseAggregator;
6
7			abstract class IndexCommand extends AbstractCommand
8			{
9
10			/**
11			* The number of items to process before updating the progress bar
12			*/
13			const PROGRESS_BAR_REDRAW_FREQUENCY = 50;
14
15			/**
16			* @return array
17			*/
18			abstract public function getData();
19
20			/**
21			* @return string
22			*/
23			abstract public function getIndex();
24
25			/**
26			* @return string
27			*/
28			abstract public function getType();
29
30			/**
31			* @param mixed $item
32			*
33			* @return array
34			*/
35			abstract public function getItemBody($item);
36
37			/**
38			* @param mixed $item
39			*
40			* @return string
41			*/
42			abstract public function getItemId($item);
43
44			/**
45			* @param mixed $item
46			*
47			* @return string
48			*/
49			abstract public function getItemParent($item);
50
51			/**
52			* @inheritdoc
53			*/
54			public function handle()
55			{
56			$this->info(sprintf('Indexing data of type "%s" into "%s"', $this->getType(), $this->getIndex()));
57
58			$data = $this->getData();
59
60			$bar = $this->output->createProgressBar($this->getCount());
61			$bar->setRedrawFrequency($this->getProgressBarRedrawFrequency());
62
63			$bulkQuery = new BulkQuery($this->getBulkSize());
64			$bulkResponseAggregator = new BulkResponseAggregator();
65
66			foreach ($data as $item) {
67			$action = new BulkAction();
68
69			$meta = [
70			'_index' => $this->getIndex(),
71			'_type' => $this->getType(),
72			'_id' => $this->getItemId($item),
73			];
74
75			if (($parent = $this->getItemParent($item)) !== null) {
76			$meta['_parent'] = $parent;
77			}
78
79			$action->setAction(BulkAction::ACTION_INDEX, $meta)
80			->setBody($this->getItemBody($item));
81
82			$bulkQuery->addAction($action);
83
84			if ($bulkQuery->isReady()) {
85			$response = $this->elasticsearchService->bulk($bulkQuery->toArray());
86			$bulkQuery->reset();
87			$bulkResponseAggregator->addResponse($response);
88			}
89
90			$bar->advance();
91			}
92
93			if ($bulkQuery->hasItems()) {
94			$response = $this->elasticsearchService->bulk($bulkQuery->toArray());
95			$bulkResponseAggregator->addResponse($response);
96			}
97
98			$bar->finish();
99
100			$hasErrors = $bulkResponseAggregator->hasErrors();
101			if ($hasErrors) {
102			$this->info("\n");
103			$errors = $bulkResponseAggregator->getErrors();
104			foreach ($errors as $error) {
105			$this->error($error);
106			}
107			}
108
109			$this->info("\nDone!");
110
111			return 0;
112			}
113
114			/**
115			* @return int the bulk size (for bulk indexing)
116			*/
117			protected function getBulkSize()
118			{
119			return BulkQuery::BULK_SIZE_DEFAULT;
120			}
121
122			/**
123			* @return int the progress bar redraw frequency
124			*/
125			protected function getProgressBarRedrawFrequency()
126			{
127			return self::PROGRESS_BAR_REDRAW_FREQUENCY;
128			}
129
130			/**
131			* Get the total count.
132			*
133			* @return int
134			*/
135			protected function getCount()
136			{
137			return count($this->getData());
138			}
139			}
140

digiaonline / lumen-elasticsearch

Pull Request — develop (#115)

IndexCommand::handle() B

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like