Completed
Push — master ( c6464d...264e6e )
by
unknown
19s
created
src/ConstraintCheck/Helper/SparqlHelper.php 1 patch
Spacing   +212 added lines, -216 removed lines patch added patch discarded remove patch
@@ -1,6 +1,6 @@  discard block
 block discarded – undo
1 1
 <?php
2 2
 
3
-declare( strict_types = 1 );
3
+declare(strict_types=1);
4 4
 
5 5
 namespace WikibaseQuality\ConstraintReport\ConstraintCheck\Helper;
6 6
 
@@ -166,143 +166,143 @@  discard block
 block discarded – undo
166 166
 		$this->defaultUserAgent = $defaultUserAgent;
167 167
 		$this->requestFactory = $requestFactory;
168 168
 		$this->entityPrefixes = [];
169
-		foreach ( $rdfVocabulary->entityNamespaceNames as $namespaceName ) {
170
-			$this->entityPrefixes[] = $rdfVocabulary->getNamespaceURI( $namespaceName );
169
+		foreach ($rdfVocabulary->entityNamespaceNames as $namespaceName) {
170
+			$this->entityPrefixes[] = $rdfVocabulary->getNamespaceURI($namespaceName);
171 171
 		}
172 172
 
173
-		$this->primaryEndpoint = $config->get( 'WBQualityConstraintsSparqlEndpoint' );
174
-		$this->additionalEndpoints = $config->get( 'WBQualityConstraintsAdditionalSparqlEndpoints' ) ?: [];
175
-		$this->maxQueryTimeMillis = $config->get( 'WBQualityConstraintsSparqlMaxMillis' );
176
-		$this->subclassOfId = new NumericPropertyId( $config->get( 'WBQualityConstraintsSubclassOfId' ) );
177
-		$this->cacheMapSize = $config->get( 'WBQualityConstraintsFormatCacheMapSize' );
173
+		$this->primaryEndpoint = $config->get('WBQualityConstraintsSparqlEndpoint');
174
+		$this->additionalEndpoints = $config->get('WBQualityConstraintsAdditionalSparqlEndpoints') ?: [];
175
+		$this->maxQueryTimeMillis = $config->get('WBQualityConstraintsSparqlMaxMillis');
176
+		$this->subclassOfId = new NumericPropertyId($config->get('WBQualityConstraintsSubclassOfId'));
177
+		$this->cacheMapSize = $config->get('WBQualityConstraintsFormatCacheMapSize');
178 178
 		$this->timeoutExceptionClasses = $config->get(
179 179
 			'WBQualityConstraintsSparqlTimeoutExceptionClasses'
180 180
 		);
181 181
 		$this->sparqlHasWikibaseSupport = $config->get(
182 182
 			'WBQualityConstraintsSparqlHasWikibaseSupport'
183 183
 		);
184
-		$this->sparqlThrottlingFallbackDuration = (int)$config->get(
184
+		$this->sparqlThrottlingFallbackDuration = (int) $config->get(
185 185
 			'WBQualityConstraintsSparqlThrottlingFallbackDuration'
186 186
 		);
187 187
 
188
-		$this->prefixes = $this->getQueryPrefixes( $rdfVocabulary );
188
+		$this->prefixes = $this->getQueryPrefixes($rdfVocabulary);
189 189
 
190 190
 		$this->rdfVocabularyWithoutNormalization = clone $rdfVocabulary;
191 191
 		// @phan-suppress-next-line PhanTypeMismatchProperty
192 192
 		$this->rdfVocabularyWithoutNormalization->normalizedPropertyValueNamespace = array_fill_keys(
193
-			array_keys( $rdfVocabulary->normalizedPropertyValueNamespace ),
193
+			array_keys($rdfVocabulary->normalizedPropertyValueNamespace),
194 194
 			null
195 195
 		);
196 196
 	}
197 197
 
198
-	private function getQueryPrefixes( RdfVocabulary $rdfVocabulary ): string {
198
+	private function getQueryPrefixes(RdfVocabulary $rdfVocabulary): string {
199 199
 		// TODO: it would probably be smarter that RdfVocabulary exposed these prefixes somehow
200 200
 		$prefixes = '';
201
-		foreach ( $rdfVocabulary->entityNamespaceNames as $sourceName => $namespaceName ) {
201
+		foreach ($rdfVocabulary->entityNamespaceNames as $sourceName => $namespaceName) {
202 202
 			$prefixes .= <<<END
203
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
203
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
204 204
 END;
205 205
 		}
206 206
 
207
-		foreach ( $rdfVocabulary->statementNamespaceNames as $sourceName => $sourceNamespaces ) {
207
+		foreach ($rdfVocabulary->statementNamespaceNames as $sourceName => $sourceNamespaces) {
208 208
 			$namespaceName = $sourceNamespaces[RdfVocabulary::NS_VALUE];
209 209
 			$prefixes .= <<<END
210
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
210
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
211 211
 END;
212 212
 		}
213 213
 
214
-		foreach ( $rdfVocabulary->propertyNamespaceNames as $sourceName => $sourceNamespaces ) {
214
+		foreach ($rdfVocabulary->propertyNamespaceNames as $sourceName => $sourceNamespaces) {
215 215
 			$namespaceName = $sourceNamespaces[RdfVocabulary::NSP_DIRECT_CLAIM];
216 216
 			$prefixes .= <<<END
217
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
217
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
218 218
 END;
219 219
 			$namespaceName = $sourceNamespaces[RdfVocabulary::NSP_CLAIM];
220 220
 			$prefixes .= <<<END
221
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
221
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
222 222
 END;
223 223
 			$namespaceName = $sourceNamespaces[RdfVocabulary::NSP_CLAIM_STATEMENT];
224 224
 			$prefixes .= <<<END
225
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
225
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
226 226
 END;
227 227
 			$namespaceName = $sourceNamespaces[RdfVocabulary::NSP_CLAIM_VALUE];
228 228
 			$prefixes .= <<<END
229
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
229
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
230 230
 END;
231 231
 			$namespaceName = $sourceNamespaces[RdfVocabulary::NSP_QUALIFIER];
232 232
 			$prefixes .= <<<END
233
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
233
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
234 234
 END;
235 235
 			$namespaceName = $sourceNamespaces[RdfVocabulary::NSP_QUALIFIER_VALUE];
236 236
 			$prefixes .= <<<END
237
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
237
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
238 238
 END;
239 239
 			$namespaceName = $sourceNamespaces[RdfVocabulary::NSP_REFERENCE];
240 240
 			$prefixes .= <<<END
241
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
241
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
242 242
 END;
243 243
 			$namespaceName = $sourceNamespaces[RdfVocabulary::NSP_REFERENCE_VALUE];
244 244
 			$prefixes .= <<<END
245
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
245
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
246 246
 END;
247 247
 		}
248 248
 		$namespaceName = RdfVocabulary::NS_ONTOLOGY;
249 249
 		$prefixes .= <<<END
250
-PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n
250
+PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n
251 251
 END;
252 252
 		return $prefixes;
253 253
 	}
254 254
 
255 255
 	/** Return a SPARQL term like `wd:Q123` for the given ID. */
256
-	private function wd( EntityId $id ): string {
257
-		$repository = $this->rdfVocabulary->getEntityRepositoryName( $id );
256
+	private function wd(EntityId $id): string {
257
+		$repository = $this->rdfVocabulary->getEntityRepositoryName($id);
258 258
 		$prefix = $this->rdfVocabulary->entityNamespaceNames[$repository];
259 259
 		return "$prefix:{$id->getSerialization()}";
260 260
 	}
261 261
 
262 262
 	/** Return a SPARQL term like `wdt:P123` for the given ID. */
263
-	private function wdt( PropertyId $id ): string {
264
-		$repository = $this->rdfVocabulary->getEntityRepositoryName( $id );
263
+	private function wdt(PropertyId $id): string {
264
+		$repository = $this->rdfVocabulary->getEntityRepositoryName($id);
265 265
 		$prefix = $this->rdfVocabulary->propertyNamespaceNames[$repository][RdfVocabulary::NSP_DIRECT_CLAIM];
266 266
 		return "$prefix:{$id->getSerialization()}";
267 267
 	}
268 268
 
269 269
 	/** Return a SPARQL term like `p:P123` for the given ID. */
270
-	private function p( PropertyId $id ): string {
271
-		$repository = $this->rdfVocabulary->getEntityRepositoryName( $id );
270
+	private function p(PropertyId $id): string {
271
+		$repository = $this->rdfVocabulary->getEntityRepositoryName($id);
272 272
 		$prefix = $this->rdfVocabulary->propertyNamespaceNames[$repository][RdfVocabulary::NSP_CLAIM];
273 273
 		return "$prefix:{$id->getSerialization()}";
274 274
 	}
275 275
 
276 276
 	/** Return a SPARQL term like `pq:P123` for the given ID. */
277
-	private function pq( PropertyId $id ): string {
278
-		$repository = $this->rdfVocabulary->getEntityRepositoryName( $id );
277
+	private function pq(PropertyId $id): string {
278
+		$repository = $this->rdfVocabulary->getEntityRepositoryName($id);
279 279
 		$prefix = $this->rdfVocabulary->propertyNamespaceNames[$repository][RdfVocabulary::NSP_QUALIFIER];
280 280
 		return "$prefix:{$id->getSerialization()}";
281 281
 	}
282 282
 
283 283
 	/** Return a SPARQL term like `wdno:P123` for the given ID. */
284
-	private function wdno( PropertyId $id ): string {
285
-		$repository = $this->rdfVocabulary->getEntityRepositoryName( $id );
284
+	private function wdno(PropertyId $id): string {
285
+		$repository = $this->rdfVocabulary->getEntityRepositoryName($id);
286 286
 		$prefix = $this->rdfVocabulary->propertyNamespaceNames[$repository][RdfVocabulary::NSP_NOVALUE];
287 287
 		return "$prefix:{$id->getSerialization()}";
288 288
 	}
289 289
 
290 290
 	/** Return a SPARQL term like `prov:NAME` for the given name. */
291
-	private function prov( string $name ): string {
291
+	private function prov(string $name): string {
292 292
 		$prefix = RdfVocabulary::NS_PROV;
293 293
 		return "$prefix:$name";
294 294
 	}
295 295
 
296 296
 	/** Return a SPARQL term like `wikibase:NAME` for the given name. */
297
-	private function wikibase( string $name ): string {
297
+	private function wikibase(string $name): string {
298 298
 		$prefix = RdfVocabulary::NS_ONTOLOGY;
299 299
 		return "$prefix:$name";
300 300
 	}
301 301
 
302 302
 	/** Return a SPARQL snippet like `MINUS { ?var wikibase:rank wikibase:DeprecatedRank. }`. */
303
-	private function minusDeprecatedRank( string $varName ): string {
303
+	private function minusDeprecatedRank(string $varName): string {
304 304
 		$deprecatedRank = RdfVocabulary::RANK_MAP[Statement::RANK_DEPRECATED];
305
-		return "MINUS { $varName {$this->wikibase( 'rank' )} {$this->wikibase( $deprecatedRank )}. }";
305
+		return "MINUS { $varName {$this->wikibase('rank')} {$this->wikibase($deprecatedRank)}. }";
306 306
 	}
307 307
 
308 308
 	/**
@@ -312,43 +312,42 @@  discard block
 block discarded – undo
312 312
 	 * @return CachedBool
313 313
 	 * @throws SparqlHelperException if the query times out or some other error occurs
314 314
 	 */
315
-	public function hasType( EntityId $id, array $classes ): CachedBool {
315
+	public function hasType(EntityId $id, array $classes): CachedBool {
316 316
 		// TODO hint:gearing is a workaround for T168973 and can hopefully be removed eventually
317 317
 		$gearingHint = $this->sparqlHasWikibaseSupport ?
318
-			' hint:Prior hint:gearing "forward".' :
319
-			'';
318
+			' hint:Prior hint:gearing "forward".' : '';
320 319
 
321 320
 		$metadatas = [];
322 321
 
323
-		foreach ( array_chunk( $classes, 20 ) as $classesChunk ) {
324
-			$classesValues = implode( ' ', array_map(
325
-				function ( string $class ) {
326
-					return $this->wd( new ItemId( $class ) );
322
+		foreach (array_chunk($classes, 20) as $classesChunk) {
323
+			$classesValues = implode(' ', array_map(
324
+				function(string $class) {
325
+					return $this->wd(new ItemId($class));
327 326
 				},
328 327
 				$classesChunk
329
-			) );
328
+			));
330 329
 
331 330
 			$query = <<<EOF
332 331
 ASK {
333
-  BIND({$this->wd( $id )} AS ?item)
332
+  BIND({$this->wd($id)} AS ?item)
334 333
   VALUES ?class { $classesValues }
335
-  ?item {$this->wdt( $this->subclassOfId )}* ?class.$gearingHint
334
+  ?item {$this->wdt($this->subclassOfId)}* ?class.$gearingHint
336 335
 }
337 336
 EOF;
338 337
 
339
-			$result = $this->runQuery( $query, $this->primaryEndpoint );
338
+			$result = $this->runQuery($query, $this->primaryEndpoint);
340 339
 			$metadatas[] = $result->getMetadata();
341
-			if ( $result->getArray()['boolean'] ) {
340
+			if ($result->getArray()['boolean']) {
342 341
 				return new CachedBool(
343 342
 					true,
344
-					Metadata::merge( $metadatas )
343
+					Metadata::merge($metadatas)
345 344
 				);
346 345
 			}
347 346
 		}
348 347
 
349 348
 		return new CachedBool(
350 349
 			false,
351
-			Metadata::merge( $metadatas )
350
+			Metadata::merge($metadatas)
352 351
 		);
353 352
 	}
354 353
 
@@ -366,12 +365,12 @@  discard block
 block discarded – undo
366 365
 		array $separators
367 366
 	): CachedEntityIds {
368 367
 		$mainSnak = $statement->getMainSnak();
369
-		if ( !( $mainSnak instanceof PropertyValueSnak ) ) {
370
-			return new CachedEntityIds( [], Metadata::blank() );
368
+		if (!($mainSnak instanceof PropertyValueSnak)) {
369
+			return new CachedEntityIds([], Metadata::blank());
371 370
 		}
372 371
 
373 372
 		$propertyId = $statement->getPropertyId();
374
-		$pPredicateAndObject = "{$this->p( $propertyId )} ?otherStatement."; // p:P123 ?otherStatement.
373
+		$pPredicateAndObject = "{$this->p($propertyId)} ?otherStatement."; // p:P123 ?otherStatement.
375 374
 		$otherStatementPredicateAndObject = $this->getSnakPredicateAndObject(
376 375
 			$entityId,
377 376
 			$mainSnak,
@@ -380,57 +379,57 @@  discard block
 block discarded – undo
380 379
 
381 380
 		$isSeparator = [];
382 381
 		$unusedSeparators = [];
383
-		foreach ( $separators as $separator ) {
382
+		foreach ($separators as $separator) {
384 383
 			$isSeparator[$separator->getSerialization()] = true;
385 384
 			$unusedSeparators[$separator->getSerialization()] = $separator;
386 385
 		}
387 386
 		$separatorFilters = '';
388
-		foreach ( $statement->getQualifiers() as $qualifier ) {
387
+		foreach ($statement->getQualifiers() as $qualifier) {
389 388
 			$qualPropertyId = $qualifier->getPropertyId();
390
-			if ( !( $isSeparator[$qualPropertyId->getSerialization()] ?? false ) ) {
389
+			if (!($isSeparator[$qualPropertyId->getSerialization()] ?? false)) {
391 390
 				continue;
392 391
 			}
393
-			unset( $unusedSeparators[$qualPropertyId->getSerialization()] );
392
+			unset($unusedSeparators[$qualPropertyId->getSerialization()]);
394 393
 			// only look for other statements with the same qualifier
395
-			if ( $qualifier instanceof PropertyValueSnak ) {
394
+			if ($qualifier instanceof PropertyValueSnak) {
396 395
 				$sepPredicateAndObject = $this->getSnakPredicateAndObject(
397 396
 					$entityId,
398 397
 					$qualifier,
399 398
 					RdfVocabulary::NSP_QUALIFIER
400 399
 				);
401 400
 				$separatorFilters .= "  ?otherStatement $sepPredicateAndObject\n";
402
-			} elseif ( $qualifier instanceof PropertyNoValueSnak ) {
403
-				$sepPredicateAndObject = "a {$this->wdno( $qualPropertyId )}."; // a wdno:P123.
401
+			} elseif ($qualifier instanceof PropertyNoValueSnak) {
402
+				$sepPredicateAndObject = "a {$this->wdno($qualPropertyId)}."; // a wdno:P123.
404 403
 				$separatorFilters .= "  ?otherStatement $sepPredicateAndObject\n";
405 404
 			} else {
406 405
 				// "some value" / "unknown value" is always different from everything else,
407 406
 				// therefore the whole statement has no duplicates and we can return immediately
408
-				return new CachedEntityIds( [], Metadata::blank() );
407
+				return new CachedEntityIds([], Metadata::blank());
409 408
 			}
410 409
 		}
411
-		foreach ( $unusedSeparators as $unusedSeparator ) {
410
+		foreach ($unusedSeparators as $unusedSeparator) {
412 411
 			// exclude other statements which have a separator that this one lacks
413
-			$separatorFilters .= "  MINUS { ?otherStatement {$this->pq( $unusedSeparator )} []. }\n";
414
-			$separatorFilters .= "  MINUS { ?otherStatement a {$this->wdno( $unusedSeparator )}. }\n";
412
+			$separatorFilters .= "  MINUS { ?otherStatement {$this->pq($unusedSeparator)} []. }\n";
413
+			$separatorFilters .= "  MINUS { ?otherStatement a {$this->wdno($unusedSeparator)}. }\n";
415 414
 		}
416 415
 
417 416
 		$query = <<<SPARQL
418 417
 SELECT DISTINCT ?otherEntity WHERE {
419 418
   ?otherEntity $pPredicateAndObject
420 419
   ?otherStatement $otherStatementPredicateAndObject
421
-  {$this->minusDeprecatedRank( '?otherStatement' )}
422
-  FILTER(?otherEntity != {$this->wd( $entityId )})
420
+  {$this->minusDeprecatedRank('?otherStatement')}
421
+  FILTER(?otherEntity != {$this->wd($entityId)})
423 422
 $separatorFilters
424 423
 }
425 424
 LIMIT 10
426 425
 SPARQL;
427 426
 
428
-		$results = [ $this->runQuery( $query, $this->primaryEndpoint ) ];
429
-		foreach ( $this->additionalEndpoints as $endpoint ) {
430
-			$results[] = $this->runQuery( $query, $endpoint );
427
+		$results = [$this->runQuery($query, $this->primaryEndpoint)];
428
+		foreach ($this->additionalEndpoints as $endpoint) {
429
+			$results[] = $this->runQuery($query, $endpoint);
431 430
 		}
432 431
 
433
-		return $this->getOtherEntities( $results );
432
+		return $this->getOtherEntities($results);
434 433
 	}
435 434
 
436 435
 	/**
@@ -449,40 +448,38 @@  discard block
 block discarded – undo
449 448
 		bool $ignoreDeprecatedStatements
450 449
 	): CachedEntityIds {
451 450
 		$propertyId = $snak->getPropertyId();
452
-		$pPredicateAndObject = "{$this->p( $propertyId )} ?otherStatement."; // p:P123 ?otherStatement.
451
+		$pPredicateAndObject = "{$this->p($propertyId)} ?otherStatement."; // p:P123 ?otherStatement.
453 452
 
454 453
 		$otherSubject = $type === Context::TYPE_QUALIFIER ?
455
-			'?otherStatement' :
456
-			"?otherStatement {$this->prov( 'wasDerivedFrom' )} ?reference.\n  ?reference";
454
+			'?otherStatement' : "?otherStatement {$this->prov('wasDerivedFrom')} ?reference.\n  ?reference";
457 455
 		$otherPredicateAndObject = $this->getSnakPredicateAndObject(
458 456
 			$entityId,
459 457
 			$snak,
460 458
 			$type === Context::TYPE_QUALIFIER ?
461
-				RdfVocabulary::NSP_QUALIFIER :
462
-				RdfVocabulary::NSP_REFERENCE
459
+				RdfVocabulary::NSP_QUALIFIER : RdfVocabulary::NSP_REFERENCE
463 460
 		);
464 461
 
465 462
 		$deprecatedFilter = '';
466
-		if ( $ignoreDeprecatedStatements ) {
467
-			$deprecatedFilter = '  ' . $this->minusDeprecatedRank( '?otherStatement' );
463
+		if ($ignoreDeprecatedStatements) {
464
+			$deprecatedFilter = '  '.$this->minusDeprecatedRank('?otherStatement');
468 465
 		}
469 466
 
470 467
 		$query = <<<SPARQL
471 468
 SELECT DISTINCT ?otherEntity WHERE {
472 469
   ?otherEntity $pPredicateAndObject
473 470
   $otherSubject $otherPredicateAndObject
474
-  FILTER(?otherEntity != {$this->wd( $entityId )})
471
+  FILTER(?otherEntity != {$this->wd($entityId)})
475 472
 $deprecatedFilter
476 473
 }
477 474
 LIMIT 10
478 475
 SPARQL;
479 476
 
480
-		$results = [ $this->runQuery( $query, $this->primaryEndpoint ) ];
481
-		foreach ( $this->additionalEndpoints as $endpoint ) {
482
-			$results[] = $this->runQuery( $query, $endpoint );
477
+		$results = [$this->runQuery($query, $this->primaryEndpoint)];
478
+		foreach ($this->additionalEndpoints as $endpoint) {
479
+			$results[] = $this->runQuery($query, $endpoint);
483 480
 		}
484 481
 
485
-		return $this->getOtherEntities( $results );
482
+		return $this->getOtherEntities($results);
486 483
 	}
487 484
 
488 485
 	/**
@@ -513,13 +510,13 @@  discard block
 block discarded – undo
513 510
 		$writer->start();
514 511
 		$writer->drain();
515 512
 		$placeholder1 = 'wbqc';
516
-		$placeholder2 = 'x' . wfRandomString( 32 );
517
-		$writer->about( $placeholder1, $placeholder2 );
513
+		$placeholder2 = 'x'.wfRandomString(32);
514
+		$writer->about($placeholder1, $placeholder2);
518 515
 
519 516
 		$propertyId = $snak->getPropertyId();
520 517
 		$pid = $propertyId->getSerialization();
521
-		$propertyRepository = $this->rdfVocabulary->getEntityRepositoryName( $propertyId );
522
-		$entityRepository = $this->rdfVocabulary->getEntityRepositoryName( $entityId );
518
+		$propertyRepository = $this->rdfVocabulary->getEntityRepositoryName($propertyId);
519
+		$entityRepository = $this->rdfVocabulary->getEntityRepositoryName($entityId);
523 520
 		$propertyNamespace = $this->rdfVocabulary->propertyNamespaceNames[$propertyRepository][$namespace];
524 521
 		$value = $snak->getDataValue();
525 522
 		if (
@@ -550,21 +547,21 @@  discard block
 block discarded – undo
550 547
 				$writer,
551 548
 				$propertyNamespace,
552 549
 				$pid,
553
-				$this->propertyDataTypeLookup->getDataTypeIdForProperty( $propertyId ),
550
+				$this->propertyDataTypeLookup->getDataTypeIdForProperty($propertyId),
554 551
 				$this->rdfVocabulary->statementNamespaceNames[$entityRepository][RdfVocabulary::NS_VALUE], // should be unused
555 552
 				$snak
556 553
 			);
557 554
 		}
558 555
 
559 556
 		$triple = $writer->drain(); // wbqc:xRANDOM ps:PID "value". or similar
560
-		return trim( str_replace( "$placeholder1:$placeholder2", '', $triple ) );
557
+		return trim(str_replace("$placeholder1:$placeholder2", '', $triple));
561 558
 	}
562 559
 
563 560
 	/**
564 561
 	 * Return SPARQL code for a string literal with $text as content.
565 562
 	 */
566
-	private function stringLiteral( string $text ): string {
567
-		return '"' . strtr( $text, [ '"' => '\\"', '\\' => '\\\\' ] ) . '"';
563
+	private function stringLiteral(string $text): string {
564
+		return '"'.strtr($text, ['"' => '\\"', '\\' => '\\\\']).'"';
568 565
 	}
569 566
 
570 567
 	/**
@@ -574,26 +571,26 @@  discard block
 block discarded – undo
574 571
 	 *
575 572
 	 * @return CachedEntityIds
576 573
 	 */
577
-	private function getOtherEntities( array $results ): CachedEntityIds {
574
+	private function getOtherEntities(array $results): CachedEntityIds {
578 575
 		$allResultBindings = [];
579 576
 		$metadatas = [];
580 577
 
581
-		foreach ( $results as $result ) {
578
+		foreach ($results as $result) {
582 579
 			$metadatas[] = $result->getMetadata();
583
-			$allResultBindings = array_merge( $allResultBindings, $result->getArray()['results']['bindings'] );
580
+			$allResultBindings = array_merge($allResultBindings, $result->getArray()['results']['bindings']);
584 581
 		}
585 582
 
586 583
 		$entityIds = array_map(
587
-			function ( $resultBindings ) {
584
+			function($resultBindings) {
588 585
 				$entityIRI = $resultBindings['otherEntity']['value'];
589
-				foreach ( $this->entityPrefixes as $entityPrefix ) {
590
-					$entityPrefixLength = strlen( $entityPrefix );
591
-					if ( substr( $entityIRI, 0, $entityPrefixLength ) === $entityPrefix ) {
586
+				foreach ($this->entityPrefixes as $entityPrefix) {
587
+					$entityPrefixLength = strlen($entityPrefix);
588
+					if (substr($entityIRI, 0, $entityPrefixLength) === $entityPrefix) {
592 589
 						try {
593 590
 							return $this->entityIdParser->parse(
594
-								substr( $entityIRI, $entityPrefixLength )
591
+								substr($entityIRI, $entityPrefixLength)
595 592
 							);
596
-						} catch ( EntityIdParsingException ) {
593
+						} catch (EntityIdParsingException) {
597 594
 							// fall through
598 595
 						}
599 596
 					}
@@ -607,8 +604,8 @@  discard block
 block discarded – undo
607 604
 		);
608 605
 
609 606
 		return new CachedEntityIds(
610
-			array_values( array_filter( array_unique( $entityIds ) ) ),
611
-			Metadata::merge( $metadatas )
607
+			array_values(array_filter(array_unique($entityIds))),
608
+			Metadata::merge($metadatas)
612 609
 		);
613 610
 	}
614 611
 
@@ -616,52 +613,52 @@  discard block
 block discarded – undo
616 613
 	 * @throws SparqlHelperException if the query times out or some other error occurs
617 614
 	 * @throws ConstraintParameterException if the $regex is invalid
618 615
 	 */
619
-	public function matchesRegularExpression( string $text, string $regex ): bool {
616
+	public function matchesRegularExpression(string $text, string $regex): bool {
620 617
 		// caching wrapper around matchesRegularExpressionWithSparql
621 618
 
622
-		$textHash = hash( 'sha256', $text );
619
+		$textHash = hash('sha256', $text);
623 620
 		$cacheKey = $this->cache->makeKey(
624 621
 			'WikibaseQualityConstraints', // extension
625 622
 			'regex', // action
626 623
 			'WDQS-Java', // regex flavor
627
-			hash( 'sha256', $regex )
624
+			hash('sha256', $regex)
628 625
 		);
629 626
 
630
-		$metric = $this->statsFactory->getCounter( 'regex_cache_total' );
627
+		$metric = $this->statsFactory->getCounter('regex_cache_total');
631 628
 
632 629
 		$cacheMapArray = $this->cache->getWithSetCallback(
633 630
 			$cacheKey,
634 631
 			WANObjectCache::TTL_DAY,
635
-			function ( $cacheMapArray ) use ( $text, $regex, $textHash, $metric ) {
632
+			function($cacheMapArray) use ($text, $regex, $textHash, $metric) {
636 633
 				// Initialize the cache map if not set
637
-				if ( $cacheMapArray === false ) {
634
+				if ($cacheMapArray === false) {
638 635
 					$metric
639
-						->setLabel( 'operation', 'refresh' )
640
-						->setLabel( 'status', 'init' )
636
+						->setLabel('operation', 'refresh')
637
+						->setLabel('status', 'init')
641 638
 						->increment();
642 639
 
643 640
 					return [];
644 641
 				}
645 642
 
646
-				$cacheMap = MapCacheLRU::newFromArray( $cacheMapArray, $this->cacheMapSize );
647
-				if ( $cacheMap->has( $textHash ) ) {
643
+				$cacheMap = MapCacheLRU::newFromArray($cacheMapArray, $this->cacheMapSize);
644
+				if ($cacheMap->has($textHash)) {
648 645
 					$metric
649
-						->setLabel( 'operation', 'refresh' )
650
-						->setLabel( 'status', 'hit' )
646
+						->setLabel('operation', 'refresh')
647
+						->setLabel('status', 'hit')
651 648
 						->increment();
652 649
 
653
-					$cacheMap->get( $textHash ); // ping cache
650
+					$cacheMap->get($textHash); // ping cache
654 651
 				} else {
655 652
 					$metric
656
-						->setLabel( 'operation', 'refresh' )
657
-						->setLabel( 'status', 'miss' )
653
+						->setLabel('operation', 'refresh')
654
+						->setLabel('status', 'miss')
658 655
 						->increment();
659 656
 
660 657
 					try {
661
-						$matches = $this->matchesRegularExpressionWithSparql( $text, $regex );
662
-					} catch ( ConstraintParameterException $e ) {
663
-						$matches = $this->serializeConstraintParameterException( $e );
664
-					} catch ( SparqlHelperException ) {
658
+						$matches = $this->matchesRegularExpressionWithSparql($text, $regex);
659
+					} catch (ConstraintParameterException $e) {
660
+						$matches = $this->serializeConstraintParameterException($e);
661
+					} catch (SparqlHelperException) {
665 662
 						// don’t cache this
666 663
 						return $cacheMap->toArray();
667 664
 					}
@@ -685,48 +682,48 @@  discard block
 block discarded – undo
685 682
 			]
686 683
 		);
687 684
 
688
-		if ( isset( $cacheMapArray[$textHash] ) ) {
685
+		if (isset($cacheMapArray[$textHash])) {
689 686
 			$metric
690
-				->setLabel( 'operation', 'none' )
691
-				->setLabel( 'status', 'hit' )
687
+				->setLabel('operation', 'none')
688
+				->setLabel('status', 'hit')
692 689
 				->increment();
693 690
 
694 691
 			$matches = $cacheMapArray[$textHash];
695
-			if ( is_bool( $matches ) ) {
692
+			if (is_bool($matches)) {
696 693
 				return $matches;
697
-			} elseif ( is_array( $matches ) &&
698
-				$matches['type'] == ConstraintParameterException::class ) {
699
-				throw $this->deserializeConstraintParameterException( $matches );
694
+			} elseif (is_array($matches) &&
695
+				$matches['type'] == ConstraintParameterException::class) {
696
+				throw $this->deserializeConstraintParameterException($matches);
700 697
 			} else {
701 698
 				throw new UnexpectedValueException(
702
-					'Value of unknown type in object cache (' .
703
-					'cache key: ' . $cacheKey . ', ' .
704
-					'cache map key: ' . $textHash . ', ' .
705
-					'value type: ' . get_debug_type( $matches ) . ')'
699
+					'Value of unknown type in object cache ('.
700
+					'cache key: '.$cacheKey.', '.
701
+					'cache map key: '.$textHash.', '.
702
+					'value type: '.get_debug_type($matches).')'
706 703
 				);
707 704
 			}
708 705
 		} else {
709 706
 			$metric
710
-				->setLabel( 'operation', 'none' )
711
-				->setLabel( 'status', 'miss' )
707
+				->setLabel('operation', 'none')
708
+				->setLabel('status', 'miss')
712 709
 				->increment();
713 710
 
714
-			return $this->matchesRegularExpressionWithSparql( $text, $regex );
711
+			return $this->matchesRegularExpressionWithSparql($text, $regex);
715 712
 		}
716 713
 	}
717 714
 
718
-	private function serializeConstraintParameterException( ConstraintParameterException $cpe ): array {
715
+	private function serializeConstraintParameterException(ConstraintParameterException $cpe): array {
719 716
 		return [
720 717
 			'type' => ConstraintParameterException::class,
721
-			'violationMessage' => $this->violationMessageSerializer->serialize( $cpe->getViolationMessage() ),
718
+			'violationMessage' => $this->violationMessageSerializer->serialize($cpe->getViolationMessage()),
722 719
 		];
723 720
 	}
724 721
 
725
-	private function deserializeConstraintParameterException( array $serialization ): ConstraintParameterException {
722
+	private function deserializeConstraintParameterException(array $serialization): ConstraintParameterException {
726 723
 		$message = $this->violationMessageDeserializer->deserialize(
727 724
 			$serialization['violationMessage']
728 725
 		);
729
-		return new ConstraintParameterException( $message );
726
+		return new ConstraintParameterException($message);
730 727
 	}
731 728
 
732 729
 	/**
@@ -736,25 +733,25 @@  discard block
 block discarded – undo
736 733
 	 * @throws SparqlHelperException if the query times out or some other error occurs
737 734
 	 * @throws ConstraintParameterException if the $regex is invalid
738 735
 	 */
739
-	public function matchesRegularExpressionWithSparql( string $text, string $regex ): bool {
740
-		$textStringLiteral = $this->stringLiteral( $text );
741
-		$regexStringLiteral = $this->stringLiteral( '^(?:' . $regex . ')$' );
736
+	public function matchesRegularExpressionWithSparql(string $text, string $regex): bool {
737
+		$textStringLiteral = $this->stringLiteral($text);
738
+		$regexStringLiteral = $this->stringLiteral('^(?:'.$regex.')$');
742 739
 
743 740
 		$query = <<<EOF
744 741
 SELECT (REGEX($textStringLiteral, $regexStringLiteral) AS ?matches) {}
745 742
 EOF;
746 743
 
747
-		$result = $this->runQuery( $query, $this->primaryEndpoint, false );
744
+		$result = $this->runQuery($query, $this->primaryEndpoint, false);
748 745
 
749 746
 		$vars = $result->getArray()['results']['bindings'][0];
750
-		if ( array_key_exists( 'matches', $vars ) ) {
747
+		if (array_key_exists('matches', $vars)) {
751 748
 			// true or false ⇒ regex okay, text matches or not
752 749
 			return $vars['matches']['value'] === 'true';
753 750
 		} else {
754 751
 			// empty result: regex broken
755 752
 			throw new ConstraintParameterException(
756
-				( new ViolationMessage( 'wbqc-violation-message-parameter-regex' ) )
757
-					->withInlineCode( $regex, Role::CONSTRAINT_PARAMETER_VALUE )
753
+				(new ViolationMessage('wbqc-violation-message-parameter-regex'))
754
+					->withInlineCode($regex, Role::CONSTRAINT_PARAMETER_VALUE)
758 755
 			);
759 756
 		}
760 757
 	}
@@ -762,14 +759,14 @@  discard block
 block discarded – undo
762 759
 	/**
763 760
 	 * Check whether the text content of an error response indicates a query timeout.
764 761
 	 */
765
-	public function isTimeout( string $responseContent ): bool {
766
-		$timeoutRegex = implode( '|', array_map(
767
-			static function ( $fqn ) {
768
-				return preg_quote( $fqn, '/' );
762
+	public function isTimeout(string $responseContent): bool {
763
+		$timeoutRegex = implode('|', array_map(
764
+			static function($fqn) {
765
+				return preg_quote($fqn, '/');
769 766
 			},
770 767
 			$this->timeoutExceptionClasses
771
-		) );
772
-		return (bool)preg_match( '/' . $timeoutRegex . '/', $responseContent );
768
+		));
769
+		return (bool) preg_match('/'.$timeoutRegex.'/', $responseContent);
773 770
 	}
774 771
 
775 772
 	/**
@@ -781,17 +778,17 @@  discard block
 block discarded – undo
781 778
 	 * @return int|bool the max-age (in seconds)
782 779
 	 * or a plain boolean if no max-age can be determined
783 780
 	 */
784
-	public function getCacheMaxAge( array $responseHeaders ) {
781
+	public function getCacheMaxAge(array $responseHeaders) {
785 782
 		if (
786
-			array_key_exists( 'x-cache-status', $responseHeaders ) &&
787
-			preg_match( '/^hit(?:-.*)?$/', $responseHeaders['x-cache-status'][0] )
783
+			array_key_exists('x-cache-status', $responseHeaders) &&
784
+			preg_match('/^hit(?:-.*)?$/', $responseHeaders['x-cache-status'][0])
788 785
 		) {
789 786
 			$maxage = [];
790 787
 			if (
791
-				array_key_exists( 'cache-control', $responseHeaders ) &&
792
-				preg_match( '/\bmax-age=(\d+)\b/', $responseHeaders['cache-control'][0], $maxage )
788
+				array_key_exists('cache-control', $responseHeaders) &&
789
+				preg_match('/\bmax-age=(\d+)\b/', $responseHeaders['cache-control'][0], $maxage)
793 790
 			) {
794
-				return intval( $maxage[1] );
791
+				return intval($maxage[1]);
795 792
 			} else {
796 793
 				return true;
797 794
 			}
@@ -812,34 +809,34 @@  discard block
 block discarded – undo
812 809
 	 * or SparlHelper::EMPTY_RETRY_AFTER if there is an empty Retry-After
813 810
 	 * or SparlHelper::INVALID_RETRY_AFTER if there is something wrong with the format
814 811
 	 */
815
-	public function getThrottling( MWHttpRequest $request ) {
816
-		$retryAfterValue = $request->getResponseHeader( 'Retry-After' );
817
-		if ( $retryAfterValue === null ) {
812
+	public function getThrottling(MWHttpRequest $request) {
813
+		$retryAfterValue = $request->getResponseHeader('Retry-After');
814
+		if ($retryAfterValue === null) {
818 815
 			return self::NO_RETRY_AFTER;
819 816
 		}
820 817
 
821
-		$trimmedRetryAfterValue = trim( $retryAfterValue );
822
-		if ( $trimmedRetryAfterValue === '' ) {
818
+		$trimmedRetryAfterValue = trim($retryAfterValue);
819
+		if ($trimmedRetryAfterValue === '') {
823 820
 			return self::EMPTY_RETRY_AFTER;
824 821
 		}
825 822
 
826
-		if ( is_numeric( $trimmedRetryAfterValue ) ) {
827
-			$delaySeconds = (int)$trimmedRetryAfterValue;
828
-			if ( $delaySeconds >= 0 ) {
829
-				return $this->getTimestampInFuture( new DateInterval( 'PT' . $delaySeconds . 'S' ) );
823
+		if (is_numeric($trimmedRetryAfterValue)) {
824
+			$delaySeconds = (int) $trimmedRetryAfterValue;
825
+			if ($delaySeconds >= 0) {
826
+				return $this->getTimestampInFuture(new DateInterval('PT'.$delaySeconds.'S'));
830 827
 			}
831 828
 		} else {
832
-			$return = strtotime( $trimmedRetryAfterValue );
833
-			if ( $return !== false ) {
834
-				return new ConvertibleTimestamp( $return );
829
+			$return = strtotime($trimmedRetryAfterValue);
830
+			if ($return !== false) {
831
+				return new ConvertibleTimestamp($return);
835 832
 			}
836 833
 		}
837 834
 		return self::INVALID_RETRY_AFTER;
838 835
 	}
839 836
 
840
-	private function getTimestampInFuture( DateInterval $delta ): ConvertibleTimestamp {
837
+	private function getTimestampInFuture(DateInterval $delta): ConvertibleTimestamp {
841 838
 		$now = new ConvertibleTimestamp();
842
-		return new ConvertibleTimestamp( $now->timestamp->add( $delta ) );
839
+		return new ConvertibleTimestamp($now->timestamp->add($delta));
843 840
 	}
844 841
 
845 842
 	/**
@@ -854,92 +851,91 @@  discard block
 block discarded – undo
854 851
 	 *
855 852
 	 * @throws SparqlHelperException if the query times out or some other error occurs
856 853
 	 */
857
-	protected function runQuery( string $query, string $endpoint, bool $needsPrefixes = true ): CachedQueryResults {
858
-		if ( $this->throttlingLock->isLocked( self::EXPIRY_LOCK_ID ) ) {
854
+	protected function runQuery(string $query, string $endpoint, bool $needsPrefixes = true): CachedQueryResults {
855
+		if ($this->throttlingLock->isLocked(self::EXPIRY_LOCK_ID)) {
859 856
 			$this->statsFactory
860
-				->getCounter( 'sparql_throttling_total' )
857
+				->getCounter('sparql_throttling_total')
861 858
 				->increment();
862 859
 
863 860
 			throw new TooManySparqlRequestsException();
864 861
 		}
865 862
 
866
-		if ( $this->sparqlHasWikibaseSupport ) {
863
+		if ($this->sparqlHasWikibaseSupport) {
867 864
 			$needsPrefixes = false;
868 865
 		}
869 866
 
870
-		if ( $needsPrefixes ) {
871
-			$query = $this->prefixes . $query;
867
+		if ($needsPrefixes) {
868
+			$query = $this->prefixes.$query;
872 869
 		}
873
-		$query = "#wbqc\n" . $query;
870
+		$query = "#wbqc\n".$query;
874 871
 
875
-		$url = $endpoint . '?' . http_build_query(
872
+		$url = $endpoint.'?'.http_build_query(
876 873
 			[
877 874
 				'query' => $query,
878 875
 				'format' => 'json',
879 876
 				'maxQueryTimeMillis' => $this->maxQueryTimeMillis,
880 877
 			],
881
-			'', ini_get( 'arg_separator.output' ),
878
+			'', ini_get('arg_separator.output'),
882 879
 			// encode spaces with %20, not +
883 880
 			PHP_QUERY_RFC3986
884 881
 		);
885 882
 
886 883
 		$options = [
887 884
 			'method' => 'GET',
888
-			'timeout' => (int)round( ( $this->maxQueryTimeMillis + 1000 ) / 1000 ),
885
+			'timeout' => (int) round(($this->maxQueryTimeMillis + 1000) / 1000),
889 886
 			'connectTimeout' => 'default',
890 887
 			'userAgent' => $this->defaultUserAgent,
891 888
 		];
892
-		$request = $this->requestFactory->create( $url, $options, __METHOD__ );
889
+		$request = $this->requestFactory->create($url, $options, __METHOD__);
893 890
 
894 891
 		$timing = $this->statsFactory
895
-			->getTiming( 'sparql_runQuery_duration_seconds' );
892
+			->getTiming('sparql_runQuery_duration_seconds');
896 893
 
897 894
 		$timing->start();
898 895
 		$requestStatus = $request->execute();
899 896
 		$timing->stop();
900 897
 
901
-		$this->guardAgainstTooManyRequestsError( $request );
898
+		$this->guardAgainstTooManyRequestsError($request);
902 899
 
903
-		$maxAge = $this->getCacheMaxAge( $request->getResponseHeaders() );
904
-		if ( $maxAge ) {
905
-			$this->statsFactory->getCounter( 'sparql_cached_total' )
900
+		$maxAge = $this->getCacheMaxAge($request->getResponseHeaders());
901
+		if ($maxAge) {
902
+			$this->statsFactory->getCounter('sparql_cached_total')
906 903
 				->increment();
907 904
 		}
908 905
 
909
-		$metric = $this->statsFactory->getCounter( 'sparql_error_total' );
910
-		if ( $requestStatus->isOK() ) {
906
+		$metric = $this->statsFactory->getCounter('sparql_error_total');
907
+		if ($requestStatus->isOK()) {
911 908
 			$json = $request->getContent();
912
-			$jsonStatus = FormatJson::parse( $json, FormatJson::FORCE_ASSOC );
909
+			$jsonStatus = FormatJson::parse($json, FormatJson::FORCE_ASSOC);
913 910
 			'@phan-var \MediaWiki\Status\Status<array> $jsonStatus';
914
-			if ( $jsonStatus->isOK() ) {
911
+			if ($jsonStatus->isOK()) {
915 912
 				return new CachedQueryResults(
916 913
 					$jsonStatus->getValue(),
917 914
 					Metadata::ofCachingMetadata(
918 915
 						$maxAge ?
919
-							CachingMetadata::ofMaximumAgeInSeconds( $maxAge ) :
920
-							CachingMetadata::fresh()
916
+							CachingMetadata::ofMaximumAgeInSeconds($maxAge) : CachingMetadata::fresh()
921 917
 					)
922 918
 				);
923 919
 			} else {
924 920
 				$jsonErrorCode = $jsonStatus->getErrors()[0]['message'];
925 921
 				$metric
926
-					->setLabel( 'type', 'json' )
927
-					->setLabel( 'code', "$jsonErrorCode" )
922
+					->setLabel('type', 'json')
923
+					->setLabel('code', "$jsonErrorCode")
928 924
 					->increment();
929 925
 				// fall through to general error handling
930 926
 			}
931 927
 		} else {
932 928
 			$metric
933
-				->setLabel( 'type', 'http' )
934
-				->setLabel( 'code', "{$request->getStatus()}" )
929
+				->setLabel('type', 'http')
930
+				->setLabel('code', "{$request->getStatus()}")
935 931
 				->increment();
936 932
 			// fall through to general error handling
937 933
 		}
938 934
 
939
-		if ( $this->isTimeout( $request->getContent() ) ) {
935
+		if ($this->isTimeout($request->getContent())) {
940 936
 			$metric
941
-				->setLabel( 'type', 'timeout' )
942
-				->setLabel( 'code', 'none' )
937
+				->setLabel('type', 'timeout')
938
+				->setLabel('code', 'none')
943 939
 				->increment();
944 940
 		}
945 941
 
@@ -952,31 +948,31 @@  discard block
 block discarded – undo
952 948
 	 * @param MWHttpRequest $request
953 949
 	 * @throws TooManySparqlRequestsException
954 950
 	 */
955
-	private function guardAgainstTooManyRequestsError( MWHttpRequest $request ): void {
956
-		if ( $request->getStatus() !== self::HTTP_TOO_MANY_REQUESTS ) {
951
+	private function guardAgainstTooManyRequestsError(MWHttpRequest $request): void {
952
+		if ($request->getStatus() !== self::HTTP_TOO_MANY_REQUESTS) {
957 953
 			return;
958 954
 		}
959 955
 
960 956
 		$fallbackBlockDuration = $this->sparqlThrottlingFallbackDuration;
961 957
 
962
-		if ( $fallbackBlockDuration < 0 ) {
963
-			throw new InvalidArgumentException( 'Fallback duration must be positive int but is: ' .
964
-				$fallbackBlockDuration );
958
+		if ($fallbackBlockDuration < 0) {
959
+			throw new InvalidArgumentException('Fallback duration must be positive int but is: '.
960
+				$fallbackBlockDuration);
965 961
 		}
966 962
 
967
-		$this->statsFactory->getCounter( 'sparql_throttling_total' )
963
+		$this->statsFactory->getCounter('sparql_throttling_total')
968 964
 			->increment();
969 965
 
970
-		$throttlingUntil = $this->getThrottling( $request );
971
-		if ( !( $throttlingUntil instanceof ConvertibleTimestamp ) ) {
972
-			$this->loggingHelper->logSparqlHelperTooManyRequestsRetryAfterInvalid( $request );
966
+		$throttlingUntil = $this->getThrottling($request);
967
+		if (!($throttlingUntil instanceof ConvertibleTimestamp)) {
968
+			$this->loggingHelper->logSparqlHelperTooManyRequestsRetryAfterInvalid($request);
973 969
 			$this->throttlingLock->lock(
974 970
 				self::EXPIRY_LOCK_ID,
975
-				$this->getTimestampInFuture( new DateInterval( 'PT' . $fallbackBlockDuration . 'S' ) )
971
+				$this->getTimestampInFuture(new DateInterval('PT'.$fallbackBlockDuration.'S'))
976 972
 			);
977 973
 		} else {
978
-			$this->loggingHelper->logSparqlHelperTooManyRequestsRetryAfterPresent( $throttlingUntil, $request );
979
-			$this->throttlingLock->lock( self::EXPIRY_LOCK_ID, $throttlingUntil );
974
+			$this->loggingHelper->logSparqlHelperTooManyRequestsRetryAfterPresent($throttlingUntil, $request);
975
+			$this->throttlingLock->lock(self::EXPIRY_LOCK_ID, $throttlingUntil);
980 976
 		}
981 977
 		throw new TooManySparqlRequestsException();
982 978
 	}
Please login to merge, or discard this patch.
src/Api/CheckConstraints.php 1 patch
Spacing   +31 added lines, -31 removed lines patch added patch discarded remove patch
@@ -1,6 +1,6 @@  discard block
 block discarded – undo
1 1
 <?php
2 2
 
3
-declare( strict_types = 1 );
3
+declare(strict_types=1);
4 4
 
5 5
 namespace WikibaseQuality\ConstraintReport\Api;
6 6
 
@@ -84,11 +84,11 @@  discard block
 block discarded – undo
84 84
 		CheckResultsRendererFactory $checkResultsRendererFactory,
85 85
 		StatsFactory $statsFactory
86 86
 	) {
87
-		parent::__construct( $main, $name );
87
+		parent::__construct($main, $name);
88 88
 		$this->entityIdParser = $entityIdParser;
89 89
 		$this->statementGuidValidator = $statementGuidValidator;
90
-		$this->resultBuilder = $apiHelperFactory->getResultBuilder( $this );
91
-		$this->errorReporter = $apiHelperFactory->getErrorReporter( $this );
90
+		$this->resultBuilder = $apiHelperFactory->getResultBuilder($this);
91
+		$this->errorReporter = $apiHelperFactory->getErrorReporter($this);
92 92
 		$this->resultsSource = $resultsSource;
93 93
 		$this->checkResultsRendererFactory = $checkResultsRendererFactory;
94 94
 		$this->statsFactory = $statsFactory;
@@ -98,19 +98,19 @@  discard block
 block discarded – undo
98 98
 	 * Evaluates the parameters, runs the requested constraint check, and sets up the result
99 99
 	 */
100 100
 	public function execute() {
101
-		$this->statsFactory->getCounter( 'check_constraints_execute_total' )
101
+		$this->statsFactory->getCounter('check_constraints_execute_total')
102 102
 			->increment();
103 103
 
104 104
 		$params = $this->extractRequestParams();
105 105
 
106
-		$this->validateParameters( $params );
107
-		$entityIds = $this->parseEntityIds( $params );
108
-		$claimIds = $this->parseClaimIds( $params );
106
+		$this->validateParameters($params);
107
+		$entityIds = $this->parseEntityIds($params);
108
+		$claimIds = $this->parseClaimIds($params);
109 109
 		$constraintIDs = $params[self::PARAM_CONSTRAINT_ID];
110 110
 		$statuses = $params[self::PARAM_STATUS];
111 111
 
112 112
 		$checkResultsRenderer = $this->checkResultsRendererFactory
113
-			->getCheckResultsRenderer( $this->getLanguage(), $this );
113
+			->getCheckResultsRenderer($this->getLanguage(), $this);
114 114
 
115 115
 		$this->getResult()->addValue(
116 116
 			null,
@@ -124,7 +124,7 @@  discard block
 block discarded – undo
124 124
 				)
125 125
 			)->getArray()
126 126
 		);
127
-		$this->resultBuilder->markSuccess( 1 );
127
+		$this->resultBuilder->markSuccess(1);
128 128
 	}
129 129
 
130 130
 	/**
@@ -132,24 +132,24 @@  discard block
 block discarded – undo
132 132
 	 *
133 133
 	 * @return EntityId[]
134 134
 	 */
135
-	private function parseEntityIds( array $params ): array {
135
+	private function parseEntityIds(array $params): array {
136 136
 		$ids = $params[self::PARAM_ID];
137 137
 
138
-		if ( $ids === null ) {
138
+		if ($ids === null) {
139 139
 			return [];
140
-		} elseif ( $ids === [] ) {
140
+		} elseif ($ids === []) {
141 141
 			$this->errorReporter->dieError(
142
-				'If ' . self::PARAM_ID . ' is specified, it must be nonempty.', 'no-data' );
142
+				'If '.self::PARAM_ID.' is specified, it must be nonempty.', 'no-data' );
143 143
 		}
144 144
 
145
-		return array_map( function ( $id ) {
145
+		return array_map(function($id) {
146 146
 			try {
147
-				return $this->entityIdParser->parse( $id );
148
-			} catch ( EntityIdParsingException ) {
147
+				return $this->entityIdParser->parse($id);
148
+			} catch (EntityIdParsingException) {
149 149
 				$this->errorReporter->dieError(
150
-					"Invalid id: $id", 'invalid-entity-id', 0, [ self::PARAM_ID => $id ] );
150
+					"Invalid id: $id", 'invalid-entity-id', 0, [self::PARAM_ID => $id] );
151 151
 			}
152
-		}, $ids );
152
+		}, $ids);
153 153
 	}
154 154
 
155 155
 	/**
@@ -157,35 +157,35 @@  discard block
 block discarded – undo
157 157
 	 *
158 158
 	 * @return string[]
159 159
 	 */
160
-	private function parseClaimIds( array $params ): array {
160
+	private function parseClaimIds(array $params): array {
161 161
 		$ids = $params[self::PARAM_CLAIM_ID];
162 162
 
163
-		if ( $ids === null ) {
163
+		if ($ids === null) {
164 164
 			return [];
165
-		} elseif ( $ids === [] ) {
165
+		} elseif ($ids === []) {
166 166
 			$this->errorReporter->dieError(
167
-				'If ' . self::PARAM_CLAIM_ID . ' is specified, it must be nonempty.', 'no-data' );
167
+				'If '.self::PARAM_CLAIM_ID.' is specified, it must be nonempty.', 'no-data' );
168 168
 		}
169 169
 
170
-		foreach ( $ids as $id ) {
171
-			if ( !$this->statementGuidValidator->validate( $id ) ) {
170
+		foreach ($ids as $id) {
171
+			if (!$this->statementGuidValidator->validate($id)) {
172 172
 				$this->errorReporter->dieError(
173
-					"Invalid claim id: $id", 'invalid-guid', 0, [ self::PARAM_CLAIM_ID => $id ] );
173
+					"Invalid claim id: $id", 'invalid-guid', 0, [self::PARAM_CLAIM_ID => $id] );
174 174
 			}
175 175
 		}
176 176
 
177 177
 		return $ids;
178 178
 	}
179 179
 
180
-	private function validateParameters( array $params ): void {
181
-		if ( $params[self::PARAM_CONSTRAINT_ID] !== null
182
-			 && empty( $params[self::PARAM_CONSTRAINT_ID] )
180
+	private function validateParameters(array $params): void {
181
+		if ($params[self::PARAM_CONSTRAINT_ID] !== null
182
+			 && empty($params[self::PARAM_CONSTRAINT_ID])
183 183
 		) {
184 184
 			$paramConstraintId = self::PARAM_CONSTRAINT_ID;
185 185
 			$this->errorReporter->dieError(
186 186
 				"If $paramConstraintId is specified, it must be nonempty.", 'no-data' );
187 187
 		}
188
-		if ( $params[self::PARAM_ID] === null && $params[self::PARAM_CLAIM_ID] === null ) {
188
+		if ($params[self::PARAM_ID] === null && $params[self::PARAM_CLAIM_ID] === null) {
189 189
 			$paramId = self::PARAM_ID;
190 190
 			$paramClaimId = self::PARAM_CLAIM_ID;
191 191
 			$this->errorReporter->dieError(
@@ -226,7 +226,7 @@  discard block
 block discarded – undo
226 226
 				],
227 227
 				ParamValidator::PARAM_ISMULTI => true,
228 228
 				ParamValidator::PARAM_ALL => true,
229
-				ParamValidator::PARAM_DEFAULT => implode( '|', CachingResultsSource::CACHED_STATUSES ),
229
+				ParamValidator::PARAM_DEFAULT => implode('|', CachingResultsSource::CACHED_STATUSES),
230 230
 				ApiBase::PARAM_HELP_MSG_PER_VALUE => [],
231 231
 			],
232 232
 		];
Please login to merge, or discard this patch.