@@ -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,24 +137,24 @@ 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->getType() !== 'wikibase-entityid' ) { |
|
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->getType() !== 'wikibase-entityid') { |
|
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 | /** @var EntityIdValue $dataValue */ |
147 | 147 | |
148 | 148 | try { |
149 | - $item = $this->entityLookup->getEntity( $dataValue->getEntityId() ); |
|
150 | - } catch ( UnresolvedEntityRedirectException $e ) { |
|
149 | + $item = $this->entityLookup->getEntity($dataValue->getEntityId()); |
|
150 | + } catch (UnresolvedEntityRedirectException $e) { |
|
151 | 151 | // Edge case (double redirect): Pretend the entity doesn't exist |
152 | 152 | $item = null; |
153 | 153 | } |
154 | 154 | |
155 | - if ( !( $item instanceof StatementListProvider ) ) { |
|
156 | - $message = new ViolationMessage( 'wbqc-violation-message-value-entity-must-exist' ); |
|
157 | - return new CheckResult( $context, $constraint, $parameters, CheckResult::STATUS_VIOLATION, $message ); |
|
155 | + if (!($item instanceof StatementListProvider)) { |
|
156 | + $message = new ViolationMessage('wbqc-violation-message-value-entity-must-exist'); |
|
157 | + return new CheckResult($context, $constraint, $parameters, CheckResult::STATUS_VIOLATION, $message); |
|
158 | 158 | } |
159 | 159 | |
160 | 160 | $statements = $item->getStatements(); |
@@ -165,7 +165,7 @@ discard block |
||
165 | 165 | $classes |
166 | 166 | ); |
167 | 167 | |
168 | - if ( $result->getBool() ) { |
|
168 | + if ($result->getBool()) { |
|
169 | 169 | $message = null; |
170 | 170 | $status = CheckResult::STATUS_COMPLIANCE; |
171 | 171 | } else { |
@@ -179,11 +179,11 @@ discard block |
||
179 | 179 | $status = CheckResult::STATUS_VIOLATION; |
180 | 180 | } |
181 | 181 | |
182 | - return ( new CheckResult( $context, $constraint, $parameters, $status, $message ) ) |
|
183 | - ->withMetadata( $result->getMetadata() ); |
|
182 | + return (new CheckResult($context, $constraint, $parameters, $status, $message)) |
|
183 | + ->withMetadata($result->getMetadata()); |
|
184 | 184 | } |
185 | 185 | |
186 | - public function checkConstraintParameters( Constraint $constraint ) { |
|
186 | + public function checkConstraintParameters(Constraint $constraint) { |
|
187 | 187 | $constraintParameters = $constraint->getConstraintParameters(); |
188 | 188 | $constraintTypeItemId = $constraint->getConstraintTypeItemId(); |
189 | 189 | $exceptions = []; |
@@ -192,7 +192,7 @@ discard block |
||
192 | 192 | $constraintParameters, |
193 | 193 | $constraintTypeItemId |
194 | 194 | ); |
195 | - } catch ( ConstraintParameterException $e ) { |
|
195 | + } catch (ConstraintParameterException $e) { |
|
196 | 196 | $exceptions[] = $e; |
197 | 197 | } |
198 | 198 | try { |
@@ -200,7 +200,7 @@ discard block |
||
200 | 200 | $constraintParameters, |
201 | 201 | $constraintTypeItemId |
202 | 202 | ); |
203 | - } catch ( ConstraintParameterException $e ) { |
|
203 | + } catch (ConstraintParameterException $e) { |
|
204 | 204 | $exceptions[] = $e; |
205 | 205 | } |
206 | 206 | return $exceptions; |
@@ -76,8 +76,8 @@ discard block |
||
76 | 76 | * @throws ConstraintParameterException |
77 | 77 | * @return array [ DataValue|null $min, DataValue|null $max, PropertyId $property, array $parameters ] |
78 | 78 | */ |
79 | - private function parseConstraintParameters( Constraint $constraint ) { |
|
80 | - list( $min, $max ) = $this->constraintParameterParser->parseQuantityRangeParameter( |
|
79 | + private function parseConstraintParameters(Constraint $constraint) { |
|
80 | + list($min, $max) = $this->constraintParameterParser->parseQuantityRangeParameter( |
|
81 | 81 | $constraint->getConstraintParameters(), |
82 | 82 | $constraint->getConstraintTypeItemId() |
83 | 83 | ); |
@@ -86,15 +86,15 @@ discard block |
||
86 | 86 | $constraint->getConstraintTypeItemId() |
87 | 87 | ); |
88 | 88 | |
89 | - if ( $min !== null ) { |
|
90 | - $parameters['minimum_quantity'] = [ $min ]; |
|
89 | + if ($min !== null) { |
|
90 | + $parameters['minimum_quantity'] = [$min]; |
|
91 | 91 | } |
92 | - if ( $max !== null ) { |
|
93 | - $parameters['maximum_quantity'] = [ $max ]; |
|
92 | + if ($max !== null) { |
|
93 | + $parameters['maximum_quantity'] = [$max]; |
|
94 | 94 | } |
95 | - $parameters['property'] = [ $property ]; |
|
95 | + $parameters['property'] = [$property]; |
|
96 | 96 | |
97 | - return [ $min, $max, $property, $parameters ]; |
|
97 | + return [$min, $max, $property, $parameters]; |
|
98 | 98 | } |
99 | 99 | |
100 | 100 | /** |
@@ -104,13 +104,13 @@ discard block |
||
104 | 104 | * |
105 | 105 | * @return bool |
106 | 106 | */ |
107 | - private function rangeInYears( $min, $max ) { |
|
108 | - $yearUnit = $this->config->get( 'WBQualityConstraintsYearUnit' ); |
|
107 | + private function rangeInYears($min, $max) { |
|
108 | + $yearUnit = $this->config->get('WBQualityConstraintsYearUnit'); |
|
109 | 109 | |
110 | - if ( $min !== null && $min->getUnit() === $yearUnit ) { |
|
110 | + if ($min !== null && $min->getUnit() === $yearUnit) { |
|
111 | 111 | return true; |
112 | 112 | } |
113 | - if ( $max !== null && $max->getUnit() === $yearUnit ) { |
|
113 | + if ($max !== null && $max->getUnit() === $yearUnit) { |
|
114 | 114 | return true; |
115 | 115 | } |
116 | 116 | |
@@ -126,59 +126,58 @@ discard block |
||
126 | 126 | * @throws ConstraintParameterException |
127 | 127 | * @return CheckResult |
128 | 128 | */ |
129 | - public function checkConstraint( Context $context, Constraint $constraint ) { |
|
130 | - if ( $context->getSnakRank() === Statement::RANK_DEPRECATED ) { |
|
131 | - return new CheckResult( $context, $constraint, [], CheckResult::STATUS_DEPRECATED ); |
|
129 | + public function checkConstraint(Context $context, Constraint $constraint) { |
|
130 | + if ($context->getSnakRank() === Statement::RANK_DEPRECATED) { |
|
131 | + return new CheckResult($context, $constraint, [], CheckResult::STATUS_DEPRECATED); |
|
132 | 132 | } |
133 | 133 | |
134 | 134 | $parameters = []; |
135 | 135 | |
136 | 136 | $snak = $context->getSnak(); |
137 | 137 | |
138 | - if ( !$snak instanceof PropertyValueSnak ) { |
|
138 | + if (!$snak instanceof PropertyValueSnak) { |
|
139 | 139 | // nothing to check |
140 | - return new CheckResult( $context, $constraint, $parameters, CheckResult::STATUS_COMPLIANCE ); |
|
140 | + return new CheckResult($context, $constraint, $parameters, CheckResult::STATUS_COMPLIANCE); |
|
141 | 141 | } |
142 | 142 | |
143 | 143 | $minuend = $snak->getDataValue(); |
144 | 144 | |
145 | 145 | /** @var PropertyId $property */ |
146 | - list( $min, $max, $property, $parameters ) = $this->parseConstraintParameters( $constraint ); |
|
146 | + list($min, $max, $property, $parameters) = $this->parseConstraintParameters($constraint); |
|
147 | 147 | |
148 | 148 | // checks only the first occurrence of the referenced property |
149 | - foreach ( $context->getSnakGroup( Context::GROUP_NON_DEPRECATED ) as $otherSnak ) { |
|
149 | + foreach ($context->getSnakGroup(Context::GROUP_NON_DEPRECATED) as $otherSnak) { |
|
150 | 150 | if ( |
151 | - !$property->equals( $otherSnak->getPropertyId() ) || |
|
151 | + !$property->equals($otherSnak->getPropertyId()) || |
|
152 | 152 | !$otherSnak instanceof PropertyValueSnak |
153 | 153 | ) { |
154 | 154 | continue; |
155 | 155 | } |
156 | 156 | |
157 | 157 | $subtrahend = $otherSnak->getDataValue(); |
158 | - if ( $subtrahend->getType() === $minuend->getType() ) { |
|
159 | - $diff = $this->rangeInYears( $min, $max ) && $minuend->getType() === 'time' ? |
|
160 | - $this->rangeCheckerHelper->getDifferenceInYears( $minuend, $subtrahend ) : |
|
161 | - $this->rangeCheckerHelper->getDifference( $minuend, $subtrahend ); |
|
158 | + if ($subtrahend->getType() === $minuend->getType()) { |
|
159 | + $diff = $this->rangeInYears($min, $max) && $minuend->getType() === 'time' ? |
|
160 | + $this->rangeCheckerHelper->getDifferenceInYears($minuend, $subtrahend) : $this->rangeCheckerHelper->getDifference($minuend, $subtrahend); |
|
162 | 161 | |
163 | - if ( $this->rangeCheckerHelper->getComparison( $min, $diff ) > 0 || |
|
164 | - $this->rangeCheckerHelper->getComparison( $diff, $max ) > 0 |
|
162 | + if ($this->rangeCheckerHelper->getComparison($min, $diff) > 0 || |
|
163 | + $this->rangeCheckerHelper->getComparison($diff, $max) > 0 |
|
165 | 164 | ) { |
166 | 165 | // at least one of $min, $max is set at this point, otherwise there could be no violation |
167 | - $openness = $min !== null ? ( $max !== null ? '' : '-rightopen' ) : '-leftopen'; |
|
166 | + $openness = $min !== null ? ($max !== null ? '' : '-rightopen') : '-leftopen'; |
|
168 | 167 | // possible message keys: |
169 | 168 | // wbqc-violation-message-diff-within-range |
170 | 169 | // wbqc-violation-message-diff-within-range-leftopen |
171 | 170 | // wbqc-violation-message-diff-within-range-rightopen |
172 | - $message = ( new ViolationMessage( "wbqc-violation-message-diff-within-range$openness" ) ) |
|
173 | - ->withEntityId( $context->getSnak()->getPropertyId(), Role::PREDICATE ) |
|
174 | - ->withDataValue( $minuend, Role::OBJECT ) |
|
175 | - ->withEntityId( $otherSnak->getPropertyId(), Role::PREDICATE ) |
|
176 | - ->withDataValue( $subtrahend, Role::OBJECT ); |
|
177 | - if ( $min !== null ) { |
|
178 | - $message = $message->withDataValue( $min, Role::OBJECT ); |
|
171 | + $message = (new ViolationMessage("wbqc-violation-message-diff-within-range$openness")) |
|
172 | + ->withEntityId($context->getSnak()->getPropertyId(), Role::PREDICATE) |
|
173 | + ->withDataValue($minuend, Role::OBJECT) |
|
174 | + ->withEntityId($otherSnak->getPropertyId(), Role::PREDICATE) |
|
175 | + ->withDataValue($subtrahend, Role::OBJECT); |
|
176 | + if ($min !== null) { |
|
177 | + $message = $message->withDataValue($min, Role::OBJECT); |
|
179 | 178 | } |
180 | - if ( $max !== null ) { |
|
181 | - $message = $message->withDataValue( $max, Role::OBJECT ); |
|
179 | + if ($max !== null) { |
|
180 | + $message = $message->withDataValue($max, Role::OBJECT); |
|
182 | 181 | } |
183 | 182 | $status = CheckResult::STATUS_VIOLATION; |
184 | 183 | } else { |
@@ -186,17 +185,17 @@ discard block |
||
186 | 185 | $status = CheckResult::STATUS_COMPLIANCE; |
187 | 186 | } |
188 | 187 | } else { |
189 | - $message = new ViolationMessage( 'wbqc-violation-message-diff-within-range-must-have-equal-types' ); |
|
188 | + $message = new ViolationMessage('wbqc-violation-message-diff-within-range-must-have-equal-types'); |
|
190 | 189 | $status = CheckResult::STATUS_VIOLATION; |
191 | 190 | } |
192 | 191 | |
193 | - return new CheckResult( $context, $constraint, $parameters, $status, $message ); |
|
192 | + return new CheckResult($context, $constraint, $parameters, $status, $message); |
|
194 | 193 | } |
195 | 194 | |
196 | - return new CheckResult( $context, $constraint, $parameters, CheckResult::STATUS_COMPLIANCE ); |
|
195 | + return new CheckResult($context, $constraint, $parameters, CheckResult::STATUS_COMPLIANCE); |
|
197 | 196 | } |
198 | 197 | |
199 | - public function checkConstraintParameters( Constraint $constraint ) { |
|
198 | + public function checkConstraintParameters(Constraint $constraint) { |
|
200 | 199 | $constraintParameters = $constraint->getConstraintParameters(); |
201 | 200 | $constraintTypeItemId = $constraint->getConstraintTypeItemId(); |
202 | 201 | $exceptions = []; |
@@ -205,7 +204,7 @@ discard block |
||
205 | 204 | $constraintParameters, |
206 | 205 | $constraintTypeItemId |
207 | 206 | ); |
208 | - } catch ( ConstraintParameterException $e ) { |
|
207 | + } catch (ConstraintParameterException $e) { |
|
209 | 208 | $exceptions[] = $e; |
210 | 209 | } |
211 | 210 | try { |
@@ -213,7 +212,7 @@ discard block |
||
213 | 212 | $constraintParameters, |
214 | 213 | $constraintTypeItemId |
215 | 214 | ); |
216 | - } catch ( ConstraintParameterException $e ) { |
|
215 | + } catch (ConstraintParameterException $e) { |
|
217 | 216 | $exceptions[] = $e; |
218 | 217 | } |
219 | 218 | return $exceptions; |
@@ -15,10 +15,10 @@ discard block |
||
15 | 15 | use Wikibase\Repo\WikibaseRepo; |
16 | 16 | |
17 | 17 | // @codeCoverageIgnoreStart |
18 | -$basePath = getenv( "MW_INSTALL_PATH" ) !== false |
|
19 | - ? getenv( "MW_INSTALL_PATH" ) : __DIR__ . "/../../.."; |
|
18 | +$basePath = getenv("MW_INSTALL_PATH") !== false |
|
19 | + ? getenv("MW_INSTALL_PATH") : __DIR__."/../../.."; |
|
20 | 20 | |
21 | -require_once $basePath . "/maintenance/Maintenance.php"; |
|
21 | +require_once $basePath."/maintenance/Maintenance.php"; |
|
22 | 22 | // @codeCoverageIgnoreEnd |
23 | 23 | |
24 | 24 | /** |
@@ -52,13 +52,13 @@ discard block |
||
52 | 52 | parent::__construct(); |
53 | 53 | |
54 | 54 | $this->addDescription( |
55 | - 'Import entities needed for constraint checks ' . |
|
55 | + 'Import entities needed for constraint checks '. |
|
56 | 56 | 'from Wikidata into the local repository.' |
57 | 57 | ); |
58 | 58 | $this->addOption( |
59 | 59 | 'config-format', |
60 | - 'The format in which the resulting configuration will be omitted: ' . |
|
61 | - '"globals" for directly settings global variables, suitable for inclusion in LocalSettings.php (default), ' . |
|
60 | + 'The format in which the resulting configuration will be omitted: '. |
|
61 | + '"globals" for directly settings global variables, suitable for inclusion in LocalSettings.php (default), '. |
|
62 | 62 | 'or "wgConf" for printing parts of arrays suitable for inclusion in $wgConf->settings.' |
63 | 63 | ); |
64 | 64 | $this->addOption( |
@@ -75,8 +75,8 @@ discard block |
||
75 | 75 | $this->entitySerializer = $repo->getAllTypesEntitySerializer(); |
76 | 76 | $this->entityDeserializer = $repo->getInternalFormatEntityDeserializer(); |
77 | 77 | $this->entityStore = $repo->getEntityStore(); |
78 | - if ( !$this->getOption( 'dry-run', false ) ) { |
|
79 | - $this->user = User::newSystemUser( 'WikibaseQualityConstraints importer' ); |
|
78 | + if (!$this->getOption('dry-run', false)) { |
|
79 | + $this->user = User::newSystemUser('WikibaseQualityConstraints importer'); |
|
80 | 80 | } |
81 | 81 | } |
82 | 82 | |
@@ -85,20 +85,20 @@ discard block |
||
85 | 85 | |
86 | 86 | $configUpdates = []; |
87 | 87 | |
88 | - $extensionJsonFile = __DIR__ . '/../extension.json'; |
|
89 | - $extensionJsonText = file_get_contents( $extensionJsonFile ); |
|
90 | - $extensionJson = json_decode( $extensionJsonText, /* assoc = */ true ); |
|
91 | - $wikidataEntityIds = $this->getEntitiesToImport( $extensionJson['config'], $this->getConfig() ); |
|
88 | + $extensionJsonFile = __DIR__.'/../extension.json'; |
|
89 | + $extensionJsonText = file_get_contents($extensionJsonFile); |
|
90 | + $extensionJson = json_decode($extensionJsonText, /* assoc = */ true); |
|
91 | + $wikidataEntityIds = $this->getEntitiesToImport($extensionJson['config'], $this->getConfig()); |
|
92 | 92 | |
93 | - foreach ( $wikidataEntityIds as $key => $wikidataEntityId ) { |
|
94 | - $localEntityId = $this->importEntityFromWikidata( $wikidataEntityId ); |
|
93 | + foreach ($wikidataEntityIds as $key => $wikidataEntityId) { |
|
94 | + $localEntityId = $this->importEntityFromWikidata($wikidataEntityId); |
|
95 | 95 | $configUpdates[$key] = [ |
96 | 96 | 'wikidata' => $wikidataEntityId, |
97 | 97 | 'local' => $localEntityId, |
98 | 98 | ]; |
99 | 99 | } |
100 | 100 | |
101 | - $this->outputConfigUpdates( $configUpdates ); |
|
101 | + $this->outputConfigUpdates($configUpdates); |
|
102 | 102 | } |
103 | 103 | |
104 | 104 | /** |
@@ -106,18 +106,18 @@ discard block |
||
106 | 106 | * @param Config $wikiConfig |
107 | 107 | * @return string[] |
108 | 108 | */ |
109 | - private function getEntitiesToImport( array $extensionJsonConfig, Config $wikiConfig ) { |
|
109 | + private function getEntitiesToImport(array $extensionJsonConfig, Config $wikiConfig) { |
|
110 | 110 | $wikidataEntityIds = []; |
111 | 111 | |
112 | - foreach ( $extensionJsonConfig as $key => $value ) { |
|
113 | - if ( !preg_match( '/Id$/', $key ) ) { |
|
112 | + foreach ($extensionJsonConfig as $key => $value) { |
|
113 | + if (!preg_match('/Id$/', $key)) { |
|
114 | 114 | continue; |
115 | 115 | } |
116 | 116 | |
117 | 117 | $wikidataEntityId = $value['value']; |
118 | - $localEntityId = $wikiConfig->get( $key ); |
|
118 | + $localEntityId = $wikiConfig->get($key); |
|
119 | 119 | |
120 | - if ( $localEntityId === $wikidataEntityId ) { |
|
120 | + if ($localEntityId === $wikidataEntityId) { |
|
121 | 121 | $wikidataEntityIds[$key] = $wikidataEntityId; |
122 | 122 | } |
123 | 123 | } |
@@ -129,10 +129,10 @@ discard block |
||
129 | 129 | * @param string $wikidataEntityId |
130 | 130 | * @return string local entity ID |
131 | 131 | */ |
132 | - private function importEntityFromWikidata( $wikidataEntityId ) { |
|
132 | + private function importEntityFromWikidata($wikidataEntityId) { |
|
133 | 133 | $wikidataEntityUrl = "https://www.wikidata.org/wiki/Special:EntityData/$wikidataEntityId.json"; |
134 | - $wikidataEntitiesJson = file_get_contents( $wikidataEntityUrl ); |
|
135 | - return $this->importEntityFromJson( $wikidataEntityId, $wikidataEntitiesJson ); |
|
134 | + $wikidataEntitiesJson = file_get_contents($wikidataEntityUrl); |
|
135 | + return $this->importEntityFromJson($wikidataEntityId, $wikidataEntitiesJson); |
|
136 | 136 | } |
137 | 137 | |
138 | 138 | /** |
@@ -140,23 +140,23 @@ discard block |
||
140 | 140 | * @param string $wikidataEntitiesJson |
141 | 141 | * @return string local entity ID |
142 | 142 | */ |
143 | - private function importEntityFromJson( $wikidataEntityId, $wikidataEntitiesJson ) { |
|
144 | - $wikidataEntityArray = json_decode( $wikidataEntitiesJson, true )['entities'][$wikidataEntityId]; |
|
145 | - $wikidataEntity = $this->entityDeserializer->deserialize( $wikidataEntityArray ); |
|
143 | + private function importEntityFromJson($wikidataEntityId, $wikidataEntitiesJson) { |
|
144 | + $wikidataEntityArray = json_decode($wikidataEntitiesJson, true)['entities'][$wikidataEntityId]; |
|
145 | + $wikidataEntity = $this->entityDeserializer->deserialize($wikidataEntityArray); |
|
146 | 146 | |
147 | - $wikidataEntity->setId( null ); |
|
147 | + $wikidataEntity->setId(null); |
|
148 | 148 | |
149 | - if ( $wikidataEntity instanceof StatementListProvider ) { |
|
149 | + if ($wikidataEntity instanceof StatementListProvider) { |
|
150 | 150 | $wikidataEntity->getStatements()->clear(); |
151 | 151 | } |
152 | 152 | |
153 | - if ( $wikidataEntity instanceof Item ) { |
|
154 | - $wikidataEntity->setSiteLinkList( new SiteLinkList() ); |
|
153 | + if ($wikidataEntity instanceof Item) { |
|
154 | + $wikidataEntity->setSiteLinkList(new SiteLinkList()); |
|
155 | 155 | } |
156 | 156 | |
157 | - if ( $this->getOption( 'dry-run', false ) ) { |
|
158 | - $wikidataEntityJson = json_encode( $this->entitySerializer->serialize( $wikidataEntity ) ); |
|
159 | - $this->output( $wikidataEntityJson . "\n" ); |
|
157 | + if ($this->getOption('dry-run', false)) { |
|
158 | + $wikidataEntityJson = json_encode($this->entitySerializer->serialize($wikidataEntity)); |
|
159 | + $this->output($wikidataEntityJson."\n"); |
|
160 | 160 | return "-$wikidataEntityId"; |
161 | 161 | } |
162 | 162 | |
@@ -169,12 +169,12 @@ discard block |
||
169 | 169 | )->getEntity(); |
170 | 170 | |
171 | 171 | return $localEntity->getId()->getSerialization(); |
172 | - } catch ( StorageException $storageException ) { |
|
173 | - return $this->storageExceptionToEntityId( $storageException ); |
|
172 | + } catch (StorageException $storageException) { |
|
173 | + return $this->storageExceptionToEntityId($storageException); |
|
174 | 174 | } |
175 | 175 | } |
176 | 176 | |
177 | - private function storageExceptionToEntityId( StorageException $storageException ) { |
|
177 | + private function storageExceptionToEntityId(StorageException $storageException) { |
|
178 | 178 | $message = $storageException->getMessage(); |
179 | 179 | // example messages: |
180 | 180 | // * Item [[Item:Q475|Q475]] already has label "as references" |
@@ -184,42 +184,42 @@ discard block |
||
184 | 184 | // * Property [[Property:P694|P694]] already has label "instance of" |
185 | 185 | // associated with language code en. |
186 | 186 | $pattern = '/[[|]([^][|]*)]] already has label .* associated with language code/'; |
187 | - if ( preg_match( $pattern, $message, $matches ) ) { |
|
187 | + if (preg_match($pattern, $message, $matches)) { |
|
188 | 188 | return $matches[1]; |
189 | 189 | } else { |
190 | 190 | throw $storageException; |
191 | 191 | } |
192 | 192 | } |
193 | 193 | |
194 | - private function outputConfigUpdates( array $configUpdates ) { |
|
195 | - $configFormat = $this->getOption( 'config-format', 'globals' ); |
|
196 | - switch ( $configFormat ) { |
|
194 | + private function outputConfigUpdates(array $configUpdates) { |
|
195 | + $configFormat = $this->getOption('config-format', 'globals'); |
|
196 | + switch ($configFormat) { |
|
197 | 197 | case 'globals': |
198 | - $this->outputConfigUpdatesGlobals( $configUpdates ); |
|
198 | + $this->outputConfigUpdatesGlobals($configUpdates); |
|
199 | 199 | break; |
200 | 200 | case 'wgConf': |
201 | - $this->outputConfigUpdatesWgConf( $configUpdates ); |
|
201 | + $this->outputConfigUpdatesWgConf($configUpdates); |
|
202 | 202 | break; |
203 | 203 | default: |
204 | - $this->error( "Invalid config format \"$configFormat\", using \"globals\"" ); |
|
205 | - $this->outputConfigUpdatesGlobals( $configUpdates ); |
|
204 | + $this->error("Invalid config format \"$configFormat\", using \"globals\""); |
|
205 | + $this->outputConfigUpdatesGlobals($configUpdates); |
|
206 | 206 | break; |
207 | 207 | } |
208 | 208 | } |
209 | 209 | |
210 | - private function outputConfigUpdatesGlobals( array $configUpdates ) { |
|
211 | - foreach ( $configUpdates as $key => $value ) { |
|
212 | - $localValueCode = var_export( $value['local'], true ); |
|
213 | - $this->output( "\$wg$key = $localValueCode;\n" ); |
|
210 | + private function outputConfigUpdatesGlobals(array $configUpdates) { |
|
211 | + foreach ($configUpdates as $key => $value) { |
|
212 | + $localValueCode = var_export($value['local'], true); |
|
213 | + $this->output("\$wg$key = $localValueCode;\n"); |
|
214 | 214 | } |
215 | 215 | } |
216 | 216 | |
217 | - private function outputConfigUpdatesWgConf( array $configUpdates ) { |
|
218 | - foreach ( $configUpdates as $key => $value ) { |
|
219 | - $keyCode = var_export( "wg$key", true ); |
|
220 | - $wikidataValueCode = var_export( $value['wikidata'], true ); |
|
221 | - $localValueCode = var_export( $value['local'], true ); |
|
222 | - $wikiIdCode = var_export( wfWikiID(), true ); |
|
217 | + private function outputConfigUpdatesWgConf(array $configUpdates) { |
|
218 | + foreach ($configUpdates as $key => $value) { |
|
219 | + $keyCode = var_export("wg$key", true); |
|
220 | + $wikidataValueCode = var_export($value['wikidata'], true); |
|
221 | + $localValueCode = var_export($value['local'], true); |
|
222 | + $wikiIdCode = var_export(wfWikiID(), true); |
|
223 | 223 | $block = <<< EOF |
224 | 224 | $keyCode => [ |
225 | 225 | 'default' => $wikidataValueCode, |
@@ -228,7 +228,7 @@ discard block |
||
228 | 228 | |
229 | 229 | |
230 | 230 | EOF; |
231 | - $this->output( $block ); |
|
231 | + $this->output($block); |
|
232 | 232 | } |
233 | 233 | } |
234 | 234 |
@@ -39,13 +39,13 @@ discard block |
||
39 | 39 | EntityIdLookup $entityIdLookup, |
40 | 40 | RdfVocabulary $rdfVocabulary |
41 | 41 | ) { |
42 | - parent::__construct( $page, $context ); |
|
42 | + parent::__construct($page, $context); |
|
43 | 43 | $this->resultsSource = $resultsSource; |
44 | 44 | $this->entityIdLookup = $entityIdLookup; |
45 | 45 | $this->rdfVocabulary = $rdfVocabulary; |
46 | 46 | } |
47 | 47 | |
48 | - public static function newFromGlobalState( Page $page, IContextSource $context ) { |
|
48 | + public static function newFromGlobalState(Page $page, IContextSource $context) { |
|
49 | 49 | $repo = WikibaseRepo::getDefaultInstance(); |
50 | 50 | |
51 | 51 | return new static( |
@@ -92,8 +92,8 @@ discard block |
||
92 | 92 | * @param string $guid |
93 | 93 | * @return string |
94 | 94 | */ |
95 | - private function cleanupGuid( $guid ) { |
|
96 | - return preg_replace( '/[^\w-]/', '-', $guid ); |
|
95 | + private function cleanupGuid($guid) { |
|
96 | + return preg_replace('/[^\w-]/', '-', $guid); |
|
97 | 97 | } |
98 | 98 | |
99 | 99 | /** |
@@ -105,60 +105,60 @@ discard block |
||
105 | 105 | $response = $this->getRequest()->response(); |
106 | 106 | $this->getOutput()->disable(); |
107 | 107 | |
108 | - if ( !$this->resultsSource instanceof CachingResultsSource ) { |
|
108 | + if (!$this->resultsSource instanceof CachingResultsSource) { |
|
109 | 109 | // TODO: make configurable whether only cached results are returned |
110 | - $response->statusHeader( 501 ); // Not Implemented |
|
110 | + $response->statusHeader(501); // Not Implemented |
|
111 | 111 | return null; |
112 | 112 | } |
113 | 113 | |
114 | - $entityId = $this->entityIdLookup->getEntityIdForTitle( $this->getTitle() ); |
|
115 | - if ( $entityId === null ) { |
|
116 | - $response->statusHeader( 404 ); // Not Found |
|
114 | + $entityId = $this->entityIdLookup->getEntityIdForTitle($this->getTitle()); |
|
115 | + if ($entityId === null) { |
|
116 | + $response->statusHeader(404); // Not Found |
|
117 | 117 | return null; |
118 | 118 | } |
119 | - $revId = $this->getRequest()->getVal( 'revision', 0 ); |
|
119 | + $revId = $this->getRequest()->getVal('revision', 0); |
|
120 | 120 | |
121 | - $results = $this->resultsSource->getStoredResults( $entityId, $revId ); |
|
122 | - if ( $results === null ) { |
|
123 | - $response->statusHeader( 204 ); // No Content |
|
121 | + $results = $this->resultsSource->getStoredResults($entityId, $revId); |
|
122 | + if ($results === null) { |
|
123 | + $response->statusHeader(204); // No Content |
|
124 | 124 | return null; |
125 | 125 | } |
126 | 126 | |
127 | 127 | $format = 'ttl'; // TODO: make format an option |
128 | 128 | |
129 | 129 | $writerFactory = new RdfWriterFactory(); |
130 | - $formatName = $writerFactory->getFormatName( $format ); |
|
131 | - $contentType = $writerFactory->getMimeTypes( $formatName )[0]; |
|
130 | + $formatName = $writerFactory->getFormatName($format); |
|
131 | + $contentType = $writerFactory->getMimeTypes($formatName)[0]; |
|
132 | 132 | |
133 | - $writer = $writerFactory->getWriter( $formatName ); |
|
134 | - foreach ( [ RdfVocabulary::NS_STATEMENT, RdfVocabulary::NS_ONTOLOGY ] as $ns ) { |
|
135 | - $writer->prefix( $ns, $this->rdfVocabulary->getNamespaceURI( $ns ) ); |
|
133 | + $writer = $writerFactory->getWriter($formatName); |
|
134 | + foreach ([RdfVocabulary::NS_STATEMENT, RdfVocabulary::NS_ONTOLOGY] as $ns) { |
|
135 | + $writer->prefix($ns, $this->rdfVocabulary->getNamespaceURI($ns)); |
|
136 | 136 | } |
137 | 137 | $writer->start(); |
138 | 138 | $writtenAny = false; |
139 | 139 | |
140 | - foreach ( $results->getArray() as $checkResult ) { |
|
141 | - if ( $checkResult instanceof NullResult ) { |
|
140 | + foreach ($results->getArray() as $checkResult) { |
|
141 | + if ($checkResult instanceof NullResult) { |
|
142 | 142 | continue; |
143 | 143 | } |
144 | - if ( $checkResult->getStatus() === CheckResult::STATUS_BAD_PARAMETERS ) { |
|
144 | + if ($checkResult->getStatus() === CheckResult::STATUS_BAD_PARAMETERS) { |
|
145 | 145 | continue; |
146 | 146 | } |
147 | 147 | $writtenAny = true; |
148 | - $writer->about( RdfVocabulary::NS_STATEMENT, |
|
149 | - $this->cleanupGuid( $checkResult->getContextCursor()->getStatementGuid() ) ) |
|
150 | - ->say( RdfVocabulary::NS_ONTOLOGY, 'hasViolationForConstraint' ) |
|
151 | - ->is( RdfVocabulary::NS_STATEMENT, |
|
152 | - $this->cleanupGuid( $checkResult->getConstraint()->getConstraintId() ) ); |
|
148 | + $writer->about(RdfVocabulary::NS_STATEMENT, |
|
149 | + $this->cleanupGuid($checkResult->getContextCursor()->getStatementGuid())) |
|
150 | + ->say(RdfVocabulary::NS_ONTOLOGY, 'hasViolationForConstraint') |
|
151 | + ->is(RdfVocabulary::NS_STATEMENT, |
|
152 | + $this->cleanupGuid($checkResult->getConstraint()->getConstraintId())); |
|
153 | 153 | } |
154 | 154 | $writer->finish(); |
155 | - if ( $writtenAny ) { |
|
156 | - $response->header( "Content-Type: $contentType; charset=UTF-8" ); |
|
155 | + if ($writtenAny) { |
|
156 | + $response->header("Content-Type: $contentType; charset=UTF-8"); |
|
157 | 157 | echo $writer->drain(); |
158 | 158 | } else { |
159 | 159 | // Do not output RDF if we haven't written any actual statements. Output 204 instead |
160 | 160 | $writer->drain(); |
161 | - $response->statusHeader( 204 ); // No Content |
|
161 | + $response->statusHeader(204); // No Content |
|
162 | 162 | } |
163 | 163 | return null; |
164 | 164 | } |
@@ -143,7 +143,7 @@ discard block |
||
143 | 143 | CheckResult::STATUS_WARNING, |
144 | 144 | CheckResult::STATUS_BAD_PARAMETERS, |
145 | 145 | ]; |
146 | - $this->cachedStatusesFlipped = array_flip( $this->cachedStatuses ); |
|
146 | + $this->cachedStatusesFlipped = array_flip($this->cachedStatuses); |
|
147 | 147 | } |
148 | 148 | |
149 | 149 | public function getResults( |
@@ -154,15 +154,15 @@ discard block |
||
154 | 154 | ) { |
155 | 155 | $results = []; |
156 | 156 | $metadatas = []; |
157 | - $statusesFlipped = array_flip( $statuses ); |
|
158 | - if ( $this->canUseStoredResults( $entityIds, $claimIds, $constraintIds, $statuses ) ) { |
|
157 | + $statusesFlipped = array_flip($statuses); |
|
158 | + if ($this->canUseStoredResults($entityIds, $claimIds, $constraintIds, $statuses)) { |
|
159 | 159 | $storedEntityIds = []; |
160 | - foreach ( $entityIds as $entityId ) { |
|
161 | - $storedResults = $this->getStoredResults( $entityId ); |
|
162 | - if ( $storedResults !== null ) { |
|
163 | - $this->loggingHelper->logCheckConstraintsCacheHit( $entityId ); |
|
164 | - foreach ( $storedResults->getArray() as $checkResult ) { |
|
165 | - if ( $this->statusSelected( $statusesFlipped, $checkResult ) ) { |
|
160 | + foreach ($entityIds as $entityId) { |
|
161 | + $storedResults = $this->getStoredResults($entityId); |
|
162 | + if ($storedResults !== null) { |
|
163 | + $this->loggingHelper->logCheckConstraintsCacheHit($entityId); |
|
164 | + foreach ($storedResults->getArray() as $checkResult) { |
|
165 | + if ($this->statusSelected($statusesFlipped, $checkResult)) { |
|
166 | 166 | $results[] = $checkResult; |
167 | 167 | } |
168 | 168 | } |
@@ -170,19 +170,19 @@ discard block |
||
170 | 170 | $storedEntityIds[] = $entityId; |
171 | 171 | } |
172 | 172 | } |
173 | - $entityIds = array_values( array_diff( $entityIds, $storedEntityIds ) ); |
|
173 | + $entityIds = array_values(array_diff($entityIds, $storedEntityIds)); |
|
174 | 174 | } |
175 | - if ( $entityIds !== [] || $claimIds !== [] ) { |
|
176 | - if ( $entityIds !== [] ) { |
|
177 | - $this->loggingHelper->logCheckConstraintsCacheMisses( $entityIds ); |
|
175 | + if ($entityIds !== [] || $claimIds !== []) { |
|
176 | + if ($entityIds !== []) { |
|
177 | + $this->loggingHelper->logCheckConstraintsCacheMisses($entityIds); |
|
178 | 178 | } |
179 | - $response = $this->getAndStoreResults( $entityIds, $claimIds, $constraintIds, $statuses ); |
|
180 | - $results = array_merge( $results, $response->getArray() ); |
|
179 | + $response = $this->getAndStoreResults($entityIds, $claimIds, $constraintIds, $statuses); |
|
180 | + $results = array_merge($results, $response->getArray()); |
|
181 | 181 | $metadatas[] = $response->getMetadata(); |
182 | 182 | } |
183 | 183 | return new CachedCheckResults( |
184 | 184 | $results, |
185 | - Metadata::merge( $metadatas ) |
|
185 | + Metadata::merge($metadatas) |
|
186 | 186 | ); |
187 | 187 | } |
188 | 188 | |
@@ -205,13 +205,13 @@ discard block |
||
205 | 205 | array $constraintIds = null, |
206 | 206 | array $statuses |
207 | 207 | ) { |
208 | - if ( $claimIds !== [] ) { |
|
208 | + if ($claimIds !== []) { |
|
209 | 209 | return false; |
210 | 210 | } |
211 | - if ( $constraintIds !== null ) { |
|
211 | + if ($constraintIds !== null) { |
|
212 | 212 | return false; |
213 | 213 | } |
214 | - if ( array_diff( $statuses, $this->cachedStatuses ) !== [] ) { |
|
214 | + if (array_diff($statuses, $this->cachedStatuses) !== []) { |
|
215 | 215 | return false; |
216 | 216 | } |
217 | 217 | return true; |
@@ -226,8 +226,8 @@ discard block |
||
226 | 226 | * @param CheckResult $result |
227 | 227 | * @return bool |
228 | 228 | */ |
229 | - private function statusSelected( array $statusesFlipped, CheckResult $result ) { |
|
230 | - return array_key_exists( $result->getStatus(), $statusesFlipped ) || |
|
229 | + private function statusSelected(array $statusesFlipped, CheckResult $result) { |
|
230 | + return array_key_exists($result->getStatus(), $statusesFlipped) || |
|
231 | 231 | $result instanceof NullResult; |
232 | 232 | } |
233 | 233 | |
@@ -244,11 +244,11 @@ discard block |
||
244 | 244 | array $constraintIds = null, |
245 | 245 | array $statuses |
246 | 246 | ) { |
247 | - $results = $this->resultsSource->getResults( $entityIds, $claimIds, $constraintIds, $statuses ); |
|
247 | + $results = $this->resultsSource->getResults($entityIds, $claimIds, $constraintIds, $statuses); |
|
248 | 248 | |
249 | - if ( $this->canStoreResults( $entityIds, $claimIds, $constraintIds, $statuses ) ) { |
|
250 | - foreach ( $entityIds as $entityId ) { |
|
251 | - $this->storeResults( $entityId, $results ); |
|
249 | + if ($this->canStoreResults($entityIds, $claimIds, $constraintIds, $statuses)) { |
|
250 | + foreach ($entityIds as $entityId) { |
|
251 | + $this->storeResults($entityId, $results); |
|
252 | 252 | } |
253 | 253 | } |
254 | 254 | |
@@ -279,10 +279,10 @@ discard block |
||
279 | 279 | array $constraintIds = null, |
280 | 280 | array $statuses |
281 | 281 | ) { |
282 | - if ( $constraintIds !== null ) { |
|
282 | + if ($constraintIds !== null) { |
|
283 | 283 | return false; |
284 | 284 | } |
285 | - if ( array_diff( $this->cachedStatuses, $statuses ) !== [] ) { |
|
285 | + if (array_diff($this->cachedStatuses, $statuses) !== []) { |
|
286 | 286 | return false; |
287 | 287 | } |
288 | 288 | return true; |
@@ -296,21 +296,21 @@ discard block |
||
296 | 296 | * May include check results for other entity IDs as well, |
297 | 297 | * or check results with statuses that we’re not interested in caching. |
298 | 298 | */ |
299 | - private function storeResults( EntityId $entityId, CachedCheckResults $results ) { |
|
299 | + private function storeResults(EntityId $entityId, CachedCheckResults $results) { |
|
300 | 300 | $latestRevisionIds = $this->getLatestRevisionIds( |
301 | 301 | $results->getMetadata()->getDependencyMetadata()->getEntityIds() |
302 | 302 | ); |
303 | - if ( $latestRevisionIds === null ) { |
|
303 | + if ($latestRevisionIds === null) { |
|
304 | 304 | return; |
305 | 305 | } |
306 | 306 | |
307 | 307 | $resultSerializations = []; |
308 | - foreach ( $results->getArray() as $checkResult ) { |
|
309 | - if ( $checkResult->getContextCursor()->getEntityId() !== $entityId->getSerialization() ) { |
|
308 | + foreach ($results->getArray() as $checkResult) { |
|
309 | + if ($checkResult->getContextCursor()->getEntityId() !== $entityId->getSerialization()) { |
|
310 | 310 | continue; |
311 | 311 | } |
312 | - if ( $this->statusSelected( $this->cachedStatusesFlipped, $checkResult ) ) { |
|
313 | - $resultSerializations[] = $this->checkResultSerializer->serialize( $checkResult ); |
|
312 | + if ($this->statusSelected($this->cachedStatusesFlipped, $checkResult)) { |
|
313 | + $resultSerializations[] = $this->checkResultSerializer->serialize($checkResult); |
|
314 | 314 | } |
315 | 315 | } |
316 | 316 | |
@@ -319,11 +319,11 @@ discard block |
||
319 | 319 | 'latestRevisionIds' => $latestRevisionIds, |
320 | 320 | ]; |
321 | 321 | $futureTime = $results->getMetadata()->getDependencyMetadata()->getFutureTime(); |
322 | - if ( $futureTime !== null ) { |
|
322 | + if ($futureTime !== null) { |
|
323 | 323 | $value['futureTime'] = $futureTime->getArrayValue(); |
324 | 324 | } |
325 | 325 | |
326 | - $this->cache->set( $entityId, $value, $this->ttlInSeconds ); |
|
326 | + $this->cache->set($entityId, $value, $this->ttlInSeconds); |
|
327 | 327 | } |
328 | 328 | |
329 | 329 | /** |
@@ -337,31 +337,30 @@ discard block |
||
337 | 337 | EntityId $entityId, |
338 | 338 | $forRevision = 0 |
339 | 339 | ) { |
340 | - $value = $this->cache->get( $entityId, $curTTL, [], $asOf ); |
|
341 | - $now = call_user_func( $this->microtime, true ); |
|
340 | + $value = $this->cache->get($entityId, $curTTL, [], $asOf); |
|
341 | + $now = call_user_func($this->microtime, true); |
|
342 | 342 | |
343 | - $dependencyMetadata = $this->checkDependencyMetadata( $value, |
|
344 | - [ $entityId->getSerialization() => $forRevision ] ); |
|
345 | - if ( $dependencyMetadata === null ) { |
|
343 | + $dependencyMetadata = $this->checkDependencyMetadata($value, |
|
344 | + [$entityId->getSerialization() => $forRevision]); |
|
345 | + if ($dependencyMetadata === null) { |
|
346 | 346 | return null; |
347 | 347 | } |
348 | 348 | |
349 | - $ageInSeconds = (int)ceil( $now - $asOf ); |
|
349 | + $ageInSeconds = (int) ceil($now - $asOf); |
|
350 | 350 | $cachingMetadata = $ageInSeconds > 0 ? |
351 | - CachingMetadata::ofMaximumAgeInSeconds( $ageInSeconds ) : |
|
352 | - CachingMetadata::fresh(); |
|
351 | + CachingMetadata::ofMaximumAgeInSeconds($ageInSeconds) : CachingMetadata::fresh(); |
|
353 | 352 | |
354 | 353 | $results = []; |
355 | - foreach ( $value['results'] as $resultSerialization ) { |
|
356 | - $results[] = $this->deserializeCheckResult( $resultSerialization, $cachingMetadata ); |
|
354 | + foreach ($value['results'] as $resultSerialization) { |
|
355 | + $results[] = $this->deserializeCheckResult($resultSerialization, $cachingMetadata); |
|
357 | 356 | } |
358 | 357 | |
359 | 358 | return new CachedCheckResults( |
360 | 359 | $results, |
361 | - Metadata::merge( [ |
|
362 | - Metadata::ofCachingMetadata( $cachingMetadata ), |
|
363 | - Metadata::ofDependencyMetadata( $dependencyMetadata ), |
|
364 | - ] ) |
|
360 | + Metadata::merge([ |
|
361 | + Metadata::ofCachingMetadata($cachingMetadata), |
|
362 | + Metadata::ofDependencyMetadata($dependencyMetadata), |
|
363 | + ]) |
|
365 | 364 | ); |
366 | 365 | } |
367 | 366 | |
@@ -377,43 +376,43 @@ discard block |
||
377 | 376 | * @return DependencyMetadata|null the dependency metadata, |
378 | 377 | * or null if $value should no longer be used |
379 | 378 | */ |
380 | - private function checkDependencyMetadata( $value, $paramRevs ) { |
|
381 | - if ( $value === false ) { |
|
379 | + private function checkDependencyMetadata($value, $paramRevs) { |
|
380 | + if ($value === false) { |
|
382 | 381 | return null; |
383 | 382 | } |
384 | 383 | |
385 | - if ( array_key_exists( 'futureTime', $value ) ) { |
|
386 | - $futureTime = TimeValue::newFromArray( $value['futureTime'] ); |
|
387 | - if ( !$this->timeValueComparer->isFutureTime( $futureTime ) ) { |
|
384 | + if (array_key_exists('futureTime', $value)) { |
|
385 | + $futureTime = TimeValue::newFromArray($value['futureTime']); |
|
386 | + if (!$this->timeValueComparer->isFutureTime($futureTime)) { |
|
388 | 387 | return null; |
389 | 388 | } |
390 | - $futureTimeDependencyMetadata = DependencyMetadata::ofFutureTime( $futureTime ); |
|
389 | + $futureTimeDependencyMetadata = DependencyMetadata::ofFutureTime($futureTime); |
|
391 | 390 | } else { |
392 | 391 | $futureTimeDependencyMetadata = DependencyMetadata::blank(); |
393 | 392 | } |
394 | 393 | |
395 | - foreach ( $paramRevs as $id => $revision ) { |
|
396 | - if ( $revision > 0 ) { |
|
397 | - $value['latestRevisionIds'][$id] = min( $revision, $value['latestRevisionIds'][$id] ?? PHP_INT_MAX ); |
|
394 | + foreach ($paramRevs as $id => $revision) { |
|
395 | + if ($revision > 0) { |
|
396 | + $value['latestRevisionIds'][$id] = min($revision, $value['latestRevisionIds'][$id] ?? PHP_INT_MAX); |
|
398 | 397 | } |
399 | 398 | } |
400 | 399 | |
401 | 400 | $dependedEntityIds = array_map( |
402 | - [ $this->entityIdParser, "parse" ], |
|
403 | - array_keys( $value['latestRevisionIds'] ) |
|
401 | + [$this->entityIdParser, "parse"], |
|
402 | + array_keys($value['latestRevisionIds']) |
|
404 | 403 | ); |
405 | 404 | |
406 | - if ( $value['latestRevisionIds'] !== $this->getLatestRevisionIds( $dependedEntityIds ) ) { |
|
405 | + if ($value['latestRevisionIds'] !== $this->getLatestRevisionIds($dependedEntityIds)) { |
|
407 | 406 | return null; |
408 | 407 | } |
409 | 408 | |
410 | 409 | return array_reduce( |
411 | 410 | $dependedEntityIds, |
412 | - function( DependencyMetadata $metadata, EntityId $entityId ) { |
|
413 | - return DependencyMetadata::merge( [ |
|
411 | + function(DependencyMetadata $metadata, EntityId $entityId) { |
|
412 | + return DependencyMetadata::merge([ |
|
414 | 413 | $metadata, |
415 | - DependencyMetadata::ofEntityId( $entityId ) |
|
416 | - ] ); |
|
414 | + DependencyMetadata::ofEntityId($entityId) |
|
415 | + ]); |
|
417 | 416 | }, |
418 | 417 | $futureTimeDependencyMetadata |
419 | 418 | ); |
@@ -433,13 +432,13 @@ discard block |
||
433 | 432 | array $resultSerialization, |
434 | 433 | CachingMetadata $cachingMetadata |
435 | 434 | ) { |
436 | - $result = $this->checkResultDeserializer->deserialize( $resultSerialization ); |
|
437 | - if ( $this->isPossiblyStaleResult( $result ) ) { |
|
435 | + $result = $this->checkResultDeserializer->deserialize($resultSerialization); |
|
436 | + if ($this->isPossiblyStaleResult($result)) { |
|
438 | 437 | $result->withMetadata( |
439 | - Metadata::merge( [ |
|
438 | + Metadata::merge([ |
|
440 | 439 | $result->getMetadata(), |
441 | - Metadata::ofCachingMetadata( $cachingMetadata ), |
|
442 | - ] ) |
|
440 | + Metadata::ofCachingMetadata($cachingMetadata), |
|
441 | + ]) |
|
443 | 442 | ); |
444 | 443 | } |
445 | 444 | return $result; |
@@ -449,8 +448,8 @@ discard block |
||
449 | 448 | * @param CheckResult $result |
450 | 449 | * @return bool |
451 | 450 | */ |
452 | - private function isPossiblyStaleResult( CheckResult $result ) { |
|
453 | - if ( $result instanceof NullResult ) { |
|
451 | + private function isPossiblyStaleResult(CheckResult $result) { |
|
452 | + if ($result instanceof NullResult) { |
|
454 | 453 | return false; |
455 | 454 | } |
456 | 455 | |
@@ -465,14 +464,14 @@ discard block |
||
465 | 464 | * @return int[]|null array from entity ID serializations to revision ID, |
466 | 465 | * or null to indicate that not all revision IDs could be loaded |
467 | 466 | */ |
468 | - private function getLatestRevisionIds( array $entityIds ) { |
|
469 | - if ( $entityIds === [] ) { |
|
467 | + private function getLatestRevisionIds(array $entityIds) { |
|
468 | + if ($entityIds === []) { |
|
470 | 469 | $this->loggingHelper->logEmptyDependencyMetadata(); |
471 | 470 | return []; |
472 | 471 | } |
473 | - if ( count( $entityIds ) > $this->maxRevisionIds ) { |
|
472 | + if (count($entityIds) > $this->maxRevisionIds) { |
|
474 | 473 | // one of those entities will probably be edited soon, so might as well skip caching |
475 | - $this->loggingHelper->logHugeDependencyMetadata( $entityIds, $this->maxRevisionIds ); |
|
474 | + $this->loggingHelper->logHugeDependencyMetadata($entityIds, $this->maxRevisionIds); |
|
476 | 475 | return null; |
477 | 476 | } |
478 | 477 | |
@@ -480,7 +479,7 @@ discard block |
||
480 | 479 | $entityIds, |
481 | 480 | EntityRevisionLookup::LATEST_FROM_REPLICA |
482 | 481 | ); |
483 | - if ( $this->hasFalseElements( $latestRevisionIds ) ) { |
|
482 | + if ($this->hasFalseElements($latestRevisionIds)) { |
|
484 | 483 | return null; |
485 | 484 | } |
486 | 485 | return $latestRevisionIds; |
@@ -490,8 +489,8 @@ discard block |
||
490 | 489 | * @param array $array |
491 | 490 | * @return bool |
492 | 491 | */ |
493 | - private function hasFalseElements( array $array ) { |
|
494 | - return in_array( false, $array, true ); |
|
492 | + private function hasFalseElements(array $array) { |
|
493 | + return in_array(false, $array, true); |
|
495 | 494 | } |
496 | 495 | |
497 | 496 | /** |
@@ -499,7 +498,7 @@ discard block |
||
499 | 498 | * |
500 | 499 | * @param callable $microtime |
501 | 500 | */ |
502 | - public function setMicrotimeFunction( callable $microtime ) { |
|
501 | + public function setMicrotimeFunction(callable $microtime) { |
|
503 | 502 | $this->microtime = $microtime; |
504 | 503 | } |
505 | 504 |