@@ -44,7 +44,7 @@ discard block |
||
| 44 | 44 | * @param ItemId $itemId |
| 45 | 45 | * @return self |
| 46 | 46 | */ |
| 47 | - public static function fromItemId( ItemId $itemId ) { |
|
| 47 | + public static function fromItemId(ItemId $itemId) { |
|
| 48 | 48 | $ret = new self; |
| 49 | 49 | $ret->itemId = $itemId; |
| 50 | 50 | return $ret; |
@@ -80,14 +80,14 @@ discard block |
||
| 80 | 80 | * @throws InvalidArgumentException |
| 81 | 81 | * @return self |
| 82 | 82 | */ |
| 83 | - public static function fromSnak( Snak $snak ) { |
|
| 84 | - switch ( true ) { |
|
| 83 | + public static function fromSnak(Snak $snak) { |
|
| 84 | + switch (true) { |
|
| 85 | 85 | case $snak instanceof PropertyValueSnak: |
| 86 | 86 | $dataValue = $snak->getDataValue(); |
| 87 | - if ( $dataValue instanceof EntityIdValue ) { |
|
| 87 | + if ($dataValue instanceof EntityIdValue) { |
|
| 88 | 88 | $itemId = $dataValue->getEntityId(); |
| 89 | - if ( $itemId instanceof ItemId ) { |
|
| 90 | - return self::fromItemId( $itemId ); |
|
| 89 | + if ($itemId instanceof ItemId) { |
|
| 90 | + return self::fromItemId($itemId); |
|
| 91 | 91 | } |
| 92 | 92 | } |
| 93 | 93 | break; |
@@ -97,7 +97,7 @@ discard block |
||
| 97 | 97 | return self::noValue(); |
| 98 | 98 | } |
| 99 | 99 | |
| 100 | - throw new InvalidArgumentException( 'Snak must contain item ID value or be a somevalue / novalue snak' ); |
|
| 100 | + throw new InvalidArgumentException('Snak must contain item ID value or be a somevalue / novalue snak'); |
|
| 101 | 101 | } |
| 102 | 102 | |
| 103 | 103 | /** |
@@ -135,8 +135,8 @@ discard block |
||
| 135 | 135 | * @return ItemId |
| 136 | 136 | */ |
| 137 | 137 | public function getItemId() { |
| 138 | - if ( !$this->isValue() ) { |
|
| 139 | - throw new DomainException( 'This value does not contain an item ID.' ); |
|
| 138 | + if (!$this->isValue()) { |
|
| 139 | + throw new DomainException('This value does not contain an item ID.'); |
|
| 140 | 140 | } |
| 141 | 141 | return $this->itemId; |
| 142 | 142 | } |
@@ -148,14 +148,14 @@ discard block |
||
| 148 | 148 | * @param Snak $snak |
| 149 | 149 | * @return bool |
| 150 | 150 | */ |
| 151 | - public function matchesSnak( Snak $snak ) { |
|
| 152 | - switch ( true ) { |
|
| 151 | + public function matchesSnak(Snak $snak) { |
|
| 152 | + switch (true) { |
|
| 153 | 153 | case $snak instanceof PropertyValueSnak: |
| 154 | 154 | $dataValue = $snak->getDataValue(); |
| 155 | 155 | return $this->isValue() && |
| 156 | 156 | $dataValue instanceof EntityIdValue && |
| 157 | 157 | $dataValue->getEntityId() instanceof ItemId && |
| 158 | - $dataValue->getEntityId()->equals( $this->getItemId() ); |
|
| 158 | + $dataValue->getEntityId()->equals($this->getItemId()); |
|
| 159 | 159 | case $snak instanceof PropertySomeValueSnak: |
| 160 | 160 | return $this->isSomeValue(); |
| 161 | 161 | case $snak instanceof PropertyNoValueSnak: |
@@ -37,25 +37,25 @@ discard block |
||
| 37 | 37 | * @param Title $title |
| 38 | 38 | * @param string[] $params should contain 'entityId' => 'Q1234' |
| 39 | 39 | */ |
| 40 | - public function __construct( Title $title, array $params ) { |
|
| 41 | - parent::__construct( self::COMMAND, $title, $params ); |
|
| 40 | + public function __construct(Title $title, array $params) { |
|
| 41 | + parent::__construct(self::COMMAND, $title, $params); |
|
| 42 | 42 | $this->removeDuplicates = true; |
| 43 | 43 | |
| 44 | - Assert::parameterType( 'string', $params['entityId'], '$params[\'entityId\']' ); |
|
| 44 | + Assert::parameterType('string', $params['entityId'], '$params[\'entityId\']'); |
|
| 45 | 45 | |
| 46 | - $resultSource = ConstraintsServices::getResultsSource( MediaWikiServices::getInstance() ); |
|
| 46 | + $resultSource = ConstraintsServices::getResultsSource(MediaWikiServices::getInstance()); |
|
| 47 | 47 | '@phan-var CachingResultsSource $resultSource'; |
| 48 | 48 | // This job should only ever be used when caching result sources are used. |
| 49 | - $this->setResultsSource( $resultSource ); |
|
| 49 | + $this->setResultsSource($resultSource); |
|
| 50 | 50 | |
| 51 | - $this->setEntityIdParser( WikibaseRepo::getEntityIdParser() ); |
|
| 51 | + $this->setEntityIdParser(WikibaseRepo::getEntityIdParser()); |
|
| 52 | 52 | } |
| 53 | 53 | |
| 54 | - public function setResultsSource( CachingResultsSource $resultsSource ) { |
|
| 54 | + public function setResultsSource(CachingResultsSource $resultsSource) { |
|
| 55 | 55 | $this->resultsSource = $resultsSource; |
| 56 | 56 | } |
| 57 | 57 | |
| 58 | - public function setEntityIdParser( EntityIdParser $parser ) { |
|
| 58 | + public function setEntityIdParser(EntityIdParser $parser) { |
|
| 59 | 59 | $this->entityIdParser = $parser; |
| 60 | 60 | } |
| 61 | 61 | |
@@ -66,19 +66,19 @@ discard block |
||
| 66 | 66 | */ |
| 67 | 67 | public function run() { |
| 68 | 68 | try { |
| 69 | - $entityId = $this->entityIdParser->parse( $this->params['entityId'] ); |
|
| 70 | - } catch ( EntityIdParsingException $e ) { |
|
| 69 | + $entityId = $this->entityIdParser->parse($this->params['entityId']); |
|
| 70 | + } catch (EntityIdParsingException $e) { |
|
| 71 | 71 | return false; |
| 72 | 72 | } |
| 73 | 73 | |
| 74 | - $this->checkConstraints( $entityId ); |
|
| 74 | + $this->checkConstraints($entityId); |
|
| 75 | 75 | |
| 76 | 76 | return true; |
| 77 | 77 | } |
| 78 | 78 | |
| 79 | - private function checkConstraints( EntityId $entityId ) { |
|
| 79 | + private function checkConstraints(EntityId $entityId) { |
|
| 80 | 80 | $this->resultsSource->getResults( |
| 81 | - [ $entityId ], |
|
| 81 | + [$entityId], |
|
| 82 | 82 | [], |
| 83 | 83 | null, |
| 84 | 84 | [] |
@@ -20,13 +20,13 @@ |
||
| 20 | 20 | * @param PropertyId $propertyId |
| 21 | 21 | * @return int |
| 22 | 22 | */ |
| 23 | - public function getPropertyCount( array $snaks, PropertyId $propertyId ) { |
|
| 24 | - return count( array_filter( |
|
| 23 | + public function getPropertyCount(array $snaks, PropertyId $propertyId) { |
|
| 24 | + return count(array_filter( |
|
| 25 | 25 | $snaks, |
| 26 | - static function ( Snak $snak ) use ( $propertyId ) { |
|
| 27 | - return $snak->getPropertyId()->equals( $propertyId ); |
|
| 26 | + static function(Snak $snak) use ($propertyId) { |
|
| 27 | + return $snak->getPropertyId()->equals($propertyId); |
|
| 28 | 28 | } |
| 29 | - ) ); |
|
| 29 | + )); |
|
| 30 | 30 | } |
| 31 | 31 | |
| 32 | 32 | } |
@@ -128,17 +128,17 @@ discard block |
||
| 128 | 128 | public function __construct( |
| 129 | 129 | $messageKey |
| 130 | 130 | ) { |
| 131 | - if ( strpos( $messageKey, self::MESSAGE_KEY_PREFIX ) !== 0 ) { |
|
| 131 | + if (strpos($messageKey, self::MESSAGE_KEY_PREFIX) !== 0) { |
|
| 132 | 132 | throw new InvalidArgumentException( |
| 133 | - 'ViolationMessage key ⧼' . |
|
| 134 | - $messageKey . |
|
| 135 | - '⧽ should start with "' . |
|
| 136 | - self::MESSAGE_KEY_PREFIX . |
|
| 133 | + 'ViolationMessage key ⧼'. |
|
| 134 | + $messageKey. |
|
| 135 | + '⧽ should start with "'. |
|
| 136 | + self::MESSAGE_KEY_PREFIX. |
|
| 137 | 137 | '".' |
| 138 | 138 | ); |
| 139 | 139 | } |
| 140 | 140 | |
| 141 | - $this->messageKeySuffix = substr( $messageKey, strlen( self::MESSAGE_KEY_PREFIX ) ); |
|
| 141 | + $this->messageKeySuffix = substr($messageKey, strlen(self::MESSAGE_KEY_PREFIX)); |
|
| 142 | 142 | $this->arguments = []; |
| 143 | 143 | } |
| 144 | 144 | |
@@ -147,7 +147,7 @@ discard block |
||
| 147 | 147 | * @return string |
| 148 | 148 | */ |
| 149 | 149 | public function getMessageKey() { |
| 150 | - return self::MESSAGE_KEY_PREFIX . $this->messageKeySuffix; |
|
| 150 | + return self::MESSAGE_KEY_PREFIX.$this->messageKeySuffix; |
|
| 151 | 151 | } |
| 152 | 152 | |
| 153 | 153 | /** |
@@ -167,9 +167,9 @@ discard block |
||
| 167 | 167 | * @param mixed $value the value, which should match the $type |
| 168 | 168 | * @return ViolationMessage |
| 169 | 169 | */ |
| 170 | - public function withArgument( $type, $role, $value ) { |
|
| 170 | + public function withArgument($type, $role, $value) { |
|
| 171 | 171 | $ret = clone $this; |
| 172 | - $ret->arguments[] = [ 'type' => $type, 'role' => $role, 'value' => $value ]; |
|
| 172 | + $ret->arguments[] = ['type' => $type, 'role' => $role, 'value' => $value]; |
|
| 173 | 173 | return $ret; |
| 174 | 174 | } |
| 175 | 175 | |
@@ -181,8 +181,8 @@ discard block |
||
| 181 | 181 | * @param string|null $role one of the Role::* constants |
| 182 | 182 | * @return ViolationMessage |
| 183 | 183 | */ |
| 184 | - public function withEntityId( EntityId $entityId, $role = null ) { |
|
| 185 | - return $this->withArgument( self::TYPE_ENTITY_ID, $role, $entityId ); |
|
| 184 | + public function withEntityId(EntityId $entityId, $role = null) { |
|
| 185 | + return $this->withArgument(self::TYPE_ENTITY_ID, $role, $entityId); |
|
| 186 | 186 | } |
| 187 | 187 | |
| 188 | 188 | /** |
@@ -199,8 +199,8 @@ discard block |
||
| 199 | 199 | * @param string|null $role one of the Role::* constants |
| 200 | 200 | * @return ViolationMessage |
| 201 | 201 | */ |
| 202 | - public function withEntityIdList( array $entityIdList, $role = null ) { |
|
| 203 | - return $this->withArgument( self::TYPE_ENTITY_ID_LIST, $role, $entityIdList ); |
|
| 202 | + public function withEntityIdList(array $entityIdList, $role = null) { |
|
| 203 | + return $this->withArgument(self::TYPE_ENTITY_ID_LIST, $role, $entityIdList); |
|
| 204 | 204 | } |
| 205 | 205 | |
| 206 | 206 | /** |
@@ -211,8 +211,8 @@ discard block |
||
| 211 | 211 | * @param string|null $role one of the Role::* constants |
| 212 | 212 | * @return ViolationMessage |
| 213 | 213 | */ |
| 214 | - public function withItemIdSnakValue( ItemIdSnakValue $value, $role = null ) { |
|
| 215 | - return $this->withArgument( self::TYPE_ITEM_ID_SNAK_VALUE, $role, $value ); |
|
| 214 | + public function withItemIdSnakValue(ItemIdSnakValue $value, $role = null) { |
|
| 215 | + return $this->withArgument(self::TYPE_ITEM_ID_SNAK_VALUE, $role, $value); |
|
| 216 | 216 | } |
| 217 | 217 | |
| 218 | 218 | /** |
@@ -229,8 +229,8 @@ discard block |
||
| 229 | 229 | * @param string|null $role one of the Role::* constants |
| 230 | 230 | * @return ViolationMessage |
| 231 | 231 | */ |
| 232 | - public function withItemIdSnakValueList( array $valueList, $role = null ) { |
|
| 233 | - return $this->withArgument( self::TYPE_ITEM_ID_SNAK_VALUE_LIST, $role, $valueList ); |
|
| 232 | + public function withItemIdSnakValueList(array $valueList, $role = null) { |
|
| 233 | + return $this->withArgument(self::TYPE_ITEM_ID_SNAK_VALUE_LIST, $role, $valueList); |
|
| 234 | 234 | } |
| 235 | 235 | |
| 236 | 236 | /** |
@@ -241,8 +241,8 @@ discard block |
||
| 241 | 241 | * @param string|null $role one of the Role::* constants |
| 242 | 242 | * @return ViolationMessage |
| 243 | 243 | */ |
| 244 | - public function withDataValue( DataValue $dataValue, $role = null ) { |
|
| 245 | - return $this->withArgument( self::TYPE_DATA_VALUE, $role, $dataValue ); |
|
| 244 | + public function withDataValue(DataValue $dataValue, $role = null) { |
|
| 245 | + return $this->withArgument(self::TYPE_DATA_VALUE, $role, $dataValue); |
|
| 246 | 246 | } |
| 247 | 247 | |
| 248 | 248 | /** |
@@ -257,8 +257,8 @@ discard block |
||
| 257 | 257 | * @param string|null $role one of the Role::* constants |
| 258 | 258 | * @return ViolationMessage |
| 259 | 259 | */ |
| 260 | - public function withDataValueType( $dataValueType, $role = null ) { |
|
| 261 | - return $this->withArgument( self::TYPE_DATA_VALUE_TYPE, $role, $dataValueType ); |
|
| 260 | + public function withDataValueType($dataValueType, $role = null) { |
|
| 261 | + return $this->withArgument(self::TYPE_DATA_VALUE_TYPE, $role, $dataValueType); |
|
| 262 | 262 | } |
| 263 | 263 | |
| 264 | 264 | /** |
@@ -269,8 +269,8 @@ discard block |
||
| 269 | 269 | * @param string|null $role one of the Role::* constants |
| 270 | 270 | * @return ViolationMessage |
| 271 | 271 | */ |
| 272 | - public function withInlineCode( $code, $role = null ) { |
|
| 273 | - return $this->withArgument( self::TYPE_INLINE_CODE, $role, $code ); |
|
| 272 | + public function withInlineCode($code, $role = null) { |
|
| 273 | + return $this->withArgument(self::TYPE_INLINE_CODE, $role, $code); |
|
| 274 | 274 | } |
| 275 | 275 | |
| 276 | 276 | /** |
@@ -281,8 +281,8 @@ discard block |
||
| 281 | 281 | * @param string|null $role one of the Role::* constants |
| 282 | 282 | * @return ViolationMessage |
| 283 | 283 | */ |
| 284 | - public function withConstraintScope( $scope, $role = null ) { |
|
| 285 | - return $this->withArgument( self::TYPE_CONSTRAINT_SCOPE, $role, $scope ); |
|
| 284 | + public function withConstraintScope($scope, $role = null) { |
|
| 285 | + return $this->withArgument(self::TYPE_CONSTRAINT_SCOPE, $role, $scope); |
|
| 286 | 286 | } |
| 287 | 287 | |
| 288 | 288 | /** |
@@ -293,8 +293,8 @@ discard block |
||
| 293 | 293 | * @param string|null $role one of the Role::* constants |
| 294 | 294 | * @return ViolationMessage |
| 295 | 295 | */ |
| 296 | - public function withConstraintScopeList( array $scopeList, $role = null ) { |
|
| 297 | - return $this->withArgument( self::TYPE_CONSTRAINT_SCOPE_LIST, $role, $scopeList ); |
|
| 296 | + public function withConstraintScopeList(array $scopeList, $role = null) { |
|
| 297 | + return $this->withArgument(self::TYPE_CONSTRAINT_SCOPE_LIST, $role, $scopeList); |
|
| 298 | 298 | } |
| 299 | 299 | |
| 300 | 300 | /** |
@@ -305,8 +305,8 @@ discard block |
||
| 305 | 305 | * @param string|null $role one of the Role::* constants |
| 306 | 306 | * @return ViolationMessage |
| 307 | 307 | */ |
| 308 | - public function withPropertyScope( $scope, $role = null ) { |
|
| 309 | - return $this->withArgument( self::TYPE_PROPERTY_SCOPE, $role, $scope ); |
|
| 308 | + public function withPropertyScope($scope, $role = null) { |
|
| 309 | + return $this->withArgument(self::TYPE_PROPERTY_SCOPE, $role, $scope); |
|
| 310 | 310 | } |
| 311 | 311 | |
| 312 | 312 | /** |
@@ -317,8 +317,8 @@ discard block |
||
| 317 | 317 | * @param string|null $role one of the Role::* constants |
| 318 | 318 | * @return ViolationMessage |
| 319 | 319 | */ |
| 320 | - public function withPropertyScopeList( array $scopeList, $role = null ) { |
|
| 321 | - return $this->withArgument( self::TYPE_PROPERTY_SCOPE_LIST, $role, $scopeList ); |
|
| 320 | + public function withPropertyScopeList(array $scopeList, $role = null) { |
|
| 321 | + return $this->withArgument(self::TYPE_PROPERTY_SCOPE_LIST, $role, $scopeList); |
|
| 322 | 322 | } |
| 323 | 323 | |
| 324 | 324 | /** |
@@ -333,8 +333,8 @@ discard block |
||
| 333 | 333 | * @param string $languageCode |
| 334 | 334 | * @return ViolationMessage |
| 335 | 335 | */ |
| 336 | - public function withLanguage( $languageCode ) { |
|
| 337 | - return $this->withArgument( self::TYPE_LANGUAGE, null, $languageCode ); |
|
| 336 | + public function withLanguage($languageCode) { |
|
| 337 | + return $this->withArgument(self::TYPE_LANGUAGE, null, $languageCode); |
|
| 338 | 338 | } |
| 339 | 339 | |
| 340 | 340 | /** |
@@ -349,8 +349,8 @@ discard block |
||
| 349 | 349 | * @param string[] $languageCodes |
| 350 | 350 | * @return ViolationMessage |
| 351 | 351 | */ |
| 352 | - public function withLanguages( $languageCodes ) { |
|
| 353 | - return $this->withArgument( self::TYPE_LANGUAGE_LIST, null, $languageCodes ); |
|
| 352 | + public function withLanguages($languageCodes) { |
|
| 353 | + return $this->withArgument(self::TYPE_LANGUAGE_LIST, null, $languageCodes); |
|
| 354 | 354 | } |
| 355 | 355 | |
| 356 | 356 | /** |
@@ -365,8 +365,8 @@ discard block |
||
| 365 | 365 | * @param string|null $role one of the Role::* constants |
| 366 | 366 | * @return ViolationMessage |
| 367 | 367 | */ |
| 368 | - public function withMultilingualText( MultilingualTextValue $text, $role = null ) { |
|
| 369 | - return $this->withArgument( self::TYPE_MULTILINGUAL_TEXT, $role, $text ); |
|
| 368 | + public function withMultilingualText(MultilingualTextValue $text, $role = null) { |
|
| 369 | + return $this->withArgument(self::TYPE_MULTILINGUAL_TEXT, $role, $text); |
|
| 370 | 370 | } |
| 371 | 371 | |
| 372 | 372 | } |
@@ -72,7 +72,7 @@ |
||
| 72 | 72 | * @return never |
| 73 | 73 | */ |
| 74 | 74 | private function __construct() { |
| 75 | - throw new LogicException( 'This class should never be instantiated.' ); |
|
| 75 | + throw new LogicException('This class should never be instantiated.'); |
|
| 76 | 76 | } |
| 77 | 77 | |
| 78 | 78 | } |
@@ -10,14 +10,13 @@ |
||
| 10 | 10 | */ |
| 11 | 11 | class ConstraintDeserializer { |
| 12 | 12 | |
| 13 | - public function deserialize( array $serialization ) { |
|
| 13 | + public function deserialize(array $serialization) { |
|
| 14 | 14 | return new Constraint( |
| 15 | 15 | $serialization['id'], |
| 16 | - new NumericPropertyId( $serialization['pid'] ), |
|
| 16 | + new NumericPropertyId($serialization['pid']), |
|
| 17 | 17 | $serialization['qid'], |
| 18 | - array_key_exists( 'params', $serialization ) ? |
|
| 19 | - $serialization['params'] : |
|
| 20 | - [] |
|
| 18 | + array_key_exists('params', $serialization) ? |
|
| 19 | + $serialization['params'] : [] |
|
| 21 | 20 | ); |
| 22 | 21 | } |
| 23 | 22 | |
@@ -26,7 +26,7 @@ discard block |
||
| 26 | 26 | /** |
| 27 | 27 | * @param ConstraintLookup $lookup The lookup to which all queries are delegated. |
| 28 | 28 | */ |
| 29 | - public function __construct( ConstraintLookup $lookup ) { |
|
| 29 | + public function __construct(ConstraintLookup $lookup) { |
|
| 30 | 30 | $this->lookup = $lookup; |
| 31 | 31 | } |
| 32 | 32 | |
@@ -35,10 +35,10 @@ discard block |
||
| 35 | 35 | * |
| 36 | 36 | * @return Constraint[] |
| 37 | 37 | */ |
| 38 | - public function queryConstraintsForProperty( NumericPropertyId $propertyId ) { |
|
| 38 | + public function queryConstraintsForProperty(NumericPropertyId $propertyId) { |
|
| 39 | 39 | $id = $propertyId->getSerialization(); |
| 40 | - if ( !array_key_exists( $id, $this->cache ) ) { |
|
| 41 | - $this->cache[$id] = $this->lookup->queryConstraintsForProperty( $propertyId ); |
|
| 40 | + if (!array_key_exists($id, $this->cache)) { |
|
| 41 | + $this->cache[$id] = $this->lookup->queryConstraintsForProperty($propertyId); |
|
| 42 | 42 | } |
| 43 | 43 | return $this->cache[$id]; |
| 44 | 44 | } |
@@ -14,6 +14,6 @@ |
||
| 14 | 14 | * |
| 15 | 15 | * @return Constraint[] |
| 16 | 16 | */ |
| 17 | - public function queryConstraintsForProperty( NumericPropertyId $propertyId ); |
|
| 17 | + public function queryConstraintsForProperty(NumericPropertyId $propertyId); |
|
| 18 | 18 | |
| 19 | 19 | } |
@@ -38,8 +38,8 @@ discard block |
||
| 38 | 38 | */ |
| 39 | 39 | private const BATCH_SIZE = 50; |
| 40 | 40 | |
| 41 | - public static function newFromGlobalState( Title $title, array $params ) { |
|
| 42 | - Assert::parameterType( 'string', $params['propertyId'], '$params["propertyId"]' ); |
|
| 41 | + public static function newFromGlobalState(Title $title, array $params) { |
|
| 42 | + Assert::parameterType('string', $params['propertyId'], '$params["propertyId"]'); |
|
| 43 | 43 | $services = MediaWikiServices::getInstance(); |
| 44 | 44 | return new UpdateConstraintsTableJob( |
| 45 | 45 | $title, |
@@ -49,8 +49,8 @@ discard block |
||
| 49 | 49 | $services->getMainConfig(), |
| 50 | 50 | ConstraintsServices::getConstraintStore(), |
| 51 | 51 | $services->getDBLoadBalancerFactory(), |
| 52 | - WikibaseRepo::getStore()->getEntityRevisionLookup( Store::LOOKUP_CACHING_DISABLED ), |
|
| 53 | - WikibaseRepo::getBaseDataModelSerializerFactory( $services ) |
|
| 52 | + WikibaseRepo::getStore()->getEntityRevisionLookup(Store::LOOKUP_CACHING_DISABLED), |
|
| 53 | + WikibaseRepo::getBaseDataModelSerializerFactory($services) |
|
| 54 | 54 | ->newSnakSerializer(), |
| 55 | 55 | $services->getJobQueueGroup() |
| 56 | 56 | ); |
@@ -118,7 +118,7 @@ discard block |
||
| 118 | 118 | Serializer $snakSerializer, |
| 119 | 119 | JobQueueGroup $jobQueueGroup |
| 120 | 120 | ) { |
| 121 | - parent::__construct( 'constraintsTableUpdate', $title, $params ); |
|
| 121 | + parent::__construct('constraintsTableUpdate', $title, $params); |
|
| 122 | 122 | |
| 123 | 123 | $this->propertyId = $propertyId; |
| 124 | 124 | $this->revisionId = $revisionId; |
@@ -130,11 +130,11 @@ discard block |
||
| 130 | 130 | $this->jobQueueGroup = $jobQueueGroup; |
| 131 | 131 | } |
| 132 | 132 | |
| 133 | - public function extractParametersFromQualifiers( SnakList $qualifiers ) { |
|
| 133 | + public function extractParametersFromQualifiers(SnakList $qualifiers) { |
|
| 134 | 134 | $parameters = []; |
| 135 | - foreach ( $qualifiers as $qualifier ) { |
|
| 135 | + foreach ($qualifiers as $qualifier) { |
|
| 136 | 136 | $qualifierId = $qualifier->getPropertyId()->getSerialization(); |
| 137 | - $paramSerialization = $this->snakSerializer->serialize( $qualifier ); |
|
| 137 | + $paramSerialization = $this->snakSerializer->serialize($qualifier); |
|
| 138 | 138 | $parameters[$qualifierId][] = $paramSerialization; |
| 139 | 139 | } |
| 140 | 140 | return $parameters; |
@@ -151,7 +151,7 @@ discard block |
||
| 151 | 151 | '@phan-var \Wikibase\DataModel\Entity\EntityIdValue $dataValue'; |
| 152 | 152 | $entityId = $dataValue->getEntityId(); |
| 153 | 153 | $constraintTypeQid = $entityId->getSerialization(); |
| 154 | - $parameters = $this->extractParametersFromQualifiers( $constraintStatement->getQualifiers() ); |
|
| 154 | + $parameters = $this->extractParametersFromQualifiers($constraintStatement->getQualifiers()); |
|
| 155 | 155 | return new Constraint( |
| 156 | 156 | $constraintId, |
| 157 | 157 | $propertyId, |
@@ -166,25 +166,25 @@ discard block |
||
| 166 | 166 | NumericPropertyId $propertyConstraintPropertyId |
| 167 | 167 | ) { |
| 168 | 168 | $constraintsStatements = $property->getStatements() |
| 169 | - ->getByPropertyId( $propertyConstraintPropertyId ) |
|
| 170 | - ->getByRank( [ Statement::RANK_PREFERRED, Statement::RANK_NORMAL ] ); |
|
| 169 | + ->getByPropertyId($propertyConstraintPropertyId) |
|
| 170 | + ->getByRank([Statement::RANK_PREFERRED, Statement::RANK_NORMAL]); |
|
| 171 | 171 | $constraints = []; |
| 172 | - foreach ( $constraintsStatements->getIterator() as $constraintStatement ) { |
|
| 172 | + foreach ($constraintsStatements->getIterator() as $constraintStatement) { |
|
| 173 | 173 | // @phan-suppress-next-line PhanTypeMismatchArgumentSuperType |
| 174 | - $constraints[] = $this->extractConstraintFromStatement( $property->getId(), $constraintStatement ); |
|
| 175 | - if ( count( $constraints ) >= self::BATCH_SIZE ) { |
|
| 176 | - $constraintStore->insertBatch( $constraints ); |
|
| 174 | + $constraints[] = $this->extractConstraintFromStatement($property->getId(), $constraintStatement); |
|
| 175 | + if (count($constraints) >= self::BATCH_SIZE) { |
|
| 176 | + $constraintStore->insertBatch($constraints); |
|
| 177 | 177 | // interrupt transaction and wait for replication |
| 178 | - $connection = $this->lbFactory->getMainLB()->getConnection( DB_PRIMARY ); |
|
| 179 | - $connection->endAtomic( __CLASS__ ); |
|
| 180 | - if ( !$connection->explicitTrxActive() ) { |
|
| 178 | + $connection = $this->lbFactory->getMainLB()->getConnection(DB_PRIMARY); |
|
| 179 | + $connection->endAtomic(__CLASS__); |
|
| 180 | + if (!$connection->explicitTrxActive()) { |
|
| 181 | 181 | $this->lbFactory->waitForReplication(); |
| 182 | 182 | } |
| 183 | - $connection->startAtomic( __CLASS__ ); |
|
| 183 | + $connection->startAtomic(__CLASS__); |
|
| 184 | 184 | $constraints = []; |
| 185 | 185 | } |
| 186 | 186 | } |
| 187 | - $constraintStore->insertBatch( $constraints ); |
|
| 187 | + $constraintStore->insertBatch($constraints); |
|
| 188 | 188 | } |
| 189 | 189 | |
| 190 | 190 | /** |
@@ -195,24 +195,24 @@ discard block |
||
| 195 | 195 | public function run() { |
| 196 | 196 | // TODO in the future: only touch constraints affected by the edit (requires T163465) |
| 197 | 197 | |
| 198 | - $propertyId = new NumericPropertyId( $this->propertyId ); |
|
| 198 | + $propertyId = new NumericPropertyId($this->propertyId); |
|
| 199 | 199 | $propertyRevision = $this->entityRevisionLookup->getEntityRevision( |
| 200 | 200 | $propertyId, |
| 201 | 201 | 0, // latest |
| 202 | 202 | LookupConstants::LATEST_FROM_REPLICA |
| 203 | 203 | ); |
| 204 | 204 | |
| 205 | - if ( $this->revisionId !== null && $propertyRevision->getRevisionId() < $this->revisionId ) { |
|
| 206 | - $this->jobQueueGroup->push( $this ); |
|
| 205 | + if ($this->revisionId !== null && $propertyRevision->getRevisionId() < $this->revisionId) { |
|
| 206 | + $this->jobQueueGroup->push($this); |
|
| 207 | 207 | return true; |
| 208 | 208 | } |
| 209 | 209 | |
| 210 | - $connection = $this->lbFactory->getMainLB()->getConnection( DB_PRIMARY ); |
|
| 210 | + $connection = $this->lbFactory->getMainLB()->getConnection(DB_PRIMARY); |
|
| 211 | 211 | // start transaction (if not started yet) – using __CLASS__, not __METHOD__, |
| 212 | 212 | // because importConstraintsForProperty() can interrupt the transaction |
| 213 | - $connection->startAtomic( __CLASS__ ); |
|
| 213 | + $connection->startAtomic(__CLASS__); |
|
| 214 | 214 | |
| 215 | - $this->constraintStore->deleteForProperty( $propertyId ); |
|
| 215 | + $this->constraintStore->deleteForProperty($propertyId); |
|
| 216 | 216 | |
| 217 | 217 | /** @var Property $property */ |
| 218 | 218 | $property = $propertyRevision->getEntity(); |
@@ -220,10 +220,10 @@ discard block |
||
| 220 | 220 | $this->importConstraintsForProperty( |
| 221 | 221 | $property, |
| 222 | 222 | $this->constraintStore, |
| 223 | - new NumericPropertyId( $this->config->get( 'WBQualityConstraintsPropertyConstraintId' ) ) |
|
| 223 | + new NumericPropertyId($this->config->get('WBQualityConstraintsPropertyConstraintId')) |
|
| 224 | 224 | ); |
| 225 | 225 | |
| 226 | - $connection->endAtomic( __CLASS__ ); |
|
| 226 | + $connection->endAtomic(__CLASS__); |
|
| 227 | 227 | |
| 228 | 228 | return true; |
| 229 | 229 | } |