Merge pull request #13 from joomla-projects/feature/available-versions

Added service to fetch available versions from TUF #11

Author: HLeithner

.env.example

@@ -64,5 +64,9 @@ AWS_USE_PATH_STYLE_ENDPOINT=false
 
 VITE_APP_NAME="${APP_NAME}"
 
+# Health interval in hours
 HEALTH_CHECK_INTERVAL=24
+# Orphan site storage period in days
 CLEANUP_SITE_DELAY=7
+# Cache time in minutes
+TUF_REPO_CACHETIME=5

app/Http/Controllers/Api/V1/SiteController.php

@@ -3,10 +3,10 @@
 namespace App\Http\Controllers\Api\V1;
 
 use App\Http\Controllers\Controller;
+use App\Http\Traits\ApiResponse;
 use App\Jobs\CheckSiteHealth;
 use App\Models\Site;
 use App\RemoteSite\Connection;
-use App\Traits\ApiResponse;
 use Carbon\Carbon;
 use GuzzleHttp\Exception\ClientException;
 use GuzzleHttp\Exception\ServerException;

app/Traits/ApiResponse.php renamed to app/Http/Traits/ApiResponse.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace App\Traits;
+namespace App\Http\Traits;
 
 use Illuminate\Http\JsonResponse;
 

app/Models/TufMetadata.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Models;
+
+use Illuminate\Database\Eloquent\Model;
+
+class TufMetadata extends Model
+{
+    public $timestamps = false;
+}

app/Providers/TUFServiceProvider.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace App\Providers;
+
+use App\Models\TufMetadata;
+use App\TUF\EloquentModelStorage;
+use App\TUF\HttpLoader;
+use GuzzleHttp\Client;
+use Illuminate\Support\Facades\App;
+use Illuminate\Support\ServiceProvider;
+use Tuf\Client\Updater;
+use Tuf\Loader\SizeCheckingLoader;
+use Tuf\Metadata\StorageInterface;
+
+class TUFServiceProvider extends ServiceProvider
+{
+    public const REPO_PATH = "https://update.joomla.org/cms/";
+
+    /**
+     * Register services.
+     *
+     * @return void
+     */
+    public function register()
+    {
+        $this->app->singleton(StorageInterface::class, function ($app) {
+            // Setup loader
+            $httpLoader = new HttpLoader(
+                self::REPO_PATH,
+                App::make(Client::class)
+            );
+
+            $sizeCheckingLoader = new SizeCheckingLoader($httpLoader);
+
+            // Setup storage
+            $storage = new EloquentModelStorage(TufMetadata::findOrFail(1));
+
+            // Create updater
+            $updater = new Updater(
+                $sizeCheckingLoader,
+                $storage
+            );
+
+            // Fetch Updates
+            $updater->refresh();
+
+            $storage->persist();
+
+            return $storage;
+        });
+    }
+}

app/RemoteSite/Connection.php

@@ -5,10 +5,9 @@
 namespace App\RemoteSite;
 
 use App\Enum\HttpMethod;
-use App\Enum\WebserviceEndpoint;
 use App\RemoteSite\Responses\FinalizeUpdate as FinalizeUpdateResponse;
-use App\RemoteSite\Responses\HealthCheck as HealthCheckResponse;
 use App\RemoteSite\Responses\GetUpdate as GetUpdateResponse;
+use App\RemoteSite\Responses\HealthCheck as HealthCheckResponse;
 use App\RemoteSite\Responses\PrepareUpdate as PrepareUpdateResponse;
 use App\RemoteSite\Responses\ResponseInterface;
 use GuzzleHttp\Client;

app/Enum/WebserviceEndpoint.php renamed to app/RemoteSite/WebserviceEndpoint.php

@@ -1,7 +1,8 @@
 <?php
 
-namespace App\Enum;
+namespace App\RemoteSite;
 
+use App\Enum\HttpMethod;
 use App\RemoteSite\Responses\FinalizeUpdate;
 use App\RemoteSite\Responses\GetUpdate;
 use App\RemoteSite\Responses\HealthCheck;

app/TUF/EloquentModelStorage.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace App\TUF;
+
+use App\Models\TufMetadata;
+use Tuf\Metadata\StorageBase;
+
+class EloquentModelStorage extends StorageBase
+{
+    public const METADATA_COLUMNS = ['root', 'targets', 'snapshot', 'timestamp', 'mirrors'];
+
+    protected TufMetadata $model;
+
+    /**
+     * @var array<string, string>
+     */
+    protected array $container = [];
+
+    public function __construct(TufMetadata $model)
+    {
+        $this->model = $model;
+
+        foreach (self::METADATA_COLUMNS as $column) {
+            if ($this->model->$column === null) {
+                continue;
+            }
+
+            $this->write($column, $this->model->$column);
+        }
+    }
+
+    public function read(string $name): ?string
+    {
+        return $this->container[$name] ?? null;
+    }
+
+    public function write(string $name, string $data): void
+    {
+        $this->container[$name] = $data;
+    }
+
+    public function delete(string $name): void
+    {
+        unset($this->container[$name]);
+    }
+
+    public function persist(): bool
+    {
+        foreach (self::METADATA_COLUMNS as $column) {
+            if (!\array_key_exists($column, $this->container)) {
+                continue;
+            }
+
+            $this->model->$column = $this->container[$column];
+        }
+
+        return $this->model->save();
+    }
+}

app/TUF/HttpLoader.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace App\TUF;
+
+use GuzzleHttp\Client;
+use GuzzleHttp\Exception\RequestException;
+use GuzzleHttp\Promise\Create;
+use GuzzleHttp\Promise\PromiseInterface;
+use Tuf\Exception\RepoFileNotFound;
+use Tuf\Loader\LoaderInterface;
+
+class HttpLoader implements LoaderInterface
+{
+    public function __construct(private readonly string $repositoryPath, private readonly Client $http)
+    {
+    }
+
+    public function load(string $locator, int $maxBytes): PromiseInterface
+    {
+        try {
+            $response = $this->http->get($this->repositoryPath . $locator);
+        } catch (RequestException $e) {
+            if ($e->getResponse()?->getStatusCode() !== 200) {
+                throw new RepoFileNotFound();
+            }
+
+            throw new HttpLoaderException($e->getMessage(), $e->getCode(), $e);
+        }
+
+        // Rewind to start
+        $response->getBody()->rewind();
+
+        // Return response
+        return Create::promiseFor($response->getBody());
+    }
+}

app/TUF/HttpLoaderException.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace App\TUF;
+
+use Tuf\Exception\TufException;
+
+class HttpLoaderException extends TufException
+{
+}