Completed
Push — master ( 4486c6...a154bc )
by
unknown
04:54
created
includes/Serializer/CrossCheckResultSerializer.php 1 patch
Spacing   +8 added lines, -8 removed lines patch added patch discarded remove patch
@@ -51,7 +51,7 @@  discard block
 block discarded – undo
51 51
 	 *
52 52
 	 * @return bool
53 53
 	 */
54
-	public function isSerializerFor( $object ) {
54
+	public function isSerializerFor($object) {
55 55
 		return $object instanceof CrossCheckResult;
56 56
 	}
57 57
 
@@ -63,25 +63,25 @@  discard block
 block discarded – undo
63 63
 	 * @return array
64 64
 	 * @throws UnsupportedObjectException
65 65
 	 */
66
-	public function serialize( $object ) {
67
-		if ( !$this->isSerializerFor( $object ) ) {
66
+	public function serialize($object) {
67
+		if (!$this->isSerializerFor($object)) {
68 68
 			throw new UnsupportedObjectException(
69 69
 				$object,
70 70
 				'CrossCheckResultSerializer can only serialize CrossCheckResult objects.'
71 71
 			);
72 72
 		}
73 73
 
74
-		return $this->getSerialized( $object );
74
+		return $this->getSerialized($object);
75 75
 	}
76 76
 
77
-	private function getSerialized( CrossCheckResult $crossCheckResult ) {
77
+	private function getSerialized(CrossCheckResult $crossCheckResult) {
78 78
 		return array(
79 79
 			'propertyId' => $crossCheckResult->getPropertyId()->getSerialization(),
80 80
 			'claimGuid' => $crossCheckResult->getClaimGuid(),
81 81
 			'externalId' => $crossCheckResult->getExternalId(),
82
-			'dataSource' => $this->dumpMetaInformationSerializer->serialize( $crossCheckResult->getDumpMetaInformation() ),
83
-			'comparisonResult' => $this->comparisonResultSerializer->serialize( $crossCheckResult->getComparisonResult() ),
84
-			'referenceResult' => $this->referenceResultSerializer->serialize( $crossCheckResult->getReferenceResult() )
82
+			'dataSource' => $this->dumpMetaInformationSerializer->serialize($crossCheckResult->getDumpMetaInformation()),
83
+			'comparisonResult' => $this->comparisonResultSerializer->serialize($crossCheckResult->getComparisonResult()),
84
+			'referenceResult' => $this->referenceResultSerializer->serialize($crossCheckResult->getReferenceResult())
85 85
 		);
86 86
 	}
87 87
 
Please login to merge, or discard this patch.
maintenance/UpdateExternalData.php 1 patch
Spacing   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -7,10 +7,10 @@  discard block
 block discarded – undo
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' )
12
-	: __DIR__ . '/../../..';
13
-require_once $basePath . '/maintenance/Maintenance.php';
10
+$basePath = getenv('MW_INSTALL_PATH') !== false
11
+	? getenv('MW_INSTALL_PATH')
12
+	: __DIR__.'/../../..';
13
+require_once $basePath.'/maintenance/Maintenance.php';
14 14
 
15 15
 /**
16 16
  * Maintenance script that evokes updates of wbqev_external_data, wbqev_dump_information, wbqev_identifier_properties
@@ -25,17 +25,17 @@  discard block
 block discarded – undo
25 25
 	public function __construct() {
26 26
 		parent::__construct();
27 27
 
28
-		$this->addDescription( 'Imports external entities from given CSV files into the local '
29
-			. 'database. CSV files can be generated using the DumpConverter.' );
30
-		$this->addOption( 'external-values-file', 'CSV file containing external values for import.', true, true );
31
-		$this->addOption( 'dump-information-file', 'CSV file containing dump meta information for import.', true, true );
32
-		$this->setBatchSize( 1000 );
28
+		$this->addDescription('Imports external entities from given CSV files into the local '
29
+			. 'database. CSV files can be generated using the DumpConverter.');
30
+		$this->addOption('external-values-file', 'CSV file containing external values for import.', true, true);
31
+		$this->addOption('dump-information-file', 'CSV file containing dump meta information for import.', true, true);
32
+		$this->setBatchSize(1000);
33 33
 	}
34 34
 
35 35
 	public function execute() {
36 36
 		$context = new CsvImportSettings(
37
-			$this->getOption( 'external-values-file' ),
38
-			$this->getOption( 'dump-information-file' ),
37
+			$this->getOption('external-values-file'),
38
+			$this->getOption('dump-information-file'),
39 39
 			$this->mBatchSize,
40 40
 			$this->isQuiet()
41 41
 		);
Please login to merge, or discard this patch.
includes/CrossCheck/Comparer/QuantityValueComparer.php 1 patch
Spacing   +6 added lines, -6 removed lines patch added patch discarded remove patch
@@ -23,9 +23,9 @@  discard block
 block discarded – undo
23 23
 	 * @throws InvalidArgumentException
24 24
 	 * @return string One of the ComparisonResult::STATUS_... constants.
25 25
 	 */
26
-	public function compare( DataValue $value, DataValue $comparativeValue ) {
27
-		if ( !$this->canCompare( $value, $comparativeValue ) ) {
28
-			throw new InvalidArgumentException( 'Given values can not be compared using this comparer.' );
26
+	public function compare(DataValue $value, DataValue $comparativeValue) {
27
+		if (!$this->canCompare($value, $comparativeValue)) {
28
+			throw new InvalidArgumentException('Given values can not be compared using this comparer.');
29 29
 		}
30 30
 
31 31
 		/**
@@ -33,8 +33,8 @@  discard block
 block discarded – undo
33 33
 		 * @var QuantityValue $comparativeValue
34 34
 		 */
35 35
 
36
-		if ( $comparativeValue->getLowerBound()->compare( $value->getUpperBound() ) <= 0 &&
37
-			$comparativeValue->getUpperBound()->compare( $value->getLowerBound() ) >= 0
36
+		if ($comparativeValue->getLowerBound()->compare($value->getUpperBound()) <= 0 &&
37
+			$comparativeValue->getUpperBound()->compare($value->getLowerBound()) >= 0
38 38
 		) {
39 39
 			return ComparisonResult::STATUS_MATCH;
40 40
 		}
@@ -50,7 +50,7 @@  discard block
 block discarded – undo
50 50
 	 *
51 51
 	 * @return bool
52 52
 	 */
53
-	public function canCompare( DataValue $value, DataValue $comparativeValue ) {
53
+	public function canCompare(DataValue $value, DataValue $comparativeValue) {
54 54
 		return $value instanceof QuantityValue && $comparativeValue instanceof QuantityValue;
55 55
 	}
56 56
 
Please login to merge, or discard this patch.
includes/ExternalDataRepo.php 1 patch
Spacing   +31 added lines, -31 removed lines patch added patch discarded remove patch
@@ -24,23 +24,23 @@  discard block
 block discarded – undo
24 24
 	 * @param PropertyId[] $propertyIds
25 25
 	 * @return array
26 26
 	 */
27
-	public function getExternalData( array $dumpIds, array $externalIds, array $propertyIds ) {
28
-		Assert::parameterElementType( 'string', $dumpIds, '$dumpIds' );
29
-		Assert::parameterElementType( 'string', $externalIds, '$externalIds' );
30
-		Assert::parameterElementType( PropertyId::class, $propertyIds, '$propertyIds' );
31
-		Assert::parameter( count( $dumpIds ) > 0, '$dumpIds', '$dumpIds has to contain at least one element.' );
32
-		Assert::parameter( count( $externalIds ) > 0, '$externalIds', '$externalIds has to contain at least one element.' );
27
+	public function getExternalData(array $dumpIds, array $externalIds, array $propertyIds) {
28
+		Assert::parameterElementType('string', $dumpIds, '$dumpIds');
29
+		Assert::parameterElementType('string', $externalIds, '$externalIds');
30
+		Assert::parameterElementType(PropertyId::class, $propertyIds, '$propertyIds');
31
+		Assert::parameter(count($dumpIds) > 0, '$dumpIds', '$dumpIds has to contain at least one element.');
32
+		Assert::parameter(count($externalIds) > 0, '$externalIds', '$externalIds has to contain at least one element.');
33 33
 
34 34
 		$conditions = array(
35 35
 			'dump_id' => $dumpIds,
36 36
 			'external_id' => $externalIds
37 37
 		);
38
-		if ( $propertyIds ) {
38
+		if ($propertyIds) {
39 39
 			$conditions['pid'] = $propertyIds;
40 40
 		}
41 41
 
42 42
 		$externalData = array();
43
-		$db = wfGetDB( DB_REPLICA );
43
+		$db = wfGetDB(DB_REPLICA);
44 44
 		$result = $db->select(
45 45
 			self::TABLE_NAME,
46 46
 			array(
@@ -52,7 +52,7 @@  discard block
 block discarded – undo
52 52
 			$conditions
53 53
 		);
54 54
 
55
-		foreach ( $result as $row ) {
55
+		foreach ($result as $row) {
56 56
 			$externalData[$row->dump_id][$row->external_id][$row->pid][] = $row->external_value;
57 57
 		}
58 58
 
@@ -68,13 +68,13 @@  discard block
 block discarded – undo
68 68
 	 * @param string $externalValue
69 69
 	 * @return bool
70 70
 	 */
71
-	public function insert( $dumpId, $externalId, PropertyId $propertyId, $externalValue ) {
72
-		Assert::parameterType( 'string', $dumpId, '$dumpId' );
73
-		Assert::parameterType( 'string', $externalId, '$externalId' );
74
-		Assert::parameterType( 'string', $externalValue, '$externalValue' );
71
+	public function insert($dumpId, $externalId, PropertyId $propertyId, $externalValue) {
72
+		Assert::parameterType('string', $dumpId, '$dumpId');
73
+		Assert::parameterType('string', $externalId, '$externalId');
74
+		Assert::parameterType('string', $externalValue, '$externalValue');
75 75
 
76
-		$externalDataBatch = array( func_get_args() );
77
-		return $this->insertBatch( $externalDataBatch );
76
+		$externalDataBatch = array(func_get_args());
77
+		return $this->insertBatch($externalDataBatch);
78 78
 	}
79 79
 
80 80
 	/**
@@ -84,10 +84,10 @@  discard block
 block discarded – undo
84 84
 	 * @throws DBError
85 85
 	 * @return bool
86 86
 	 */
87
-	public function insertBatch( array $externalDataBatch ) {
88
-		$db = wfGetDB( DB_MASTER );
87
+	public function insertBatch(array $externalDataBatch) {
88
+		$db = wfGetDB(DB_MASTER);
89 89
 		$accumulator = array_map(
90
-			function ( $externalData ) use ( $db ) {
90
+			function($externalData) use ($db) {
91 91
 				return array(
92 92
 					'dump_id' => $externalData[0],
93 93
 					'external_id' => $externalData[1],
@@ -100,10 +100,10 @@  discard block
 block discarded – undo
100 100
 
101 101
 		try {
102 102
 			$db->begin();
103
-			$result = $db->insert( self::TABLE_NAME, $accumulator );
103
+			$result = $db->insert(self::TABLE_NAME, $accumulator);
104 104
 			$db->commit();
105 105
 		}
106
-		catch( DBError $ex ) {
106
+		catch (DBError $ex) {
107 107
 			$db->rollback();
108 108
 			throw $ex;
109 109
 		}
@@ -118,21 +118,21 @@  discard block
 block discarded – undo
118 118
 	 * @param int $batchSize
119 119
 	 * @throws \DBUnexpectedError
120 120
 	 */
121
-	public function deleteOfDump( $dumpId, $batchSize = 1000 ) {
122
-		Assert::parameterType( 'string', $dumpId, '$dumpId' );
123
-		Assert::parameterType( 'integer', $batchSize, 'batchSize' );
121
+	public function deleteOfDump($dumpId, $batchSize = 1000) {
122
+		Assert::parameterType('string', $dumpId, '$dumpId');
123
+		Assert::parameterType('integer', $batchSize, 'batchSize');
124 124
 
125
-		$db = wfGetDB( DB_MASTER );
126
-		if ( $db->getType() === 'sqlite' ) {
127
-			$db->delete( self::TABLE_NAME, array( 'dump_id' => $dumpId ) );
125
+		$db = wfGetDB(DB_MASTER);
126
+		if ($db->getType() === 'sqlite') {
127
+			$db->delete(self::TABLE_NAME, array('dump_id' => $dumpId));
128 128
 		} else {
129 129
 			do {
130
-				$db->commit( __METHOD__, 'flush' );
130
+				$db->commit(__METHOD__, 'flush');
131 131
 				wfGetLBFactory()->waitForReplication();
132
-				$table = $db->tableName( self::TABLE_NAME );
133
-				$condition = 'dump_id = ' . $db->addQuotes( $dumpId );
134
-				$db->query( sprintf( 'DELETE FROM %s WHERE %s LIMIT %d', $table, $condition, $batchSize ) );
135
-			} while ( $db->affectedRows() > 0 );
132
+				$table = $db->tableName(self::TABLE_NAME);
133
+				$condition = 'dump_id = '.$db->addQuotes($dumpId);
134
+				$db->query(sprintf('DELETE FROM %s WHERE %s LIMIT %d', $table, $condition, $batchSize));
135
+			} while ($db->affectedRows() > 0);
136 136
 		}
137 137
 	}
138 138
 
Please login to merge, or discard this patch.