@@ -91,9 +91,9 @@ discard block |
||
| 91 | 91 | * @throws SparqlHelperException if the checker uses SPARQL and the query times out or some other error occurs |
| 92 | 92 | * @return CheckResult |
| 93 | 93 | */ |
| 94 | - public function checkConstraint( Context $context, Constraint $constraint ) { |
|
| 95 | - if ( $context->getSnakRank() === Statement::RANK_DEPRECATED ) { |
|
| 96 | - return new CheckResult( $context, $constraint, [], CheckResult::STATUS_DEPRECATED ); |
|
| 94 | + public function checkConstraint(Context $context, Constraint $constraint) { |
|
| 95 | + if ($context->getSnakRank() === Statement::RANK_DEPRECATED) { |
|
| 96 | + return new CheckResult($context, $constraint, [], CheckResult::STATUS_DEPRECATED); |
|
| 97 | 97 | } |
| 98 | 98 | |
| 99 | 99 | $parameters = []; |
@@ -105,8 +105,8 @@ discard block |
||
| 105 | 105 | $constraintTypeItemId |
| 106 | 106 | ); |
| 107 | 107 | $parameters['class'] = array_map( |
| 108 | - function( $id ) { |
|
| 109 | - return new ItemId( $id ); |
|
| 108 | + function($id) { |
|
| 109 | + return new ItemId($id); |
|
| 110 | 110 | }, |
| 111 | 111 | $classes |
| 112 | 112 | ); |
@@ -116,19 +116,19 @@ discard block |
||
| 116 | 116 | $constraintTypeItemId |
| 117 | 117 | ); |
| 118 | 118 | $relationIds = []; |
| 119 | - if ( $relation === 'instance' || $relation === 'instanceOrSubclass' ) { |
|
| 120 | - $relationIds[] = $this->config->get( 'WBQualityConstraintsInstanceOfId' ); |
|
| 119 | + if ($relation === 'instance' || $relation === 'instanceOrSubclass') { |
|
| 120 | + $relationIds[] = $this->config->get('WBQualityConstraintsInstanceOfId'); |
|
| 121 | 121 | } |
| 122 | - if ( $relation === 'subclass' || $relation === 'instanceOrSubclass' ) { |
|
| 123 | - $relationIds[] = $this->config->get( 'WBQualityConstraintsSubclassOfId' ); |
|
| 122 | + if ($relation === 'subclass' || $relation === 'instanceOrSubclass') { |
|
| 123 | + $relationIds[] = $this->config->get('WBQualityConstraintsSubclassOfId'); |
|
| 124 | 124 | } |
| 125 | - $parameters['relation'] = [ $relation ]; |
|
| 125 | + $parameters['relation'] = [$relation]; |
|
| 126 | 126 | |
| 127 | 127 | $snak = $context->getSnak(); |
| 128 | 128 | |
| 129 | - if ( !$snak instanceof PropertyValueSnak ) { |
|
| 129 | + if (!$snak instanceof PropertyValueSnak) { |
|
| 130 | 130 | // nothing to check |
| 131 | - return new CheckResult( $context, $constraint, $parameters, CheckResult::STATUS_COMPLIANCE ); |
|
| 131 | + return new CheckResult($context, $constraint, $parameters, CheckResult::STATUS_COMPLIANCE); |
|
| 132 | 132 | } |
| 133 | 133 | |
| 134 | 134 | $dataValue = $snak->getDataValue(); |
@@ -137,23 +137,23 @@ discard block |
||
| 137 | 137 | * error handling: |
| 138 | 138 | * type of $dataValue for properties with 'Value type' constraint has to be 'wikibase-entityid' |
| 139 | 139 | */ |
| 140 | - if ( !$dataValue instanceof EntityIdValue ) { |
|
| 141 | - $message = ( new ViolationMessage( 'wbqc-violation-message-value-needed-of-type' ) ) |
|
| 142 | - ->withEntityId( new ItemId( $constraintTypeItemId ), Role::CONSTRAINT_TYPE_ITEM ) |
|
| 143 | - ->withDataValueType( 'wikibase-entityid' ); |
|
| 144 | - return new CheckResult( $context, $constraint, $parameters, CheckResult::STATUS_VIOLATION, $message ); |
|
| 140 | + if (!$dataValue instanceof EntityIdValue) { |
|
| 141 | + $message = (new ViolationMessage('wbqc-violation-message-value-needed-of-type')) |
|
| 142 | + ->withEntityId(new ItemId($constraintTypeItemId), Role::CONSTRAINT_TYPE_ITEM) |
|
| 143 | + ->withDataValueType('wikibase-entityid'); |
|
| 144 | + return new CheckResult($context, $constraint, $parameters, CheckResult::STATUS_VIOLATION, $message); |
|
| 145 | 145 | } |
| 146 | 146 | |
| 147 | 147 | try { |
| 148 | - $item = $this->entityLookup->getEntity( $dataValue->getEntityId() ); |
|
| 149 | - } catch ( UnresolvedEntityRedirectException $e ) { |
|
| 148 | + $item = $this->entityLookup->getEntity($dataValue->getEntityId()); |
|
| 149 | + } catch (UnresolvedEntityRedirectException $e) { |
|
| 150 | 150 | // Edge case (double redirect): Pretend the entity doesn't exist |
| 151 | 151 | $item = null; |
| 152 | 152 | } |
| 153 | 153 | |
| 154 | - if ( !( $item instanceof StatementListProvidingEntity ) ) { |
|
| 155 | - $message = new ViolationMessage( 'wbqc-violation-message-value-entity-must-exist' ); |
|
| 156 | - return new CheckResult( $context, $constraint, $parameters, CheckResult::STATUS_VIOLATION, $message ); |
|
| 154 | + if (!($item instanceof StatementListProvidingEntity)) { |
|
| 155 | + $message = new ViolationMessage('wbqc-violation-message-value-entity-must-exist'); |
|
| 156 | + return new CheckResult($context, $constraint, $parameters, CheckResult::STATUS_VIOLATION, $message); |
|
| 157 | 157 | } |
| 158 | 158 | |
| 159 | 159 | $statements = $item->getStatements(); |
@@ -164,7 +164,7 @@ discard block |
||
| 164 | 164 | $classes |
| 165 | 165 | ); |
| 166 | 166 | |
| 167 | - if ( $result->getBool() ) { |
|
| 167 | + if ($result->getBool()) { |
|
| 168 | 168 | $message = null; |
| 169 | 169 | $status = CheckResult::STATUS_COMPLIANCE; |
| 170 | 170 | } else { |
@@ -178,11 +178,11 @@ discard block |
||
| 178 | 178 | $status = CheckResult::STATUS_VIOLATION; |
| 179 | 179 | } |
| 180 | 180 | |
| 181 | - return ( new CheckResult( $context, $constraint, $parameters, $status, $message ) ) |
|
| 182 | - ->withMetadata( $result->getMetadata() ); |
|
| 181 | + return (new CheckResult($context, $constraint, $parameters, $status, $message)) |
|
| 182 | + ->withMetadata($result->getMetadata()); |
|
| 183 | 183 | } |
| 184 | 184 | |
| 185 | - public function checkConstraintParameters( Constraint $constraint ) { |
|
| 185 | + public function checkConstraintParameters(Constraint $constraint) { |
|
| 186 | 186 | $constraintParameters = $constraint->getConstraintParameters(); |
| 187 | 187 | $constraintTypeItemId = $constraint->getConstraintTypeItemId(); |
| 188 | 188 | $exceptions = []; |
@@ -191,7 +191,7 @@ discard block |
||
| 191 | 191 | $constraintParameters, |
| 192 | 192 | $constraintTypeItemId |
| 193 | 193 | ); |
| 194 | - } catch ( ConstraintParameterException $e ) { |
|
| 194 | + } catch (ConstraintParameterException $e) { |
|
| 195 | 195 | $exceptions[] = $e; |
| 196 | 196 | } |
| 197 | 197 | try { |
@@ -199,7 +199,7 @@ discard block |
||
| 199 | 199 | $constraintParameters, |
| 200 | 200 | $constraintTypeItemId |
| 201 | 201 | ); |
| 202 | - } catch ( ConstraintParameterException $e ) { |
|
| 202 | + } catch (ConstraintParameterException $e) { |
|
| 203 | 203 | $exceptions[] = $e; |
| 204 | 204 | } |
| 205 | 205 | return $exceptions; |
@@ -53,7 +53,7 @@ discard block |
||
| 53 | 53 | $this->config = $config; |
| 54 | 54 | $this->timeParser = new IsoTimestampParser(); |
| 55 | 55 | $this->timeCalculator = new TimeValueCalculator(); |
| 56 | - $this->timeValueComparer = new TimeValueComparer( $this->timeCalculator ); |
|
| 56 | + $this->timeValueComparer = new TimeValueComparer($this->timeCalculator); |
|
| 57 | 57 | $this->unitConverter = $unitConverter; |
| 58 | 58 | } |
| 59 | 59 | |
@@ -61,10 +61,10 @@ discard block |
||
| 61 | 61 | * @param UnboundedQuantityValue $value |
| 62 | 62 | * @return UnboundedQuantityValue $value converted to standard units if possible, otherwise unchanged $value. |
| 63 | 63 | */ |
| 64 | - private function standardize( UnboundedQuantityValue $value ) { |
|
| 65 | - if ( $this->unitConverter !== null ) { |
|
| 66 | - $standard = $this->unitConverter->toStandardUnits( $value ); |
|
| 67 | - if ( $standard !== null ) { |
|
| 64 | + private function standardize(UnboundedQuantityValue $value) { |
|
| 65 | + if ($this->unitConverter !== null) { |
|
| 66 | + $standard = $this->unitConverter->toStandardUnits($value); |
|
| 67 | + if ($standard !== null) { |
|
| 68 | 68 | return $standard; |
| 69 | 69 | } else { |
| 70 | 70 | return $value; |
@@ -86,33 +86,33 @@ discard block |
||
| 86 | 86 | * when $lhs is respectively less than, equal to, or greater than $rhs. |
| 87 | 87 | * (In other words, just like the “spaceship” operator <=>.) |
| 88 | 88 | */ |
| 89 | - public function getComparison( DataValue $lhs = null, DataValue $rhs = null ) { |
|
| 90 | - if ( $lhs === null || $rhs === null ) { |
|
| 89 | + public function getComparison(DataValue $lhs = null, DataValue $rhs = null) { |
|
| 90 | + if ($lhs === null || $rhs === null) { |
|
| 91 | 91 | return 0; |
| 92 | 92 | } |
| 93 | 93 | |
| 94 | - if ( $lhs->getType() !== $rhs->getType() ) { |
|
| 95 | - throw new InvalidArgumentException( 'Different data value types' ); |
|
| 94 | + if ($lhs->getType() !== $rhs->getType()) { |
|
| 95 | + throw new InvalidArgumentException('Different data value types'); |
|
| 96 | 96 | } |
| 97 | 97 | |
| 98 | - switch ( $lhs->getType() ) { |
|
| 98 | + switch ($lhs->getType()) { |
|
| 99 | 99 | case 'time': |
| 100 | 100 | /** @var TimeValue $lhs */ |
| 101 | 101 | /** @var TimeValue $rhs */ |
| 102 | 102 | '@phan-var TimeValue $lhs'; |
| 103 | 103 | '@phan-var TimeValue $rhs'; |
| 104 | - return $this->timeValueComparer->getComparison( $lhs, $rhs ); |
|
| 104 | + return $this->timeValueComparer->getComparison($lhs, $rhs); |
|
| 105 | 105 | case 'quantity': |
| 106 | 106 | /** @var QuantityValue|UnboundedQuantityValue $lhs */ |
| 107 | 107 | /** @var QuantityValue|UnboundedQuantityValue $rhs */ |
| 108 | 108 | '@phan-var QuantityValue|UnboundedQuantityValue $lhs'; |
| 109 | 109 | '@phan-var QuantityValue|UnboundedQuantityValue $rhs'; |
| 110 | - $lhsStandard = $this->standardize( $lhs ); |
|
| 111 | - $rhsStandard = $this->standardize( $rhs ); |
|
| 112 | - return $lhsStandard->getAmount()->compare( $rhsStandard->getAmount() ); |
|
| 110 | + $lhsStandard = $this->standardize($lhs); |
|
| 111 | + $rhsStandard = $this->standardize($rhs); |
|
| 112 | + return $lhsStandard->getAmount()->compare($rhsStandard->getAmount()); |
|
| 113 | 113 | } |
| 114 | 114 | |
| 115 | - throw new InvalidArgumentException( 'Unsupported data value type' ); |
|
| 115 | + throw new InvalidArgumentException('Unsupported data value type'); |
|
| 116 | 116 | } |
| 117 | 117 | |
| 118 | 118 | /** |
@@ -127,71 +127,71 @@ discard block |
||
| 127 | 127 | * @throws InvalidArgumentException if the values do not both have the same, supported data value type |
| 128 | 128 | * @return UnboundedQuantityValue |
| 129 | 129 | */ |
| 130 | - public function getDifference( DataValue $minuend, DataValue $subtrahend ) { |
|
| 131 | - if ( $minuend->getType() === 'time' && $subtrahend->getType() === 'time' ) { |
|
| 132 | - $minuendSeconds = $this->timeCalculator->getTimestamp( $minuend ); |
|
| 133 | - $subtrahendSeconds = $this->timeCalculator->getTimestamp( $subtrahend ); |
|
| 130 | + public function getDifference(DataValue $minuend, DataValue $subtrahend) { |
|
| 131 | + if ($minuend->getType() === 'time' && $subtrahend->getType() === 'time') { |
|
| 132 | + $minuendSeconds = $this->timeCalculator->getTimestamp($minuend); |
|
| 133 | + $subtrahendSeconds = $this->timeCalculator->getTimestamp($subtrahend); |
|
| 134 | 134 | return UnboundedQuantityValue::newFromNumber( |
| 135 | 135 | $minuendSeconds - $subtrahendSeconds, |
| 136 | - $this->config->get( 'WBQualityConstraintsSecondUnit' ) |
|
| 136 | + $this->config->get('WBQualityConstraintsSecondUnit') |
|
| 137 | 137 | ); |
| 138 | 138 | } |
| 139 | - if ( $minuend->getType() === 'quantity' && $subtrahend->getType() === 'quantity' ) { |
|
| 140 | - $minuendStandard = $this->standardize( $minuend ); |
|
| 141 | - $subtrahendStandard = $this->standardize( $subtrahend ); |
|
| 139 | + if ($minuend->getType() === 'quantity' && $subtrahend->getType() === 'quantity') { |
|
| 140 | + $minuendStandard = $this->standardize($minuend); |
|
| 141 | + $subtrahendStandard = $this->standardize($subtrahend); |
|
| 142 | 142 | $minuendValue = $minuendStandard->getAmount()->getValueFloat(); |
| 143 | 143 | $subtrahendValue = $subtrahendStandard->getAmount()->getValueFloat(); |
| 144 | 144 | $diff = $minuendValue - $subtrahendValue; |
| 145 | 145 | // we don’t check whether both quantities have the same standard unit – |
| 146 | 146 | // that’s the job of a different constraint type, Units (T164372) |
| 147 | - return UnboundedQuantityValue::newFromNumber( $diff, $minuendStandard->getUnit() ); |
|
| 147 | + return UnboundedQuantityValue::newFromNumber($diff, $minuendStandard->getUnit()); |
|
| 148 | 148 | } |
| 149 | 149 | |
| 150 | - throw new InvalidArgumentException( 'Unsupported or different data value types' ); |
|
| 150 | + throw new InvalidArgumentException('Unsupported or different data value types'); |
|
| 151 | 151 | } |
| 152 | 152 | |
| 153 | - public function getDifferenceInYears( TimeValue $minuend, TimeValue $subtrahend ) { |
|
| 154 | - if ( !preg_match( '/^([-+]\d{1,16})-(.*)$/', $minuend->getTime(), $minuendMatches ) || |
|
| 155 | - !preg_match( '/^([-+]\d{1,16})-(.*)$/', $subtrahend->getTime(), $subtrahendMatches ) |
|
| 153 | + public function getDifferenceInYears(TimeValue $minuend, TimeValue $subtrahend) { |
|
| 154 | + if (!preg_match('/^([-+]\d{1,16})-(.*)$/', $minuend->getTime(), $minuendMatches) || |
|
| 155 | + !preg_match('/^([-+]\d{1,16})-(.*)$/', $subtrahend->getTime(), $subtrahendMatches) |
|
| 156 | 156 | ) { |
| 157 | - throw new InvalidArgumentException( 'TimeValue::getTime() did not match expected format' ); |
|
| 157 | + throw new InvalidArgumentException('TimeValue::getTime() did not match expected format'); |
|
| 158 | 158 | } |
| 159 | - $minuendYear = (float)$minuendMatches[1]; |
|
| 160 | - $subtrahendYear = (float)$subtrahendMatches[1]; |
|
| 159 | + $minuendYear = (float) $minuendMatches[1]; |
|
| 160 | + $subtrahendYear = (float) $subtrahendMatches[1]; |
|
| 161 | 161 | $minuendRest = $minuendMatches[2]; |
| 162 | 162 | $subtrahendRest = $subtrahendMatches[2]; |
| 163 | 163 | |
| 164 | 164 | // calculate difference of years |
| 165 | 165 | $diff = $minuendYear - $subtrahendYear; |
| 166 | - if ( $minuendYear > 0.0 && $subtrahendYear < 0.0 ) { |
|
| 166 | + if ($minuendYear > 0.0 && $subtrahendYear < 0.0) { |
|
| 167 | 167 | $diff -= 1.0; // there is no year 0, remove it from difference |
| 168 | - } elseif ( $minuendYear < 0.0 && $subtrahendYear > 0.0 ) { |
|
| 168 | + } elseif ($minuendYear < 0.0 && $subtrahendYear > 0.0) { |
|
| 169 | 169 | $diff -= -1.0; // there is no year 0, remove it from negative difference |
| 170 | 170 | } |
| 171 | 171 | |
| 172 | 172 | // adjust for date within year by parsing the month-day part within the same year |
| 173 | - $minuendDateValue = $this->timeParser->parse( '+0000000000001970-' . $minuendRest ); |
|
| 174 | - $subtrahendDateValue = $this->timeParser->parse( '+0000000000001970-' . $subtrahendRest ); |
|
| 175 | - $minuendDateSeconds = $this->timeCalculator->getTimestamp( $minuendDateValue ); |
|
| 176 | - $subtrahendDateSeconds = $this->timeCalculator->getTimestamp( $subtrahendDateValue ); |
|
| 177 | - if ( $minuendDateSeconds < $subtrahendDateSeconds ) { |
|
| 173 | + $minuendDateValue = $this->timeParser->parse('+0000000000001970-'.$minuendRest); |
|
| 174 | + $subtrahendDateValue = $this->timeParser->parse('+0000000000001970-'.$subtrahendRest); |
|
| 175 | + $minuendDateSeconds = $this->timeCalculator->getTimestamp($minuendDateValue); |
|
| 176 | + $subtrahendDateSeconds = $this->timeCalculator->getTimestamp($subtrahendDateValue); |
|
| 177 | + if ($minuendDateSeconds < $subtrahendDateSeconds) { |
|
| 178 | 178 | // difference in the last year is actually less than one full year |
| 179 | 179 | // e. g. 1975-03-01 - 1974-09-01 is just six months |
| 180 | 180 | // (we don’t need sub-year precision in the difference, adjusting by 0.5 is enough) |
| 181 | 181 | $diff -= 0.5; |
| 182 | - } elseif ( $minuendDateSeconds > $subtrahendDateSeconds ) { |
|
| 182 | + } elseif ($minuendDateSeconds > $subtrahendDateSeconds) { |
|
| 183 | 183 | // difference in the last year is actually more than one full year |
| 184 | 184 | // e. g. 1975-09-01 - 1974-03-01 is 18 months |
| 185 | 185 | // (we don’t need sub-year precision in the difference, adjusting by 0.5 is enough) |
| 186 | 186 | $diff += 0.5; |
| 187 | 187 | } |
| 188 | 188 | |
| 189 | - $unit = $this->config->get( 'WBQualityConstraintsYearUnit' ); |
|
| 190 | - return UnboundedQuantityValue::newFromNumber( $diff, $unit ); |
|
| 189 | + $unit = $this->config->get('WBQualityConstraintsYearUnit'); |
|
| 190 | + return UnboundedQuantityValue::newFromNumber($diff, $unit); |
|
| 191 | 191 | } |
| 192 | 192 | |
| 193 | - public function isFutureTime( TimeValue $timeValue ) { |
|
| 194 | - return $this->timeValueComparer->isFutureTime( $timeValue ); |
|
| 193 | + public function isFutureTime(TimeValue $timeValue) { |
|
| 194 | + return $this->timeValueComparer->isFutureTime($timeValue); |
|
| 195 | 195 | } |
| 196 | 196 | |
| 197 | 197 | } |
@@ -80,23 +80,23 @@ discard block |
||
| 80 | 80 | * @return bool |
| 81 | 81 | * @throws OverflowException if $entitiesChecked exceeds the configured limit |
| 82 | 82 | */ |
| 83 | - private function isSubclassOf( EntityId $comparativeClass, array $classesToCheck, &$entitiesChecked = 0 ) { |
|
| 84 | - $maxEntities = $this->config->get( 'WBQualityConstraintsTypeCheckMaxEntities' ); |
|
| 83 | + private function isSubclassOf(EntityId $comparativeClass, array $classesToCheck, &$entitiesChecked = 0) { |
|
| 84 | + $maxEntities = $this->config->get('WBQualityConstraintsTypeCheckMaxEntities'); |
|
| 85 | 85 | if ( ++$entitiesChecked > $maxEntities ) { |
| 86 | - throw new OverflowException( 'Too many entities to check' ); |
|
| 86 | + throw new OverflowException('Too many entities to check'); |
|
| 87 | 87 | } |
| 88 | 88 | |
| 89 | - $item = $this->entityLookup->getEntity( $comparativeClass ); |
|
| 90 | - if ( !( $item instanceof StatementListProvider ) ) { |
|
| 89 | + $item = $this->entityLookup->getEntity($comparativeClass); |
|
| 90 | + if (!($item instanceof StatementListProvider)) { |
|
| 91 | 91 | return false; // lookup failed, probably because item doesn't exist |
| 92 | 92 | } |
| 93 | 93 | |
| 94 | - $subclassId = $this->config->get( 'WBQualityConstraintsSubclassOfId' ); |
|
| 94 | + $subclassId = $this->config->get('WBQualityConstraintsSubclassOfId'); |
|
| 95 | 95 | /** @var Statement $statement */ |
| 96 | - foreach ( $item->getStatements()->getByPropertyId( new PropertyId( $subclassId ) ) as $statement ) { |
|
| 96 | + foreach ($item->getStatements()->getByPropertyId(new PropertyId($subclassId)) as $statement) { |
|
| 97 | 97 | $mainSnak = $statement->getMainSnak(); |
| 98 | 98 | |
| 99 | - if ( !( $this->hasCorrectType( $mainSnak ) ) ) { |
|
| 99 | + if (!($this->hasCorrectType($mainSnak))) { |
|
| 100 | 100 | continue; |
| 101 | 101 | } |
| 102 | 102 | /** @var PropertyValueSnak $mainSnak */ |
@@ -106,11 +106,11 @@ discard block |
||
| 106 | 106 | '@phan-var EntityIdValue $dataValue'; |
| 107 | 107 | $comparativeClass = $dataValue->getEntityId(); |
| 108 | 108 | |
| 109 | - if ( in_array( $comparativeClass->getSerialization(), $classesToCheck ) ) { |
|
| 109 | + if (in_array($comparativeClass->getSerialization(), $classesToCheck)) { |
|
| 110 | 110 | return true; |
| 111 | 111 | } |
| 112 | 112 | |
| 113 | - if ( $this->isSubclassOf( $comparativeClass, $classesToCheck, $entitiesChecked ) ) { |
|
| 113 | + if ($this->isSubclassOf($comparativeClass, $classesToCheck, $entitiesChecked)) { |
|
| 114 | 114 | return true; |
| 115 | 115 | } |
| 116 | 116 | } |
@@ -131,48 +131,48 @@ discard block |
||
| 131 | 131 | * @return CachedBool |
| 132 | 132 | * @throws SparqlHelperException if SPARQL is used and the query times out or some other error occurs |
| 133 | 133 | */ |
| 134 | - public function isSubclassOfWithSparqlFallback( EntityId $comparativeClass, array $classesToCheck ) { |
|
| 134 | + public function isSubclassOfWithSparqlFallback(EntityId $comparativeClass, array $classesToCheck) { |
|
| 135 | 135 | try { |
| 136 | 136 | $entitiesChecked = 0; |
| 137 | - $start1 = microtime( true ); |
|
| 138 | - $isSubclass = $this->isSubclassOf( $comparativeClass, $classesToCheck, $entitiesChecked ); |
|
| 139 | - $end1 = microtime( true ); |
|
| 137 | + $start1 = microtime(true); |
|
| 138 | + $isSubclass = $this->isSubclassOf($comparativeClass, $classesToCheck, $entitiesChecked); |
|
| 139 | + $end1 = microtime(true); |
|
| 140 | 140 | $this->dataFactory->timing( |
| 141 | 141 | 'wikibase.quality.constraints.type.php.success.timing', |
| 142 | - ( $end1 - $start1 ) * 1000 |
|
| 142 | + ($end1 - $start1) * 1000 |
|
| 143 | 143 | ); |
| 144 | 144 | $this->dataFactory->timing( // not really a timing, but works like one (we want percentiles etc.) |
| 145 | 145 | 'wikibase.quality.constraints.type.php.success.entities', |
| 146 | 146 | $entitiesChecked |
| 147 | 147 | ); |
| 148 | 148 | |
| 149 | - return new CachedBool( $isSubclass, Metadata::blank() ); |
|
| 150 | - } catch ( OverflowException $e ) { |
|
| 151 | - $end1 = microtime( true ); |
|
| 149 | + return new CachedBool($isSubclass, Metadata::blank()); |
|
| 150 | + } catch (OverflowException $e) { |
|
| 151 | + $end1 = microtime(true); |
|
| 152 | 152 | $this->dataFactory->timing( |
| 153 | 153 | 'wikibase.quality.constraints.type.php.overflow.timing', |
| 154 | - ( $end1 - $start1 ) * 1000 |
|
| 154 | + ($end1 - $start1) * 1000 |
|
| 155 | 155 | ); |
| 156 | 156 | |
| 157 | - if ( !( $this->sparqlHelper instanceof DummySparqlHelper ) ) { |
|
| 157 | + if (!($this->sparqlHelper instanceof DummySparqlHelper)) { |
|
| 158 | 158 | $this->dataFactory->increment( |
| 159 | 159 | 'wikibase.quality.constraints.sparql.typeFallback' |
| 160 | 160 | ); |
| 161 | 161 | |
| 162 | - $start2 = microtime( true ); |
|
| 162 | + $start2 = microtime(true); |
|
| 163 | 163 | $hasType = $this->sparqlHelper->hasType( |
| 164 | 164 | $comparativeClass->getSerialization(), |
| 165 | 165 | $classesToCheck |
| 166 | 166 | ); |
| 167 | - $end2 = microtime( true ); |
|
| 167 | + $end2 = microtime(true); |
|
| 168 | 168 | $this->dataFactory->timing( |
| 169 | 169 | 'wikibase.quality.constraints.type.sparql.success.timing', |
| 170 | - ( $end2 - $start2 ) * 1000 |
|
| 170 | + ($end2 - $start2) * 1000 |
|
| 171 | 171 | ); |
| 172 | 172 | |
| 173 | 173 | return $hasType; |
| 174 | 174 | } else { |
| 175 | - return new CachedBool( false, Metadata::blank() ); |
|
| 175 | + return new CachedBool(false, Metadata::blank()); |
|
| 176 | 176 | } |
| 177 | 177 | } |
| 178 | 178 | } |
@@ -190,13 +190,13 @@ discard block |
||
| 190 | 190 | * @return CachedBool |
| 191 | 191 | * @throws SparqlHelperException if SPARQL is used and the query times out or some other error occurs |
| 192 | 192 | */ |
| 193 | - public function hasClassInRelation( StatementList $statements, array $relationIds, array $classesToCheck ) { |
|
| 193 | + public function hasClassInRelation(StatementList $statements, array $relationIds, array $classesToCheck) { |
|
| 194 | 194 | $metadatas = []; |
| 195 | 195 | |
| 196 | - foreach ( $this->getStatementsByPropertyIds( $statements, $relationIds ) as $statement ) { |
|
| 196 | + foreach ($this->getStatementsByPropertyIds($statements, $relationIds) as $statement) { |
|
| 197 | 197 | $mainSnak = $statement->getMainSnak(); |
| 198 | 198 | |
| 199 | - if ( !$this->hasCorrectType( $mainSnak ) ) { |
|
| 199 | + if (!$this->hasCorrectType($mainSnak)) { |
|
| 200 | 200 | continue; |
| 201 | 201 | } |
| 202 | 202 | /** @var PropertyValueSnak $mainSnak */ |
@@ -206,24 +206,24 @@ discard block |
||
| 206 | 206 | '@phan-var EntityIdValue $dataValue'; |
| 207 | 207 | $comparativeClass = $dataValue->getEntityId(); |
| 208 | 208 | |
| 209 | - if ( in_array( $comparativeClass->getSerialization(), $classesToCheck ) ) { |
|
| 209 | + if (in_array($comparativeClass->getSerialization(), $classesToCheck)) { |
|
| 210 | 210 | // discard $metadatas, we know this is fresh |
| 211 | - return new CachedBool( true, Metadata::blank() ); |
|
| 211 | + return new CachedBool(true, Metadata::blank()); |
|
| 212 | 212 | } |
| 213 | 213 | |
| 214 | - $result = $this->isSubclassOfWithSparqlFallback( $comparativeClass, $classesToCheck ); |
|
| 214 | + $result = $this->isSubclassOfWithSparqlFallback($comparativeClass, $classesToCheck); |
|
| 215 | 215 | $metadatas[] = $result->getMetadata(); |
| 216 | - if ( $result->getBool() ) { |
|
| 216 | + if ($result->getBool()) { |
|
| 217 | 217 | return new CachedBool( |
| 218 | 218 | true, |
| 219 | - Metadata::merge( $metadatas ) |
|
| 219 | + Metadata::merge($metadatas) |
|
| 220 | 220 | ); |
| 221 | 221 | } |
| 222 | 222 | } |
| 223 | 223 | |
| 224 | 224 | return new CachedBool( |
| 225 | 225 | false, |
| 226 | - Metadata::merge( $metadatas ) |
|
| 226 | + Metadata::merge($metadatas) |
|
| 227 | 227 | ); |
| 228 | 228 | } |
| 229 | 229 | |
@@ -232,7 +232,7 @@ discard block |
||
| 232 | 232 | * @return bool |
| 233 | 233 | * @phan-assert PropertyValueSnak $mainSnak |
| 234 | 234 | */ |
| 235 | - private function hasCorrectType( Snak $mainSnak ) { |
|
| 235 | + private function hasCorrectType(Snak $mainSnak) { |
|
| 236 | 236 | return $mainSnak instanceof PropertyValueSnak |
| 237 | 237 | && $mainSnak->getDataValue()->getType() === 'wikibase-entityid'; |
| 238 | 238 | } |
@@ -249,12 +249,12 @@ discard block |
||
| 249 | 249 | ) { |
| 250 | 250 | $statementArrays = []; |
| 251 | 251 | |
| 252 | - foreach ( $propertyIdSerializations as $propertyIdSerialization ) { |
|
| 253 | - $propertyId = new PropertyId( $propertyIdSerialization ); |
|
| 254 | - $statementArrays[] = $statements->getByPropertyId( $propertyId )->toArray(); |
|
| 252 | + foreach ($propertyIdSerializations as $propertyIdSerialization) { |
|
| 253 | + $propertyId = new PropertyId($propertyIdSerialization); |
|
| 254 | + $statementArrays[] = $statements->getByPropertyId($propertyId)->toArray(); |
|
| 255 | 255 | } |
| 256 | 256 | |
| 257 | - return call_user_func_array( 'array_merge', $statementArrays ); |
|
| 257 | + return call_user_func_array('array_merge', $statementArrays); |
|
| 258 | 258 | } |
| 259 | 259 | |
| 260 | 260 | /** |
@@ -266,10 +266,10 @@ discard block |
||
| 266 | 266 | * |
| 267 | 267 | * @return ViolationMessage |
| 268 | 268 | */ |
| 269 | - public function getViolationMessage( PropertyId $propertyId, EntityId $entityId, array $classes, $checker, $relation ) { |
|
| 269 | + public function getViolationMessage(PropertyId $propertyId, EntityId $entityId, array $classes, $checker, $relation) { |
|
| 270 | 270 | $classes = array_map( |
| 271 | - function( $itemIdSerialization ) { |
|
| 272 | - return new ItemId( $itemIdSerialization ); |
|
| 271 | + function($itemIdSerialization) { |
|
| 272 | + return new ItemId($itemIdSerialization); |
|
| 273 | 273 | }, |
| 274 | 274 | $classes |
| 275 | 275 | ); |
@@ -281,10 +281,10 @@ discard block |
||
| 281 | 281 | // wbqc-violation-message-valueType-instance |
| 282 | 282 | // wbqc-violation-message-valueType-subclass |
| 283 | 283 | // wbqc-violation-message-valueType-instanceOrSubclass |
| 284 | - return ( new ViolationMessage( 'wbqc-violation-message-' . $checker . '-' . $relation ) ) |
|
| 285 | - ->withEntityId( $propertyId, Role::CONSTRAINT_PROPERTY ) |
|
| 286 | - ->withEntityId( $entityId, Role::SUBJECT ) |
|
| 287 | - ->withEntityIdList( $classes, Role::OBJECT ); |
|
| 284 | + return (new ViolationMessage('wbqc-violation-message-'.$checker.'-'.$relation)) |
|
| 285 | + ->withEntityId($propertyId, Role::CONSTRAINT_PROPERTY) |
|
| 286 | + ->withEntityId($entityId, Role::SUBJECT) |
|
| 287 | + ->withEntityIdList($classes, Role::OBJECT); |
|
| 288 | 288 | } |
| 289 | 289 | |
| 290 | 290 | } |
@@ -13,8 +13,8 @@ discard block |
||
| 13 | 13 | * @param ContextCursor $cursor |
| 14 | 14 | * @return array |
| 15 | 15 | */ |
| 16 | - public function serialize( ContextCursor $cursor ) { |
|
| 17 | - if ( $cursor instanceof EntityContextCursor ) { |
|
| 16 | + public function serialize(ContextCursor $cursor) { |
|
| 17 | + if ($cursor instanceof EntityContextCursor) { |
|
| 18 | 18 | return [ |
| 19 | 19 | 't' => '\entity', |
| 20 | 20 | 'i' => $cursor->getEntityId(), |
@@ -30,9 +30,9 @@ discard block |
||
| 30 | 30 | 'h' => $cursor->getSnakHash(), |
| 31 | 31 | ]; |
| 32 | 32 | |
| 33 | - if ( $type === Context::TYPE_QUALIFIER || $type === Context::TYPE_REFERENCE ) { |
|
| 33 | + if ($type === Context::TYPE_QUALIFIER || $type === Context::TYPE_REFERENCE) { |
|
| 34 | 34 | $serialization['P'] = $cursor->getSnakPropertyId(); |
| 35 | - if ( $type === Context::TYPE_REFERENCE ) { |
|
| 35 | + if ($type === Context::TYPE_REFERENCE) { |
|
| 36 | 36 | /** @var ReferenceContextCursor $cursor */ |
| 37 | 37 | '@phan-var ReferenceContextCursor $cursor'; |
| 38 | 38 | $serialization['r'] = $cursor->getReferenceHash(); |
@@ -84,9 +84,9 @@ discard block |
||
| 84 | 84 | * @throws ConstraintParameterException |
| 85 | 85 | * @return CheckResult |
| 86 | 86 | */ |
| 87 | - public function checkConstraint( Context $context, Constraint $constraint ) { |
|
| 88 | - if ( $context->getSnakRank() === Statement::RANK_DEPRECATED ) { |
|
| 89 | - return new CheckResult( $context, $constraint, [], CheckResult::STATUS_DEPRECATED ); |
|
| 87 | + public function checkConstraint(Context $context, Constraint $constraint) { |
|
| 88 | + if ($context->getSnakRank() === Statement::RANK_DEPRECATED) { |
|
| 89 | + return new CheckResult($context, $constraint, [], CheckResult::STATUS_DEPRECATED); |
|
| 90 | 90 | } |
| 91 | 91 | |
| 92 | 92 | $parameters = []; |
@@ -94,28 +94,28 @@ discard block |
||
| 94 | 94 | |
| 95 | 95 | $snak = $context->getSnak(); |
| 96 | 96 | |
| 97 | - if ( !$snak instanceof PropertyValueSnak ) { |
|
| 97 | + if (!$snak instanceof PropertyValueSnak) { |
|
| 98 | 98 | // nothing to check |
| 99 | - return new CheckResult( $context, $constraint, $parameters, CheckResult::STATUS_COMPLIANCE ); |
|
| 99 | + return new CheckResult($context, $constraint, $parameters, CheckResult::STATUS_COMPLIANCE); |
|
| 100 | 100 | } |
| 101 | 101 | |
| 102 | 102 | $dataValue = $snak->getDataValue(); |
| 103 | 103 | |
| 104 | - list( $min, $max ) = $this->parseRangeParameter( |
|
| 104 | + list($min, $max) = $this->parseRangeParameter( |
|
| 105 | 105 | $constraintParameters, |
| 106 | 106 | $constraint->getConstraintTypeItemId(), |
| 107 | 107 | $dataValue->getType() |
| 108 | 108 | ); |
| 109 | 109 | $parameterKey = $dataValue->getType() === 'quantity' ? 'quantity' : 'date'; |
| 110 | - if ( $min !== null ) { |
|
| 111 | - $parameters['minimum_' . $parameterKey] = [ $min ]; |
|
| 110 | + if ($min !== null) { |
|
| 111 | + $parameters['minimum_'.$parameterKey] = [$min]; |
|
| 112 | 112 | } |
| 113 | - if ( $max !== null ) { |
|
| 114 | - $parameters['maximum_' . $parameterKey] = [ $max ]; |
|
| 113 | + if ($max !== null) { |
|
| 114 | + $parameters['maximum_'.$parameterKey] = [$max]; |
|
| 115 | 115 | } |
| 116 | 116 | |
| 117 | - if ( $this->rangeCheckerHelper->getComparison( $min, $dataValue ) > 0 || |
|
| 118 | - $this->rangeCheckerHelper->getComparison( $dataValue, $max ) > 0 |
|
| 117 | + if ($this->rangeCheckerHelper->getComparison($min, $dataValue) > 0 || |
|
| 118 | + $this->rangeCheckerHelper->getComparison($dataValue, $max) > 0 |
|
| 119 | 119 | ) { |
| 120 | 120 | $message = $this->getViolationMessage( |
| 121 | 121 | $context->getSnak()->getPropertyId(), |
@@ -131,16 +131,16 @@ discard block |
||
| 131 | 131 | |
| 132 | 132 | if ( |
| 133 | 133 | $dataValue instanceof TimeValue && |
| 134 | - ( $min instanceof NowValue || $max instanceof NowValue ) && |
|
| 135 | - $this->rangeCheckerHelper->isFutureTime( $dataValue ) |
|
| 134 | + ($min instanceof NowValue || $max instanceof NowValue) && |
|
| 135 | + $this->rangeCheckerHelper->isFutureTime($dataValue) |
|
| 136 | 136 | ) { |
| 137 | - $dependencyMetadata = DependencyMetadata::ofFutureTime( $dataValue ); |
|
| 137 | + $dependencyMetadata = DependencyMetadata::ofFutureTime($dataValue); |
|
| 138 | 138 | } else { |
| 139 | 139 | $dependencyMetadata = DependencyMetadata::blank(); |
| 140 | 140 | } |
| 141 | 141 | |
| 142 | - return ( new CheckResult( $context, $constraint, $parameters, $status, $message ) ) |
|
| 143 | - ->withMetadata( Metadata::ofDependencyMetadata( $dependencyMetadata ) ); |
|
| 142 | + return (new CheckResult($context, $constraint, $parameters, $status, $message)) |
|
| 143 | + ->withMetadata(Metadata::ofDependencyMetadata($dependencyMetadata)); |
|
| 144 | 144 | } |
| 145 | 145 | |
| 146 | 146 | /** |
@@ -151,8 +151,8 @@ discard block |
||
| 151 | 151 | * @throws ConstraintParameterException if the parameter is invalid or missing |
| 152 | 152 | * @return DataValue[] a pair of two data values, either of which may be null to signify an open range |
| 153 | 153 | */ |
| 154 | - private function parseRangeParameter( array $constraintParameters, $constraintTypeItemId, $type ) { |
|
| 155 | - switch ( $type ) { |
|
| 154 | + private function parseRangeParameter(array $constraintParameters, $constraintTypeItemId, $type) { |
|
| 155 | + switch ($type) { |
|
| 156 | 156 | case 'quantity': |
| 157 | 157 | return $this->constraintParameterParser->parseQuantityRangeParameter( |
| 158 | 158 | $constraintParameters, |
@@ -166,10 +166,10 @@ discard block |
||
| 166 | 166 | } |
| 167 | 167 | |
| 168 | 168 | throw new ConstraintParameterException( |
| 169 | - ( new ViolationMessage( 'wbqc-violation-message-value-needed-of-types-2' ) ) |
|
| 170 | - ->withEntityId( new ItemId( $constraintTypeItemId ), Role::CONSTRAINT_TYPE_ITEM ) |
|
| 171 | - ->withDataValueType( 'quantity' ) |
|
| 172 | - ->withDataValueType( 'time' ) |
|
| 169 | + (new ViolationMessage('wbqc-violation-message-value-needed-of-types-2')) |
|
| 170 | + ->withEntityId(new ItemId($constraintTypeItemId), Role::CONSTRAINT_TYPE_ITEM) |
|
| 171 | + ->withDataValueType('quantity') |
|
| 172 | + ->withDataValueType('time') |
|
| 173 | 173 | ); |
| 174 | 174 | } |
| 175 | 175 | |
@@ -181,7 +181,7 @@ discard block |
||
| 181 | 181 | * |
| 182 | 182 | * @return ViolationMessage |
| 183 | 183 | */ |
| 184 | - private function getViolationMessage( PropertyId $predicate, DataValue $value, $min, $max ) { |
|
| 184 | + private function getViolationMessage(PropertyId $predicate, DataValue $value, $min, $max) { |
|
| 185 | 185 | // possible message keys: |
| 186 | 186 | // wbqc-violation-message-range-quantity-closed |
| 187 | 187 | // wbqc-violation-message-range-quantity-leftopen |
@@ -194,39 +194,39 @@ discard block |
||
| 194 | 194 | // wbqc-violation-message-range-time-rightopen |
| 195 | 195 | // wbqc-violation-message-range-time-rightopen-leftnow |
| 196 | 196 | $messageKey = 'wbqc-violation-message-range'; |
| 197 | - $messageKey .= '-' . $value->getType(); |
|
| 197 | + $messageKey .= '-'.$value->getType(); |
|
| 198 | 198 | // at least one of $min, $max is set, otherwise there could be no violation |
| 199 | - $messageKey .= '-' . ( $min !== null ? ( $max !== null ? 'closed' : 'rightopen' ) : 'leftopen' ); |
|
| 200 | - if ( $min instanceof NowValue ) { |
|
| 199 | + $messageKey .= '-'.($min !== null ? ($max !== null ? 'closed' : 'rightopen') : 'leftopen'); |
|
| 200 | + if ($min instanceof NowValue) { |
|
| 201 | 201 | $messageKey .= '-leftnow'; |
| 202 | - } elseif ( $max instanceof NowValue ) { |
|
| 202 | + } elseif ($max instanceof NowValue) { |
|
| 203 | 203 | $messageKey .= '-rightnow'; |
| 204 | 204 | } |
| 205 | - $message = ( new ViolationMessage( $messageKey ) ) |
|
| 206 | - ->withEntityId( $predicate, Role::PREDICATE ) |
|
| 207 | - ->withDataValue( $value, Role::OBJECT ); |
|
| 208 | - if ( $min !== null && !( $min instanceof NowValue ) ) { |
|
| 209 | - $message = $message->withDataValue( $min, Role::OBJECT ); |
|
| 205 | + $message = (new ViolationMessage($messageKey)) |
|
| 206 | + ->withEntityId($predicate, Role::PREDICATE) |
|
| 207 | + ->withDataValue($value, Role::OBJECT); |
|
| 208 | + if ($min !== null && !($min instanceof NowValue)) { |
|
| 209 | + $message = $message->withDataValue($min, Role::OBJECT); |
|
| 210 | 210 | } |
| 211 | - if ( $max !== null && !( $max instanceof NowValue ) ) { |
|
| 212 | - $message = $message->withDataValue( $max, Role::OBJECT ); |
|
| 211 | + if ($max !== null && !($max instanceof NowValue)) { |
|
| 212 | + $message = $message->withDataValue($max, Role::OBJECT); |
|
| 213 | 213 | } |
| 214 | 214 | return $message; |
| 215 | 215 | } |
| 216 | 216 | |
| 217 | - public function checkConstraintParameters( Constraint $constraint ) { |
|
| 217 | + public function checkConstraintParameters(Constraint $constraint) { |
|
| 218 | 218 | $constraintParameters = $constraint->getConstraintParameters(); |
| 219 | 219 | $exceptions = []; |
| 220 | 220 | try { |
| 221 | 221 | // we don’t have a data value here, so get the type from the property instead |
| 222 | 222 | // (the distinction between data type and data value type is irrelevant for 'quantity' and 'time') |
| 223 | - $type = $this->propertyDataTypeLookup->getDataTypeIdForProperty( $constraint->getPropertyId() ); |
|
| 223 | + $type = $this->propertyDataTypeLookup->getDataTypeIdForProperty($constraint->getPropertyId()); |
|
| 224 | 224 | $this->parseRangeParameter( |
| 225 | 225 | $constraintParameters, |
| 226 | 226 | $constraint->getConstraintTypeItemId(), |
| 227 | 227 | $type |
| 228 | 228 | ); |
| 229 | - } catch ( ConstraintParameterException $e ) { |
|
| 229 | + } catch (ConstraintParameterException $e) { |
|
| 230 | 230 | $exceptions[] = $e; |
| 231 | 231 | } |
| 232 | 232 | return $exceptions; |
@@ -162,58 +162,58 @@ discard block |
||
| 162 | 162 | $this->defaultUserAgent = $defaultUserAgent; |
| 163 | 163 | $this->requestFactory = $requestFactory; |
| 164 | 164 | $this->entityPrefixes = []; |
| 165 | - foreach ( $rdfVocabulary->entityNamespaceNames as $namespaceName ) { |
|
| 166 | - $this->entityPrefixes[] = $rdfVocabulary->getNamespaceURI( $namespaceName ); |
|
| 165 | + foreach ($rdfVocabulary->entityNamespaceNames as $namespaceName) { |
|
| 166 | + $this->entityPrefixes[] = $rdfVocabulary->getNamespaceURI($namespaceName); |
|
| 167 | 167 | } |
| 168 | 168 | |
| 169 | - $this->prefixes = $this->getQueryPrefixes( $rdfVocabulary ); |
|
| 169 | + $this->prefixes = $this->getQueryPrefixes($rdfVocabulary); |
|
| 170 | 170 | } |
| 171 | 171 | |
| 172 | - private function getQueryPrefixes( RdfVocabulary $rdfVocabulary ) { |
|
| 172 | + private function getQueryPrefixes(RdfVocabulary $rdfVocabulary) { |
|
| 173 | 173 | // TODO: it would probably be smarter that RdfVocubulary exposed these prefixes somehow |
| 174 | 174 | $prefixes = ''; |
| 175 | - foreach ( $rdfVocabulary->entityNamespaceNames as $sourceName => $namespaceName ) { |
|
| 175 | + foreach ($rdfVocabulary->entityNamespaceNames as $sourceName => $namespaceName) { |
|
| 176 | 176 | $prefixes .= <<<END |
| 177 | -PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n |
|
| 177 | +PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n |
|
| 178 | 178 | END; |
| 179 | 179 | } |
| 180 | 180 | $prefixes .= <<<END |
| 181 | -PREFIX wds: <{$rdfVocabulary->getNamespaceURI( RdfVocabulary::NS_STATEMENT )}> |
|
| 182 | -PREFIX wdv: <{$rdfVocabulary->getNamespaceURI( RdfVocabulary::NS_VALUE )}>\n |
|
| 181 | +PREFIX wds: <{$rdfVocabulary->getNamespaceURI(RdfVocabulary::NS_STATEMENT)}> |
|
| 182 | +PREFIX wdv: <{$rdfVocabulary->getNamespaceURI(RdfVocabulary::NS_VALUE)}>\n |
|
| 183 | 183 | END; |
| 184 | 184 | |
| 185 | - foreach ( $rdfVocabulary->propertyNamespaceNames as $sourceName => $sourceNamespaces ) { |
|
| 185 | + foreach ($rdfVocabulary->propertyNamespaceNames as $sourceName => $sourceNamespaces) { |
|
| 186 | 186 | $namespaceName = $sourceNamespaces[RdfVocabulary::NSP_DIRECT_CLAIM]; |
| 187 | 187 | $prefixes .= <<<END |
| 188 | -PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n |
|
| 188 | +PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n |
|
| 189 | 189 | END; |
| 190 | 190 | $namespaceName = $sourceNamespaces[RdfVocabulary::NSP_CLAIM]; |
| 191 | 191 | $prefixes .= <<<END |
| 192 | -PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n |
|
| 192 | +PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n |
|
| 193 | 193 | END; |
| 194 | 194 | $namespaceName = $sourceNamespaces[RdfVocabulary::NSP_CLAIM_STATEMENT]; |
| 195 | 195 | $prefixes .= <<<END |
| 196 | -PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n |
|
| 196 | +PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n |
|
| 197 | 197 | END; |
| 198 | 198 | $namespaceName = $sourceNamespaces[RdfVocabulary::NSP_QUALIFIER]; |
| 199 | 199 | $prefixes .= <<<END |
| 200 | -PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n |
|
| 200 | +PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n |
|
| 201 | 201 | END; |
| 202 | 202 | $namespaceName = $sourceNamespaces[RdfVocabulary::NSP_QUALIFIER_VALUE]; |
| 203 | 203 | $prefixes .= <<<END |
| 204 | -PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n |
|
| 204 | +PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n |
|
| 205 | 205 | END; |
| 206 | 206 | $namespaceName = $sourceNamespaces[RdfVocabulary::NSP_REFERENCE]; |
| 207 | 207 | $prefixes .= <<<END |
| 208 | -PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n |
|
| 208 | +PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n |
|
| 209 | 209 | END; |
| 210 | 210 | $namespaceName = $sourceNamespaces[RdfVocabulary::NSP_REFERENCE_VALUE]; |
| 211 | 211 | $prefixes .= <<<END |
| 212 | -PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI( $namespaceName )}>\n |
|
| 212 | +PREFIX {$namespaceName}: <{$rdfVocabulary->getNamespaceURI($namespaceName)}>\n |
|
| 213 | 213 | END; |
| 214 | 214 | } |
| 215 | 215 | $prefixes .= <<<END |
| 216 | -PREFIX wikibase: <{$rdfVocabulary->getNamespaceURI( RdfVocabulary::NS_ONTOLOGY )}>\n |
|
| 216 | +PREFIX wikibase: <{$rdfVocabulary->getNamespaceURI(RdfVocabulary::NS_ONTOLOGY)}>\n |
|
| 217 | 217 | END; |
| 218 | 218 | return $prefixes; |
| 219 | 219 | } |
@@ -225,22 +225,21 @@ discard block |
||
| 225 | 225 | * @return CachedBool |
| 226 | 226 | * @throws SparqlHelperException if the query times out or some other error occurs |
| 227 | 227 | */ |
| 228 | - public function hasType( $id, array $classes ) { |
|
| 229 | - $subclassOfId = $this->config->get( 'WBQualityConstraintsSubclassOfId' ); |
|
| 228 | + public function hasType($id, array $classes) { |
|
| 229 | + $subclassOfId = $this->config->get('WBQualityConstraintsSubclassOfId'); |
|
| 230 | 230 | // TODO hint:gearing is a workaround for T168973 and can hopefully be removed eventually |
| 231 | - $gearingHint = $this->config->get( 'WBQualityConstraintsSparqlHasWikibaseSupport' ) ? |
|
| 232 | - ' hint:Prior hint:gearing "forward".' : |
|
| 233 | - ''; |
|
| 231 | + $gearingHint = $this->config->get('WBQualityConstraintsSparqlHasWikibaseSupport') ? |
|
| 232 | + ' hint:Prior hint:gearing "forward".' : ''; |
|
| 234 | 233 | |
| 235 | 234 | $metadatas = []; |
| 236 | 235 | |
| 237 | - foreach ( array_chunk( $classes, 20 ) as $classesChunk ) { |
|
| 238 | - $classesValues = implode( ' ', array_map( |
|
| 239 | - function( $class ) { |
|
| 240 | - return 'wd:' . $class; |
|
| 236 | + foreach (array_chunk($classes, 20) as $classesChunk) { |
|
| 237 | + $classesValues = implode(' ', array_map( |
|
| 238 | + function($class) { |
|
| 239 | + return 'wd:'.$class; |
|
| 241 | 240 | }, |
| 242 | 241 | $classesChunk |
| 243 | - ) ); |
|
| 242 | + )); |
|
| 244 | 243 | |
| 245 | 244 | $query = <<<EOF |
| 246 | 245 | ASK { |
@@ -250,19 +249,19 @@ discard block |
||
| 250 | 249 | } |
| 251 | 250 | EOF; |
| 252 | 251 | |
| 253 | - $result = $this->runQuery( $query ); |
|
| 252 | + $result = $this->runQuery($query); |
|
| 254 | 253 | $metadatas[] = $result->getMetadata(); |
| 255 | - if ( $result->getArray()['boolean'] ) { |
|
| 254 | + if ($result->getArray()['boolean']) { |
|
| 256 | 255 | return new CachedBool( |
| 257 | 256 | true, |
| 258 | - Metadata::merge( $metadatas ) |
|
| 257 | + Metadata::merge($metadatas) |
|
| 259 | 258 | ); |
| 260 | 259 | } |
| 261 | 260 | } |
| 262 | 261 | |
| 263 | 262 | return new CachedBool( |
| 264 | 263 | false, |
| 265 | - Metadata::merge( $metadatas ) |
|
| 264 | + Metadata::merge($metadatas) |
|
| 266 | 265 | ); |
| 267 | 266 | } |
| 268 | 267 | |
@@ -278,10 +277,10 @@ discard block |
||
| 278 | 277 | $ignoreDeprecatedStatements |
| 279 | 278 | ) { |
| 280 | 279 | $pid = $statement->getPropertyId()->serialize(); |
| 281 | - $guid = str_replace( '$', '-', $statement->getGuid() ); |
|
| 280 | + $guid = str_replace('$', '-', $statement->getGuid()); |
|
| 282 | 281 | |
| 283 | 282 | $deprecatedFilter = ''; |
| 284 | - if ( $ignoreDeprecatedStatements ) { |
|
| 283 | + if ($ignoreDeprecatedStatements) { |
|
| 285 | 284 | $deprecatedFilter = 'MINUS { ?otherStatement wikibase:rank wikibase:DeprecatedRank. }'; |
| 286 | 285 | } |
| 287 | 286 | |
@@ -300,9 +299,9 @@ discard block |
||
| 300 | 299 | LIMIT 10 |
| 301 | 300 | EOF; |
| 302 | 301 | |
| 303 | - $result = $this->runQuery( $query ); |
|
| 302 | + $result = $this->runQuery($query); |
|
| 304 | 303 | |
| 305 | - return $this->getOtherEntities( $result ); |
|
| 304 | + return $this->getOtherEntities($result); |
|
| 306 | 305 | } |
| 307 | 306 | |
| 308 | 307 | /** |
@@ -327,16 +326,15 @@ discard block |
||
| 327 | 326 | $dataType = $this->propertyDataTypeLookup->getDataTypeIdForProperty( |
| 328 | 327 | $snak->getPropertyId() |
| 329 | 328 | ); |
| 330 | - list( $value, $isFullValue ) = $this->getRdfLiteral( $dataType, $dataValue ); |
|
| 331 | - if ( $isFullValue ) { |
|
| 329 | + list($value, $isFullValue) = $this->getRdfLiteral($dataType, $dataValue); |
|
| 330 | + if ($isFullValue) { |
|
| 332 | 331 | $prefix .= 'v'; |
| 333 | 332 | } |
| 334 | 333 | $path = $type === Context::TYPE_QUALIFIER ? |
| 335 | - "$prefix:$pid" : |
|
| 336 | - "prov:wasDerivedFrom/$prefix:$pid"; |
|
| 334 | + "$prefix:$pid" : "prov:wasDerivedFrom/$prefix:$pid"; |
|
| 337 | 335 | |
| 338 | 336 | $deprecatedFilter = ''; |
| 339 | - if ( $ignoreDeprecatedStatements ) { |
|
| 337 | + if ($ignoreDeprecatedStatements) { |
|
| 340 | 338 | $deprecatedFilter = <<< EOF |
| 341 | 339 | MINUS { ?otherStatement wikibase:rank wikibase:DeprecatedRank. } |
| 342 | 340 | EOF; |
@@ -356,9 +354,9 @@ discard block |
||
| 356 | 354 | LIMIT 10 |
| 357 | 355 | EOF; |
| 358 | 356 | |
| 359 | - $result = $this->runQuery( $query ); |
|
| 357 | + $result = $this->runQuery($query); |
|
| 360 | 358 | |
| 361 | - return $this->getOtherEntities( $result ); |
|
| 359 | + return $this->getOtherEntities($result); |
|
| 362 | 360 | } |
| 363 | 361 | |
| 364 | 362 | /** |
@@ -368,8 +366,8 @@ discard block |
||
| 368 | 366 | * |
| 369 | 367 | * @return string |
| 370 | 368 | */ |
| 371 | - private function stringLiteral( $text ) { |
|
| 372 | - return '"' . strtr( $text, [ '"' => '\\"', '\\' => '\\\\' ] ) . '"'; |
|
| 369 | + private function stringLiteral($text) { |
|
| 370 | + return '"'.strtr($text, ['"' => '\\"', '\\' => '\\\\']).'"'; |
|
| 373 | 371 | } |
| 374 | 372 | |
| 375 | 373 | /** |
@@ -379,18 +377,18 @@ discard block |
||
| 379 | 377 | * |
| 380 | 378 | * @return CachedEntityIds |
| 381 | 379 | */ |
| 382 | - private function getOtherEntities( CachedQueryResults $results ) { |
|
| 383 | - return new CachedEntityIds( array_map( |
|
| 384 | - function ( $resultBindings ) { |
|
| 380 | + private function getOtherEntities(CachedQueryResults $results) { |
|
| 381 | + return new CachedEntityIds(array_map( |
|
| 382 | + function($resultBindings) { |
|
| 385 | 383 | $entityIRI = $resultBindings['otherEntity']['value']; |
| 386 | - foreach ( $this->entityPrefixes as $entityPrefix ) { |
|
| 387 | - $entityPrefixLength = strlen( $entityPrefix ); |
|
| 388 | - if ( substr( $entityIRI, 0, $entityPrefixLength ) === $entityPrefix ) { |
|
| 384 | + foreach ($this->entityPrefixes as $entityPrefix) { |
|
| 385 | + $entityPrefixLength = strlen($entityPrefix); |
|
| 386 | + if (substr($entityIRI, 0, $entityPrefixLength) === $entityPrefix) { |
|
| 389 | 387 | try { |
| 390 | 388 | return $this->entityIdParser->parse( |
| 391 | - substr( $entityIRI, $entityPrefixLength ) |
|
| 389 | + substr($entityIRI, $entityPrefixLength) |
|
| 392 | 390 | ); |
| 393 | - } catch ( EntityIdParsingException $e ) { |
|
| 391 | + } catch (EntityIdParsingException $e) { |
|
| 394 | 392 | // fall through |
| 395 | 393 | } |
| 396 | 394 | } |
@@ -401,7 +399,7 @@ discard block |
||
| 401 | 399 | return null; |
| 402 | 400 | }, |
| 403 | 401 | $results->getArray()['results']['bindings'] |
| 404 | - ), $results->getMetadata() ); |
|
| 402 | + ), $results->getMetadata()); |
|
| 405 | 403 | } |
| 406 | 404 | |
| 407 | 405 | // @codingStandardsIgnoreStart cyclomatic complexity of this function is too high |
@@ -414,49 +412,49 @@ discard block |
||
| 414 | 412 | * @return array the literal or IRI as a string in SPARQL syntax, |
| 415 | 413 | * and a boolean indicating whether it refers to a full value node or not |
| 416 | 414 | */ |
| 417 | - private function getRdfLiteral( $dataType, DataValue $dataValue ) { |
|
| 418 | - switch ( $dataType ) { |
|
| 415 | + private function getRdfLiteral($dataType, DataValue $dataValue) { |
|
| 416 | + switch ($dataType) { |
|
| 419 | 417 | case 'string': |
| 420 | 418 | case 'external-id': |
| 421 | - return [ $this->stringLiteral( $dataValue->getValue() ), false ]; |
|
| 419 | + return [$this->stringLiteral($dataValue->getValue()), false]; |
|
| 422 | 420 | case 'commonsMedia': |
| 423 | - $url = $this->rdfVocabulary->getMediaFileURI( $dataValue->getValue() ); |
|
| 424 | - return [ '<' . $url . '>', false ]; |
|
| 421 | + $url = $this->rdfVocabulary->getMediaFileURI($dataValue->getValue()); |
|
| 422 | + return ['<'.$url.'>', false]; |
|
| 425 | 423 | case 'geo-shape': |
| 426 | - $url = $this->rdfVocabulary->getGeoShapeURI( $dataValue->getValue() ); |
|
| 427 | - return [ '<' . $url . '>', false ]; |
|
| 424 | + $url = $this->rdfVocabulary->getGeoShapeURI($dataValue->getValue()); |
|
| 425 | + return ['<'.$url.'>', false]; |
|
| 428 | 426 | case 'tabular-data': |
| 429 | - $url = $this->rdfVocabulary->getTabularDataURI( $dataValue->getValue() ); |
|
| 430 | - return [ '<' . $url . '>', false ]; |
|
| 427 | + $url = $this->rdfVocabulary->getTabularDataURI($dataValue->getValue()); |
|
| 428 | + return ['<'.$url.'>', false]; |
|
| 431 | 429 | case 'url': |
| 432 | 430 | $url = $dataValue->getValue(); |
| 433 | - if ( !preg_match( '/^[^<>"{}\\\\|^`\\x00-\\x20]*$/D', $url ) ) { |
|
| 431 | + if (!preg_match('/^[^<>"{}\\\\|^`\\x00-\\x20]*$/D', $url)) { |
|
| 434 | 432 | // not a valid URL for SPARQL (see SPARQL spec, production 139 IRIREF) |
| 435 | 433 | // such an URL should never reach us, so just throw |
| 436 | - throw new InvalidArgumentException( 'invalid URL: ' . $url ); |
|
| 434 | + throw new InvalidArgumentException('invalid URL: '.$url); |
|
| 437 | 435 | } |
| 438 | - return [ '<' . $url . '>', false ]; |
|
| 436 | + return ['<'.$url.'>', false]; |
|
| 439 | 437 | case 'wikibase-item': |
| 440 | 438 | case 'wikibase-property': |
| 441 | 439 | /** @var EntityIdValue $dataValue */ |
| 442 | 440 | '@phan-var EntityIdValue $dataValue'; |
| 443 | - return [ 'wd:' . $dataValue->getEntityId()->getSerialization(), false ]; |
|
| 441 | + return ['wd:'.$dataValue->getEntityId()->getSerialization(), false]; |
|
| 444 | 442 | case 'monolingualtext': |
| 445 | 443 | /** @var MonolingualTextValue $dataValue */ |
| 446 | 444 | '@phan-var MonolingualTextValue $dataValue'; |
| 447 | 445 | $lang = $dataValue->getLanguageCode(); |
| 448 | - if ( !preg_match( '/^[a-zA-Z]+(-[a-zA-Z0-9]+)*$/D', $lang ) ) { |
|
| 446 | + if (!preg_match('/^[a-zA-Z]+(-[a-zA-Z0-9]+)*$/D', $lang)) { |
|
| 449 | 447 | // not a valid language tag for SPARQL (see SPARQL spec, production 145 LANGTAG) |
| 450 | 448 | // such a language tag should never reach us, so just throw |
| 451 | - throw new InvalidArgumentException( 'invalid language tag: ' . $lang ); |
|
| 449 | + throw new InvalidArgumentException('invalid language tag: '.$lang); |
|
| 452 | 450 | } |
| 453 | - return [ $this->stringLiteral( $dataValue->getText() ) . '@' . $lang, false ]; |
|
| 451 | + return [$this->stringLiteral($dataValue->getText()).'@'.$lang, false]; |
|
| 454 | 452 | case 'globe-coordinate': |
| 455 | 453 | case 'quantity': |
| 456 | 454 | case 'time': |
| 457 | - return [ 'wdv:' . $dataValue->getHash(), true ]; |
|
| 455 | + return ['wdv:'.$dataValue->getHash(), true]; |
|
| 458 | 456 | default: |
| 459 | - throw new InvalidArgumentException( 'unknown data type: ' . $dataType ); |
|
| 457 | + throw new InvalidArgumentException('unknown data type: '.$dataType); |
|
| 460 | 458 | } |
| 461 | 459 | } |
| 462 | 460 | // @codingStandardsIgnoreEnd |
@@ -469,44 +467,44 @@ discard block |
||
| 469 | 467 | * @throws SparqlHelperException if the query times out or some other error occurs |
| 470 | 468 | * @throws ConstraintParameterException if the $regex is invalid |
| 471 | 469 | */ |
| 472 | - public function matchesRegularExpression( $text, $regex ) { |
|
| 470 | + public function matchesRegularExpression($text, $regex) { |
|
| 473 | 471 | // caching wrapper around matchesRegularExpressionWithSparql |
| 474 | 472 | |
| 475 | - $textHash = hash( 'sha256', $text ); |
|
| 473 | + $textHash = hash('sha256', $text); |
|
| 476 | 474 | $cacheKey = $this->cache->makeKey( |
| 477 | 475 | 'WikibaseQualityConstraints', // extension |
| 478 | 476 | 'regex', // action |
| 479 | 477 | 'WDQS-Java', // regex flavor |
| 480 | - hash( 'sha256', $regex ) |
|
| 478 | + hash('sha256', $regex) |
|
| 481 | 479 | ); |
| 482 | - $cacheMapSize = $this->config->get( 'WBQualityConstraintsFormatCacheMapSize' ); |
|
| 480 | + $cacheMapSize = $this->config->get('WBQualityConstraintsFormatCacheMapSize'); |
|
| 483 | 481 | |
| 484 | 482 | $cacheMapArray = $this->cache->getWithSetCallback( |
| 485 | 483 | $cacheKey, |
| 486 | 484 | WANObjectCache::TTL_DAY, |
| 487 | - function( $cacheMapArray ) use ( $text, $regex, $textHash, $cacheMapSize ) { |
|
| 485 | + function($cacheMapArray) use ($text, $regex, $textHash, $cacheMapSize) { |
|
| 488 | 486 | // Initialize the cache map if not set |
| 489 | - if ( $cacheMapArray === false ) { |
|
| 487 | + if ($cacheMapArray === false) { |
|
| 490 | 488 | $key = 'wikibase.quality.constraints.regex.cache.refresh.init'; |
| 491 | - $this->dataFactory->increment( $key ); |
|
| 489 | + $this->dataFactory->increment($key); |
|
| 492 | 490 | return []; |
| 493 | 491 | } |
| 494 | 492 | |
| 495 | 493 | $key = 'wikibase.quality.constraints.regex.cache.refresh'; |
| 496 | - $this->dataFactory->increment( $key ); |
|
| 497 | - $cacheMap = MapCacheLRU::newFromArray( $cacheMapArray, $cacheMapSize ); |
|
| 498 | - if ( $cacheMap->has( $textHash ) ) { |
|
| 494 | + $this->dataFactory->increment($key); |
|
| 495 | + $cacheMap = MapCacheLRU::newFromArray($cacheMapArray, $cacheMapSize); |
|
| 496 | + if ($cacheMap->has($textHash)) { |
|
| 499 | 497 | $key = 'wikibase.quality.constraints.regex.cache.refresh.hit'; |
| 500 | - $this->dataFactory->increment( $key ); |
|
| 501 | - $cacheMap->get( $textHash ); // ping cache |
|
| 498 | + $this->dataFactory->increment($key); |
|
| 499 | + $cacheMap->get($textHash); // ping cache |
|
| 502 | 500 | } else { |
| 503 | 501 | $key = 'wikibase.quality.constraints.regex.cache.refresh.miss'; |
| 504 | - $this->dataFactory->increment( $key ); |
|
| 502 | + $this->dataFactory->increment($key); |
|
| 505 | 503 | try { |
| 506 | - $matches = $this->matchesRegularExpressionWithSparql( $text, $regex ); |
|
| 507 | - } catch ( ConstraintParameterException $e ) { |
|
| 508 | - $matches = $this->serializeConstraintParameterException( $e ); |
|
| 509 | - } catch ( SparqlHelperException $e ) { |
|
| 504 | + $matches = $this->matchesRegularExpressionWithSparql($text, $regex); |
|
| 505 | + } catch (ConstraintParameterException $e) { |
|
| 506 | + $matches = $this->serializeConstraintParameterException($e); |
|
| 507 | + } catch (SparqlHelperException $e) { |
|
| 510 | 508 | // don’t cache this |
| 511 | 509 | return $cacheMap->toArray(); |
| 512 | 510 | } |
@@ -530,42 +528,42 @@ discard block |
||
| 530 | 528 | ] |
| 531 | 529 | ); |
| 532 | 530 | |
| 533 | - if ( isset( $cacheMapArray[$textHash] ) ) { |
|
| 531 | + if (isset($cacheMapArray[$textHash])) { |
|
| 534 | 532 | $key = 'wikibase.quality.constraints.regex.cache.hit'; |
| 535 | - $this->dataFactory->increment( $key ); |
|
| 533 | + $this->dataFactory->increment($key); |
|
| 536 | 534 | $matches = $cacheMapArray[$textHash]; |
| 537 | - if ( is_bool( $matches ) ) { |
|
| 535 | + if (is_bool($matches)) { |
|
| 538 | 536 | return $matches; |
| 539 | - } elseif ( is_array( $matches ) && |
|
| 540 | - $matches['type'] == ConstraintParameterException::class ) { |
|
| 541 | - throw $this->deserializeConstraintParameterException( $matches ); |
|
| 537 | + } elseif (is_array($matches) && |
|
| 538 | + $matches['type'] == ConstraintParameterException::class) { |
|
| 539 | + throw $this->deserializeConstraintParameterException($matches); |
|
| 542 | 540 | } else { |
| 543 | 541 | throw new MWException( |
| 544 | - 'Value of unknown type in object cache (' . |
|
| 545 | - 'cache key: ' . $cacheKey . ', ' . |
|
| 546 | - 'cache map key: ' . $textHash . ', ' . |
|
| 547 | - 'value type: ' . gettype( $matches ) . ')' |
|
| 542 | + 'Value of unknown type in object cache ('. |
|
| 543 | + 'cache key: '.$cacheKey.', '. |
|
| 544 | + 'cache map key: '.$textHash.', '. |
|
| 545 | + 'value type: '.gettype($matches).')' |
|
| 548 | 546 | ); |
| 549 | 547 | } |
| 550 | 548 | } else { |
| 551 | 549 | $key = 'wikibase.quality.constraints.regex.cache.miss'; |
| 552 | - $this->dataFactory->increment( $key ); |
|
| 553 | - return $this->matchesRegularExpressionWithSparql( $text, $regex ); |
|
| 550 | + $this->dataFactory->increment($key); |
|
| 551 | + return $this->matchesRegularExpressionWithSparql($text, $regex); |
|
| 554 | 552 | } |
| 555 | 553 | } |
| 556 | 554 | |
| 557 | - private function serializeConstraintParameterException( ConstraintParameterException $cpe ) { |
|
| 555 | + private function serializeConstraintParameterException(ConstraintParameterException $cpe) { |
|
| 558 | 556 | return [ |
| 559 | 557 | 'type' => ConstraintParameterException::class, |
| 560 | - 'violationMessage' => $this->violationMessageSerializer->serialize( $cpe->getViolationMessage() ), |
|
| 558 | + 'violationMessage' => $this->violationMessageSerializer->serialize($cpe->getViolationMessage()), |
|
| 561 | 559 | ]; |
| 562 | 560 | } |
| 563 | 561 | |
| 564 | - private function deserializeConstraintParameterException( array $serialization ) { |
|
| 562 | + private function deserializeConstraintParameterException(array $serialization) { |
|
| 565 | 563 | $message = $this->violationMessageDeserializer->deserialize( |
| 566 | 564 | $serialization['violationMessage'] |
| 567 | 565 | ); |
| 568 | - return new ConstraintParameterException( $message ); |
|
| 566 | + return new ConstraintParameterException($message); |
|
| 569 | 567 | } |
| 570 | 568 | |
| 571 | 569 | /** |
@@ -579,25 +577,25 @@ discard block |
||
| 579 | 577 | * @throws SparqlHelperException if the query times out or some other error occurs |
| 580 | 578 | * @throws ConstraintParameterException if the $regex is invalid |
| 581 | 579 | */ |
| 582 | - public function matchesRegularExpressionWithSparql( $text, $regex ) { |
|
| 583 | - $textStringLiteral = $this->stringLiteral( $text ); |
|
| 584 | - $regexStringLiteral = $this->stringLiteral( '^(?:' . $regex . ')$' ); |
|
| 580 | + public function matchesRegularExpressionWithSparql($text, $regex) { |
|
| 581 | + $textStringLiteral = $this->stringLiteral($text); |
|
| 582 | + $regexStringLiteral = $this->stringLiteral('^(?:'.$regex.')$'); |
|
| 585 | 583 | |
| 586 | 584 | $query = <<<EOF |
| 587 | 585 | SELECT (REGEX($textStringLiteral, $regexStringLiteral) AS ?matches) {} |
| 588 | 586 | EOF; |
| 589 | 587 | |
| 590 | - $result = $this->runQuery( $query, false ); |
|
| 588 | + $result = $this->runQuery($query, false); |
|
| 591 | 589 | |
| 592 | 590 | $vars = $result->getArray()['results']['bindings'][0]; |
| 593 | - if ( array_key_exists( 'matches', $vars ) ) { |
|
| 591 | + if (array_key_exists('matches', $vars)) { |
|
| 594 | 592 | // true or false ⇒ regex okay, text matches or not |
| 595 | 593 | return $vars['matches']['value'] === 'true'; |
| 596 | 594 | } else { |
| 597 | 595 | // empty result: regex broken |
| 598 | 596 | throw new ConstraintParameterException( |
| 599 | - ( new ViolationMessage( 'wbqc-violation-message-parameter-regex' ) ) |
|
| 600 | - ->withInlineCode( $regex, Role::CONSTRAINT_PARAMETER_VALUE ) |
|
| 597 | + (new ViolationMessage('wbqc-violation-message-parameter-regex')) |
|
| 598 | + ->withInlineCode($regex, Role::CONSTRAINT_PARAMETER_VALUE) |
|
| 601 | 599 | ); |
| 602 | 600 | } |
| 603 | 601 | } |
@@ -609,14 +607,14 @@ discard block |
||
| 609 | 607 | * |
| 610 | 608 | * @return boolean |
| 611 | 609 | */ |
| 612 | - public function isTimeout( $responseContent ) { |
|
| 613 | - $timeoutRegex = implode( '|', array_map( |
|
| 614 | - function ( $fqn ) { |
|
| 615 | - return preg_quote( $fqn, '/' ); |
|
| 610 | + public function isTimeout($responseContent) { |
|
| 611 | + $timeoutRegex = implode('|', array_map( |
|
| 612 | + function($fqn) { |
|
| 613 | + return preg_quote($fqn, '/'); |
|
| 616 | 614 | }, |
| 617 | - $this->config->get( 'WBQualityConstraintsSparqlTimeoutExceptionClasses' ) |
|
| 618 | - ) ); |
|
| 619 | - return (bool)preg_match( '/' . $timeoutRegex . '/', $responseContent ); |
|
| 615 | + $this->config->get('WBQualityConstraintsSparqlTimeoutExceptionClasses') |
|
| 616 | + )); |
|
| 617 | + return (bool) preg_match('/'.$timeoutRegex.'/', $responseContent); |
|
| 620 | 618 | } |
| 621 | 619 | |
| 622 | 620 | /** |
@@ -628,17 +626,17 @@ discard block |
||
| 628 | 626 | * @return int|boolean the max-age (in seconds) |
| 629 | 627 | * or a plain boolean if no max-age can be determined |
| 630 | 628 | */ |
| 631 | - public function getCacheMaxAge( $responseHeaders ) { |
|
| 629 | + public function getCacheMaxAge($responseHeaders) { |
|
| 632 | 630 | if ( |
| 633 | - array_key_exists( 'x-cache-status', $responseHeaders ) && |
|
| 634 | - preg_match( '/^hit(?:-.*)?$/', $responseHeaders['x-cache-status'][0] ) |
|
| 631 | + array_key_exists('x-cache-status', $responseHeaders) && |
|
| 632 | + preg_match('/^hit(?:-.*)?$/', $responseHeaders['x-cache-status'][0]) |
|
| 635 | 633 | ) { |
| 636 | 634 | $maxage = []; |
| 637 | 635 | if ( |
| 638 | - array_key_exists( 'cache-control', $responseHeaders ) && |
|
| 639 | - preg_match( '/\bmax-age=(\d+)\b/', $responseHeaders['cache-control'][0], $maxage ) |
|
| 636 | + array_key_exists('cache-control', $responseHeaders) && |
|
| 637 | + preg_match('/\bmax-age=(\d+)\b/', $responseHeaders['cache-control'][0], $maxage) |
|
| 640 | 638 | ) { |
| 641 | - return intval( $maxage[1] ); |
|
| 639 | + return intval($maxage[1]); |
|
| 642 | 640 | } else { |
| 643 | 641 | return true; |
| 644 | 642 | } |
@@ -659,34 +657,34 @@ discard block |
||
| 659 | 657 | * or SparlHelper::EMPTY_RETRY_AFTER if there is an empty Retry-After |
| 660 | 658 | * or SparlHelper::INVALID_RETRY_AFTER if there is something wrong with the format |
| 661 | 659 | */ |
| 662 | - public function getThrottling( MWHttpRequest $request ) { |
|
| 663 | - $retryAfterValue = $request->getResponseHeader( 'Retry-After' ); |
|
| 664 | - if ( $retryAfterValue === null ) { |
|
| 660 | + public function getThrottling(MWHttpRequest $request) { |
|
| 661 | + $retryAfterValue = $request->getResponseHeader('Retry-After'); |
|
| 662 | + if ($retryAfterValue === null) { |
|
| 665 | 663 | return self::NO_RETRY_AFTER; |
| 666 | 664 | } |
| 667 | 665 | |
| 668 | - $trimmedRetryAfterValue = trim( $retryAfterValue ); |
|
| 669 | - if ( empty( $trimmedRetryAfterValue ) ) { |
|
| 666 | + $trimmedRetryAfterValue = trim($retryAfterValue); |
|
| 667 | + if (empty($trimmedRetryAfterValue)) { |
|
| 670 | 668 | return self::EMPTY_RETRY_AFTER; |
| 671 | 669 | } |
| 672 | 670 | |
| 673 | - if ( is_numeric( $trimmedRetryAfterValue ) ) { |
|
| 674 | - $delaySeconds = (int)$trimmedRetryAfterValue; |
|
| 675 | - if ( $delaySeconds >= 0 ) { |
|
| 676 | - return $this->getTimestampInFuture( new DateInterval( 'PT' . $delaySeconds . 'S' ) ); |
|
| 671 | + if (is_numeric($trimmedRetryAfterValue)) { |
|
| 672 | + $delaySeconds = (int) $trimmedRetryAfterValue; |
|
| 673 | + if ($delaySeconds >= 0) { |
|
| 674 | + return $this->getTimestampInFuture(new DateInterval('PT'.$delaySeconds.'S')); |
|
| 677 | 675 | } |
| 678 | 676 | } else { |
| 679 | - $return = strtotime( $trimmedRetryAfterValue ); |
|
| 680 | - if ( !empty( $return ) ) { |
|
| 681 | - return new ConvertibleTimestamp( $return ); |
|
| 677 | + $return = strtotime($trimmedRetryAfterValue); |
|
| 678 | + if (!empty($return)) { |
|
| 679 | + return new ConvertibleTimestamp($return); |
|
| 682 | 680 | } |
| 683 | 681 | } |
| 684 | 682 | return self::INVALID_RETRY_AFTER; |
| 685 | 683 | } |
| 686 | 684 | |
| 687 | - private function getTimestampInFuture( DateInterval $delta ) { |
|
| 685 | + private function getTimestampInFuture(DateInterval $delta) { |
|
| 688 | 686 | $now = new ConvertibleTimestamp(); |
| 689 | - return new ConvertibleTimestamp( $now->timestamp->add( $delta ) ); |
|
| 687 | + return new ConvertibleTimestamp($now->timestamp->add($delta)); |
|
| 690 | 688 | } |
| 691 | 689 | |
| 692 | 690 | /** |
@@ -700,97 +698,96 @@ discard block |
||
| 700 | 698 | * |
| 701 | 699 | * @throws SparqlHelperException if the query times out or some other error occurs |
| 702 | 700 | */ |
| 703 | - public function runQuery( $query, $needsPrefixes = true ) { |
|
| 701 | + public function runQuery($query, $needsPrefixes = true) { |
|
| 704 | 702 | |
| 705 | - if ( $this->throttlingLock->isLocked( self::EXPIRY_LOCK_ID ) ) { |
|
| 706 | - $this->dataFactory->increment( 'wikibase.quality.constraints.sparql.throttling' ); |
|
| 703 | + if ($this->throttlingLock->isLocked(self::EXPIRY_LOCK_ID)) { |
|
| 704 | + $this->dataFactory->increment('wikibase.quality.constraints.sparql.throttling'); |
|
| 707 | 705 | throw new TooManySparqlRequestsException(); |
| 708 | 706 | } |
| 709 | 707 | |
| 710 | - $endpoint = $this->config->get( 'WBQualityConstraintsSparqlEndpoint' ); |
|
| 711 | - $maxQueryTimeMillis = $this->config->get( 'WBQualityConstraintsSparqlMaxMillis' ); |
|
| 712 | - $fallbackBlockDuration = (int)$this->config->get( 'WBQualityConstraintsSparqlThrottlingFallbackDuration' ); |
|
| 708 | + $endpoint = $this->config->get('WBQualityConstraintsSparqlEndpoint'); |
|
| 709 | + $maxQueryTimeMillis = $this->config->get('WBQualityConstraintsSparqlMaxMillis'); |
|
| 710 | + $fallbackBlockDuration = (int) $this->config->get('WBQualityConstraintsSparqlThrottlingFallbackDuration'); |
|
| 713 | 711 | |
| 714 | - if ( $fallbackBlockDuration < 0 ) { |
|
| 715 | - throw new InvalidArgumentException( 'Fallback duration must be positive int but is: ' . |
|
| 716 | - $fallbackBlockDuration ); |
|
| 712 | + if ($fallbackBlockDuration < 0) { |
|
| 713 | + throw new InvalidArgumentException('Fallback duration must be positive int but is: '. |
|
| 714 | + $fallbackBlockDuration); |
|
| 717 | 715 | } |
| 718 | 716 | |
| 719 | - if ( $this->config->get( 'WBQualityConstraintsSparqlHasWikibaseSupport' ) ) { |
|
| 717 | + if ($this->config->get('WBQualityConstraintsSparqlHasWikibaseSupport')) { |
|
| 720 | 718 | $needsPrefixes = false; |
| 721 | 719 | } |
| 722 | 720 | |
| 723 | - if ( $needsPrefixes ) { |
|
| 724 | - $query = $this->prefixes . $query; |
|
| 721 | + if ($needsPrefixes) { |
|
| 722 | + $query = $this->prefixes.$query; |
|
| 725 | 723 | } |
| 726 | - $query = "#wbqc\n" . $query; |
|
| 724 | + $query = "#wbqc\n".$query; |
|
| 727 | 725 | |
| 728 | - $url = $endpoint . '?' . http_build_query( |
|
| 726 | + $url = $endpoint.'?'.http_build_query( |
|
| 729 | 727 | [ |
| 730 | 728 | 'query' => $query, |
| 731 | 729 | 'format' => 'json', |
| 732 | 730 | 'maxQueryTimeMillis' => $maxQueryTimeMillis, |
| 733 | 731 | ], |
| 734 | - null, ini_get( 'arg_separator.output' ), |
|
| 732 | + null, ini_get('arg_separator.output'), |
|
| 735 | 733 | // encode spaces with %20, not + |
| 736 | 734 | PHP_QUERY_RFC3986 |
| 737 | 735 | ); |
| 738 | 736 | |
| 739 | 737 | $options = [ |
| 740 | 738 | 'method' => 'GET', |
| 741 | - 'timeout' => (int)round( ( $maxQueryTimeMillis + 1000 ) / 1000 ), |
|
| 739 | + 'timeout' => (int) round(($maxQueryTimeMillis + 1000) / 1000), |
|
| 742 | 740 | 'connectTimeout' => 'default', |
| 743 | 741 | 'userAgent' => $this->defaultUserAgent, |
| 744 | 742 | ]; |
| 745 | - $request = $this->requestFactory->create( $url, $options ); |
|
| 746 | - $startTime = microtime( true ); |
|
| 743 | + $request = $this->requestFactory->create($url, $options); |
|
| 744 | + $startTime = microtime(true); |
|
| 747 | 745 | $status = $request->execute(); |
| 748 | - $endTime = microtime( true ); |
|
| 746 | + $endTime = microtime(true); |
|
| 749 | 747 | $this->dataFactory->timing( |
| 750 | 748 | 'wikibase.quality.constraints.sparql.timing', |
| 751 | - ( $endTime - $startTime ) * 1000 |
|
| 749 | + ($endTime - $startTime) * 1000 |
|
| 752 | 750 | ); |
| 753 | 751 | |
| 754 | - if ( $request->getStatus() === self::HTTP_TOO_MANY_REQUESTS ) { |
|
| 755 | - $this->dataFactory->increment( 'wikibase.quality.constraints.sparql.throttling' ); |
|
| 756 | - $throttlingUntil = $this->getThrottling( $request ); |
|
| 757 | - if ( !( $throttlingUntil instanceof ConvertibleTimestamp ) ) { |
|
| 758 | - $this->loggingHelper->logSparqlHelperTooManyRequestsRetryAfterInvalid( $request ); |
|
| 752 | + if ($request->getStatus() === self::HTTP_TOO_MANY_REQUESTS) { |
|
| 753 | + $this->dataFactory->increment('wikibase.quality.constraints.sparql.throttling'); |
|
| 754 | + $throttlingUntil = $this->getThrottling($request); |
|
| 755 | + if (!($throttlingUntil instanceof ConvertibleTimestamp)) { |
|
| 756 | + $this->loggingHelper->logSparqlHelperTooManyRequestsRetryAfterInvalid($request); |
|
| 759 | 757 | $this->throttlingLock->lock( |
| 760 | 758 | self::EXPIRY_LOCK_ID, |
| 761 | - $this->getTimestampInFuture( new DateInterval( 'PT' . $fallbackBlockDuration . 'S' ) ) |
|
| 759 | + $this->getTimestampInFuture(new DateInterval('PT'.$fallbackBlockDuration.'S')) |
|
| 762 | 760 | ); |
| 763 | 761 | } else { |
| 764 | - $this->loggingHelper->logSparqlHelperTooManyRequestsRetryAfterPresent( $throttlingUntil, $request ); |
|
| 765 | - $this->throttlingLock->lock( self::EXPIRY_LOCK_ID, $throttlingUntil ); |
|
| 762 | + $this->loggingHelper->logSparqlHelperTooManyRequestsRetryAfterPresent($throttlingUntil, $request); |
|
| 763 | + $this->throttlingLock->lock(self::EXPIRY_LOCK_ID, $throttlingUntil); |
|
| 766 | 764 | } |
| 767 | 765 | throw new TooManySparqlRequestsException(); |
| 768 | 766 | } |
| 769 | 767 | |
| 770 | - $maxAge = $this->getCacheMaxAge( $request->getResponseHeaders() ); |
|
| 771 | - if ( $maxAge ) { |
|
| 772 | - $this->dataFactory->increment( 'wikibase.quality.constraints.sparql.cached' ); |
|
| 768 | + $maxAge = $this->getCacheMaxAge($request->getResponseHeaders()); |
|
| 769 | + if ($maxAge) { |
|
| 770 | + $this->dataFactory->increment('wikibase.quality.constraints.sparql.cached'); |
|
| 773 | 771 | } |
| 774 | 772 | |
| 775 | - if ( $status->isOK() ) { |
|
| 773 | + if ($status->isOK()) { |
|
| 776 | 774 | $json = $request->getContent(); |
| 777 | - $arr = json_decode( $json, true ); |
|
| 775 | + $arr = json_decode($json, true); |
|
| 778 | 776 | return new CachedQueryResults( |
| 779 | 777 | $arr, |
| 780 | 778 | Metadata::ofCachingMetadata( |
| 781 | 779 | $maxAge ? |
| 782 | - CachingMetadata::ofMaximumAgeInSeconds( $maxAge ) : |
|
| 783 | - CachingMetadata::fresh() |
|
| 780 | + CachingMetadata::ofMaximumAgeInSeconds($maxAge) : CachingMetadata::fresh() |
|
| 784 | 781 | ) |
| 785 | 782 | ); |
| 786 | 783 | } else { |
| 787 | - $this->dataFactory->increment( 'wikibase.quality.constraints.sparql.error' ); |
|
| 784 | + $this->dataFactory->increment('wikibase.quality.constraints.sparql.error'); |
|
| 788 | 785 | |
| 789 | 786 | $this->dataFactory->increment( |
| 790 | 787 | "wikibase.quality.constraints.sparql.error.http.{$request->getStatus()}" |
| 791 | 788 | ); |
| 792 | 789 | |
| 793 | - if ( $this->isTimeout( $request->getContent() ) ) { |
|
| 790 | + if ($this->isTimeout($request->getContent())) { |
|
| 794 | 791 | $this->dataFactory->increment( |
| 795 | 792 | 'wikibase.quality.constraints.sparql.error.timeout' |
| 796 | 793 | ); |
@@ -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( PropertyId $propertyId ) { |
|
| 38 | + public function queryConstraintsForProperty(PropertyId $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 | } |
@@ -64,6 +64,7 @@ |
||
| 64 | 64 | * |
| 65 | 65 | * @param ?array $result |
| 66 | 66 | * @param array[] &$container |
| 67 | + * @return void |
|
| 67 | 68 | */ |
| 68 | 69 | public function storeCheckResultInArray( ?array $result, array &$container ); |
| 69 | 70 | |
@@ -65,6 +65,6 @@ |
||
| 65 | 65 | * @param ?array $result |
| 66 | 66 | * @param array[] &$container |
| 67 | 67 | */ |
| 68 | - public function storeCheckResultInArray( ?array $result, array &$container ); |
|
| 68 | + public function storeCheckResultInArray(?array $result, array &$container); |
|
| 69 | 69 | |
| 70 | 70 | } |
@@ -35,7 +35,7 @@ discard block |
||
| 35 | 35 | * @codeCoverageIgnore This method is not supported. |
| 36 | 36 | */ |
| 37 | 37 | public function getType() { |
| 38 | - throw new LogicException( 'EntityContextCursor has no full associated context' ); |
|
| 38 | + throw new LogicException('EntityContextCursor has no full associated context'); |
|
| 39 | 39 | } |
| 40 | 40 | |
| 41 | 41 | public function getEntityId() { |
@@ -46,35 +46,35 @@ discard block |
||
| 46 | 46 | * @codeCoverageIgnore This method is not supported. |
| 47 | 47 | */ |
| 48 | 48 | public function getStatementPropertyId() { |
| 49 | - throw new LogicException( 'EntityContextCursor has no full associated context' ); |
|
| 49 | + throw new LogicException('EntityContextCursor has no full associated context'); |
|
| 50 | 50 | } |
| 51 | 51 | |
| 52 | 52 | /** |
| 53 | 53 | * @codeCoverageIgnore This method is not supported. |
| 54 | 54 | */ |
| 55 | 55 | public function getStatementGuid() { |
| 56 | - throw new LogicException( 'EntityContextCursor has no full associated context' ); |
|
| 56 | + throw new LogicException('EntityContextCursor has no full associated context'); |
|
| 57 | 57 | } |
| 58 | 58 | |
| 59 | 59 | /** |
| 60 | 60 | * @codeCoverageIgnore This method is not supported. |
| 61 | 61 | */ |
| 62 | 62 | public function getSnakPropertyId() { |
| 63 | - throw new LogicException( 'EntityContextCursor has no full associated context' ); |
|
| 63 | + throw new LogicException('EntityContextCursor has no full associated context'); |
|
| 64 | 64 | } |
| 65 | 65 | |
| 66 | 66 | /** |
| 67 | 67 | * @codeCoverageIgnore This method is not supported. |
| 68 | 68 | */ |
| 69 | 69 | public function getSnakHash() { |
| 70 | - throw new LogicException( 'EntityContextCursor has no full associated context' ); |
|
| 70 | + throw new LogicException('EntityContextCursor has no full associated context'); |
|
| 71 | 71 | } |
| 72 | 72 | |
| 73 | 73 | /** |
| 74 | 74 | * @codeCoverageIgnore This method is not supported. |
| 75 | 75 | */ |
| 76 | - public function &getMainArray( array &$container ) { |
|
| 77 | - throw new LogicException( 'EntityContextCursor cannot store check results' ); |
|
| 76 | + public function &getMainArray(array &$container) { |
|
| 77 | + throw new LogicException('EntityContextCursor cannot store check results'); |
|
| 78 | 78 | } |
| 79 | 79 | |
| 80 | 80 | /** |
@@ -83,14 +83,14 @@ discard block |
||
| 83 | 83 | * @param ?array $result must be null |
| 84 | 84 | * @param array[] &$container |
| 85 | 85 | */ |
| 86 | - public function storeCheckResultInArray( ?array $result, array &$container ) { |
|
| 87 | - if ( $result !== null ) { |
|
| 88 | - throw new LogicException( 'EntityContextCursor cannot store check results' ); |
|
| 86 | + public function storeCheckResultInArray(?array $result, array &$container) { |
|
| 87 | + if ($result !== null) { |
|
| 88 | + throw new LogicException('EntityContextCursor cannot store check results'); |
|
| 89 | 89 | } |
| 90 | 90 | |
| 91 | 91 | // this ensures that the claims array is present in the $container, |
| 92 | 92 | // populating it if necessary, even though we ignore the return value |
| 93 | - $this->getClaimsArray( $container ); |
|
| 93 | + $this->getClaimsArray($container); |
|
| 94 | 94 | } |
| 95 | 95 | |
| 96 | 96 | } |