GBProd\ElasticsearchDataProviderBundle\DataProvider\DataProvider

Complexity

Total Complexity

6

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

94.29%

Importance

Changes	5
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	run()	0	18	1
	populate()	0	1	?
A	index()	0	23	2
A	flushBulk()	0	7	1
A	shouldFlushBulk()	0	4	1
A	count()	0	4	1

<?php

namespace GBProd\ElasticsearchDataProviderBundle\DataProvider;

use Elasticsearch\Client;
use GBProd\ElasticsearchDataProviderBundle\Event\HasIndexedDocument;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

/**
 * Abstract class for data providing
 *
 * @author gbprod <contact@gb-prod.fr>
 */
abstract class DataProvider implements DataProviderInterface
{
    const BATCH_SIZE = 1000;
    
    /**
     * @var Client
     */
    private $client;

    /**
     * @var string
     */
    private $index;

    /**
     * @var string
     */
    private $type;
    
    /**
     * @var EventDispatcherInterface
     */
    private $dispatcher;

    /**
     * @var int
     */
    private $currentBulkSize;

    /**
     * {@inheritdoc}
     */
    public function run(
        Client $client, 
        $index, 
        $type, 
        EventDispatcherInterface $dispatcher
    ) {
        $this->client     = $client;
        $this->index      = $index;
        $this->type       = $type;
        $this->dispatcher = $dispatcher;
        
        $this->currentBulkSize = 0;
        $this->currentBulk     = ['body' => []];

The property currentBulk does not seem to exist. Did you mean currentBulkSize?

        
        $this->populate();
    
        $this->flushBulk();
    }

    /**
     * Populate
     *
     * @return null
     */
    abstract protected function populate();

    /**
     * Index document
     *
     * @param string $id
     * @param array  $body
     */
    public function index($id, array $body)
    {
        $this->currentBulk['body'][] = [

The property currentBulk does not seem to exist. Did you mean currentBulkSize?

            'index' => [
                '_index' => $this->index,
                '_type'  => $this->type,
                '_id'    => $id,
            ]
        ];
    
        $this->currentBulk['body'][] = $body;

The property currentBulk does not seem to exist. Did you mean currentBulkSize?

        
        if ($this->shouldFlushBulk()) {
            $this->flushBulk();
        }
        
        $this->currentBulkSize++;
        
        $this->dispatcher->dispatch(
            'elasticsearch.has_indexed_document',
            new HasIndexedDocument($id)
        );
    }
    
    protected function flushBulk()
    {
        $this->client->bulk($this->currentBulk);

The property currentBulk does not seem to exist. Did you mean currentBulkSize?

        $this->currentBulkSize = 0;
        $this->currentBulk     = ['body' => []];

The property currentBulk does not seem to exist. Did you mean currentBulkSize?

    }
    
    private function shouldFlushBulk()
    {
        return $this->currentBulkSize >= self::BATCH_SIZE;
    }
    
    /**
     * {@inheritdoc}
     */
    public function count()
    {
        return null;
    }
}