PagesImporter::runImportLoop() - Code Metrics - JeroenDeDauw/Replicator - Measure and Improve Code Quality continuously with Scrutinizer

PagesImporter::runImportLoop() A
last analyzed 2019-04-21 21:30 UTC

↳ Parent: PagesImporter

Complexity

Conditions	4
Paths	4

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	4.128

Importance

Changes

Metric	Value
dl	0
loc	18
ccs	8
cts	10
cp	0.8
rs	9.6666
c	0
b	0
f	0
cc	4
nc	4
nop	1
crap	4.128

<?php

namespace Queryr\Replicator\Importer;

use Iterator;
use Queryr\Replicator\Model\EntityPage;

/**
 * @licence GNU GPL v2+
 * @author Jeroen De Dauw < [email protected] >
 */
class PagesImporter {

	private $importer;
	private $statsReporter;
	private $onAborted;

	private $shouldStop = false;

	public function __construct( PageImporter $importer, StatsReporter $statsReporter, callable $onAborted = null ) {
		$this->importer = $importer;
		$this->statsReporter = $statsReporter;
		$this->onAborted = $onAborted;
	}

	public function importPages( Iterator $entityPageIterator ) {
		$startTime = microtime( true );

		$reporter = new StatsTrackingReporter( $this->importer->getReporter() );

		$this->importer->setReporter( $reporter );

		$this->runImportLoop( $entityPageIterator );

		$stats = $reporter->getStats();
		$stats->setDuration( microtime( true ) - $startTime );
		$this->statsReporter->reportStats( $stats );
	}

	private function runImportLoop( Iterator $entityPageIterator ) {
		$this->shouldStop = false;

		/**
		 * @var EntityPage $entityPage
		 */
		foreach ( $entityPageIterator as $entityPage ) {
			$this->importer->import( $entityPage );

			pcntl_signal_dispatch();
			if ( $this->shouldStop ) {
				if ( $this->onAborted !== null ) {
					call_user_func( $this->onAborted, $entityPage->getTitle() );
				}
				return;
			}
		}
	}

	public function stop() {
		$this->shouldStop = true;
	}

}



1		<?php
2
3		namespace Queryr\Replicator\Importer;
4
5		use Iterator;
6		use Queryr\Replicator\Model\EntityPage;
7
8		/**
9		* @licence GNU GPL v2+
10		* @author Jeroen De Dauw < [email protected] >
11		*/
12		class PagesImporter {
13
14		private $importer;
15		private $statsReporter;
16		private $onAborted;
17
18		private $shouldStop = false;
19
20	1	public function __construct( PageImporter $importer, StatsReporter $statsReporter, callable $onAborted = null ) {
21	1	$this->importer = $importer;
22	1	$this->statsReporter = $statsReporter;
23	1	$this->onAborted = $onAborted;
24	1	}
25
26	1	public function importPages( Iterator $entityPageIterator ) {
27	1	$startTime = microtime( true );
28
29	1	$reporter = new StatsTrackingReporter( $this->importer->getReporter() );
30
31	1	$this->importer->setReporter( $reporter );
32
33	1	$this->runImportLoop( $entityPageIterator );
34
35	1	$stats = $reporter->getStats();
36	1	$stats->setDuration( microtime( true ) - $startTime );
37	1	$this->statsReporter->reportStats( $stats );
38	1	}
39
40	1	private function runImportLoop( Iterator $entityPageIterator ) {
41	1	$this->shouldStop = false;
42
43		/**
44		* @var EntityPage $entityPage
45		*/
46	1	foreach ( $entityPageIterator as $entityPage ) {
47	1	$this->importer->import( $entityPage );
48
49	1	pcntl_signal_dispatch();
50	1	if ( $this->shouldStop ) {
51		if ( $this->onAborted !== null ) {
52		call_user_func( $this->onAborted, $entityPage->getTitle() );
53		}
54	1	return;
55		}
56		}
57	1	}
58
59		public function stop() {
60		$this->shouldStop = true;
61		}
62
63		}
64
65

JeroenDeDauw / Replicator

PagesImporter::runImportLoop() A last analyzed 2019-04-21 21:30 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

PagesImporter::runImportLoop() A
last analyzed 2019-04-21 21:30 UTC