Wikibase\JsonDumpReader\Iterator\EntityDumpIterator

Complexity

Total Complexity

13

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

92.11%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	onError()	0	3	1
A	current()	0	3	1
A	next()	0	7	1
A	key()	0	3	1
A	valid()	0	3	1
A	rewind()	0	5	1
A	getCurrentFromObject()	0	19	4
A	reportError()	0	5	2

<?php

namespace Wikibase\JsonDumpReader\Iterator;

use Deserializers\Deserializer;
use Deserializers\Exceptions\DeserializationException;
use Iterator;
use Wikibase\DataModel\Entity\EntityDocument;

/**
 * Package private
 *
 * @licence GNU GPL v2+
 * @author Jeroen De Dauw < jeroendedauw@gmail.com >
 */
class EntityDumpIterator implements Iterator {

	/**
	 * @var Deserializer
	 */
	private $deserializer;

	/**
	 * @var Iterator
	 */
	private $dumpIterator;

	/**
	 * @var callable|null
	 */
	private $errorReporter = null;

	/**
	 * @var EntityDocument|null
	 */
	private $current = null;

	public function __construct( Iterator $objectIterator, Deserializer $entityDeserializer ) {
		$this->dumpIterator = $objectIterator;
		$this->deserializer = $entityDeserializer;
	}

	/**
	 * @param callable|null $errorReporter
	 */
	public function onError( callable $errorReporter = null ) {
		$this->errorReporter = $errorReporter;
	}

	/**
	 * @return EntityDocument|null
	 */
	public function current() {
		return $this->current;
	}

	/**
	 * @return EntityDocument|null
	 */
	public function next() {
		$this->dumpIterator->next();

		$this->getCurrentFromObject();

		return $this->current;
	}

	private function getCurrentFromObject() {
		while ( true ) {
			try {
				$jsonData = $this->dumpIterator->current();

				if ( $jsonData === null ) {
					$this->current = null;
					return;
				}

				$this->current = $this->deserializer->deserialize( $jsonData );
				return;
			}
			catch ( DeserializationException $ex ) {
				$this->reportError( $ex->getMessage() );
				$this->dumpIterator->next();
			}
		}
	}

	private function reportError( $errorMessage ) {
		if ( $this->errorReporter !== null ) {
			call_user_func( $this->errorReporter, $errorMessage );
		}
	}

	public function key() {
		return $this->current->getId()->getSerialization();
	}

	public function valid() {
		return $this->current !== null;
	}

	public function rewind() {
		$this->current = null;
		$this->dumpIterator->rewind();
		$this->getCurrentFromObject();
	}

}