@@ -21,7 +21,7 @@ discard block |
||
21 | 21 | * |
22 | 22 | * @return bool |
23 | 23 | */ |
24 | - public function isSerializerFor( $object ) { |
|
24 | + public function isSerializerFor($object) { |
|
25 | 25 | return $object instanceof DumpMetaInformation; |
26 | 26 | } |
27 | 27 | |
@@ -33,32 +33,32 @@ discard block |
||
33 | 33 | * @return array |
34 | 34 | * @throws UnsupportedObjectException |
35 | 35 | */ |
36 | - public function serialize( $object ) { |
|
37 | - if ( !$this->isSerializerFor( $object ) ) { |
|
36 | + public function serialize($object) { |
|
37 | + if (!$this->isSerializerFor($object)) { |
|
38 | 38 | throw new UnsupportedObjectException( |
39 | 39 | $object, |
40 | 40 | 'DumpMetaInformationSerializer can only serialize DumpMetaInformation objects.' |
41 | 41 | ); |
42 | 42 | } |
43 | 43 | |
44 | - return $this->getSerialized( $object ); |
|
44 | + return $this->getSerialized($object); |
|
45 | 45 | } |
46 | 46 | |
47 | - private function getSerialized( DumpMetaInformation $dumpMetaInformation ) { |
|
47 | + private function getSerialized(DumpMetaInformation $dumpMetaInformation) { |
|
48 | 48 | $identifierPropertyIds = array_map( |
49 | - function( PropertyId $id ) { |
|
49 | + function(PropertyId $id) { |
|
50 | 50 | return $id->getSerialization(); |
51 | 51 | }, |
52 | 52 | $dumpMetaInformation->getIdentifierPropertyIds() |
53 | 53 | ); |
54 | 54 | |
55 | - $this->setIndexedTagName( $identifierPropertyIds, 'propertyId' ); |
|
55 | + $this->setIndexedTagName($identifierPropertyIds, 'propertyId'); |
|
56 | 56 | |
57 | 57 | return array( |
58 | 58 | 'dumpId' => $dumpMetaInformation->getDumpId(), |
59 | 59 | 'sourceItemId' => $dumpMetaInformation->getSourceItemId()->getSerialization(), |
60 | 60 | 'identifierPropertyIds' => $identifierPropertyIds, |
61 | - 'importDate' => wfTimestamp( TS_ISO_8601, $dumpMetaInformation->getImportDate() ), |
|
61 | + 'importDate' => wfTimestamp(TS_ISO_8601, $dumpMetaInformation->getImportDate()), |
|
62 | 62 | 'language' => $dumpMetaInformation->getLanguageCode(), |
63 | 63 | 'sourceUrl' => $dumpMetaInformation->getSourceUrl(), |
64 | 64 | 'size' => $dumpMetaInformation->getSize(), |
@@ -7,8 +7,8 @@ discard block |
||
7 | 7 | use WikibaseQuality\ExternalValidation\UpdateExternalData\CsvImportSettings; |
8 | 8 | use WikibaseQuality\ExternalValidation\UpdateExternalData\ExternalDataImporter; |
9 | 9 | |
10 | -$basePath = getenv( 'MW_INSTALL_PATH' ) !== false |
|
11 | - ? getenv( 'MW_INSTALL_PATH' ) |
|
10 | +$basePath = getenv('MW_INSTALL_PATH') !== false |
|
11 | + ? getenv('MW_INSTALL_PATH') |
|
12 | 12 | : __DIR__ . '/../../..'; |
13 | 13 | require_once $basePath . '/maintenance/Maintenance.php'; |
14 | 14 | |
@@ -25,16 +25,16 @@ discard block |
||
25 | 25 | public function __construct() { |
26 | 26 | parent::__construct(); |
27 | 27 | |
28 | - $this->addDescription( "Imports external entities from given CSV files into the local database. CSV files can be generated using the DumpConverter." ); |
|
29 | - $this->addOption( 'external-values-file', 'CSV file containing external values for import.', true, true ); |
|
30 | - $this->addOption( 'dump-information-file', 'CSV file containing dump meta information for import.', true, true ); |
|
31 | - $this->setBatchSize( 1000 ); |
|
28 | + $this->addDescription("Imports external entities from given CSV files into the local database. CSV files can be generated using the DumpConverter."); |
|
29 | + $this->addOption('external-values-file', 'CSV file containing external values for import.', true, true); |
|
30 | + $this->addOption('dump-information-file', 'CSV file containing dump meta information for import.', true, true); |
|
31 | + $this->setBatchSize(1000); |
|
32 | 32 | } |
33 | 33 | |
34 | 34 | public function execute() { |
35 | 35 | $context = new CsvImportSettings( |
36 | - $this->getOption( 'external-values-file' ), |
|
37 | - $this->getOption( 'dump-information-file' ), |
|
36 | + $this->getOption('external-values-file'), |
|
37 | + $this->getOption('dump-information-file'), |
|
38 | 38 | $this->mBatchSize, |
39 | 39 | $this->isQuiet() |
40 | 40 | ); |
@@ -26,7 +26,7 @@ discard block |
||
26 | 26 | * |
27 | 27 | * @throws InvalidArgumentException |
28 | 28 | */ |
29 | - public function __construct( array $results = array() ) { |
|
29 | + public function __construct(array $results = array()) { |
|
30 | 30 | Assert::parameterElementType( |
31 | 31 | 'WikibaseQuality\ExternalValidation\CrossCheck\Result\CrossCheckResult', |
32 | 32 | $results, |
@@ -41,7 +41,7 @@ discard block |
||
41 | 41 | * |
42 | 42 | * @param CrossCheckResult $result |
43 | 43 | */ |
44 | - public function add( CrossCheckResult $result ) { |
|
44 | + public function add(CrossCheckResult $result) { |
|
45 | 45 | $this->results[] = $result; |
46 | 46 | } |
47 | 47 | |
@@ -50,8 +50,8 @@ discard block |
||
50 | 50 | * |
51 | 51 | * @param self $resultList |
52 | 52 | */ |
53 | - public function merge( self $resultList ) { |
|
54 | - $this->results = array_merge( $this->results, $resultList->results ); |
|
53 | + public function merge(self $resultList) { |
|
54 | + $this->results = array_merge($this->results, $resultList->results); |
|
55 | 55 | } |
56 | 56 | |
57 | 57 | /** |
@@ -62,9 +62,9 @@ discard block |
||
62 | 62 | public function getPropertyIds() { |
63 | 63 | $propertyIds = array(); |
64 | 64 | |
65 | - foreach ( $this->results as $result ) { |
|
65 | + foreach ($this->results as $result) { |
|
66 | 66 | $propertyId = $result->getPropertyId(); |
67 | - if ( !in_array( $propertyId, $propertyIds ) ) { |
|
67 | + if (!in_array($propertyId, $propertyIds)) { |
|
68 | 68 | $propertyIds[] = $propertyId; |
69 | 69 | } |
70 | 70 | } |
@@ -79,16 +79,16 @@ discard block |
||
79 | 79 | * |
80 | 80 | * @return self |
81 | 81 | */ |
82 | - public function getByPropertyId( PropertyId $propertyId ) { |
|
82 | + public function getByPropertyId(PropertyId $propertyId) { |
|
83 | 83 | $results = array(); |
84 | 84 | |
85 | - foreach ( $this->results as $result ) { |
|
86 | - if ( $result->getPropertyId()->equals( $propertyId ) ) { |
|
85 | + foreach ($this->results as $result) { |
|
86 | + if ($result->getPropertyId()->equals($propertyId)) { |
|
87 | 87 | $results[] = $result; |
88 | 88 | } |
89 | 89 | } |
90 | 90 | |
91 | - return new self( $results ); |
|
91 | + return new self($results); |
|
92 | 92 | } |
93 | 93 | |
94 | 94 | /** |
@@ -107,7 +107,7 @@ discard block |
||
107 | 107 | * @codeCoverageIgnore |
108 | 108 | */ |
109 | 109 | public function getIterator() { |
110 | - return new ArrayIterator( $this->results ); |
|
110 | + return new ArrayIterator($this->results); |
|
111 | 111 | } |
112 | 112 | |
113 | 113 | /** |
@@ -116,7 +116,7 @@ discard block |
||
116 | 116 | * @return int |
117 | 117 | */ |
118 | 118 | public function count() { |
119 | - return count( $this->results ); |
|
119 | + return count($this->results); |
|
120 | 120 | } |
121 | 121 | |
122 | 122 | } |
@@ -43,7 +43,7 @@ discard block |
||
43 | 43 | * @param StatementGuidParser $statementGuidParser |
44 | 44 | * @param CrossChecker $crossChecker |
45 | 45 | */ |
46 | - public function __construct( EntityLookup $entityLookup, StatementGuidParser $statementGuidParser, CrossChecker $crossChecker ) { |
|
46 | + public function __construct(EntityLookup $entityLookup, StatementGuidParser $statementGuidParser, CrossChecker $crossChecker) { |
|
47 | 47 | $this->entityLookup = $entityLookup; |
48 | 48 | $this->statementGuidParser = $statementGuidParser; |
49 | 49 | $this->crossChecker = $crossChecker; |
@@ -56,11 +56,11 @@ discard block |
||
56 | 56 | * |
57 | 57 | * @return CrossCheckResultList|null |
58 | 58 | */ |
59 | - public function crossCheckEntityById( EntityId $entityId ) { |
|
60 | - $entity = $this->entityLookup->getEntity( $entityId ); |
|
59 | + public function crossCheckEntityById(EntityId $entityId) { |
|
60 | + $entity = $this->entityLookup->getEntity($entityId); |
|
61 | 61 | |
62 | - if ( $entity instanceof StatementListProvider ) { |
|
63 | - return $this->crossCheckStatements( $entity->getStatements() ); |
|
62 | + if ($entity instanceof StatementListProvider) { |
|
63 | + return $this->crossCheckStatements($entity->getStatements()); |
|
64 | 64 | } |
65 | 65 | |
66 | 66 | return null; |
@@ -73,12 +73,12 @@ discard block |
||
73 | 73 | * |
74 | 74 | * @return CrossCheckResultList[] |
75 | 75 | */ |
76 | - public function crossCheckEntitiesByIds( array $entityIds ) { |
|
77 | - Assert::parameterElementType( 'Wikibase\DataModel\Entity\EntityId', $entityIds, '$entityIds' ); |
|
76 | + public function crossCheckEntitiesByIds(array $entityIds) { |
|
77 | + Assert::parameterElementType('Wikibase\DataModel\Entity\EntityId', $entityIds, '$entityIds'); |
|
78 | 78 | |
79 | 79 | $results = array(); |
80 | - foreach ( $entityIds as $entityId ) { |
|
81 | - $results[$entityId->getSerialization()] = $this->crossCheckEntityById( $entityId ); |
|
80 | + foreach ($entityIds as $entityId) { |
|
81 | + $results[$entityId->getSerialization()] = $this->crossCheckEntityById($entityId); |
|
82 | 82 | } |
83 | 83 | |
84 | 84 | return $results; |
@@ -91,8 +91,8 @@ discard block |
||
91 | 91 | * |
92 | 92 | * @return CrossCheckResultList |
93 | 93 | */ |
94 | - public function crossCheckStatements( StatementList $statements ) { |
|
95 | - return $this->crossChecker->crossCheckStatements( $statements, $statements ); |
|
94 | + public function crossCheckStatements(StatementList $statements) { |
|
95 | + return $this->crossChecker->crossCheckStatements($statements, $statements); |
|
96 | 96 | } |
97 | 97 | |
98 | 98 | /** |
@@ -103,14 +103,14 @@ discard block |
||
103 | 103 | * @return CrossCheckResultList[] |
104 | 104 | * @throws InvalidArgumentException |
105 | 105 | */ |
106 | - public function crossCheckEntities( array $entities ) { |
|
107 | - Assert::parameterElementType( 'Wikibase\DataModel\Entity\EntityDocument', $entities, '$entities' ); |
|
106 | + public function crossCheckEntities(array $entities) { |
|
107 | + Assert::parameterElementType('Wikibase\DataModel\Entity\EntityDocument', $entities, '$entities'); |
|
108 | 108 | |
109 | 109 | $results = array(); |
110 | - foreach ( $entities as $entity ) { |
|
110 | + foreach ($entities as $entity) { |
|
111 | 111 | $entityId = $entity->getId()->getSerialization(); |
112 | - if ( $entity instanceof StatementListProvider ) { |
|
113 | - $results[$entityId] = $this->crossCheckStatements( $entity->getStatements() ); |
|
112 | + if ($entity instanceof StatementListProvider) { |
|
113 | + $results[$entityId] = $this->crossCheckStatements($entity->getStatements()); |
|
114 | 114 | } |
115 | 115 | } |
116 | 116 | |
@@ -126,13 +126,13 @@ discard block |
||
126 | 126 | * @return CrossCheckResultList|null |
127 | 127 | * @throws InvalidArgumentException |
128 | 128 | */ |
129 | - public function crossCheckEntityByIdWithProperties( EntityId $entityId, array $propertyIds ) { |
|
130 | - Assert::parameterElementType( 'Wikibase\DataModel\Entity\PropertyId', $propertyIds, '$propertyIds' ); |
|
129 | + public function crossCheckEntityByIdWithProperties(EntityId $entityId, array $propertyIds) { |
|
130 | + Assert::parameterElementType('Wikibase\DataModel\Entity\PropertyId', $propertyIds, '$propertyIds'); |
|
131 | 131 | |
132 | - $entity = $this->entityLookup->getEntity( $entityId ); |
|
132 | + $entity = $this->entityLookup->getEntity($entityId); |
|
133 | 133 | |
134 | - if ( $entity instanceof StatementListProvider ) { |
|
135 | - return $this->crossCheckStatementsWithProperties( $entity->getStatements(), $propertyIds ); |
|
134 | + if ($entity instanceof StatementListProvider) { |
|
135 | + return $this->crossCheckStatementsWithProperties($entity->getStatements(), $propertyIds); |
|
136 | 136 | } |
137 | 137 | |
138 | 138 | return null; |
@@ -147,13 +147,13 @@ discard block |
||
147 | 147 | * @return CrossCheckResultList[] |
148 | 148 | * @throws InvalidArgumentException |
149 | 149 | */ |
150 | - public function crossCheckEntitiesByIdWithProperties( array $entityIds, array $propertyIds ) { |
|
151 | - Assert::parameterElementType( 'Wikibase\DataModel\Entity\EntityId', $entityIds, '$entityIds' ); |
|
152 | - Assert::parameterElementType( 'Wikibase\DataModel\Entity\PropertyId', $propertyIds, '$propertyIds' ); |
|
150 | + public function crossCheckEntitiesByIdWithProperties(array $entityIds, array $propertyIds) { |
|
151 | + Assert::parameterElementType('Wikibase\DataModel\Entity\EntityId', $entityIds, '$entityIds'); |
|
152 | + Assert::parameterElementType('Wikibase\DataModel\Entity\PropertyId', $propertyIds, '$propertyIds'); |
|
153 | 153 | |
154 | 154 | $results = array(); |
155 | - foreach ( $entityIds as $entityId ) { |
|
156 | - $results[$entityId->getSerialization()] = $this->crossCheckEntityByIdWithProperties( $entityId, $propertyIds ); |
|
155 | + foreach ($entityIds as $entityId) { |
|
156 | + $results[$entityId->getSerialization()] = $this->crossCheckEntityByIdWithProperties($entityId, $propertyIds); |
|
157 | 157 | } |
158 | 158 | |
159 | 159 | return $results; |
@@ -168,17 +168,17 @@ discard block |
||
168 | 168 | * @return CrossCheckResultList |
169 | 169 | * @throws InvalidArgumentException |
170 | 170 | */ |
171 | - public function crossCheckStatementsWithProperties( StatementList $entityStatements, array $propertyIds ) { |
|
172 | - Assert::parameterElementType( 'Wikibase\DataModel\Entity\PropertyId', $propertyIds, '$propertyIds' ); |
|
171 | + public function crossCheckStatementsWithProperties(StatementList $entityStatements, array $propertyIds) { |
|
172 | + Assert::parameterElementType('Wikibase\DataModel\Entity\PropertyId', $propertyIds, '$propertyIds'); |
|
173 | 173 | |
174 | 174 | $statements = new StatementList(); |
175 | - foreach ( $entityStatements->toArray() as $statement ) { |
|
176 | - if ( in_array( $statement->getPropertyId(), $propertyIds ) ) { |
|
177 | - $statements->addStatement( $statement ); |
|
175 | + foreach ($entityStatements->toArray() as $statement) { |
|
176 | + if (in_array($statement->getPropertyId(), $propertyIds)) { |
|
177 | + $statements->addStatement($statement); |
|
178 | 178 | } |
179 | 179 | } |
180 | 180 | |
181 | - return $this->crossChecker->crossCheckStatements( $entityStatements, $statements ); |
|
181 | + return $this->crossChecker->crossCheckStatements($entityStatements, $statements); |
|
182 | 182 | } |
183 | 183 | |
184 | 184 | /** |
@@ -190,14 +190,14 @@ discard block |
||
190 | 190 | * @return CrossCheckResultList[] |
191 | 191 | * @throws InvalidArgumentException |
192 | 192 | */ |
193 | - public function crossCheckEntitiesWithProperties( array $entities, array $propertyIds ) { |
|
194 | - Assert::parameterElementType( 'Wikibase\DataModel\Entity\EntityDocument', $entities, '$entities' ); |
|
195 | - Assert::parameterElementType( 'Wikibase\DataModel\Entity\PropertyId', $propertyIds, '$propertyIds' ); |
|
193 | + public function crossCheckEntitiesWithProperties(array $entities, array $propertyIds) { |
|
194 | + Assert::parameterElementType('Wikibase\DataModel\Entity\EntityDocument', $entities, '$entities'); |
|
195 | + Assert::parameterElementType('Wikibase\DataModel\Entity\PropertyId', $propertyIds, '$propertyIds'); |
|
196 | 196 | |
197 | 197 | $results = array(); |
198 | - foreach ( $entities as $entity ) { |
|
198 | + foreach ($entities as $entity) { |
|
199 | 199 | $entityId = $entity->getId()->getSerialization(); |
200 | - if ( $entity instanceof StatementListProvider ) { |
|
200 | + if ($entity instanceof StatementListProvider) { |
|
201 | 201 | $results[$entityId] = $this->crossCheckStatementsWithProperties( |
202 | 202 | $entity->getStatements(), |
203 | 203 | $propertyIds |
@@ -216,12 +216,12 @@ discard block |
||
216 | 216 | * @return CrossCheckResultList |
217 | 217 | * @throws InvalidArgumentException |
218 | 218 | */ |
219 | - public function crossCheckStatementByGuid( $guid ) { |
|
220 | - $this->assertIsString( $guid, '$guid' ); |
|
219 | + public function crossCheckStatementByGuid($guid) { |
|
220 | + $this->assertIsString($guid, '$guid'); |
|
221 | 221 | |
222 | - $resultList = $this->crossCheckStatementsByGuids( array( $guid ) ); |
|
222 | + $resultList = $this->crossCheckStatementsByGuids(array($guid)); |
|
223 | 223 | |
224 | - return reset( $resultList ); |
|
224 | + return reset($resultList); |
|
225 | 225 | } |
226 | 226 | |
227 | 227 | /** |
@@ -232,21 +232,21 @@ discard block |
||
232 | 232 | * @return CrossCheckResultList[] |
233 | 233 | * @throws InvalidArgumentException |
234 | 234 | */ |
235 | - public function crossCheckStatementsByGuids( array $guids ) { |
|
236 | - $this->assertIsArrayOfStrings( $guids, '$guids' ); |
|
235 | + public function crossCheckStatementsByGuids(array $guids) { |
|
236 | + $this->assertIsArrayOfStrings($guids, '$guids'); |
|
237 | 237 | |
238 | 238 | $entityIds = array(); |
239 | 239 | $groupedStatementGuids = array(); |
240 | - foreach ( $guids as $guid ) { |
|
241 | - $serializedEntityId = $this->statementGuidParser->parse( $guid )->getEntityId(); |
|
240 | + foreach ($guids as $guid) { |
|
241 | + $serializedEntityId = $this->statementGuidParser->parse($guid)->getEntityId(); |
|
242 | 242 | $entityIds[$serializedEntityId->getSerialization()] = $serializedEntityId; |
243 | 243 | $groupedStatementGuids[$serializedEntityId->getSerialization()][] = $guid; |
244 | 244 | } |
245 | 245 | |
246 | 246 | $resultLists = array(); |
247 | - foreach ( $groupedStatementGuids as $serializedEntityId => $guidsOfEntity ) { |
|
248 | - $entityId = $entityIds[ $serializedEntityId ]; |
|
249 | - $resultLists[ $serializedEntityId ] = $this->crossCheckClaimsOfEntity( $entityId, $guidsOfEntity ); |
|
247 | + foreach ($groupedStatementGuids as $serializedEntityId => $guidsOfEntity) { |
|
248 | + $entityId = $entityIds[$serializedEntityId]; |
|
249 | + $resultLists[$serializedEntityId] = $this->crossCheckClaimsOfEntity($entityId, $guidsOfEntity); |
|
250 | 250 | } |
251 | 251 | |
252 | 252 | return $resultLists; |
@@ -258,18 +258,18 @@ discard block |
||
258 | 258 | * |
259 | 259 | * @return CrossCheckResultList|null |
260 | 260 | */ |
261 | - private function crossCheckClaimsOfEntity( EntityId $entityId, array $guids ) { |
|
262 | - $entity = $this->entityLookup->getEntity( $entityId ); |
|
261 | + private function crossCheckClaimsOfEntity(EntityId $entityId, array $guids) { |
|
262 | + $entity = $this->entityLookup->getEntity($entityId); |
|
263 | 263 | |
264 | - if ( $entity instanceof StatementListProvider ) { |
|
264 | + if ($entity instanceof StatementListProvider) { |
|
265 | 265 | $statements = new StatementList(); |
266 | - foreach ( $entity->getStatements()->toArray() as $statement ) { |
|
267 | - if ( in_array( $statement->getGuid(), $guids ) ) { |
|
268 | - $statements->addStatement( $statement ); |
|
266 | + foreach ($entity->getStatements()->toArray() as $statement) { |
|
267 | + if (in_array($statement->getGuid(), $guids)) { |
|
268 | + $statements->addStatement($statement); |
|
269 | 269 | } |
270 | 270 | } |
271 | 271 | |
272 | - return $this->crossChecker->crossCheckStatements( $entity->getStatements(), $statements ); |
|
272 | + return $this->crossChecker->crossCheckStatements($entity->getStatements(), $statements); |
|
273 | 273 | } |
274 | 274 | |
275 | 275 | return null; |
@@ -281,9 +281,9 @@ discard block |
||
281 | 281 | * |
282 | 282 | * @throws InvalidArgumentException |
283 | 283 | */ |
284 | - private function assertIsString( $string, $parameterName ) { |
|
285 | - if ( !is_string( $string ) ) { |
|
286 | - throw new InvalidArgumentException( "$parameterName must be string." ); |
|
284 | + private function assertIsString($string, $parameterName) { |
|
285 | + if (!is_string($string)) { |
|
286 | + throw new InvalidArgumentException("$parameterName must be string."); |
|
287 | 287 | } |
288 | 288 | } |
289 | 289 | |
@@ -293,10 +293,10 @@ discard block |
||
293 | 293 | * |
294 | 294 | * @throws InvalidArgumentException |
295 | 295 | */ |
296 | - private function assertIsArrayOfStrings( array $strings, $parameterName ) { |
|
297 | - foreach ( $strings as $string ) { |
|
298 | - if ( !is_string( $string ) ) { |
|
299 | - throw new InvalidArgumentException( "Each element of $parameterName must be string." ); |
|
296 | + private function assertIsArrayOfStrings(array $strings, $parameterName) { |
|
297 | + foreach ($strings as $string) { |
|
298 | + if (!is_string($string)) { |
|
299 | + throw new InvalidArgumentException("Each element of $parameterName must be string."); |
|
300 | 300 | } |
301 | 301 | } |
302 | 302 | } |