Port\Elasticsearch\ScrollReader

Complexity

Total Complexity

6

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	setScrollTTL()	0	4	1
A	getItems()	0	20	4

<?php declare(strict_types=1);

namespace Port\Elasticsearch;

use Elasticsearch\Client;
use Port\Reader;

class ScrollReader implements Reader

There is at least one abstract method in this class. Maybe declare it as abstract, or implement the remaining methods: current, key, next, rewind, valid

{
    private $client;

    private $query;

    private $scrollTTL = '1m';

    public function __construct($client, array $query)
    {
        $this->client = $client;
        $this->query = $query;
    }

    public function setScrollTTL(string $ttl): void
    {
        $this->scrollTTL = $ttl;
    }

    public function getItems(): \Generator
    {
        $query = $this->query;
        $query['scroll'] = $this->scollTTL;

The property scollTTL does not seem to exist. Did you mean scrollTTL?

        $response = $this->client->search($this->query);

        while (isset($response['hits']['hits']) && count($response['hits']['hits']) > 0) {

            foreach ($response['hits']['hits'] as $doc) {
                yield $doc;
            }
        
            $response = $client->scroll([

The variable $client does not exist. Did you forget to declare it?

                    'scroll_id' => $response['_scroll_id'],
                    'scroll' => $this->scrollTTL,
                ]
            );
        }
    }
}