@@ -190,7 +190,7 @@ |
||
| 190 | 190 | $endpoint = $this->siteConfiguration->getMetaWikimediaWebServiceEndpoint(); |
| 191 | 191 | $response = $this->httpHelper->get($endpoint, $parameters); |
| 192 | 192 | $response = json_decode($response, true); |
| 193 | - } |
|
| 193 | + } |
|
| 194 | 194 | catch (CurlException $ex) { |
| 195 | 195 | // failed getting identification status, so throw a nicer error. |
| 196 | 196 | $message = 'Could not contact metawiki API to determine user\' identification status. ' |
@@ -376,7 +376,8 @@ |
||
| 376 | 376 | return new DateTime($logTime); |
| 377 | 377 | } |
| 378 | 378 | |
| 379 | - public function getLastUpdated() { |
|
| 379 | + public function getLastUpdated() |
|
| 380 | + { |
|
| 380 | 381 | $logQuery = $this->dbObject->prepare(<<<SQL |
| 381 | 382 | SELECT max(d.ts) FROM ( |
| 382 | 383 | SELECT r.date AS ts FROM request r WHERE r.id = :requestr |
@@ -117,7 +117,8 @@ |
||
| 117 | 117 | Logger::backgroundJobIssue($this->getDatabase(), $job); |
| 118 | 118 | |
| 119 | 119 | $database->commit(); |
| 120 | - } catch (Exception $ex) { |
|
| 120 | + } |
|
| 121 | + catch (Exception $ex) { |
|
| 121 | 122 | // oops, something went horribly wrong trying to handle this in a nice way; let's just fall back to |
| 122 | 123 | // logging this to disk for a tool root to investigate. |
| 123 | 124 | ExceptionHandler::logExceptionToDisk($ex, $this->getSiteConfiguration()); |
@@ -407,7 +407,7 @@ |
||
| 407 | 407 | /** @var Domain $domain */ |
| 408 | 408 | $domain = Domain::getById($objectId, $database); |
| 409 | 409 | |
| 410 | - if($domain === false ){ |
|
| 410 | + if($domain === false ) { |
|
| 411 | 411 | return "Domain #{$objectId}"; |
| 412 | 412 | } |
| 413 | 413 | |
@@ -63,7 +63,8 @@ |
||
| 63 | 63 | } |
| 64 | 64 | |
| 65 | 65 | |
| 66 | - public static function getAll(PdoDatabase $database) { |
|
| 66 | + public static function getAll(PdoDatabase $database) |
|
| 67 | + { |
|
| 67 | 68 | $statement = $database->prepare("SELECT * FROM domain;"); |
| 68 | 69 | $statement->execute(); |
| 69 | 70 | |
@@ -97,7 +97,8 @@ |
||
| 97 | 97 | $amqpConfig = $this->siteConfiguration->getAmqpConfiguration(); |
| 98 | 98 | if ($amqpConfig['tls']) { |
| 99 | 99 | $connection = new AMQPSSLConnection($amqpConfig['host'], $amqpConfig['port'], $amqpConfig['user'], $amqpConfig['password'], $amqpConfig['vhost'], ['verify_peer' => true]); |
| 100 | - } else { |
|
| 100 | + } |
|
| 101 | + else { |
|
| 101 | 102 | $connection = new AMQPStreamConnection($amqpConfig['host'], $amqpConfig['port'], $amqpConfig['user'], $amqpConfig['password'], $amqpConfig['vhost']); |
| 102 | 103 | } |
| 103 | 104 | $channel = $connection->channel(); |