nextcloud / server

lib/private/Updater/ChangesCheck.php

Indentation +137 added lines, -137 removed lines

@@ -32,141 +32,141 @@
 use OCP\ILogger;
 
 class ChangesCheck {
-	/** @var IClientService */
-	protected $clientService;
-	/** @var ChangesMapper */
-	private $mapper;
-	/** @var ILogger */
-	private $logger;
-
-	const RESPONSE_NO_CONTENT = 0;
-	const RESPONSE_USE_CACHE = 1;
-	const RESPONSE_HAS_CONTENT = 2;
-
-	public function __construct(IClientService $clientService, ChangesMapper $mapper, ILogger $logger) {
-		$this->clientService = $clientService;
-		$this->mapper = $mapper;
-		$this->logger = $logger;
-	}
-
-	/**
-	 * @throws DoesNotExistException
-	 */
-	public function getChangesForVersion(string $version): array {
-		$version = $this->normalizeVersion($version);
-		$changesInfo = $this->mapper->getChanges($version);
-		$changesData = json_decode($changesInfo->getData(), true);
-		if(empty($changesData)) {
-			throw new DoesNotExistException();
-		}
-		return $changesData;
-	}
-
-	/**
-	 * @throws \Exception
-	 */
-	public function check(string $uri, string $version): array {
-		try {
-			$version = $this->normalizeVersion($version);
-			$changesInfo = $this->mapper->getChanges($version);
-			if($changesInfo->getLastCheck() + 1800 > time()) {
-				return json_decode($changesInfo->getData(), true);
-			}
-		} catch (DoesNotExistException $e) {
-			$changesInfo = new ChangesResult();
-		}
-
-		$response = $this->queryChangesServer($uri, $changesInfo);
-
-		switch($this->evaluateResponse($response)) {
-			case self::RESPONSE_NO_CONTENT:
-				return [];
-			case self::RESPONSE_USE_CACHE:
-				return json_decode($changesInfo->getData(), true);
-			case self::RESPONSE_HAS_CONTENT:
-			default:
-				$data = $this->extractData($response->getBody());
-				$changesInfo->setData(json_encode($data));
-				$changesInfo->setEtag($response->getHeader('Etag'));
-				$this->cacheResult($changesInfo, $version);
-
-				return $data;
-		}
-	}
-
-	protected function evaluateResponse(IResponse $response): int {
-		if($response->getStatusCode() === 304) {
-			return self::RESPONSE_USE_CACHE;
-		} else if($response->getStatusCode() === 404) {
-			return self::RESPONSE_NO_CONTENT;
-		} else if($response->getStatusCode() === 200) {
-			return self::RESPONSE_HAS_CONTENT;
-		}
-		$this->logger->debug('Unexpected return code {code} from changelog server', [
-			'app' => 'core',
-			'code' => $response->getStatusCode(),
-		]);
-		return self::RESPONSE_NO_CONTENT;
-	}
-
-	protected function cacheResult(ChangesResult $entry, string $version) {
-		if($entry->getVersion() === $version) {
-			$this->mapper->update($entry);
-		} else {
-			$entry->setVersion($version);
-			$this->mapper->insert($entry);
-		}
-	}
-
-	/**
-	 * @throws \Exception
-	 */
-	protected function queryChangesServer(string $uri, ChangesResult $entry): IResponse {
-		$headers = [];
-		if($entry->getEtag() !== '') {
-			$headers['If-None-Match'] = [$entry->getEtag()];
-		}
-
-		$entry->setLastCheck(time());
-		$client = $this->clientService->newClient();
-		return $client->get($uri, [
-			'headers' => $headers,
-		]);
-	}
-
-	protected function extractData($body):array {
-		$data = [];
-		if ($body) {
-			$loadEntities = libxml_disable_entity_loader(true);
-			$xml = @simplexml_load_string($body);
-			libxml_disable_entity_loader($loadEntities);
-			if ($xml !== false) {
-				$data['changelogURL'] = (string)$xml->changelog['href'];
-				$data['whatsNew'] = [];
-				foreach($xml->whatsNew as $infoSet) {
-					$data['whatsNew'][(string)$infoSet['lang']] = [
-						'regular' => (array)$infoSet->regular->item,
-						'admin' => (array)$infoSet->admin->item,
-					];
-				}
-			} else {
-				libxml_clear_errors();
-			}
-		}
-		return $data;
-	}
-
-	/**
-	 * returns a x.y.z form of the provided version. Extra numbers will be
-	 * omitted, missing ones added as zeros.
-	 */
-	public function normalizeVersion(string $version): string {
-		$versionNumbers = array_slice(explode('.', $version), 0, 3);
-		$versionNumbers[0] = $versionNumbers[0] ?: '0'; // deal with empty input
-		while(count($versionNumbers) < 3) {
-			// changelog server expects x.y.z, pad 0 if it is too short
-			$versionNumbers[] = 0;
-		}
-		return implode('.', $versionNumbers);
-	}
+    /** @var IClientService */
+    protected $clientService;
+    /** @var ChangesMapper */
+    private $mapper;
+    /** @var ILogger */
+    private $logger;
+
+    const RESPONSE_NO_CONTENT = 0;
+    const RESPONSE_USE_CACHE = 1;
+    const RESPONSE_HAS_CONTENT = 2;
+
+    public function __construct(IClientService $clientService, ChangesMapper $mapper, ILogger $logger) {
+        $this->clientService = $clientService;
+        $this->mapper = $mapper;
+        $this->logger = $logger;
+    }
+
+    /**
+     * @throws DoesNotExistException
+     */
+    public function getChangesForVersion(string $version): array {
+        $version = $this->normalizeVersion($version);
+        $changesInfo = $this->mapper->getChanges($version);
+        $changesData = json_decode($changesInfo->getData(), true);
+        if(empty($changesData)) {
+            throw new DoesNotExistException();
+        }
+        return $changesData;
+    }
+
+    /**
+     * @throws \Exception
+     */
+    public function check(string $uri, string $version): array {
+        try {
+            $version = $this->normalizeVersion($version);
+            $changesInfo = $this->mapper->getChanges($version);
+            if($changesInfo->getLastCheck() + 1800 > time()) {
+                return json_decode($changesInfo->getData(), true);
+            }
+        } catch (DoesNotExistException $e) {
+            $changesInfo = new ChangesResult();
+        }
+
+        $response = $this->queryChangesServer($uri, $changesInfo);
+
+        switch($this->evaluateResponse($response)) {
+            case self::RESPONSE_NO_CONTENT:
+                return [];
+            case self::RESPONSE_USE_CACHE:
+                return json_decode($changesInfo->getData(), true);
+            case self::RESPONSE_HAS_CONTENT:
+            default:
+                $data = $this->extractData($response->getBody());
+                $changesInfo->setData(json_encode($data));
+                $changesInfo->setEtag($response->getHeader('Etag'));
+                $this->cacheResult($changesInfo, $version);
+
+                return $data;
+        }
+    }
+
+    protected function evaluateResponse(IResponse $response): int {
+        if($response->getStatusCode() === 304) {
+            return self::RESPONSE_USE_CACHE;
+        } else if($response->getStatusCode() === 404) {
+            return self::RESPONSE_NO_CONTENT;
+        } else if($response->getStatusCode() === 200) {
+            return self::RESPONSE_HAS_CONTENT;
+        }
+        $this->logger->debug('Unexpected return code {code} from changelog server', [
+            'app' => 'core',
+            'code' => $response->getStatusCode(),
+        ]);
+        return self::RESPONSE_NO_CONTENT;
+    }
+
+    protected function cacheResult(ChangesResult $entry, string $version) {
+        if($entry->getVersion() === $version) {
+            $this->mapper->update($entry);
+        } else {
+            $entry->setVersion($version);
+            $this->mapper->insert($entry);
+        }
+    }
+
+    /**
+     * @throws \Exception
+     */
+    protected function queryChangesServer(string $uri, ChangesResult $entry): IResponse {
+        $headers = [];
+        if($entry->getEtag() !== '') {
+            $headers['If-None-Match'] = [$entry->getEtag()];
+        }
+
+        $entry->setLastCheck(time());
+        $client = $this->clientService->newClient();
+        return $client->get($uri, [
+            'headers' => $headers,
+        ]);
+    }
+
+    protected function extractData($body):array {
+        $data = [];
+        if ($body) {
+            $loadEntities = libxml_disable_entity_loader(true);
+            $xml = @simplexml_load_string($body);
+            libxml_disable_entity_loader($loadEntities);
+            if ($xml !== false) {
+                $data['changelogURL'] = (string)$xml->changelog['href'];
+                $data['whatsNew'] = [];
+                foreach($xml->whatsNew as $infoSet) {
+                    $data['whatsNew'][(string)$infoSet['lang']] = [
+                        'regular' => (array)$infoSet->regular->item,
+                        'admin' => (array)$infoSet->admin->item,
+                    ];
+                }
+            } else {
+                libxml_clear_errors();
+            }
+        }
+        return $data;
+    }
+
+    /**
+     * returns a x.y.z form of the provided version. Extra numbers will be
+     * omitted, missing ones added as zeros.
+     */
+    public function normalizeVersion(string $version): string {
+        $versionNumbers = array_slice(explode('.', $version), 0, 3);
+        $versionNumbers[0] = $versionNumbers[0] ?: '0'; // deal with empty input
+        while(count($versionNumbers) < 3) {
+            // changelog server expects x.y.z, pad 0 if it is too short
+            $versionNumbers[] = 0;
+        }
+        return implode('.', $versionNumbers);
+    }
 }

Spacing +14 added lines, -14 removed lines

@@ -56,7 +56,7 @@ 
 		$version = $this->normalizeVersion($version);
 		$changesInfo = $this->mapper->getChanges($version);
 		$changesData = json_decode($changesInfo->getData(), true);
-		if(empty($changesData)) {
+		if (empty($changesData)) {
 			throw new DoesNotExistException();
 		}
 		return $changesData;
@@ -69,7 +69,7 @@ 
 		try {
 			$version = $this->normalizeVersion($version);
 			$changesInfo = $this->mapper->getChanges($version);
-			if($changesInfo->getLastCheck() + 1800 > time()) {
+			if ($changesInfo->getLastCheck() + 1800 > time()) {
 				return json_decode($changesInfo->getData(), true);
 			}
 		} catch (DoesNotExistException $e) {
@@ -78,7 +78,7 @@ 
 
 		$response = $this->queryChangesServer($uri, $changesInfo);
 
-		switch($this->evaluateResponse($response)) {
+		switch ($this->evaluateResponse($response)) {
 			case self::RESPONSE_NO_CONTENT:
 				return [];
 			case self::RESPONSE_USE_CACHE:
@@ -95,11 +95,11 @@ 
 	}
 
 	protected function evaluateResponse(IResponse $response): int {
-		if($response->getStatusCode() === 304) {
+		if ($response->getStatusCode() === 304) {
 			return self::RESPONSE_USE_CACHE;
-		} else if($response->getStatusCode() === 404) {
+		} else if ($response->getStatusCode() === 404) {
 			return self::RESPONSE_NO_CONTENT;
-		} else if($response->getStatusCode() === 200) {
+		} else if ($response->getStatusCode() === 200) {
 			return self::RESPONSE_HAS_CONTENT;
 		}
 		$this->logger->debug('Unexpected return code {code} from changelog server', [
@@ -110,7 +110,7 @@ 
 	}
 
 	protected function cacheResult(ChangesResult $entry, string $version) {
-		if($entry->getVersion() === $version) {
+		if ($entry->getVersion() === $version) {
 			$this->mapper->update($entry);
 		} else {
 			$entry->setVersion($version);
@@ -123,7 +123,7 @@ 
 	 */
 	protected function queryChangesServer(string $uri, ChangesResult $entry): IResponse {
 		$headers = [];
-		if($entry->getEtag() !== '') {
+		if ($entry->getEtag() !== '') {
 			$headers['If-None-Match'] = [$entry->getEtag()];
 		}
 
@@ -141,12 +141,12 @@ 
 			$xml = @simplexml_load_string($body);
 			libxml_disable_entity_loader($loadEntities);
 			if ($xml !== false) {
-				$data['changelogURL'] = (string)$xml->changelog['href'];
+				$data['changelogURL'] = (string) $xml->changelog['href'];
 				$data['whatsNew'] = [];
-				foreach($xml->whatsNew as $infoSet) {
-					$data['whatsNew'][(string)$infoSet['lang']] = [
-						'regular' => (array)$infoSet->regular->item,
-						'admin' => (array)$infoSet->admin->item,
+				foreach ($xml->whatsNew as $infoSet) {
+					$data['whatsNew'][(string) $infoSet['lang']] = [
+						'regular' => (array) $infoSet->regular->item,
+						'admin' => (array) $infoSet->admin->item,
 					];
 				}
 			} else {
@@ -163,7 +163,7 @@ 
 	public function normalizeVersion(string $version): string {
 		$versionNumbers = array_slice(explode('.', $version), 0, 3);
 		$versionNumbers[0] = $versionNumbers[0] ?: '0'; // deal with empty input
-		while(count($versionNumbers) < 3) {
+		while (count($versionNumbers) < 3) {
 			// changelog server expects x.y.z, pad 0 if it is too short
 			$versionNumbers[] = 0;
 		}