Completed
Push — master ( 9ae715...9d4e1e )
by
unknown
01:54
created
includes/CrossCheck/ValueParser/MultilingualTextValueParser.php 1 patch
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -17,7 +17,7 @@  discard block
 block discarded – undo
17 17
 	 */
18 18
 	private $monolingualTextValueParser;
19 19
 
20
-	public function __construct( ValueParser $monolingualTextValueParser ) {
20
+	public function __construct(ValueParser $monolingualTextValueParser) {
21 21
 		$this->monolingualTextValueParser = $monolingualTextValueParser;
22 22
 	}
23 23
 
@@ -28,11 +28,11 @@  discard block
 block discarded – undo
28 28
 	 *
29 29
 	 * @return MultilingualTextValue
30 30
 	 */
31
-	public function parse( $value ) {
32
-		Assert::parameterType( 'string', $value, '$value' );
31
+	public function parse($value) {
32
+		Assert::parameterType('string', $value, '$value');
33 33
 
34 34
 		return new MultilingualTextValue(
35
-			[ $this->monolingualTextValueParser->parse( $value ) ]
35
+			[$this->monolingualTextValueParser->parse($value)]
36 36
 		);
37 37
 	}
38 38
 
Please login to merge, or discard this patch.
includes/Serializer/SerializerFactory.php 1 patch
Spacing   +3 added lines, -3 removed lines patch added patch discarded remove patch
@@ -20,7 +20,7 @@  discard block
 block discarded – undo
20 20
 	 */
21 21
 	private $referenceSerializer;
22 22
 
23
-	public function __construct( Serializer $dataValueSerializer, Serializer $referenceSerializer ) {
23
+	public function __construct(Serializer $dataValueSerializer, Serializer $referenceSerializer) {
24 24
 		$this->dataValueSerializer = $dataValueSerializer;
25 25
 		$this->referenceSerializer = $referenceSerializer;
26 26
 	}
@@ -42,7 +42,7 @@  discard block
 block discarded – undo
42 42
 	 * @return Serializer
43 43
 	 */
44 44
 	public function newComparisonResultSerializer() {
45
-		return new ComparisonResultSerializer( $this->dataValueSerializer );
45
+		return new ComparisonResultSerializer($this->dataValueSerializer);
46 46
 	}
47 47
 
48 48
 	/**
@@ -73,7 +73,7 @@  discard block
 block discarded – undo
73 73
 	 * @return Serializer
74 74
 	 */
75 75
 	public function newReferenceResultSerializer() {
76
-		return new ReferenceResultSerializer( $this->referenceSerializer );
76
+		return new ReferenceResultSerializer($this->referenceSerializer);
77 77
 	}
78 78
 
79 79
 }
Please login to merge, or discard this patch.
includes/Serializer/ComparisonResultSerializer.php 1 patch
Spacing   +10 added lines, -10 removed lines patch added patch discarded remove patch
@@ -18,7 +18,7 @@  discard block
 block discarded – undo
18 18
 	 */
19 19
 	private $dataValueSerializer;
20 20
 
21
-	public function __construct( Serializer $dataValueSerializer ) {
21
+	public function __construct(Serializer $dataValueSerializer) {
22 22
 		$this->dataValueSerializer = $dataValueSerializer;
23 23
 	}
24 24
 
@@ -29,7 +29,7 @@  discard block
 block discarded – undo
29 29
 	 *
30 30
 	 * @return bool
31 31
 	 */
32
-	public function isSerializerFor( $object ) {
32
+	public function isSerializerFor($object) {
33 33
 		return $object instanceof ComparisonResult;
34 34
 	}
35 35
 
@@ -41,29 +41,29 @@  discard block
 block discarded – undo
41 41
 	 * @return array
42 42
 	 * @throws UnsupportedObjectException
43 43
 	 */
44
-	public function serialize( $object ) {
45
-		if ( !$this->isSerializerFor( $object ) ) {
44
+	public function serialize($object) {
45
+		if (!$this->isSerializerFor($object)) {
46 46
 			throw new UnsupportedObjectException(
47 47
 				$object,
48 48
 				'ComparisonResultSerializer can only serialize ComparisonResult objects.'
49 49
 			);
50 50
 		}
51 51
 
52
-		return $this->getSerialized( $object );
52
+		return $this->getSerialized($object);
53 53
 	}
54 54
 
55
-	private function getSerialized( ComparisonResult $comparisonResult ) {
55
+	private function getSerialized(ComparisonResult $comparisonResult) {
56 56
 		$dataValueSerializer = $this->dataValueSerializer;
57 57
 		$externalValues = array_map(
58
-			function ( $dataValue ) use ( $dataValueSerializer ) {
59
-				return $dataValueSerializer->serialize( $dataValue );
58
+			function($dataValue) use ($dataValueSerializer) {
59
+				return $dataValueSerializer->serialize($dataValue);
60 60
 			},
61 61
 			$comparisonResult->getExternalValues()
62 62
 		);
63
-		$this->setIndexedTagName( $externalValues, 'dataValue' );
63
+		$this->setIndexedTagName($externalValues, 'dataValue');
64 64
 
65 65
 		return [
66
-			'localValue' => $this->dataValueSerializer->serialize( $comparisonResult->getLocalValue() ),
66
+			'localValue' => $this->dataValueSerializer->serialize($comparisonResult->getLocalValue()),
67 67
 			'externalValues' => $externalValues,
68 68
 			'result' => $comparisonResult->getStatus()
69 69
 		];
Please login to merge, or discard this patch.
includes/Serializer/CrossCheckResultListSerializer.php 1 patch
Spacing   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -18,7 +18,7 @@  discard block
 block discarded – undo
18 18
 	 */
19 19
 	private $crossCheckResultSerializer;
20 20
 
21
-	public function __construct( Serializer $crossCheckResultSerializer ) {
21
+	public function __construct(Serializer $crossCheckResultSerializer) {
22 22
 		$this->crossCheckResultSerializer = $crossCheckResultSerializer;
23 23
 	}
24 24
 
@@ -29,7 +29,7 @@  discard block
 block discarded – undo
29 29
 	 *
30 30
 	 * @return bool
31 31
 	 */
32
-	public function isSerializerFor( $object ) {
32
+	public function isSerializerFor($object) {
33 33
 		return $object instanceof CrossCheckResultList;
34 34
 	}
35 35
 
@@ -41,29 +41,29 @@  discard block
 block discarded – undo
41 41
 	 * @return array
42 42
 	 * @throws UnsupportedObjectException
43 43
 	 */
44
-	public function serialize( $object ) {
45
-		if ( !$this->isSerializerFor( $object ) ) {
44
+	public function serialize($object) {
45
+		if (!$this->isSerializerFor($object)) {
46 46
 			throw new UnsupportedObjectException(
47 47
 				$object,
48 48
 				'CrossCheckResultListSerializer can only serialize CrossCheckResultList objects.'
49 49
 			);
50 50
 		}
51 51
 
52
-		return $this->getSerialized( $object );
52
+		return $this->getSerialized($object);
53 53
 	}
54 54
 
55
-	private function getSerialized( CrossCheckResultList $resultList ) {
55
+	private function getSerialized(CrossCheckResultList $resultList) {
56 56
 		$serialization = [];
57
-		$this->setKeyAttributeName( $serialization, 'property', 'id' );
57
+		$this->setKeyAttributeName($serialization, 'property', 'id');
58 58
 
59
-		foreach ( $resultList->getPropertyIds() as $propertyId ) {
59
+		foreach ($resultList->getPropertyIds() as $propertyId) {
60 60
 			$id = $propertyId->getSerialization();
61 61
 			$resultSerialization = [];
62 62
 
63
-			$this->setIndexedTagName( $resultSerialization, 'result' );
63
+			$this->setIndexedTagName($resultSerialization, 'result');
64 64
 
65
-			foreach ( $resultList->getByPropertyId( $propertyId ) as $result ) {
66
-				$resultSerialization[] = $this->crossCheckResultSerializer->serialize( $result );
65
+			foreach ($resultList->getByPropertyId($propertyId) as $result) {
66
+				$resultSerialization[] = $this->crossCheckResultSerializer->serialize($result);
67 67
 			}
68 68
 
69 69
 			$serialization[$id] = $resultSerialization;
Please login to merge, or discard this patch.
includes/Serializer/ReferenceResultSerializer.php 1 patch
Spacing   +7 added lines, -7 removed lines patch added patch discarded remove patch
@@ -18,7 +18,7 @@  discard block
 block discarded – undo
18 18
 	 */
19 19
 	private $referenceSerializer;
20 20
 
21
-	public function __construct( Serializer $referenceSerializer ) {
21
+	public function __construct(Serializer $referenceSerializer) {
22 22
 		$this->referenceSerializer = $referenceSerializer;
23 23
 	}
24 24
 
@@ -29,7 +29,7 @@  discard block
 block discarded – undo
29 29
 	 *
30 30
 	 * @return bool
31 31
 	 */
32
-	public function isSerializerFor( $object ) {
32
+	public function isSerializerFor($object) {
33 33
 		return $object instanceof ReferenceResult;
34 34
 	}
35 35
 
@@ -41,20 +41,20 @@  discard block
 block discarded – undo
41 41
 	 * @return array
42 42
 	 * @throws UnsupportedObjectException
43 43
 	 */
44
-	public function serialize( $object ) {
45
-		if ( !$this->isSerializerFor( $object ) ) {
44
+	public function serialize($object) {
45
+		if (!$this->isSerializerFor($object)) {
46 46
 			throw new UnsupportedObjectException(
47 47
 				$object,
48 48
 				'ReferenceResultSerializer can only serialize ReferenceResult objects.'
49 49
 			);
50 50
 		}
51 51
 
52
-		return $this->getSerialized( $object );
52
+		return $this->getSerialized($object);
53 53
 	}
54 54
 
55
-	private function getSerialized( ReferenceResult $referenceResult ) {
55
+	private function getSerialized(ReferenceResult $referenceResult) {
56 56
 		return [
57
-			'reference' => $this->referenceSerializer->serialize( $referenceResult->getReference() ),
57
+			'reference' => $this->referenceSerializer->serialize($referenceResult->getReference()),
58 58
 			'status' => $referenceResult->getStatus()
59 59
 		];
60 60
 	}
Please login to merge, or discard this patch.
specials/SpecialExternalDatabases.php 1 patch
Spacing   +38 added lines, -38 removed lines patch added patch discarded remove patch
@@ -53,10 +53,10 @@  discard block
 block discarded – undo
53 53
 		EntityIdHtmlLinkFormatterFactory $entityIdHtmlLinkFormatterFactory,
54 54
 		DumpMetaInformationLookup $dumpMetaInformationRepo
55 55
 	) {
56
-		parent::__construct( 'ExternalDatabases' );
56
+		parent::__construct('ExternalDatabases');
57 57
 
58 58
 		$this->entityIdLinkFormatter = $entityIdHtmlLinkFormatterFactory->getEntityIdFormatter(
59
-			new LanguageLabelDescriptionLookup( $termLookup, $this->getLanguage()->getCode() )
59
+			new LanguageLabelDescriptionLookup($termLookup, $this->getLanguage()->getCode())
60 60
 		);
61 61
 
62 62
 		$this->dumpMetaInformationRepo = $dumpMetaInformationRepo;
@@ -77,7 +77,7 @@  discard block
 block discarded – undo
77 77
 	 * @return string
78 78
 	 */
79 79
 	public function getDescription() {
80
-		return $this->msg( 'wbqev-externaldbs' )->text();
80
+		return $this->msg('wbqev-externaldbs')->text();
81 81
 	}
82 82
 
83 83
 	/**
@@ -85,51 +85,51 @@  discard block
 block discarded – undo
85 85
 	 *
86 86
 	 * @param string|null $subPage
87 87
 	 */
88
-	public function execute( $subPage ) {
88
+	public function execute($subPage) {
89 89
 		$out = $this->getOutput();
90 90
 
91 91
 		$this->setHeaders();
92 92
 
93 93
 		$out->addHTML(
94
-			Html::openElement( 'p' )
95
-			. $this->msg( 'wbqev-externaldbs-instructions' )->parse()
96
-			. Html::closeElement( 'p' )
97
-			. Html::openElement( 'h3' )
98
-			. $this->msg( 'wbqev-externaldbs-overview-headline' )->parse()
99
-			. Html::closeElement( 'h3' )
94
+			Html::openElement('p')
95
+			. $this->msg('wbqev-externaldbs-instructions')->parse()
96
+			. Html::closeElement('p')
97
+			. Html::openElement('h3')
98
+			. $this->msg('wbqev-externaldbs-overview-headline')->parse()
99
+			. Html::closeElement('h3')
100 100
 		);
101 101
 
102 102
 		$dumps = $this->dumpMetaInformationRepo->getAll();
103
-		if ( count( $dumps ) > 0 ) {
103
+		if (count($dumps) > 0) {
104 104
 			$groupedDumpMetaInformation = [];
105
-			foreach ( $dumps as $dump ) {
105
+			foreach ($dumps as $dump) {
106 106
 				$sourceItemId = $dump->getSourceItemId()->getSerialization();
107 107
 				$groupedDumpMetaInformation[$sourceItemId][] = $dump;
108 108
 			}
109 109
 
110 110
 			$table = new HtmlTableBuilder(
111 111
 				[
112
-					$this->msg( 'wbqev-externaldbs-name' )->escaped(),
113
-					$this->msg( 'wbqev-externaldbs-id' )->escaped(),
114
-					$this->msg( 'wbqev-externaldbs-import-date' )->escaped(),
115
-					$this->msg( 'wbqev-externaldbs-language' )->escaped(),
116
-					$this->msg( 'wbqev-externaldbs-source-urls' )->escaped(),
117
-					$this->msg( 'wbqev-externaldbs-size' )->escaped(),
118
-					$this->msg( 'wbqev-externaldbs-license' )->escaped()
112
+					$this->msg('wbqev-externaldbs-name')->escaped(),
113
+					$this->msg('wbqev-externaldbs-id')->escaped(),
114
+					$this->msg('wbqev-externaldbs-import-date')->escaped(),
115
+					$this->msg('wbqev-externaldbs-language')->escaped(),
116
+					$this->msg('wbqev-externaldbs-source-urls')->escaped(),
117
+					$this->msg('wbqev-externaldbs-size')->escaped(),
118
+					$this->msg('wbqev-externaldbs-license')->escaped()
119 119
 				],
120 120
 				true
121 121
 			);
122 122
 
123
-			foreach ( $groupedDumpMetaInformation as $dumpMetaInformation ) {
124
-				$table->appendRows( $this->getRowGroup( $dumpMetaInformation ) );
123
+			foreach ($groupedDumpMetaInformation as $dumpMetaInformation) {
124
+				$table->appendRows($this->getRowGroup($dumpMetaInformation));
125 125
 			}
126 126
 
127
-			$out->addHTML( $table->toHtml() );
127
+			$out->addHTML($table->toHtml());
128 128
 		} else {
129 129
 			$out->addHTML(
130
-				Html::openElement( 'p' )
131
-				. $this->msg( 'wbqev-externaldbs-no-databases' )->escaped()
132
-				. Html::closeElement( 'p' )
130
+				Html::openElement('p')
131
+				. $this->msg('wbqev-externaldbs-no-databases')->escaped()
132
+				. Html::closeElement('p')
133 133
 			);
134 134
 		}
135 135
 	}
@@ -141,12 +141,12 @@  discard block
 block discarded – undo
141 141
 	 *
142 142
 	 * @return array
143 143
 	 */
144
-	private function getRowGroup( array $dumpMetaInformationGroup ) {
144
+	private function getRowGroup(array $dumpMetaInformationGroup) {
145 145
 		$rows = [];
146 146
 
147
-		foreach ( $dumpMetaInformationGroup as $dumpMetaInformation ) {
147
+		foreach ($dumpMetaInformationGroup as $dumpMetaInformation) {
148 148
 			$dumpId = $dumpMetaInformation->getDumpId();
149
-			$importDate = $this->getLanguage()->timeanddate( $dumpMetaInformation->getImportDate() );
149
+			$importDate = $this->getLanguage()->timeanddate($dumpMetaInformation->getImportDate());
150 150
 			$language = Language::fetchLanguageName(
151 151
 				$dumpMetaInformation->getLanguageCode(),
152 152
 				$this->getLanguage()->getCode()
@@ -155,23 +155,23 @@  discard block
 block discarded – undo
155 155
 				$dumpMetaInformation->getSourceUrl(),
156 156
 				$dumpMetaInformation->getSourceUrl()
157 157
 			);
158
-			$size = $this->getLanguage()->formatSize( $dumpMetaInformation->getSize() );
159
-			$license = $this->entityIdLinkFormatter->formatEntityId( $dumpMetaInformation->getLicenseItemId() );
158
+			$size = $this->getLanguage()->formatSize($dumpMetaInformation->getSize());
159
+			$license = $this->entityIdLinkFormatter->formatEntityId($dumpMetaInformation->getLicenseItemId());
160 160
 			$rows[] = [
161
-				new HtmlTableCellBuilder( $dumpId ),
162
-				new HtmlTableCellBuilder( $importDate ),
163
-				new HtmlTableCellBuilder( $language ),
164
-				new HtmlTableCellBuilder( $sourceUrl, [], true ),
165
-				new HtmlTableCellBuilder( $size ),
166
-				new HtmlTableCellBuilder( $license, [], true )
161
+				new HtmlTableCellBuilder($dumpId),
162
+				new HtmlTableCellBuilder($importDate),
163
+				new HtmlTableCellBuilder($language),
164
+				new HtmlTableCellBuilder($sourceUrl, [], true),
165
+				new HtmlTableCellBuilder($size),
166
+				new HtmlTableCellBuilder($license, [], true)
167 167
 			];
168 168
 		}
169 169
 
170 170
 		array_unshift(
171 171
 			$rows[0],
172 172
 			new HtmlTableCellBuilder(
173
-				$this->entityIdLinkFormatter->formatEntityId( $dumpMetaInformationGroup[0]->getSourceItemId() ),
174
-				[ 'rowspan' => (string)count( $dumpMetaInformationGroup ) ],
173
+				$this->entityIdLinkFormatter->formatEntityId($dumpMetaInformationGroup[0]->getSourceItemId()),
174
+				['rowspan' => (string)count($dumpMetaInformationGroup)],
175 175
 				true
176 176
 			)
177 177
 		);
Please login to merge, or discard this patch.
WikibaseQualityExternalValidationHooks.php 1 patch
Spacing   +4 added lines, -4 removed lines patch added patch discarded remove patch
@@ -15,10 +15,10 @@
 block discarded – undo
15 15
 	 *
16 16
 	 * @return bool
17 17
 	 */
18
-	public static function onCreateSchema( DatabaseUpdater $updater ) {
19
-		$updater->addExtensionTable( 'wbqev_dump_information', __DIR__ . '/sql/create_wbqev_dump_information.sql' );
20
-		$updater->addExtensionTable( 'wbqev_external_data', __DIR__ . '/sql/create_wbqev_external_data.sql' );
21
-		$updater->addExtensionTable( 'wbqev_identifier_properties', __DIR__ . '/sql/create_wbqev_identifier_properties.sql' );
18
+	public static function onCreateSchema(DatabaseUpdater $updater) {
19
+		$updater->addExtensionTable('wbqev_dump_information', __DIR__.'/sql/create_wbqev_dump_information.sql');
20
+		$updater->addExtensionTable('wbqev_external_data', __DIR__.'/sql/create_wbqev_external_data.sql');
21
+		$updater->addExtensionTable('wbqev_identifier_properties', __DIR__.'/sql/create_wbqev_identifier_properties.sql');
22 22
 
23 23
 		return true;
24 24
 	}
Please login to merge, or discard this patch.
includes/DumpMetaInformation/SqlDumpMetaInformationRepo.php 1 patch
Spacing   +42 added lines, -42 removed lines patch added patch discarded remove patch
@@ -28,18 +28,18 @@  discard block
 block discarded – undo
28 28
 	 * @return DumpMetaInformation[]
29 29
 	 * @throws InvalidArgumentException
30 30
 	 */
31
-	public function getWithIds( array $dumpIds ) {
32
-		if ( $dumpIds === [] ) {
31
+	public function getWithIds(array $dumpIds) {
32
+		if ($dumpIds === []) {
33 33
 			return [];
34 34
 		}
35 35
 
36
-		foreach ( $dumpIds as $dumpId ) {
37
-			if ( !is_string( $dumpId ) ) {
38
-				throw new InvalidArgumentException( '$dumpIds must contain only strings.' );
36
+		foreach ($dumpIds as $dumpId) {
37
+			if (!is_string($dumpId)) {
38
+				throw new InvalidArgumentException('$dumpIds must contain only strings.');
39 39
 			}
40 40
 		}
41 41
 
42
-		$db = wfGetDB( DB_REPLICA );
42
+		$db = wfGetDB(DB_REPLICA);
43 43
 		$result = $db->select(
44 44
 			[
45 45
 				self::META_TABLE_NAME,
@@ -59,7 +59,7 @@  discard block
 block discarded – undo
59 59
 			]
60 60
 		);
61 61
 
62
-		return $this->buildDumpMetaInformationFromResult( $result );
62
+		return $this->buildDumpMetaInformationFromResult($result);
63 63
 	}
64 64
 
65 65
 	/**
@@ -71,20 +71,20 @@  discard block
 block discarded – undo
71 71
 	 * @throws InvalidArgumentException
72 72
 	 * @return DumpMetaInformation[]
73 73
 	 */
74
-	public function getWithIdentifierProperties( array $identifierPropertyIds ) {
75
-		if ( $identifierPropertyIds === [] ) {
74
+	public function getWithIdentifierProperties(array $identifierPropertyIds) {
75
+		if ($identifierPropertyIds === []) {
76 76
 			return [];
77 77
 		}
78 78
 
79
-		foreach ( $identifierPropertyIds as $propertyId ) {
80
-			if ( !( $propertyId instanceof PropertyId ) ) {
81
-				throw new InvalidArgumentException( '$identifierProperties must contain only PropertyIds.' );
79
+		foreach ($identifierPropertyIds as $propertyId) {
80
+			if (!($propertyId instanceof PropertyId)) {
81
+				throw new InvalidArgumentException('$identifierProperties must contain only PropertyIds.');
82 82
 			}
83 83
 		}
84 84
 
85
-		$db = wfGetDB( DB_REPLICA );
85
+		$db = wfGetDB(DB_REPLICA);
86 86
 		$identifierPropertyIds = array_map(
87
-			function( PropertyId $id ) {
87
+			function(PropertyId $id) {
88 88
 				return $id->getSerialization();
89 89
 			},
90 90
 			$identifierPropertyIds
@@ -97,13 +97,13 @@  discard block
 block discarded – undo
97 97
 			]
98 98
 		);
99 99
 		$dumpIds = [];
100
-		foreach ( $result as $row ) {
101
-			if ( !in_array( $row->dump_id, $dumpIds ) ) {
100
+		foreach ($result as $row) {
101
+			if (!in_array($row->dump_id, $dumpIds)) {
102 102
 				$dumpIds[] = $row->dump_id;
103 103
 			}
104 104
 		}
105 105
 
106
-		return $this->getWithIds( $dumpIds );
106
+		return $this->getWithIds($dumpIds);
107 107
 	}
108 108
 
109 109
 	/**
@@ -113,7 +113,7 @@  discard block
 block discarded – undo
113 113
 	 * @return DumpMetaInformation[]
114 114
 	 */
115 115
 	public function getAll() {
116
-		$db = wfGetDB( DB_REPLICA );
116
+		$db = wfGetDB(DB_REPLICA);
117 117
 		$result = $db->select(
118 118
 			[
119 119
 				self::META_TABLE_NAME,
@@ -131,7 +131,7 @@  discard block
 block discarded – undo
131 131
 			]
132 132
 		);
133 133
 
134
-		return $this->buildDumpMetaInformationFromResult( $result );
134
+		return $this->buildDumpMetaInformationFromResult($result);
135 135
 	}
136 136
 
137 137
 	/**
@@ -139,34 +139,34 @@  discard block
 block discarded – undo
139 139
 	 * @return null|array
140 140
 	 * @throws UnexpectedValueException
141 141
 	 */
142
-	private function buildDumpMetaInformationFromResult( IResultWrapper $result ) {
142
+	private function buildDumpMetaInformationFromResult(IResultWrapper $result) {
143 143
 		$aggregatedRows = [];
144
-		foreach ( $result as $row ) {
145
-			if ( array_key_exists( $row->id, $aggregatedRows ) ) {
146
-				$propertyId = new PropertyId( $row->identifier_pid );
144
+		foreach ($result as $row) {
145
+			if (array_key_exists($row->id, $aggregatedRows)) {
146
+				$propertyId = new PropertyId($row->identifier_pid);
147 147
 				$aggregatedRows[$row->id]->identifier_pid[] = $propertyId;
148 148
 			} else {
149
-				if ( $row->identifier_pid !== null ) {
150
-					$propertyId = new PropertyId( $row->identifier_pid );
151
-					$row->identifier_pid = [ $propertyId ];
149
+				if ($row->identifier_pid !== null) {
150
+					$propertyId = new PropertyId($row->identifier_pid);
151
+					$row->identifier_pid = [$propertyId];
152 152
 				}
153 153
 				$aggregatedRows[$row->id] = $row;
154 154
 			}
155 155
 		}
156 156
 
157 157
 		$dumpMetaInformation = [];
158
-		foreach ( $aggregatedRows as $row ) {
158
+		foreach ($aggregatedRows as $row) {
159 159
 			$dumpId = $row->id;
160
-			$sourceItemId = new ItemId( $row->source_qid );
161
-			$importDate = wfTimestamp( TS_MW, $row->import_date );
160
+			$sourceItemId = new ItemId($row->source_qid);
161
+			$importDate = wfTimestamp(TS_MW, $row->import_date);
162 162
 			$language = $row->language;
163 163
 			$sourceUrl = $row->source_url;
164 164
 			$size = (int)$row->size;
165
-			$licenseItemId = new ItemId( $row->license_qid );
165
+			$licenseItemId = new ItemId($row->license_qid);
166 166
 			$identifierPropertyIds = $row->identifier_pid;
167 167
 
168 168
 			$dumpMetaInformation[$row->dump_id] =
169
-				new DumpMetaInformation( $dumpId,
169
+				new DumpMetaInformation($dumpId,
170 170
 					$sourceItemId,
171 171
 					$identifierPropertyIds,
172 172
 					$importDate,
@@ -185,22 +185,22 @@  discard block
 block discarded – undo
185 185
 	 *
186 186
 	 * @param DumpMetaInformation $dumpMetaInformation
187 187
 	 */
188
-	public function save( DumpMetaInformation $dumpMetaInformation ) {
189
-		$db = wfGetDB( DB_REPLICA );
188
+	public function save(DumpMetaInformation $dumpMetaInformation) {
189
+		$db = wfGetDB(DB_REPLICA);
190 190
 		$dumpId = $dumpMetaInformation->getDumpId();
191
-		$accumulator = $this->getDumpInformationFields( $db, $dumpMetaInformation );
191
+		$accumulator = $this->getDumpInformationFields($db, $dumpMetaInformation);
192 192
 
193 193
 		$existing = $db->selectRow(
194 194
 			self::META_TABLE_NAME,
195
-			[ 'id' ],
196
-			[ 'id' => $dumpId ]
195
+			['id'],
196
+			['id' => $dumpId]
197 197
 		);
198 198
 
199
-		if ( $existing ) {
199
+		if ($existing) {
200 200
 			$db->update(
201 201
 				self::META_TABLE_NAME,
202 202
 				$accumulator,
203
-				[ 'id' => $dumpId ]
203
+				['id' => $dumpId]
204 204
 			);
205 205
 		} else {
206 206
 			$db->insert(
@@ -211,12 +211,12 @@  discard block
 block discarded – undo
211 211
 
212 212
 		$db->delete(
213 213
 			self::IDENTIFIER_PROPERTIES_TABLE_NAME,
214
-			[ 'dump_id' => $dumpId ]
214
+			['dump_id' => $dumpId]
215 215
 		);
216 216
 		$db->insert(
217 217
 			self::IDENTIFIER_PROPERTIES_TABLE_NAME,
218 218
 			array_map(
219
-				function ( PropertyId $identifierPropertyId ) use ( $dumpId ) {
219
+				function(PropertyId $identifierPropertyId) use ($dumpId) {
220 220
 					return [
221 221
 						'dump_id' => $dumpId,
222 222
 						'identifier_pid' => $identifierPropertyId->getSerialization()
@@ -232,11 +232,11 @@  discard block
 block discarded – undo
232 232
 	 * @param DumpMetaInformation $dumpMetaInformation
233 233
 	 * @return array
234 234
 	 */
235
-	private function getDumpInformationFields( IDatabase $db, DumpMetaInformation $dumpMetaInformation ) {
235
+	private function getDumpInformationFields(IDatabase $db, DumpMetaInformation $dumpMetaInformation) {
236 236
 		return [
237 237
 			'id' => $dumpMetaInformation->getDumpId(),
238 238
 			'source_qid' => $dumpMetaInformation->getSourceItemId()->getSerialization(),
239
-			'import_date' => $db->timestamp( $dumpMetaInformation->getImportDate() ),
239
+			'import_date' => $db->timestamp($dumpMetaInformation->getImportDate()),
240 240
 			'language' => $dumpMetaInformation->getLanguageCode(),
241 241
 			'source_url' => $dumpMetaInformation->getSourceUrl(),
242 242
 			'size' => $dumpMetaInformation->getSize(),
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 = [
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 = [];
43
-		$db = wfGetDB( DB_REPLICA );
43
+		$db = wfGetDB(DB_REPLICA);
44 44
 		$result = $db->select(
45 45
 			self::TABLE_NAME,
46 46
 			[
@@ -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 = [ func_get_args() ];
77
-		return $this->insertBatch( $externalDataBatch );
76
+		$externalDataBatch = [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 [
92 92
 					'dump_id' => $externalData[0],
93 93
 					'external_id' => $externalData[1],
@@ -100,9 +100,9 @@  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
-		} catch ( DBError $ex ) {
105
+		} catch (DBError $ex) {
106 106
 			$db->rollback();
107 107
 			throw $ex;
108 108
 		}
@@ -117,22 +117,22 @@  discard block
 block discarded – undo
117 117
 	 * @param int $batchSize
118 118
 	 * @throws \Wikimedia\Rdbms\DBUnexpectedError
119 119
 	 */
120
-	public function deleteOfDump( $dumpId, $batchSize = 1000 ) {
121
-		Assert::parameterType( 'string', $dumpId, '$dumpId' );
122
-		Assert::parameterType( 'integer', $batchSize, 'batchSize' );
120
+	public function deleteOfDump($dumpId, $batchSize = 1000) {
121
+		Assert::parameterType('string', $dumpId, '$dumpId');
122
+		Assert::parameterType('integer', $batchSize, 'batchSize');
123 123
 
124 124
 		$lbFactory = MediaWikiServices::getInstance()->getDBLoadBalancerFactory();
125
-		$db = $lbFactory->getMainLB()->getConnection( DB_MASTER );
126
-		if ( $db->getType() === 'sqlite' ) {
127
-			$db->delete( self::TABLE_NAME, [ 'dump_id' => $dumpId ] );
125
+		$db = $lbFactory->getMainLB()->getConnection(DB_MASTER);
126
+		if ($db->getType() === 'sqlite') {
127
+			$db->delete(self::TABLE_NAME, ['dump_id' => $dumpId]);
128 128
 		} else {
129 129
 			do {
130
-				$db->commit( __METHOD__, 'flush' );
130
+				$db->commit(__METHOD__, 'flush');
131 131
 				$lbFactory->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.