Queryr\Replicator\EntitySource\BatchingEntityPageFetcher

Complexity

Total Complexity

8

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

95.24%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	addPagesToFetch()	0	3	1
A	fetchNext()	0	19	5
A	rewind()	0	3	1

<?php

namespace Queryr\Replicator\EntitySource;

use BatchingIterator\BatchingFetcher;
use Queryr\Replicator\Model\EntityPage;

/**
 * @licence GNU GPL v2+
 * @author Jeroen De Dauw < jeroendedauw@gmail.com >
 */
class BatchingEntityPageFetcher implements BatchingFetcher {

	/**
	 * @var EntityPageBatchFetcher
	 */
	private $batchFetcher;

	/**
	 * @var string[]
	 */
	private $pagesToFetch;

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

	public function __construct( EntityPageBatchFetcher $batchFetcher, array $pagesToFetch ) {
		$this->batchFetcher = $batchFetcher;
		$this->pagesToFetch = array_unique( $pagesToFetch );
		$this->rewind();
	}

	public function addPagesToFetch( array $pagesToFetch ) {
		$this->pagesToFetch = array_unique( array_merge( $this->pagesToFetch, $pagesToFetch ) );

It seems like array_unique(array_merge($this->pagesToFetch, $pagesToFetch)) of type array is incompatible with the declared type array<integer,string> of property $pagesToFetch.

	}

	/**
	 * @see BatchingFetcher::fetchNext
	 *
	 * @param int $maxFetchCount
	 *
	 * @return EntityPage[]
	 */
	public function fetchNext( $maxFetchCount ) {
		if ( !is_int( $maxFetchCount ) || $maxFetchCount < 1 ) {
			throw new \InvalidArgumentException( '$maxFetchCount needs to be int > 0' );
		}

		do {
			$idsInBatch = array_slice( $this->pagesToFetch, $this->position, $maxFetchCount );
			$this->position = min( $this->position + $maxFetchCount, count( $this->pagesToFetch ) );


			if ( empty( $idsInBatch ) ) {
				return [];
			}

			 $foundPages = $this->batchFetcher->fetchEntityPages( $idsInBatch );
		} while( $foundPages === [] );

		return $foundPages;
	}

	/**
	 * @see BatchingFetcher::rewind
	 */
	public function rewind() {
		$this->position = 0;
	}

}