123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176 |
- <?php
- declare(strict_types=1);
- namespace OC\Updater;
- use OCP\AppFramework\Db\DoesNotExistException;
- use OCP\Http\Client\IClientService;
- use OCP\Http\Client\IResponse;
- use Psr\Log\LoggerInterface;
- class ChangesCheck {
-
- protected $clientService;
-
- private $mapper;
- private LoggerInterface $logger;
- public const RESPONSE_NO_CONTENT = 0;
- public const RESPONSE_USE_CACHE = 1;
- public const RESPONSE_HAS_CONTENT = 2;
- public function __construct(IClientService $clientService, ChangesMapper $mapper, LoggerInterface $logger) {
- $this->clientService = $clientService;
- $this->mapper = $mapper;
- $this->logger = $logger;
- }
-
- 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('Unable to decode changes info');
- }
- return $changesData;
- }
-
- 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 Changes();
- }
- $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;
- } elseif ($response->getStatusCode() === 404) {
- return self::RESPONSE_NO_CONTENT;
- } elseif ($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(Changes $entry, string $version) {
- if ($entry->getVersion() === $version) {
- $this->mapper->update($entry);
- } else {
- $entry->setVersion($version);
- $this->mapper->insert($entry);
- }
- }
-
- protected function queryChangesServer(string $uri, Changes $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) {
- if (\LIBXML_VERSION < 20900) {
- $loadEntities = libxml_disable_entity_loader(true);
- $xml = @simplexml_load_string($body);
- libxml_disable_entity_loader($loadEntities);
- } else {
- $xml = @simplexml_load_string($body);
- }
- 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;
- }
-
- public function normalizeVersion(string $version): string {
- $versionNumbers = array_slice(explode('.', $version), 0, 3);
- $versionNumbers[0] = $versionNumbers[0] ?: '0';
- while (count($versionNumbers) < 3) {
-
- $versionNumbers[] = 0;
- }
- return implode('.', $versionNumbers);
- }
- }
|