Wikibase\JsonDumpReader\Iterator\ObjectDumpIterator

Complexity

Total Complexity

13

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

97.37%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	onError()	0	3	1
A	current()	0	3	1
A	next()	0	6	1
A	getCurrentFromString()	0	20	4
A	reportError()	0	5	2
A	key()	0	3	1
A	valid()	0	3	1
A	rewind()	0	5	1

<?php

declare( strict_types = 1 );

namespace Wikibase\JsonDumpReader\Iterator;

use Iterator;

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

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

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

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

	public function __construct( Iterator $stringIterator ) {
		$this->stringIterator = $stringIterator;
	}

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

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

	/**
	 * @return string|null
	 */
	public function next() {
		$this->stringIterator->next();
		$this->getCurrentFromString();

		return $this->current;
	}

	private function getCurrentFromString() {
		while ( true ) {
			$jsonString = $this->stringIterator->current();

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

			$data = json_decode( $jsonString, true );
			if ( $data === null ) {
				$this->reportError( json_last_error_msg() );
				$this->stringIterator->next();
			}
			else {
				$this->current = $data;
				return;
			}
		}
	}

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

	public function key() {
		return $this->stringIterator->key();
	}

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

	public function rewind() {
		$this->current = null;
		$this->stringIterator->rewind();
		$this->getCurrentFromString();
	}

}