Completed
Push — master ( 7c1895...8e1ae8 )
by
unknown
02:48
created
specials/SpecialExternalDatabases.php 1 patch
Spacing   +38 added lines, -38 removed lines patch added patch discarded remove patch
@@ -54,10 +54,10 @@  discard block
 block discarded – undo
54 54
 		TermLookup $termLookup,
55 55
 		EntityIdHtmlLinkFormatterFactory $entityIdHtmlLinkFormatterFactory,
56 56
 		DumpMetaInformationLookup $dumpMetaInformationRepo ) {
57
-		parent::__construct( 'ExternalDatabases' );
57
+		parent::__construct('ExternalDatabases');
58 58
 
59 59
 		$this->entityIdLinkFormatter = $entityIdHtmlLinkFormatterFactory->getEntityIdFormatter(
60
-			new LanguageLabelDescriptionLookup( $termLookup, $this->getLanguage()->getCode() )
60
+			new LanguageLabelDescriptionLookup($termLookup, $this->getLanguage()->getCode())
61 61
 		);
62 62
 
63 63
 		$this->dumpMetaInformationRepo = $dumpMetaInformationRepo;
@@ -78,7 +78,7 @@  discard block
 block discarded – undo
78 78
 	 * @return string
79 79
 	 */
80 80
 	public function getDescription() {
81
-		return $this->msg( 'wbqev-externaldbs' )->text();
81
+		return $this->msg('wbqev-externaldbs')->text();
82 82
 	}
83 83
 
84 84
 	/**
@@ -86,51 +86,51 @@  discard block
 block discarded – undo
86 86
 	 *
87 87
 	 * @param string|null $subPage
88 88
 	 */
89
-	public function execute( $subPage ) {
89
+	public function execute($subPage) {
90 90
 		$out = $this->getOutput();
91 91
 
92 92
 		$this->setHeaders();
93 93
 
94 94
 		$out->addHTML(
95
-			Html::openElement( 'p' )
96
-			. $this->msg( 'wbqev-externaldbs-instructions' )->parse()
97
-			. Html::closeElement( 'p' )
98
-			. Html::openElement( 'h3' )
99
-			. $this->msg( 'wbqev-externaldbs-overview-headline' )->parse()
100
-			. Html::closeElement( 'h3' )
95
+			Html::openElement('p')
96
+			. $this->msg('wbqev-externaldbs-instructions')->parse()
97
+			. Html::closeElement('p')
98
+			. Html::openElement('h3')
99
+			. $this->msg('wbqev-externaldbs-overview-headline')->parse()
100
+			. Html::closeElement('h3')
101 101
 		);
102 102
 
103 103
 		$dumps = $this->dumpMetaInformationRepo->getAll();
104
-		if ( count( $dumps ) > 0 ) {
104
+		if (count($dumps) > 0) {
105 105
 			$groupedDumpMetaInformation = array();
106
-			foreach ( $dumps as $dump ) {
106
+			foreach ($dumps as $dump) {
107 107
 				$sourceItemId = $dump->getSourceItemId()->getSerialization();
108 108
 				$groupedDumpMetaInformation[$sourceItemId][] = $dump;
109 109
 			}
110 110
 
111 111
 			$table = new HtmlTableBuilder(
112 112
 				array(
113
-					$this->msg( 'wbqev-externaldbs-name' )->escaped(),
114
-					$this->msg( 'wbqev-externaldbs-id' )->escaped(),
115
-					$this->msg( 'wbqev-externaldbs-import-date' )->escaped(),
116
-					$this->msg( 'wbqev-externaldbs-language' )->escaped(),
117
-					$this->msg( 'wbqev-externaldbs-source-urls' )->escaped(),
118
-					$this->msg( 'wbqev-externaldbs-size' )->escaped(),
119
-					$this->msg( 'wbqev-externaldbs-license' )->escaped()
113
+					$this->msg('wbqev-externaldbs-name')->escaped(),
114
+					$this->msg('wbqev-externaldbs-id')->escaped(),
115
+					$this->msg('wbqev-externaldbs-import-date')->escaped(),
116
+					$this->msg('wbqev-externaldbs-language')->escaped(),
117
+					$this->msg('wbqev-externaldbs-source-urls')->escaped(),
118
+					$this->msg('wbqev-externaldbs-size')->escaped(),
119
+					$this->msg('wbqev-externaldbs-license')->escaped()
120 120
 				),
121 121
 				true
122 122
 			);
123 123
 
124
-			foreach ( $groupedDumpMetaInformation as $dumpMetaInformation ) {
125
-				$table->appendRows( $this->getRowGroup( $dumpMetaInformation ) );
124
+			foreach ($groupedDumpMetaInformation as $dumpMetaInformation) {
125
+				$table->appendRows($this->getRowGroup($dumpMetaInformation));
126 126
 			}
127 127
 
128
-			$out->addHTML( $table->toHtml() );
128
+			$out->addHTML($table->toHtml());
129 129
 		} else {
130 130
 			$out->addHTML(
131
-				Html::openElement( 'p' )
132
-				. $this->msg( 'wbqev-externaldbs-no-databases' )->escaped()
133
-				. Html::closeElement( 'p' )
131
+				Html::openElement('p')
132
+				. $this->msg('wbqev-externaldbs-no-databases')->escaped()
133
+				. Html::closeElement('p')
134 134
 			);
135 135
 		}
136 136
 	}
@@ -142,12 +142,12 @@  discard block
 block discarded – undo
142 142
 	 *
143 143
 	 * @return array
144 144
 	 */
145
-	private function getRowGroup( array $dumpMetaInformationGroup ) {
145
+	private function getRowGroup(array $dumpMetaInformationGroup) {
146 146
 		$rows = array();
147 147
 
148
-		foreach ( $dumpMetaInformationGroup as $dumpMetaInformation ) {
148
+		foreach ($dumpMetaInformationGroup as $dumpMetaInformation) {
149 149
 			$dumpId = $dumpMetaInformation->getDumpId();
150
-			$importDate = $this->getLanguage()->timeanddate( $dumpMetaInformation->getImportDate() );
150
+			$importDate = $this->getLanguage()->timeanddate($dumpMetaInformation->getImportDate());
151 151
 			$language = Language::fetchLanguageName(
152 152
 				$dumpMetaInformation->getLanguageCode(),
153 153
 				$this->getLanguage()->getCode()
@@ -156,23 +156,23 @@  discard block
 block discarded – undo
156 156
 				$dumpMetaInformation->getSourceUrl(),
157 157
 				$dumpMetaInformation->getSourceUrl()
158 158
 			);
159
-			$size = $this->getLanguage()->formatSize( $dumpMetaInformation->getSize() );
160
-			$license = $this->entityIdLinkFormatter->formatEntityId( $dumpMetaInformation->getLicenseItemId() );
159
+			$size = $this->getLanguage()->formatSize($dumpMetaInformation->getSize());
160
+			$license = $this->entityIdLinkFormatter->formatEntityId($dumpMetaInformation->getLicenseItemId());
161 161
 			$rows[] = array(
162
-				new HtmlTableCellBuilder( $dumpId ),
163
-				new HtmlTableCellBuilder( $importDate ),
164
-				new HtmlTableCellBuilder( $language ),
165
-				new HtmlTableCellBuilder( $sourceUrl, array(), true ),
166
-				new HtmlTableCellBuilder( $size ),
167
-				new HtmlTableCellBuilder( $license, array(), true )
162
+				new HtmlTableCellBuilder($dumpId),
163
+				new HtmlTableCellBuilder($importDate),
164
+				new HtmlTableCellBuilder($language),
165
+				new HtmlTableCellBuilder($sourceUrl, array(), true),
166
+				new HtmlTableCellBuilder($size),
167
+				new HtmlTableCellBuilder($license, array(), true)
168 168
 			);
169 169
 		}
170 170
 
171 171
 		array_unshift(
172 172
 			$rows[0],
173 173
 			new HtmlTableCellBuilder(
174
-				$this->entityIdLinkFormatter->formatEntityId( $dumpMetaInformationGroup[0]->getSourceItemId() ),
175
-				array( 'rowspan' => (string)count( $dumpMetaInformationGroup ) ),
174
+				$this->entityIdLinkFormatter->formatEntityId($dumpMetaInformationGroup[0]->getSourceItemId()),
175
+				array('rowspan' => (string)count($dumpMetaInformationGroup)),
176 176
 				true
177 177
 			)
178 178
 		);
Please login to merge, or discard this patch.
includes/DumpMetaInformation/DumpMetaInformationLookup.php 1 patch
Spacing   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -20,7 +20,7 @@  discard block
 block discarded – undo
20 20
 	 * @return DumpMetaInformation[]
21 21
 	 * @throws \InvalidArgumentException
22 22
 	 */
23
-	public function getWithIds( array $dumpIds );
23
+	public function getWithIds(array $dumpIds);
24 24
 
25 25
 	/**
26 26
 	 * Gets DumpMetaInformation for specific identifier properties from database
@@ -30,7 +30,7 @@  discard block
 block discarded – undo
30 30
 	 *
31 31
 	 * @return DumpMetaInformation[]
32 32
 	 */
33
-	public function getWithIdentifierProperties( array $identifierPropertyIds );
33
+	public function getWithIdentifierProperties(array $identifierPropertyIds);
34 34
 
35 35
 	/**
36 36
 	 * Gets all DumpMetaInformation from database
Please login to merge, or discard this patch.
includes/Serializer/CrossCheckResultSerializer.php 1 patch
Spacing   +8 added lines, -8 removed lines patch added patch discarded remove patch
@@ -51,7 +51,7 @@  discard block
 block discarded – undo
51 51
 	 *
52 52
 	 * @return bool
53 53
 	 */
54
-	public function isSerializerFor( $object ) {
54
+	public function isSerializerFor($object) {
55 55
 		return $object instanceof CrossCheckResult;
56 56
 	}
57 57
 
@@ -63,25 +63,25 @@  discard block
 block discarded – undo
63 63
 	 * @return array
64 64
 	 * @throws UnsupportedObjectException
65 65
 	 */
66
-	public function serialize( $object ) {
67
-		if ( !$this->isSerializerFor( $object ) ) {
66
+	public function serialize($object) {
67
+		if (!$this->isSerializerFor($object)) {
68 68
 			throw new UnsupportedObjectException(
69 69
 				$object,
70 70
 				'CrossCheckResultSerializer can only serialize CrossCheckResult objects.'
71 71
 			);
72 72
 		}
73 73
 
74
-		return $this->getSerialized( $object );
74
+		return $this->getSerialized($object);
75 75
 	}
76 76
 
77
-	private function getSerialized( CrossCheckResult $crossCheckResult ) {
77
+	private function getSerialized(CrossCheckResult $crossCheckResult) {
78 78
 		return array(
79 79
 			'propertyId' => $crossCheckResult->getPropertyId()->getSerialization(),
80 80
 			'claimGuid' => $crossCheckResult->getClaimGuid(),
81 81
 			'externalId' => $crossCheckResult->getExternalId(),
82
-			'dataSource' => $this->dumpMetaInformationSerializer->serialize( $crossCheckResult->getDumpMetaInformation() ),
83
-			'comparisonResult' => $this->comparisonResultSerializer->serialize( $crossCheckResult->getComparisonResult() ),
84
-			'referenceResult' => $this->referenceResultSerializer->serialize( $crossCheckResult->getReferenceResult() )
82
+			'dataSource' => $this->dumpMetaInformationSerializer->serialize($crossCheckResult->getDumpMetaInformation()),
83
+			'comparisonResult' => $this->comparisonResultSerializer->serialize($crossCheckResult->getComparisonResult()),
84
+			'referenceResult' => $this->referenceResultSerializer->serialize($crossCheckResult->getReferenceResult())
85 85
 		);
86 86
 	}
87 87
 
Please login to merge, or discard this patch.
maintenance/UpdateExternalData.php 1 patch
Spacing   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -7,10 +7,10 @@  discard block
 block discarded – undo
7 7
 use WikibaseQuality\ExternalValidation\UpdateExternalData\CsvImportSettings;
8 8
 use WikibaseQuality\ExternalValidation\UpdateExternalData\ExternalDataImporter;
9 9
 
10
-$basePath = getenv( 'MW_INSTALL_PATH' ) !== false
11
-	? getenv( 'MW_INSTALL_PATH' )
12
-	: __DIR__ . '/../../..';
13
-require_once $basePath . '/maintenance/Maintenance.php';
10
+$basePath = getenv('MW_INSTALL_PATH') !== false
11
+	? getenv('MW_INSTALL_PATH')
12
+	: __DIR__.'/../../..';
13
+require_once $basePath.'/maintenance/Maintenance.php';
14 14
 
15 15
 /**
16 16
  * Maintenance script that evokes updates of wbqev_external_data, wbqev_dump_information, wbqev_identifier_properties
@@ -25,17 +25,17 @@  discard block
 block discarded – undo
25 25
 	public function __construct() {
26 26
 		parent::__construct();
27 27
 
28
-		$this->addDescription( 'Imports external entities from given CSV files into the local '
29
-			. 'database. CSV files can be generated using the DumpConverter.' );
30
-		$this->addOption( 'external-values-file', 'CSV file containing external values for import.', true, true );
31
-		$this->addOption( 'dump-information-file', 'CSV file containing dump meta information for import.', true, true );
32
-		$this->setBatchSize( 1000 );
28
+		$this->addDescription('Imports external entities from given CSV files into the local '
29
+			. 'database. CSV files can be generated using the DumpConverter.');
30
+		$this->addOption('external-values-file', 'CSV file containing external values for import.', true, true);
31
+		$this->addOption('dump-information-file', 'CSV file containing dump meta information for import.', true, true);
32
+		$this->setBatchSize(1000);
33 33
 	}
34 34
 
35 35
 	public function execute() {
36 36
 		$context = new CsvImportSettings(
37
-			$this->getOption( 'external-values-file' ),
38
-			$this->getOption( 'dump-information-file' ),
37
+			$this->getOption('external-values-file'),
38
+			$this->getOption('dump-information-file'),
39 39
 			$this->mBatchSize,
40 40
 			$this->isQuiet()
41 41
 		);
Please login to merge, or discard this patch.
includes/CrossCheck/Comparer/QuantityValueComparer.php 1 patch
Spacing   +6 added lines, -6 removed lines patch added patch discarded remove patch
@@ -23,9 +23,9 @@  discard block
 block discarded – undo
23 23
 	 * @throws InvalidArgumentException
24 24
 	 * @return string One of the ComparisonResult::STATUS_... constants.
25 25
 	 */
26
-	public function compare( DataValue $value, DataValue $comparativeValue ) {
27
-		if ( !$this->canCompare( $value, $comparativeValue ) ) {
28
-			throw new InvalidArgumentException( 'Given values can not be compared using this comparer.' );
26
+	public function compare(DataValue $value, DataValue $comparativeValue) {
27
+		if (!$this->canCompare($value, $comparativeValue)) {
28
+			throw new InvalidArgumentException('Given values can not be compared using this comparer.');
29 29
 		}
30 30
 
31 31
 		/**
@@ -33,8 +33,8 @@  discard block
 block discarded – undo
33 33
 		 * @var QuantityValue $comparativeValue
34 34
 		 */
35 35
 
36
-		if ( $comparativeValue->getLowerBound()->compare( $value->getUpperBound() ) <= 0 &&
37
-			$comparativeValue->getUpperBound()->compare( $value->getLowerBound() ) >= 0
36
+		if ($comparativeValue->getLowerBound()->compare($value->getUpperBound()) <= 0 &&
37
+			$comparativeValue->getUpperBound()->compare($value->getLowerBound()) >= 0
38 38
 		) {
39 39
 			return ComparisonResult::STATUS_MATCH;
40 40
 		}
@@ -50,7 +50,7 @@  discard block
 block discarded – undo
50 50
 	 *
51 51
 	 * @return bool
52 52
 	 */
53
-	public function canCompare( DataValue $value, DataValue $comparativeValue ) {
53
+	public function canCompare(DataValue $value, DataValue $comparativeValue) {
54 54
 		return $value instanceof QuantityValue && $comparativeValue instanceof QuantityValue;
55 55
 	}
56 56
 
Please login to merge, or discard this patch.
includes/DumpMetaInformation/SqlDumpMetaInformationRepo.php 1 patch
Spacing   +42 added lines, -42 removed lines patch added patch discarded remove patch
@@ -29,18 +29,18 @@  discard block
 block discarded – undo
29 29
 	 * @return DumpMetaInformation[]
30 30
 	 * @throws InvalidArgumentException
31 31
 	 */
32
-	public function getWithIds( array $dumpIds ) {
33
-		if ( $dumpIds === [] ) {
32
+	public function getWithIds(array $dumpIds) {
33
+		if ($dumpIds === []) {
34 34
 			return [];
35 35
 		}
36 36
 
37
-		foreach ( $dumpIds as $dumpId ) {
38
-			if ( !is_string( $dumpId ) ) {
39
-				throw new InvalidArgumentException( '$dumpIds must contain only strings.' );
37
+		foreach ($dumpIds as $dumpId) {
38
+			if (!is_string($dumpId)) {
39
+				throw new InvalidArgumentException('$dumpIds must contain only strings.');
40 40
 			}
41 41
 		}
42 42
 
43
-		$db = wfGetDB( DB_REPLICA );
43
+		$db = wfGetDB(DB_REPLICA);
44 44
 		$result = $db->select(
45 45
 			array(
46 46
 				self::META_TABLE_NAME,
@@ -60,7 +60,7 @@  discard block
 block discarded – undo
60 60
 			)
61 61
 		);
62 62
 
63
-		return $this->buildDumpMetaInformationFromResult( $result );
63
+		return $this->buildDumpMetaInformationFromResult($result);
64 64
 	}
65 65
 
66 66
 	/**
@@ -72,20 +72,20 @@  discard block
 block discarded – undo
72 72
 	 * @throws InvalidArgumentException
73 73
 	 * @return DumpMetaInformation[]
74 74
 	 */
75
-	public function getWithIdentifierProperties( array $identifierPropertyIds ) {
76
-		if ( $identifierPropertyIds === [] ) {
75
+	public function getWithIdentifierProperties(array $identifierPropertyIds) {
76
+		if ($identifierPropertyIds === []) {
77 77
 			return [];
78 78
 		}
79 79
 
80
-		foreach ( $identifierPropertyIds as $propertyId ) {
81
-			if ( !( $propertyId instanceof PropertyId ) ) {
82
-				throw new InvalidArgumentException( '$identifierProperties must contain only PropertyIds.' );
80
+		foreach ($identifierPropertyIds as $propertyId) {
81
+			if (!($propertyId instanceof PropertyId)) {
82
+				throw new InvalidArgumentException('$identifierProperties must contain only PropertyIds.');
83 83
 			}
84 84
 		}
85 85
 
86
-		$db = wfGetDB( DB_REPLICA );
86
+		$db = wfGetDB(DB_REPLICA);
87 87
 		$identifierPropertyIds = array_map(
88
-			function( PropertyId $id ) {
88
+			function(PropertyId $id) {
89 89
 				return $id->getSerialization();
90 90
 			},
91 91
 			$identifierPropertyIds
@@ -98,13 +98,13 @@  discard block
 block discarded – undo
98 98
 			)
99 99
 		);
100 100
 		$dumpIds = array();
101
-		foreach ( $result as $row ) {
102
-			if ( !in_array( $row->dump_id, $dumpIds ) ) {
101
+		foreach ($result as $row) {
102
+			if (!in_array($row->dump_id, $dumpIds)) {
103 103
 				$dumpIds[] = $row->dump_id;
104 104
 			}
105 105
 		}
106 106
 
107
-		return $this->getWithIds( $dumpIds );
107
+		return $this->getWithIds($dumpIds);
108 108
 	}
109 109
 
110 110
 	/**
@@ -114,7 +114,7 @@  discard block
 block discarded – undo
114 114
 	 * @return DumpMetaInformation[]
115 115
 	 */
116 116
 	public function getAll() {
117
-		$db = wfGetDB( DB_REPLICA );
117
+		$db = wfGetDB(DB_REPLICA);
118 118
 		$result = $db->select(
119 119
 			array(
120 120
 				self::META_TABLE_NAME,
@@ -132,7 +132,7 @@  discard block
 block discarded – undo
132 132
 			)
133 133
 		);
134 134
 
135
-		return $this->buildDumpMetaInformationFromResult( $result );
135
+		return $this->buildDumpMetaInformationFromResult($result);
136 136
 	}
137 137
 
138 138
 	/**
@@ -140,34 +140,34 @@  discard block
 block discarded – undo
140 140
 	 * @return null|array
141 141
 	 * @throws UnexpectedValueException
142 142
 	 */
143
-	private function buildDumpMetaInformationFromResult( ResultWrapper $result ) {
143
+	private function buildDumpMetaInformationFromResult(ResultWrapper $result) {
144 144
 		$aggregatedRows = array();
145
-		foreach ( $result as $row ) {
146
-			if ( array_key_exists( $row->id, $aggregatedRows ) ) {
147
-				$propertyId = new PropertyId( $row->identifier_pid );
145
+		foreach ($result as $row) {
146
+			if (array_key_exists($row->id, $aggregatedRows)) {
147
+				$propertyId = new PropertyId($row->identifier_pid);
148 148
 				$aggregatedRows[$row->id]->identifier_pid[] = $propertyId;
149 149
 			} else {
150
-				if ( $row->identifier_pid !== null ) {
151
-					$propertyId = new PropertyId( $row->identifier_pid );
152
-					$row->identifier_pid = array( $propertyId );
150
+				if ($row->identifier_pid !== null) {
151
+					$propertyId = new PropertyId($row->identifier_pid);
152
+					$row->identifier_pid = array($propertyId);
153 153
 				}
154 154
 				$aggregatedRows[$row->id] = $row;
155 155
 			}
156 156
 		}
157 157
 
158 158
 		$dumpMetaInformation = array();
159
-		foreach ( $aggregatedRows as $row ) {
159
+		foreach ($aggregatedRows as $row) {
160 160
 			$dumpId = $row->id;
161
-			$sourceItemId = new ItemId( $row->source_qid );
162
-			$importDate = wfTimestamp( TS_MW, $row->import_date );
161
+			$sourceItemId = new ItemId($row->source_qid);
162
+			$importDate = wfTimestamp(TS_MW, $row->import_date);
163 163
 			$language = $row->language;
164 164
 			$sourceUrl = $row->source_url;
165 165
 			$size = (int)$row->size;
166
-			$licenseItemId = new ItemId( $row->license_qid );
166
+			$licenseItemId = new ItemId($row->license_qid);
167 167
 			$identifierPropertyIds = $row->identifier_pid;
168 168
 
169 169
 			$dumpMetaInformation[$row->dump_id] =
170
-				new DumpMetaInformation( $dumpId,
170
+				new DumpMetaInformation($dumpId,
171 171
 					$sourceItemId,
172 172
 					$identifierPropertyIds,
173 173
 					$importDate,
@@ -186,22 +186,22 @@  discard block
 block discarded – undo
186 186
 	 *
187 187
 	 * @param DumpMetaInformation $dumpMetaInformation
188 188
 	 */
189
-	public function save( DumpMetaInformation $dumpMetaInformation ) {
190
-		$db = wfGetDB( DB_REPLICA );
189
+	public function save(DumpMetaInformation $dumpMetaInformation) {
190
+		$db = wfGetDB(DB_REPLICA);
191 191
 		$dumpId = $dumpMetaInformation->getDumpId();
192
-		$accumulator = $this->getDumpInformationFields( $db, $dumpMetaInformation );
192
+		$accumulator = $this->getDumpInformationFields($db, $dumpMetaInformation);
193 193
 
194 194
 		$existing = $db->selectRow(
195 195
 			self::META_TABLE_NAME,
196
-			array( 'id' ),
197
-			array( 'id' => $dumpId )
196
+			array('id'),
197
+			array('id' => $dumpId)
198 198
 		);
199 199
 
200
-		if ( $existing ) {
200
+		if ($existing) {
201 201
 			$db->update(
202 202
 				self::META_TABLE_NAME,
203 203
 				$accumulator,
204
-				array( 'id' => $dumpId )
204
+				array('id' => $dumpId)
205 205
 			);
206 206
 		} else {
207 207
 			$db->insert(
@@ -212,12 +212,12 @@  discard block
 block discarded – undo
212 212
 
213 213
 		$db->delete(
214 214
 			self::IDENTIFIER_PROPERTIES_TABLE_NAME,
215
-			array( 'dump_id' => $dumpId )
215
+			array('dump_id' => $dumpId)
216 216
 		);
217 217
 		$db->insert(
218 218
 			self::IDENTIFIER_PROPERTIES_TABLE_NAME,
219 219
 			array_map(
220
-				function ( PropertyId $identifierPropertyId ) use ( $dumpId ) {
220
+				function(PropertyId $identifierPropertyId) use ($dumpId) {
221 221
 					return array(
222 222
 						'dump_id' => $dumpId,
223 223
 						'identifier_pid' => $identifierPropertyId->getSerialization()
@@ -233,11 +233,11 @@  discard block
 block discarded – undo
233 233
 	 * @param DumpMetaInformation $dumpMetaInformation
234 234
 	 * @return array
235 235
 	 */
236
-	private function getDumpInformationFields( Database $db,  DumpMetaInformation $dumpMetaInformation ) {
236
+	private function getDumpInformationFields(Database $db, DumpMetaInformation $dumpMetaInformation) {
237 237
 		return array(
238 238
 			'id' => $dumpMetaInformation->getDumpId(),
239 239
 			'source_qid' => $dumpMetaInformation->getSourceItemId()->getSerialization(),
240
-			'import_date' => $db->timestamp( $dumpMetaInformation->getImportDate() ),
240
+			'import_date' => $db->timestamp($dumpMetaInformation->getImportDate()),
241 241
 			'language' => $dumpMetaInformation->getLanguageCode(),
242 242
 			'source_url' => $dumpMetaInformation->getSourceUrl(),
243 243
 			'size' => $dumpMetaInformation->getSize(),
Please login to merge, or discard this patch.
includes/DumpMetaInformation/DumpMetaInformation.php 1 patch
Spacing   +30 added lines, -30 removed lines patch added patch discarded remove patch
@@ -83,27 +83,27 @@  discard block
 block discarded – undo
83 83
 	 *
84 84
 	 * @throws InvalidArgumentException
85 85
 	 */
86
-	public function __construct( $dumpId,
86
+	public function __construct($dumpId,
87 87
 								 ItemId $sourceItemId,
88 88
 								 array $identifierPropertyIds,
89 89
 								 $importDate,
90 90
 								 $languageCode,
91 91
 								 $sourceUrl,
92 92
 								 $size,
93
-								 ItemId $licenseItemId ) {
93
+								 ItemId $licenseItemId) {
94 94
 		Assert::parameterElementType(
95 95
 			PropertyId::class,
96 96
 			$identifierPropertyIds,
97 97
 			'$identifierPropertyIds'
98 98
 		);
99 99
 
100
-		$this->setDumpId( $dumpId );
100
+		$this->setDumpId($dumpId);
101 101
 		$this->sourceItemId = $sourceItemId;
102 102
 		$this->identifierPropertyIds = $identifierPropertyIds;
103
-		$this->setImportDate( $importDate );
104
-		$this->setLanguageCode( $languageCode );
105
-		$this->setSourceUrl( $sourceUrl );
106
-		$this->setSize( $size );
103
+		$this->setImportDate($importDate);
104
+		$this->setLanguageCode($languageCode);
105
+		$this->setSourceUrl($sourceUrl);
106
+		$this->setSize($size);
107 107
 		$this->licenseItemId = $licenseItemId;
108 108
 	}
109 109
 
@@ -168,10 +168,10 @@  discard block
 block discarded – undo
168 168
 	 *
169 169
 	 * @throws InvalidArgumentException
170 170
 	 */
171
-	private function setDumpId( $dumpId ) {
172
-		Assert::parameterType( 'string', $dumpId, '$dumpId' );
173
-		$length = strlen( $dumpId );
174
-		if ( $length < 1 || $length > 25 ) {
171
+	private function setDumpId($dumpId) {
172
+		Assert::parameterType('string', $dumpId, '$dumpId');
173
+		$length = strlen($dumpId);
174
+		if ($length < 1 || $length > 25) {
175 175
 			throw new InvalidArgumentException('$dumpId must be between 1 and 25 characters.');
176 176
 		}
177 177
 
@@ -183,10 +183,10 @@  discard block
 block discarded – undo
183 183
 	 *
184 184
 	 * @throws InvalidArgumentException
185 185
 	 */
186
-	private function setLanguageCode( $languageCode ) {
187
-		Assert::parameterType( 'string', $languageCode, '$languageCode' );
188
-		if ( !Language::isValidCode( $languageCode ) ) {
189
-			throw new InvalidArgumentException( '$languageCode is not valid.' );
186
+	private function setLanguageCode($languageCode) {
187
+		Assert::parameterType('string', $languageCode, '$languageCode');
188
+		if (!Language::isValidCode($languageCode)) {
189
+			throw new InvalidArgumentException('$languageCode is not valid.');
190 190
 		}
191 191
 
192 192
 		$this->languageCode = $languageCode;
@@ -197,12 +197,12 @@  discard block
 block discarded – undo
197 197
 	 *
198 198
 	 * @throws InvalidArgumentException
199 199
 	 */
200
-	private function setImportDate( $importDate ) {
201
-		Assert::parameterType( 'string', $importDate, '$importDate' );
200
+	private function setImportDate($importDate) {
201
+		Assert::parameterType('string', $importDate, '$importDate');
202 202
 
203
-		$timestamp = wfTimestamp( TS_MW, $importDate );
204
-		if ( !$timestamp ) {
205
-			throw new InvalidArgumentException( '$updatedAt has invalid timestamp format.' );
203
+		$timestamp = wfTimestamp(TS_MW, $importDate);
204
+		if (!$timestamp) {
205
+			throw new InvalidArgumentException('$updatedAt has invalid timestamp format.');
206 206
 		}
207 207
 
208 208
 		$this->importDate = $importDate;
@@ -213,13 +213,13 @@  discard block
 block discarded – undo
213 213
 	 *
214 214
 	 * @throws InvalidArgumentException
215 215
 	 */
216
-	private function setSourceUrl( $sourceUrl ) {
217
-		Assert::parameterType( 'string', $sourceUrl, '$sourceUrl' );
218
-		if ( strlen( $sourceUrl ) > 300 ) {
219
-			throw new InvalidArgumentException( '$sourceUrl must not be longer than 300 characters.' );
216
+	private function setSourceUrl($sourceUrl) {
217
+		Assert::parameterType('string', $sourceUrl, '$sourceUrl');
218
+		if (strlen($sourceUrl) > 300) {
219
+			throw new InvalidArgumentException('$sourceUrl must not be longer than 300 characters.');
220 220
 		}
221
-		if ( !filter_var( $sourceUrl, FILTER_VALIDATE_URL ) ) {
222
-			throw new InvalidArgumentException( '$sourceUrl is not a valid url.' );
221
+		if (!filter_var($sourceUrl, FILTER_VALIDATE_URL)) {
222
+			throw new InvalidArgumentException('$sourceUrl is not a valid url.');
223 223
 		}
224 224
 
225 225
 		$this->sourceUrl = $sourceUrl;
@@ -230,10 +230,10 @@  discard block
 block discarded – undo
230 230
 	 *
231 231
 	 * @throws InvalidArgumentException
232 232
 	 */
233
-	private function setSize( $size ) {
234
-		Assert::parameterType( 'integer', $size, '$size' );
235
-		if ( $size <= 0 ) {
236
-			throw new InvalidArgumentException( '$size must be positive integer.' );
233
+	private function setSize($size) {
234
+		Assert::parameterType('integer', $size, '$size');
235
+		if ($size <= 0) {
236
+			throw new InvalidArgumentException('$size must be positive integer.');
237 237
 		}
238 238
 
239 239
 		$this->size = $size;
Please login to merge, or discard this patch.
includes/UpdateExternalData/ExternalDataImporter.php 1 patch
Spacing   +41 added lines, -41 removed lines patch added patch discarded remove patch
@@ -51,13 +51,13 @@  discard block
 block discarded – undo
51 51
 	public function import() {
52 52
 		$dumpIds = $this->insertMetaInformation();
53 53
 
54
-		$this->log( "\nDelete old database entries...\n" );
54
+		$this->log("\nDelete old database entries...\n");
55 55
 
56
-		foreach ( $dumpIds as $dumpId ) {
57
-			$this->externalDataRepo->deleteOfDump( $dumpId, $this->importSettings->getBatchSize() );
56
+		foreach ($dumpIds as $dumpId) {
57
+			$this->externalDataRepo->deleteOfDump($dumpId, $this->importSettings->getBatchSize());
58 58
 		}
59 59
 
60
-		$this->log( "\n" );
60
+		$this->log("\n");
61 61
 
62 62
 		$this->insertExternalValues();
63 63
 	}
@@ -68,52 +68,52 @@  discard block
 block discarded – undo
68 68
 	 * @return array
69 69
 	 */
70 70
 	protected function insertMetaInformation() {
71
-		$this->log( "Insert new dump meta information\n" );
71
+		$this->log("Insert new dump meta information\n");
72 72
 
73
-		$csvFile = fopen( $this->importSettings->getDumpInformationFilePath(), 'rb' );
74
-		if ( !$csvFile ) {
75
-			exit( 'Error while reading CSV file.' );
73
+		$csvFile = fopen($this->importSettings->getDumpInformationFilePath(), 'rb');
74
+		if (!$csvFile) {
75
+			exit('Error while reading CSV file.');
76 76
 		}
77 77
 
78 78
 		$i = 0;
79 79
 		$dumpIds = array();
80
-		while ( $data = fgetcsv( $csvFile ) ) {
80
+		while ($data = fgetcsv($csvFile)) {
81 81
 			$identifierPropertyIds = array_map(
82
-				function ( $propertyId ) {
83
-					return new PropertyId( $propertyId );
82
+				function($propertyId) {
83
+					return new PropertyId($propertyId);
84 84
 				},
85
-				json_decode( $data[2] )
85
+				json_decode($data[2])
86 86
 			);
87 87
 			try {
88 88
 				$dumpMetaInformation = new DumpMetaInformation(
89 89
 					$data[0],
90
-					new ItemId( $data[1] ),
90
+					new ItemId($data[1]),
91 91
 					$identifierPropertyIds,
92 92
 					$data[3],
93 93
 					$data[4],
94 94
 					$data[5],
95
-					intval( $data[6] ),
96
-					new ItemId( $data[7] )
95
+					intval($data[6]),
96
+					new ItemId($data[7])
97 97
 				);
98
-			} catch ( \InvalidArgumentException $e ) {
99
-				exit( 'Input file has bad formatted values.' );
98
+			} catch (\InvalidArgumentException $e) {
99
+				exit('Input file has bad formatted values.');
100 100
 			}
101 101
 			$dumpIds[] = $dumpMetaInformation->getDumpId();
102 102
 
103 103
 			try {
104
-				$this->dumpMetaInformationStore->save( $dumpMetaInformation );
105
-			} catch ( \DBError $e ) {
106
-				exit( 'Unknown database error occurred.' );
104
+				$this->dumpMetaInformationStore->save($dumpMetaInformation);
105
+			} catch (\DBError $e) {
106
+				exit('Unknown database error occurred.');
107 107
 			}
108 108
 
109 109
 			$i++;
110
-			$this->log( "\r\033[K" );
111
-			$this->log( "$i rows inserted or updated" );
110
+			$this->log("\r\033[K");
111
+			$this->log("$i rows inserted or updated");
112 112
 		}
113 113
 
114
-		fclose( $csvFile );
114
+		fclose($csvFile);
115 115
 
116
-		$this->log( "\n" );
116
+		$this->log("\n");
117 117
 
118 118
 		return $dumpIds;
119 119
 	}
@@ -122,31 +122,31 @@  discard block
 block discarded – undo
122 122
 	 * Inserts external values stored in csv file into database
123 123
 	 */
124 124
 	private function insertExternalValues() {
125
-		$this->log( "Insert new data values\n" );
125
+		$this->log("Insert new data values\n");
126 126
 
127
-		$csvFile = fopen( $this->importSettings->getExternalValuesFilePath(), 'rb' );
128
-		if ( !$csvFile ) {
129
-			exit( 'Error while reading CSV file.' );
127
+		$csvFile = fopen($this->importSettings->getExternalValuesFilePath(), 'rb');
128
+		if (!$csvFile) {
129
+			exit('Error while reading CSV file.');
130 130
 		}
131 131
 
132 132
 		$i = 0;
133 133
 		$accumulator = array();
134
-		while ( true ) {
135
-			$data = fgetcsv( $csvFile );
136
-			if ( $data === false || ++$i % $this->importSettings->getBatchSize() === 0 ) {
134
+		while (true) {
135
+			$data = fgetcsv($csvFile);
136
+			if ($data === false || ++$i % $this->importSettings->getBatchSize() === 0) {
137 137
 				try {
138
-					$this->externalDataRepo->insertBatch( $accumulator );
139
-				} catch ( \DBError $e ) {
140
-					exit( 'Unknown database error occurred.' );
138
+					$this->externalDataRepo->insertBatch($accumulator);
139
+				} catch (\DBError $e) {
140
+					exit('Unknown database error occurred.');
141 141
 				}
142 142
 				wfGetLBFactory()->waitForReplication();
143 143
 
144
-				$this->log( "\r\033[K" );
145
-				$this->log( "$i rows inserted" );
144
+				$this->log("\r\033[K");
145
+				$this->log("$i rows inserted");
146 146
 
147 147
 				$accumulator = array();
148 148
 
149
-				if ( $data === false ) {
149
+				if ($data === false) {
150 150
 					break;
151 151
 				}
152 152
 			}
@@ -154,16 +154,16 @@  discard block
 block discarded – undo
154 154
 			$accumulator[] = $data;
155 155
 		}
156 156
 
157
-		fclose( $csvFile );
157
+		fclose($csvFile);
158 158
 
159
-		$this->log( "\n" );
159
+		$this->log("\n");
160 160
 	}
161 161
 
162 162
 	/**
163 163
 	 * @param string $text
164 164
 	 */
165
-	private function log( $text ) {
166
-		if ( !$this->importSettings->isQuiet() ) {
165
+	private function log($text) {
166
+		if (!$this->importSettings->isQuiet()) {
167 167
 			print $text;
168 168
 		}
169 169
 	}
Please login to merge, or discard this patch.
includes/CrossCheck/CrossChecker.php 1 patch
Spacing   +55 added lines, -55 removed lines patch added patch discarded remove patch
@@ -95,22 +95,22 @@  discard block
 block discarded – undo
95 95
 	 * @return CrossCheckResultList
96 96
 	 * @throws InvalidArgumentException
97 97
 	 */
98
-	public function crossCheckStatements( StatementList $entityStatements, StatementList $statements ) {
98
+	public function crossCheckStatements(StatementList $entityStatements, StatementList $statements) {
99 99
 		$statementsOfEntity = $entityStatements->toArray();
100 100
 
101
-		foreach ( $statements as $statement ) {
102
-			if ( !in_array( $statement, $statementsOfEntity ) ) {
103
-				throw new InvalidArgumentException( 'All statements in $statements must belong to the entity.' );
101
+		foreach ($statements as $statement) {
102
+			if (!in_array($statement, $statementsOfEntity)) {
103
+				throw new InvalidArgumentException('All statements in $statements must belong to the entity.');
104 104
 			}
105 105
 		}
106 106
 
107 107
 		$resultList = new CrossCheckResultList();
108
-		if ( $statements->count() > 0 ) {
109
-			$applicableDumps = $this->getApplicableDumps( $entityStatements );
110
-			foreach ( $applicableDumps as $identifierPropertyId => $dumpMetaInformationList ) {
111
-				$identifierPropertyId = new PropertyId( $identifierPropertyId );
108
+		if ($statements->count() > 0) {
109
+			$applicableDumps = $this->getApplicableDumps($entityStatements);
110
+			foreach ($applicableDumps as $identifierPropertyId => $dumpMetaInformationList) {
111
+				$identifierPropertyId = new PropertyId($identifierPropertyId);
112 112
 
113
-				if ( $this->isIdentifierProperty( $identifierPropertyId ) ) {
113
+				if ($this->isIdentifierProperty($identifierPropertyId)) {
114 114
 					$resultList->merge(
115 115
 						$this->crossCheckStatementsWithIdentifier(
116 116
 							$entityStatements,
@@ -133,17 +133,17 @@  discard block
 block discarded – undo
133 133
 	 *
134 134
 	 * @return array[]
135 135
 	 */
136
-	private function getApplicableDumps( StatementList $statements ) {
136
+	private function getApplicableDumps(StatementList $statements) {
137 137
 		$applicableDumps = array();
138 138
 		$identifierPropertyIds = $statements->getPropertyIds();
139 139
 		$dumpMetaInformation = $this->dumpMetaInformationLookup->getWithIdentifierProperties(
140 140
 			$identifierPropertyIds
141 141
 		);
142 142
 
143
-		foreach ( $dumpMetaInformation as $dump ) {
144
-			foreach ( $dump->getIdentifierPropertyIds() as $identifierPropertyId ) {
143
+		foreach ($dumpMetaInformation as $dump) {
144
+			foreach ($dump->getIdentifierPropertyIds() as $identifierPropertyId) {
145 145
 				$serialization = $identifierPropertyId->getSerialization();
146
-				$applicableDumps[ $serialization ][ $dump->getDumpId() ] = $dump;
146
+				$applicableDumps[$serialization][$dump->getDumpId()] = $dump;
147 147
 			}
148 148
 		}
149 149
 
@@ -168,36 +168,36 @@  discard block
 block discarded – undo
168 168
 	) {
169 169
 		$resultList = new CrossCheckResultList();
170 170
 
171
-		$externalIds = $this->getExternalIds( $entityStatements, $identifierPropertyId );
172
-		if ( !$externalIds ) {
171
+		$externalIds = $this->getExternalIds($entityStatements, $identifierPropertyId);
172
+		if (!$externalIds) {
173 173
 			return $resultList;
174 174
 		}
175 175
 
176 176
 		$dumpIds = array_map(
177
-			function ( DumpMetaInformation $dumpMetaInformation ) {
177
+			function(DumpMetaInformation $dumpMetaInformation) {
178 178
 				return $dumpMetaInformation->getDumpId();
179 179
 			},
180 180
 			$dumpMetaInformationList
181 181
 		);
182
-		$externalData = $this->externalDataRepo->getExternalData( $dumpIds, $externalIds, $statements->getPropertyIds() );
182
+		$externalData = $this->externalDataRepo->getExternalData($dumpIds, $externalIds, $statements->getPropertyIds());
183 183
 
184
-		foreach ( $externalData as $dumpId => $externalDataPerDump ) {
185
-			$dumpMetaInformation = $dumpMetaInformationList[ $dumpId ];
184
+		foreach ($externalData as $dumpId => $externalDataPerDump) {
185
+			$dumpMetaInformation = $dumpMetaInformationList[$dumpId];
186 186
 			$comparativeValueParser = $this->valueParserFactory->newComparativeValueParser(
187 187
 				$dumpMetaInformation->getLanguageCode()
188 188
 			);
189 189
 
190
-			foreach ( $externalDataPerDump as $externalId => $externalDataPerId ) {
190
+			foreach ($externalDataPerDump as $externalId => $externalDataPerId) {
191 191
 				$externalId = (string)$externalId;
192
-				foreach ( $externalDataPerId as $propertyId => $externalValues ) {
193
-					$propertyId = new PropertyId( $propertyId );
192
+				foreach ($externalDataPerId as $propertyId => $externalValues) {
193
+					$propertyId = new PropertyId($propertyId);
194 194
 					$resultList->merge(
195 195
 						$this->crossCheckExternalValues(
196 196
 							$dumpMetaInformation,
197 197
 							$identifierPropertyId,
198 198
 							$externalId,
199 199
 							$externalValues,
200
-							$statements->getByPropertyId( $propertyId ),
200
+							$statements->getByPropertyId($propertyId),
201 201
 							$comparativeValueParser
202 202
 						)
203 203
 					);
@@ -228,10 +228,10 @@  discard block
 block discarded – undo
228 228
 	) {
229 229
 		$resultList = new CrossCheckResultList();
230 230
 
231
-		foreach ( $statements->toArray() as $statement ) {
232
-			$comparisonResult = $this->compareStatement( $statement, $externalValues, $comparativeValueParser );
231
+		foreach ($statements->toArray() as $statement) {
232
+			$comparisonResult = $this->compareStatement($statement, $externalValues, $comparativeValueParser);
233 233
 
234
-			if ( $comparisonResult ) {
234
+			if ($comparisonResult) {
235 235
 				$referencesResult = $this->referenceHandler->checkForReferences(
236 236
 					$statement,
237 237
 					$identifierPropertyId,
@@ -265,31 +265,31 @@  discard block
 block discarded – undo
265 265
 	 * @return ComparisonResult|bool
266 266
 	 */
267 267
 	private function compareStatement(
268
-		Statement $statement,array $externalValues,
268
+		Statement $statement, array $externalValues,
269 269
 		ComparativeValueParser $comparativeValueParser
270 270
 	) {
271 271
 		$mainSnak = $statement->getMainSnak();
272
-		if ( $mainSnak instanceof PropertyValueSnak ) {
272
+		if ($mainSnak instanceof PropertyValueSnak) {
273 273
 			$dataValue = $mainSnak->getDataValue();
274 274
 
275 275
 			$results = array();
276
-			$comparativeValues = $this->parseExternalValues( $dataValue, $externalValues, $comparativeValueParser );
277
-			foreach ( $comparativeValues as $comparativeValue ) {
278
-				$result = $this->dataValueComparer->compare( $dataValue, $comparativeValue );
279
-				if ( $result ) {
276
+			$comparativeValues = $this->parseExternalValues($dataValue, $externalValues, $comparativeValueParser);
277
+			foreach ($comparativeValues as $comparativeValue) {
278
+				$result = $this->dataValueComparer->compare($dataValue, $comparativeValue);
279
+				if ($result) {
280 280
 					$results[] = $result;
281 281
 				}
282 282
 			}
283 283
 
284
-			if ( $results ) {
284
+			if ($results) {
285 285
 				$result = ComparisonResult::STATUS_MISMATCH;
286
-				if ( in_array( ComparisonResult::STATUS_MATCH, $results ) ) {
286
+				if (in_array(ComparisonResult::STATUS_MATCH, $results)) {
287 287
 					$result = ComparisonResult::STATUS_MATCH;
288
-				} elseif ( in_array( ComparisonResult::STATUS_PARTIAL_MATCH, $results ) ) {
288
+				} elseif (in_array(ComparisonResult::STATUS_PARTIAL_MATCH, $results)) {
289 289
 					$result = ComparisonResult::STATUS_PARTIAL_MATCH;
290 290
 				}
291 291
 
292
-				return new ComparisonResult( $dataValue, $comparativeValues, $result );
292
+				return new ComparisonResult($dataValue, $comparativeValues, $result);
293 293
 			}
294 294
 		}
295 295
 
@@ -309,13 +309,13 @@  discard block
 block discarded – undo
309 309
 		ComparativeValueParser $comparativeValueParser
310 310
 	) {
311 311
 		$parsedValues = array();
312
-		foreach ( $externalValues as $externalValue ) {
312
+		foreach ($externalValues as $externalValue) {
313 313
 			try {
314
-				$parsedValue = $comparativeValueParser->parse( $externalValue, $dataValue->getType() );
315
-				if ( $parsedValue ) {
314
+				$parsedValue = $comparativeValueParser->parse($externalValue, $dataValue->getType());
315
+				if ($parsedValue) {
316 316
 					$parsedValues[] = $parsedValue;
317 317
 				}
318
-			} catch ( ParseException $e ) {
318
+			} catch (ParseException $e) {
319 319
 			}
320 320
 		}
321 321
 
@@ -330,12 +330,12 @@  discard block
 block discarded – undo
330 330
 	 *
331 331
 	 * @return string[]
332 332
 	 */
333
-	private function getExternalIds( StatementList $statements, PropertyId $identifierPropertyId ) {
333
+	private function getExternalIds(StatementList $statements, PropertyId $identifierPropertyId) {
334 334
 		$externalIds = array();
335
-		$identifierStatements = $statements->getByPropertyId( $identifierPropertyId );
336
-		$values = $this->getDataValues( $identifierStatements );
337
-		foreach ( $values as $value ) {
338
-			if ( $value instanceof StringValue ) {
335
+		$identifierStatements = $statements->getByPropertyId($identifierPropertyId);
336
+		$values = $this->getDataValues($identifierStatements);
337
+		foreach ($values as $value) {
338
+			if ($value instanceof StringValue) {
339 339
 				$externalIds[] = $value->getValue();
340 340
 			}
341 341
 		}
@@ -347,15 +347,15 @@  discard block
 block discarded – undo
347 347
 	 * @param PropertyId $identifierPropertyId
348 348
 	 * @return bool
349 349
 	 */
350
-	private function isIdentifierProperty( PropertyId $identifierPropertyId ) {
350
+	private function isIdentifierProperty(PropertyId $identifierPropertyId) {
351 351
 		global $wgWBQEVInstanceOfPID, $wgWBQEVIdentifierPropertyQID;
352 352
 		/** @var Property $property */
353
-		$property = $this->entityLookup->getEntity( $identifierPropertyId );
354
-		$instanceOfPropertyId = new PropertyId( $wgWBQEVInstanceOfPID );
355
-		$statements = $property->getStatements()->getByPropertyId( $instanceOfPropertyId );
356
-		$values = $this->getDataValues( $statements );
357
-		foreach ( $values as $value ) {
358
-			if ( $value instanceof EntityIdValue
353
+		$property = $this->entityLookup->getEntity($identifierPropertyId);
354
+		$instanceOfPropertyId = new PropertyId($wgWBQEVInstanceOfPID);
355
+		$statements = $property->getStatements()->getByPropertyId($instanceOfPropertyId);
356
+		$values = $this->getDataValues($statements);
357
+		foreach ($values as $value) {
358
+			if ($value instanceof EntityIdValue
359 359
 				&& $value->getEntityId()->getSerialization() === $wgWBQEVIdentifierPropertyQID
360 360
 			) {
361 361
 				return true;
@@ -371,12 +371,12 @@  discard block
 block discarded – undo
371 371
 	 * @param StatementList $statementList
372 372
 	 * @return DataValue[]
373 373
 	 */
374
-	private function getDataValues( StatementList $statementList ) {
374
+	private function getDataValues(StatementList $statementList) {
375 375
 		$dataValues = array();
376 376
 
377
-		foreach ( $statementList->toArray() as $statement ) {
377
+		foreach ($statementList->toArray() as $statement) {
378 378
 			$mainSnak = $statement->getMainSnak();
379
-			if ( $mainSnak instanceof PropertyValueSnak ) {
379
+			if ($mainSnak instanceof PropertyValueSnak) {
380 380
 				$dataValues[] = $mainSnak->getDataValue();
381 381
 			}
382 382
 		}
Please login to merge, or discard this patch.